state

Documentation

Overview

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

Index

• Variables
• func NewPersistentSyncState(db *sql.DB) *sqliteSyncState
• func NewSyncState() *memorySyncState
• type GroupID
• type MessageID
• type PeerID
• type RecordType
• type State
• type SyncState

Variables

var (
	ErrStateNotFound = errors.New("state not found")
)

Functions

func NewPersistentSyncState

func NewPersistentSyncState(db *sql.DB) *sqliteSyncState

func NewSyncState

func NewSyncState() *memorySyncState

Types

type GroupID

type GroupID [32]byte

type MessageID

type MessageID [32]byte

type PeerID

type PeerID [65]byte

PeerID is the ID for a specific peer.

type RecordType

type RecordType int

RecordType is the type for a specific record, either `OFFER`, `REQUEST` or `MESSAGE`.

const (
	OFFER RecordType = iota
	REQUEST
	MESSAGE
)

type State

type State struct {
	Type      RecordType
	SendCount uint64
	SendEpoch int64
	// GroupID is optional, thus nullable
	GroupID   *GroupID
	PeerID    PeerID
	MessageID MessageID
}

State is a struct used to store a records state(https://github.com/status-im/bigbrother-specs/blob/master/data_sync/mvds.md#state).

type SyncState

type SyncState interface {
	Add(newState State) error
	Remove(id MessageID, peer PeerID) error
	All(epoch int64) ([]State, error)
	Map(epoch int64, process func(State) State) error
}