embed

Documentation

Index

• type EmbedDatastore
  • func NewEmbedDatastore(dbDirectory string) (*EmbedDatastore, error)
  • func (m *EmbedDatastore) AddPrefix(prefix string) datastore.Datastore
  • func (ds *EmbedDatastore) Apply(key string, pb proto.Message) error
  • func (ds *EmbedDatastore) Close() error
  • func (ds *EmbedDatastore) Delete(key string) error
  • func (ds EmbedDatastore) Get(key string, pb proto.Message) error
  • func (ds *EmbedDatastore) IsLocked(key string) bool
  • func (ds EmbedDatastore) List(f func(length int) []proto.Message) error
  • func (ds *EmbedDatastore) Lock(key string) bool
  • func (ds *EmbedDatastore) Unlock(key string) bool

Types

type EmbedDatastore

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

func NewEmbedDatastore

func NewEmbedDatastore(dbDirectory string) (*EmbedDatastore, error)

func (*EmbedDatastore) AddPrefix

func (m *EmbedDatastore) AddPrefix(prefix string) datastore.Datastore

func (*EmbedDatastore) Apply

func (ds *EmbedDatastore) Apply(key string, pb proto.Message) error

func (*EmbedDatastore) Close

func (ds *EmbedDatastore) Close() error

func (*EmbedDatastore) Delete

func (ds *EmbedDatastore) Delete(key string) error

func (EmbedDatastore) Get

func (ds EmbedDatastore) Get(key string, pb proto.Message) error

func (*EmbedDatastore) IsLocked

func (ds *EmbedDatastore) IsLocked(key string) bool

func (EmbedDatastore) List

func (ds EmbedDatastore) List(f func(length int) []proto.Message) error

func (*EmbedDatastore) Lock

func (ds *EmbedDatastore) Lock(key string) bool

func (*EmbedDatastore) Unlock

func (ds *EmbedDatastore) Unlock(key string) bool