svs

type BoltDB struct {
	// contains filtered or unexported fields
}

type Constants struct {
	SyncInterval                   time.Duration
	SuppressionInterval            time.Duration
	SyncIntervalJitter             float64 // percentage variance 0.00<=x<=1.00
	SuppressionIntervalJitter      float64 // percentage variance 0.00<=x<=1.00
	DataInterestLifeTime           time.Duration
	DataInterestRetries            uint // 0 = no retry
	DataPacketFreshness            time.Duration
	SyncInterestLifeTime           time.Duration
	DataComponent                  enc.Component
	SyncComponent                  enc.Component
	MaxConcurrentDataInterests     int32 // 0 = inf
	InitialFetchQueueSize          uint  // only helps to mitigate allocation resizing
	InitialMissingChannelSize      uint  // only helps to mitigate allocation resizing
	InitialStatusChangeChannelSize uint  // only helps to mitigate allocation resizing
	HeartbeatsToRenew              uint
	HeartbeatsToExpire             uint
	TrackRate                      time.Duration
	HeartbeatRate                  time.Duration
	MonitorInterval                time.Duration
}

type Core interface {
	Listen()
	Activate(bool)
	Shutdown()
	Update(enc.Name, uint64)
	StateVector() *StateVector
	FeedInterest(ndn.Interest, enc.Wire, enc.Wire, ndn.ReplyFunc, time.Time)
	Subscribe() chan SyncUpdate
}

type Database interface {
	Get([]byte) []byte
	Set([]byte, []byte) error
	Remove([]byte) error
	Close()
}

type HandlingOption int

type HealthConfig struct {
	Source               enc.Name
	GroupPrefix          enc.Name
	FormalEncoding       bool
	EfficientSuppression bool
}

type HealthSync interface {
	Listen()
	Activate(bool)
	Shutdown()
	// TODO: NeedStatus + PublishStatus (publish/pull at a rate)
	Core() Core
	Tracker() Tracker
}

type MissingData struct {
	Dataset  enc.Name
	StartSeq uint64
	EndSeq   uint64
}

type NamingScheme int

type NativeConfig struct {
	Source               enc.Name
	GroupPrefix          enc.Name
	NamingScheme         NamingScheme
	HandlingOption       HandlingOption
	StoragePath          string
	DataCallback         func(source enc.Name, seqno uint64, data ndn.Data)
	FormalEncoding       bool
	EfficientSuppression bool
}

type NativeSync interface {
	Listen()
	Activate(bool)
	Shutdown()
	NeedData(enc.Name, uint64)
	PublishData([]byte)
	FeedInterest(ndn.Interest, enc.Wire, enc.Wire, ndn.ReplyFunc, time.Time)
	Core() Core
}

type OneStateCoreConfig struct {
	SyncPrefix     enc.Name
	FormalEncoding bool
}

type Scheduler interface {
	ApplyBounds(time.Duration, time.Duration)
	Start(bool)
	Stop()
	Skip()
	Reset()
	Set(time.Duration)
	TimeLeft() time.Duration
}

type SharedConfig struct {
	Source               enc.Name
	GroupPrefix          enc.Name
	HandlingOption       HandlingOption
	StoragePath          string
	DataCallback         func(enc.Name, uint64, ndn.Data)
	FormalEncoding       bool
	EfficientSuppression bool
	// high-level only
	CacheOthers bool
}

type SharedSync interface {
	Listen()
	Activate(bool)
	Shutdown()
	NeedData(enc.Name, uint64, bool)
	PublishData([]byte)
	FeedInterest(ndn.Interest, enc.Wire, enc.Wire, ndn.ReplyFunc, time.Time)
	Core() Core
}

type StateVector struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

type Status int

type StatusChange struct {
	Node      string
	OldStatus Status
	NewStatus Status
}

type SyncUpdate []MissingData

type Tracker interface {
	Reset(string)
	Detect()
	Status(string) Status
	UntilBeat() time.Duration
	Chan() chan StatusChange
}

type TwoStateCoreConfig struct {
	SyncPrefix           enc.Name
	FormalEncoding       bool
	EfficientSuppression bool
}