state

Documentation

Overview

Package state contains everything related to the synchronization state for MVDS.

Index

• func NewSyncState() *memorySyncState
• type GroupID
• type MessageID
• type PeerID
• type RecordType
• type State
• type SyncState

Functions

func NewSyncState

func NewSyncState() *memorySyncState

Types

type GroupID

type GroupID [32]byte

type MessageID

type MessageID [32]byte

type PeerID

type PeerID [65]byte

type RecordType

type RecordType int

const (
	OFFER RecordType = iota
	REQUEST
	MESSAGE
)

type State

type State struct {
	Type      RecordType
	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(epoch int64, process func(GroupID, MessageID, PeerID, State) State) error
}