headsync

Documentation

Index

• Constants
• 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 New() HeadSync
• 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)

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()
	Close() error
}

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 TreeHeads

type TreeHeads struct {
	Id    string
	Heads []string
}