state

Documentation

Index

• func NewSyncState() *memorySyncState
• type GroupID
• type MessageID
  • func ID(m protobuf.Message) MessageID
• type PeerID
  • func PublicKeyToPeerID(k ecdsa.PublicKey) PeerID
• type State
• type SyncState

Functions

func NewSyncState

func NewSyncState() *memorySyncState

Types

type GroupID

type GroupID [32]byte

type MessageID

type MessageID [32]byte

func ID

func ID(m protobuf.Message) MessageID

ID creates the MessageID for a Message

type PeerID

type PeerID [64]byte

func PublicKeyToPeerID

func PublicKeyToPeerID(k ecdsa.PublicKey) PeerID

Turns an ECSDA PublicKey to a PeerID

type State

type State struct {
	SendCount uint64
	SendEpoch int64
}

type SyncState

type SyncState interface {
	Get(group GroupID, id MessageID, peer PeerID) (State, error)
	Set(group GroupID, id MessageID, peer PeerID, newState State) error
	Remove(group GroupID, id MessageID, peer PeerID) error
	Map(process func(GroupID, MessageID, PeerID, State) State) error
}