crdt - GitLite

KO | EN

gitlite — search

#python #hacktoberfest #typescript #llm #golang #android #deep-learning #linux #docker #nodejs #awesome #awesome-list #ios #openai

crdt

(★ 834)

Commutative Replicated Data Types for easy collaborative/distributed systems.

파일 탐색기

최종 버전 다운로드 (.zip)

- - .gitignore
  - bundle.js
  - chat.js
  - client.js
  - index.html
  - jquery-1.7.2.min.js
  - jquery-ui-1.8.20.custom.min.js
  - jquery-ui.js
  - jquery.js
  - make
  - mouses.js
  - package.json
  - server.js
  - sets.js
- - bundle.js
  - client.js
  - heartbeat.js
  - index.html
  - make
  - node-client.js
  - package.json
  - README.markdown
  - server.js
- autonode.js
- tcp.js
- - index.js
- __proto__.js
- add.js
- eventually-consistent.js
- insert.js
- insert_with_id.js
- loop.js
- rm.js
- seq.js
- sets.js
- simple.js
- streaming.js
- tcp.js
.gitignore
.travis.yml
debug.js
doc.js
index.js
LICENSE
package.json
README.md
row.js
seq.js
set.js

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/dominictarr/crdt

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd crdt

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. Node.js

쉬움 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Node.js npm 명령어를 쓰려면 Node.js가 설치되어 있어야 합니다. LTS(장기지원) 버전을 추천합니다.

npm install

package.json에 명시된 라이브러리들을 내려받아 설치합니다.

npm start

개발/실행 서버를 켭니다.

✅ 명령어 실행 후 터미널에 나타나는 주소(보통 http://localhost:3000 형태)를 브라우저에서 열어보세요.

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# CRDT - Commutative Replicated Data Types

a CRDT is a data type designed so that operations on it commute - give the same result
independent of the order in which they are applied.

[![testling badge](https://ci.testling.com/dominictarr/crdt.png)](https://ci.testling.com/dominictarr/crdt)
[![build status](https://secure.travis-ci.org/dominictarr/crdt.png)](http://travis-ci.org/dominictarr/crdt)

CRDTs give you eventual consistency for free. it is not necessary to track concurrent changes
and use complicated merge algorithms. this module is useful for collaborative/distributed/peer2peer (same things)
applications.

Further Reading: [A comprehensive study of
Convergent and Commutative Replicated Data Types
](http://hal.upmc.fr/docs/00/55/55/88/PDF/techreport.pdf)

## replicating documents

create two documents,

``` js
var Doc = require('crdt').Doc
var A = new Doc()
var B = new Doc()
```

then pipe them together

``` js
var as
(as = A.createStream())
  .pipe(B.createStream())
  .pipe(as)
```

We just replicated two documents with in the same process...
this is the idea, but of course, we want to do it on different machines...

notice the pattern is basically the same...

the client side ...

``` js
var net = require('net')
var es  = require('es')
var Doc = require('crdt').Doc

var A = new Doc()

var stream
(stream = net.connect())
  .pipe(A.createStream())
  .pipe(stream)
```

and the server ...

``` js
var net = require('net')
var es  = require('es')
var Doc = require('crdt').Doc

var A = new Doc()

net.createServer(function (stream) {
  stream
    .pipe(A.createStream())
    .pipe(stream)
})
```

## Doc

### Doc#add(obj = {id: ID, ...})

Add a `Row` to the document initialized to `obj`.
If `obj` doesn't have a unique `id` property, a random key will be created.

Return the `Row` object.

### Doc#get(id)

Get a `Row` from the document by `id`.

### Doc#set(id, doc)

Sets `Row` with ID `id` to `doc`. Returns the `Row`. It has all the effects and
implications of calling `Row#set`.

### Doc#rm(id)

Remove a `Row` from the document by `id`
Also removes from all sets as well.

### Doc#toJSON()
Returns a raw `Doc` object.

### Doc#createSet (key, value)

Create a `Set` a set is a collection of rows defined by a particular
value on a particular property.

``` js

var cheeses = doc.createSet('type', 'cheese')

```

`key` and `value` must both be strings.

### Doc#createSet (filter)

You can also create a `Set` using a filter function.

```js
var cheeses = doc.createSet(function (state) {
    return state.type === 'cheese'
})
```

A filter function should just be a more expressive filter and
shouldn't be a stateful function

### Doc#createSeq (key, value)

same as `Doc#createSet` except that seqs have a significant order.

sequences can also be created with a filter using `Doc#createSeq(filter)`

### Doc#createStream (opts)

create a stream that is used to connect to another Doc instance.

### event: doc.emit('create', row)

Emitted when a new `Row` is created

### event: doc.emit('row_update', row)

Emitted when a new `Row` is updated

## Row

an object with in a crdt `Doc`

### Row#set(key, value)

set `key` to `value`. if `Row#set(obj)` is called instead
all the keys in obj will update atomically.

This causes a 'change' event to be emitted, and an update message
to be sent down the stream. (note, if the stream in not yet connected,
that is okay, current state of the document is replicated as soon as the
streams are connected.)

### Row#get(key)

get the current value for a key.

### Row#toJSON()

return a raw object ready for serialization.
this is not a JSON string yet, misleading name,
but that is the correct JSON.stringify api.

### event: Row.emit('change', changed)

Emitted when a row is changed. this may be the result of a local or a
remote update.

changed is the a hash of the fields that have changed.

### event: Row.emit('removed')

Emitted when a row is removed. This may be the result of a local or a remote
update.

## Set

A collection of `Rows` within a document.

### Set#asArray()

get the contents of this set as a regular js `Array`

### Set#toJSON()

calls `toJSON` on the each `Row` in the set and puts it in an array.

### Set#has(row|id)

check if a row|id is a member of the set.

### Set#get(id)

get an item in this set, if it exists.

### Set#each(iter), Set#forEach(iter)

Iterate over the `Rows` in the set.

### Set#onEach(iter)

Iterate over the `Rows` in the set and any new row that may be
added to the set in the future.

### Set#remove(row)

removes a row from the set. sets the set's `key`, to null.
note, if you have multiple sets with the same key, they are mutually exclusive,
and adding a node to a different set will remove it from the first one.

### event: Set.emit('add', Row)

Emitted when a row is added to the set.

### event: Set.emit('changes', Row, changed)

Emitted when a row in the set changed. The changed value contains a hash
of the key / values that changed.

### event: Set.emit('remove', Row)

Emitted when a row is removed from the set

## Seq

just like a Set, but the items are ordered.
they will begiven a `_sort` property.

### Seq#first()

get the first item in the seq.

### Seq#last()

get the last item in the seq.

### Seq#has(row|id)

check if a row|id is a member of the seq. (inherited from `Set`)

### Seq#indexOf(id | row)

find the index of the given row or id.

### Seq#at(index)

get the item currently at `index`

### Seq#unshift(row)

push a `Row` onto the start of the `Seq`

### Seq#push(row)

push a `Row` onto the end of the `Seq`

### Seq#length()

get the number of items currently in the `Seq`.

### Seq#pop()

remove the last item.

### Seq#shift()

remove the first item.

### Seq#before(item, id | row)

insert `item` before the given `row/id`.

### Seq#after(item, id | row)

insert `item` after the given `row/id`.

### Seq#next(key)

Finds the item that is after this key

### Seq#prev(key)

Finds the item that is before this key

### event: Seq.emit('move', Row)

Emitted when the row has changed it's position in the sequence