headsync

Documentation

Index

• Constants
• func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
• type Client
• type DiffManager
  • func NewDiffManager(diffContainer ldiff.DiffContainer, storage spacestorage.SpaceStorage, ...) *DiffManager
  • func (dm *DiffManager) AllIds() []string
  • func (dm *DiffManager) FillDiff(ctx context.Context) error
  • func (dm *DiffManager) HandleRangeRequest(ctx context.Context, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
  • func (dm *DiffManager) TryDiff(ctx context.Context, rdiff RemoteDiff) (newIds, changedIds, removedIds []string, err error)
  • func (dm *DiffManager) UpdateHeads(update headstorage.HeadsUpdate)
• type DiffSyncer
• type HeadSync
  • func New() HeadSync
• type RemoteDiff
  • func NewRemoteDiff(spaceId string, client Client) RemoteDiff
• type TreeHeads

Constants

const CName = "common.commonspace.headsync"

Functions

func HandleRangeRequest

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

Types

type Client

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

type DiffManager

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

func NewDiffManager

func NewDiffManager(
	diffContainer ldiff.DiffContainer,
	storage spacestorage.SpaceStorage,
	syncAcl syncacl.SyncAcl,
	log logger.CtxLogger,
	ctx context.Context,
	deletionState deletionstate.ObjectDeletionState,
	keyValue kvinterfaces.KeyValueService,
) *DiffManager

func (*DiffManager) AllIds

func (dm *DiffManager) AllIds() []string

func (*DiffManager) FillDiff

func (dm *DiffManager) FillDiff(ctx context.Context) error

func (*DiffManager) HandleRangeRequest

func (dm *DiffManager) HandleRangeRequest(ctx context.Context, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)

func (*DiffManager) TryDiff

func (dm *DiffManager) TryDiff(ctx context.Context, rdiff RemoteDiff) (newIds, changedIds, removedIds []string, err error)

func (*DiffManager) UpdateHeads

func (dm *DiffManager) UpdateHeads(update headstorage.HeadsUpdate)

type DiffSyncer

type DiffSyncer interface {
	Sync(ctx context.Context) error
	Init()
	Close()
}

type HeadSync

type HeadSync interface {
	app.ComponentRunnable
	ExternalIds() []string
	AllIds() []string
	HandleRangeRequest(ctx context.Context, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
}

func New

func New() HeadSync

type RemoteDiff

type RemoteDiff interface {
	ldiff.RemoteTypeChecker
	ldiff.Remote
}

func NewRemoteDiff

func NewRemoteDiff(spaceId string, client Client) RemoteDiff

type TreeHeads

type TreeHeads struct {
	Id    string
	Heads []string
}