syncstatus

Documentation

Index

• Constants
• type StatusService
  • func NewNoOpSyncStatus() StatusService
  • func NewSyncStatusProvider() StatusService
• type StatusServiceProvider
• type StatusUpdater
• type StatusWatcher
• type SyncStatus
• type UpdateReceiver

Constants

const CName = "common.commonspace.syncstatus"

Types

type StatusService

type StatusService interface {
	app.ComponentRunnable
	StatusUpdater
	StatusWatcher
}

func NewNoOpSyncStatus

func NewNoOpSyncStatus() StatusService

func NewSyncStatusProvider

func NewSyncStatusProvider() StatusService

type StatusServiceProvider

type StatusServiceProvider interface {
	app.Component
	NewStatusService() StatusService
}

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)
}

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 UpdateReceiver

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