syncstatus

Documentation

Index

• type StatusProvider
  • func NewSyncStatusProvider(spaceId string, deps SyncStatusDeps) StatusProvider
• type StatusUpdater
  • func NewNoOpSyncStatus() StatusUpdater
• type StatusWatcher
• type SyncStatus
• type SyncStatusDeps
  • func DefaultDeps(configuration nodeconf.NodeConf, store spacestorage.SpaceStorage) SyncStatusDeps
• type UpdateReceiver

Types

type StatusProvider

type StatusProvider interface {
	StatusUpdater
	StatusWatcher
}

func NewSyncStatusProvider

func NewSyncStatusProvider(spaceId string, deps SyncStatusDeps) StatusProvider

type StatusUpdater

type StatusUpdater interface {
	HeadsChange(treeId string, heads []string)
	HeadsReceive(senderId, treeId string, heads []string)

	SetNodesOnline(senderId string, online bool)
	StateCounter() uint64
	RemoveAllExcept(senderId string, differentRemoteIds []string, stateCounter uint64)

	Run()
	Close() error
}

func NewNoOpSyncStatus

func NewNoOpSyncStatus() StatusUpdater

type StatusWatcher

type StatusWatcher interface {
	Watch(treeId string) (err error)
	Unwatch(treeId string)
	SetUpdateReceiver(updater UpdateReceiver)
}

type SyncStatus

type SyncStatus int

const (
	StatusUnknown SyncStatus = iota
	StatusSynced
	StatusNotSynced
)

type SyncStatusDeps

type SyncStatusDeps struct {
	UpdateIntervalSecs int
	UpdateTimeout      time.Duration
	Configuration      nodeconf.NodeConf
	Storage            spacestorage.SpaceStorage
}

func DefaultDeps

func DefaultDeps(configuration nodeconf.NodeConf, store spacestorage.SpaceStorage) SyncStatusDeps

type UpdateReceiver

type UpdateReceiver interface {
	UpdateTree(ctx context.Context, treeId string, status SyncStatus) (err error)
	UpdateNodeConnection(online bool)
}