treestorage

Documentation

Index

• Variables
• func CreateHeadsPayload(heads []string) []byte
• func JoinStringsToBytes(strs ...string) []byte
• func ParseHeads(headsPayload []byte) []string
• type Exporter
• type InMemoryTreeStorage
  • func (t *InMemoryTreeStorage) AddRawChange(change *treechangeproto.RawTreeChangeWithId) error
  • func (t *InMemoryTreeStorage) AddRawChangesSetHeads(changes []*treechangeproto.RawTreeChangeWithId, heads []string) error
  • func (t *InMemoryTreeStorage) AllChanges() []*treechangeproto.RawTreeChangeWithId
  • func (t *InMemoryTreeStorage) Copy() *InMemoryTreeStorage
  • func (t *InMemoryTreeStorage) Delete() error
  • func (t *InMemoryTreeStorage) Equal(other *InMemoryTreeStorage) bool
  • func (t *InMemoryTreeStorage) GetAppendRawChange(ctx context.Context, buf []byte, id string) (*treechangeproto.RawTreeChangeWithId, error)
  • func (t *InMemoryTreeStorage) GetRawChange(ctx context.Context, changeId string) (*treechangeproto.RawTreeChangeWithId, error)
  • func (t *InMemoryTreeStorage) HasChange(ctx context.Context, id string) (bool, error)
  • func (t *InMemoryTreeStorage) Heads() ([]string, error)
  • func (t *InMemoryTreeStorage) Id() string
  • func (t *InMemoryTreeStorage) Root() (*treechangeproto.RawTreeChangeWithId, error)
  • func (t *InMemoryTreeStorage) SetHeads(heads []string) error
  • func (t *InMemoryTreeStorage) SetReturnErrorOnAdd(err error)
• type TreeStorage
  • func NewInMemoryTreeStorage(root *treechangeproto.RawTreeChangeWithId, heads []string, ...) (TreeStorage, error)
• type TreeStorageCreatePayload
• type TreeStorageCreatorFunc

Variables

var (
	ErrUnknownTreeId = errors.New("tree does not exist")
	ErrTreeExists    = errors.New("tree already exists")
	ErrUnknownChange = errors.New("change doesn't exist")
)

Functions

func CreateHeadsPayload

func CreateHeadsPayload(heads []string) []byte

func JoinStringsToBytes

func JoinStringsToBytes(strs ...string) []byte

func ParseHeads

func ParseHeads(headsPayload []byte) []string

Types

type Exporter

type Exporter interface {
	TreeStorage(root *treechangeproto.RawTreeChangeWithId) (TreeStorage, error)
}

type InMemoryTreeStorage

type InMemoryTreeStorage struct {
	Changes map[string]*treechangeproto.RawTreeChangeWithId

	sync.RWMutex
	// contains filtered or unexported fields
}

func (*InMemoryTreeStorage) AddRawChange

func (t *InMemoryTreeStorage) AddRawChange(change *treechangeproto.RawTreeChangeWithId) error

func (*InMemoryTreeStorage) AddRawChangesSetHeads

func (t *InMemoryTreeStorage) AddRawChangesSetHeads(changes []*treechangeproto.RawTreeChangeWithId, heads []string) error

func (*InMemoryTreeStorage) AllChanges

func (t *InMemoryTreeStorage) AllChanges() []*treechangeproto.RawTreeChangeWithId

func (*InMemoryTreeStorage) Copy

func (t *InMemoryTreeStorage) Copy() *InMemoryTreeStorage

func (*InMemoryTreeStorage) Delete

func (t *InMemoryTreeStorage) Delete() error

func (*InMemoryTreeStorage) Equal

func (t *InMemoryTreeStorage) Equal(other *InMemoryTreeStorage) bool

func (*InMemoryTreeStorage) GetAppendRawChange

func (t *InMemoryTreeStorage) GetAppendRawChange(ctx context.Context, buf []byte, id string) (*treechangeproto.RawTreeChangeWithId, error)

func (*InMemoryTreeStorage) GetRawChange

func (t *InMemoryTreeStorage) GetRawChange(ctx context.Context, changeId string) (*treechangeproto.RawTreeChangeWithId, error)

func (*InMemoryTreeStorage) HasChange

func (t *InMemoryTreeStorage) HasChange(ctx context.Context, id string) (bool, error)

func (*InMemoryTreeStorage) Heads

func (t *InMemoryTreeStorage) Heads() ([]string, error)

func (*InMemoryTreeStorage) Id

func (t *InMemoryTreeStorage) Id() string

func (*InMemoryTreeStorage) Root

func (t *InMemoryTreeStorage) Root() (*treechangeproto.RawTreeChangeWithId, error)

func (*InMemoryTreeStorage) SetHeads

func (t *InMemoryTreeStorage) SetHeads(heads []string) error

func (*InMemoryTreeStorage) SetReturnErrorOnAdd

func (t *InMemoryTreeStorage) SetReturnErrorOnAdd(err error)

type TreeStorage

type TreeStorage interface {
	Id() string
	Root() (*treechangeproto.RawTreeChangeWithId, error)
	Heads() ([]string, error)
	SetHeads(heads []string) error
	AddRawChange(change *treechangeproto.RawTreeChangeWithId) error
	AddRawChangesSetHeads(changes []*treechangeproto.RawTreeChangeWithId, heads []string) error

	GetRawChange(ctx context.Context, id string) (*treechangeproto.RawTreeChangeWithId, error)
	GetAppendRawChange(ctx context.Context, buf []byte, id string) (*treechangeproto.RawTreeChangeWithId, error)
	HasChange(ctx context.Context, id string) (bool, error)
	Delete() error
}

func NewInMemoryTreeStorage

func NewInMemoryTreeStorage(
	root *treechangeproto.RawTreeChangeWithId,
	heads []string,
	changes []*treechangeproto.RawTreeChangeWithId) (TreeStorage, error)

type TreeStorageCreatePayload

type TreeStorageCreatePayload struct {
	RootRawChange *treechangeproto.RawTreeChangeWithId
	Changes       []*treechangeproto.RawTreeChangeWithId
	Heads         []string
}

type TreeStorageCreatorFunc

type TreeStorageCreatorFunc = func(payload TreeStorageCreatePayload) (TreeStorage, error)