headsync

Documentation

Index

• func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
• func NewRemoteDiff(spaceId string, client Client) ldiff.Remote
• type Client
• type DiffSyncer
• type HeadSync
  • func NewHeadSync(spaceId string, spaceIsDeleted *atomic.Bool, syncPeriod int, ...) HeadSync
• type TreeHeads

Functions

func HandleRangeRequest

func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)

func NewRemoteDiff

func NewRemoteDiff(spaceId string, client Client) ldiff.Remote

Types

type Client

type Client interface {
	HeadSync(ctx context.Context, in *spacesyncproto.HeadSyncRequest) (*spacesyncproto.HeadSyncResponse, error)
}

type DiffSyncer

type DiffSyncer interface {
	Sync(ctx context.Context) error
	RemoveObjects(ids []string)
	UpdateHeads(id string, heads []string)
	Init(deletionState settingsstate.ObjectDeletionState)
	Close() error
}

type HeadSync

type HeadSync interface {
	Init(objectIds []string, deletionState settingsstate.ObjectDeletionState)

	UpdateHeads(id string, heads []string)
	HandleRangeRequest(ctx context.Context, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
	RemoveObjects(ids []string)
	AllIds() []string
	DebugAllHeads() (res []TreeHeads)

	Close() (err error)
}

func NewHeadSync

func NewHeadSync(
	spaceId string,
	spaceIsDeleted *atomic.Bool,
	syncPeriod int,
	configuration nodeconf.NodeConf,
	storage spacestorage.SpaceStorage,
	peerManager peermanager.PeerManager,
	cache treemanager.TreeManager,
	syncStatus syncstatus.StatusUpdater,
	credentialProvider credentialprovider.CredentialProvider,
	log logger.CtxLogger) HeadSync

type TreeHeads

type TreeHeads struct {
	Id    string
	Heads []string
}