node

Nov 5, 2019

Changes in this version

type Mode

+ const BatchMode

+ const InteractiveMode

type Node

+ func (n *Node) AppendEphemeralMessage(groupID state.GroupID, data []byte) (state.MessageID, error)

+ func (n *Node) AppendMessageWithMetadata(groupID state.GroupID, data []byte, metadata *protobuf.Metadata) (state.MessageID, error)

+ type ResolutionMode int

+ const ConsistentMode

+ const EventualMode

Aug 29, 2019

Changes in this version

type Node

+ func NewEphemeralNode(id state.PeerID, t transport.Transport, nextEpoch CalculateNextEpoch, ...) *Node

+ func NewPersistentNode(db *sql.DB, st transport.Transport, id state.PeerID, mode Mode, ...) (*Node, error)

+ func (n *Node) CurrentEpoch() int64

Aug 6, 2019

Changes in this version

type Node

+ func (n *Node) Subscribe() chan protobuf.Message

+ func (n *Node) Unsubscribe()

Jul 25, 2019

Changes in this version

+ type CalculateNextEpoch func(count uint64, epoch int64) int64

+ type Mode int

+ const BATCH

+ const INTERACTIVE

+ type Node struct

+ ID state.PeerID

+ func NewNode(ms store.MessageStore, st transport.Transport, ss state.SyncState, ...) *Node

+ func (n *Node) AddPeer(group state.GroupID, id state.PeerID) error

+ func (n *Node) AppendMessage(groupID state.GroupID, data []byte) (state.MessageID, error)

+ func (n *Node) IsPeerInGroup(g state.GroupID, p state.PeerID) (bool, error)

+ func (n *Node) RequestMessage(group state.GroupID, id state.MessageID) error

+ func (n *Node) Start(duration time.Duration)

+ func (n *Node) Stop()