node

Jan 11, 2024

Changes in this version

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

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

+ func (n *Node) Unsubscribe()

Jul 15, 2019

Changes in this version

type Node

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

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

Jun 14, 2019

Changes in this version

type Node

+ func (n *Node) Start()

+ func (n *Node) Stop()

Jun 10, 2019

Changes in this version

+ type Mode string

+ 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)

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

+ func (n *Node) Run()

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