gleamunison/sync_types

Types

ConnectError

pub type ConnectError {
  PeerNotFound(PeerId)
  CookieMismatch(PeerId)
  Timeout(PeerId)
  Refused(PeerId, reason: String)
}

Constructors

```
PeerNotFound(PeerId)
```
```
CookieMismatch(PeerId)
```
```
Timeout(PeerId)
```
```
Refused(PeerId, reason: String)
```

PeerId

</>

pub type PeerId {
  PeerId(name: String)
}

Constructors

```
PeerId(name: String)
```

PeerState

</>

pub type PeerState {
  PeerState(
    last_seen: Int,
    refs: set.Set(identity.DefinitionRef),
    status: PeerStatus,
  )
}

Constructors

PeerState(
  last_seen: Int,
  refs: set.Set(identity.DefinitionRef),
  status: PeerStatus,
)

PeerStatus

</>

pub type PeerStatus {
  Connected
  Disconnected
  Syncing
  Failed(String)
}

Constructors

```
Connected
```
```
Disconnected
```
```
Syncing
```
```
Failed(String)
```

SyncError

</>

pub type SyncError {
  ConnectionFailed(PeerId, ConnectError)
  TransferFailed(PeerId, message: String)
  HashConflict(
    PeerId,
    ref: identity.DefinitionRef,
    local: BitArray,
    remote: BitArray,
  )
}

Constructors

```
ConnectionFailed(PeerId, ConnectError)
```
```
TransferFailed(PeerId, message: String)
```

HashConflict(
  PeerId,
  ref: identity.DefinitionRef,
  local: BitArray,
  remote: BitArray,
)

SyncState

</>

pub type SyncState {
  SyncState(
    peers: dict.Dict(PeerId, PeerState),
    known_refs: set.Set(identity.DefinitionRef),
  )
}

Constructors

SyncState(
  peers: dict.Dict(PeerId, PeerState),
  known_refs: set.Set(identity.DefinitionRef),
)

Values

sync_connect

</>

pub fn sync_connect(node: String) -> Result(Nil, String)

sync_push_defs

</>

pub fn sync_push_defs(
  node: String,
  defs: List(#(String, BitArray)),
) -> Result(Nil, String)

sync_receive_diff

</>

pub fn sync_receive_diff(
  node: String,
) -> Result(List(String), String)

sync_request_defs

</>

pub fn sync_request_defs(
  node: String,
  refs: List(String),
) -> Result(List(#(String, BitArray)), String)

sync_send_refs

</>

pub fn sync_send_refs(
  node: String,
  refs: List(String),
) -> Result(Nil, String)