storage

Documentation

Index

• type Backend
• type Store
  • func (s *Store) Read(ctx context.Context, q collation.Query) (collation.Result, error)
  • func (s *Store) Write(ctx context.Context, r collation.Row) error
• type Transaction
  • func (t Transaction) Do(data []byte, init bool) error

Types

type Backend

type Backend interface {
	// Read a buffer value stored against key k into buffer buf.
	// The return value will be false if the key could not be found in the map.
	Get(k uint64, buf []byte) bool

	// Update finds the buffer stored against key k and atomically updates it with
	// v using the function fn. It returns the error returned by fn, if any. The
	// function fn may be called multiple times during a single call to Update, or
	// not called at all.
	Update(k uint64, fn func(data []byte, init bool) error) error
}

type Store

type Store struct {
	Backend  Backend
	Collator collation.Collator
}

func (*Store) Read

func (s *Store) Read(ctx context.Context, q collation.Query) (collation.Result, error)

func (*Store) Write

func (s *Store) Write(ctx context.Context, r collation.Row) error

type Transaction

type Transaction struct {
	Row collation.Row
	Fn  func(r collation.Row, data []byte, init bool) error
}

func (Transaction) Do

func (t Transaction) Do(data []byte, init bool) error