headstorage

type DeletedStatus int

type EntryIterator func(entry HeadsEntry) (bool, error)

type HeadStorage interface {
	AddObserver(observer Observer)
	IterateEntries(ctx context.Context, iterOpts IterOpts, iter EntryIterator) error
	GetEntry(ctx context.Context, id string) (HeadsEntry, error)
	DeleteEntryTx(txCtx context.Context, id string) error
	UpdateEntryTx(txCtx context.Context, update HeadsUpdate) error
	UpdateEntry(ctx context.Context, update HeadsUpdate) error
}

type HeadsEntry struct {
	Id             string
	Heads          []string
	CommonSnapshot string
	DeletedStatus  DeletedStatus
	IsDerived      bool
}

type HeadsUpdate struct {
	Id             string
	Heads          []string
	CommonSnapshot *string
	DeletedStatus  *DeletedStatus
	IsDerived      *bool
}

type IterOpts struct {
	Deleted bool
}

type Observer interface {
	OnUpdate(update HeadsUpdate)
}