headsync

Documentation

Index

• Constants
• func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
• type Client
• 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 DiffSyncer

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

type HeadSync

type HeadSync interface {
	app.ComponentRunnable
	ExternalIds() []string
	DebugAllHeads() (res []TreeHeads)
	AllIds() []string
	UpdateHeads(id string, heads []string)
	HandleRangeRequest(ctx context.Context, req *spacesyncproto.HeadSyncRequest) (resp *spacesyncproto.HeadSyncResponse, err error)
	RemoveObjects(ids []string)
}

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
}