kv

README

This is the kv backend, backed by the https://github.com/dfuse-io/kvdb abstraction layer.

This is the currently recommended backend.

Documentation

Index

• Constants
• Variables
• type KVStore
  • func NewStore(ctx context.Context, dsnString string) (*KVStore, error)
  • func (s *KVStore) Close() error
  • func (s *KVStore) FetchABI(ctx context.Context, prefixKey, keyStart, keyEnd string) (rowKey string, rawABI []byte, err error)
  • func (s *KVStore) FetchIndex(ctx context.Context, tableKey, prefixKey, keyStart string) (rowKey string, rawIndex []byte, err error)
  • func (s *KVStore) FetchLastWrittenBlock(ctx context.Context, key string) (out bstream.BlockRef, err error)
  • func (s *KVStore) FetchTabletRow(ctx context.Context, key string, onTabletRow store.OnTabletRow) error
  • func (s *KVStore) FetchTabletRows(ctx context.Context, keys []string, onTabletRow store.OnTabletRow) error
  • func (s *KVStore) HasTabletRow(ctx context.Context, keyPrefix string) (exists bool, err error)
  • func (s *KVStore) NewBatch(logger *zap.Logger) store.Batch
  • func (s *KVStore) ScanLastShardsWrittenBlock(ctx context.Context, keyPrefix string, onBlockRef store.OnBlockRef) error
  • func (s *KVStore) ScanTabletRows(ctx context.Context, keyStart, keyEnd string, onTabletRow store.OnTabletRow) error

Constants

const (
	TblPrefixRows  = 0x00
	TblPrefixIndex = 0x01
	TblPrefixABIs  = 0x02
	TblPrefixLast  = 0x03
)

Variables

var TableMapper = map[byte]string{}

var TblPrefixName = map[byte]string{
	TblPrefixRows:  "tablet",
	TblPrefixIndex: "index",
	TblPrefixABIs:  "abi",
	TblPrefixLast:  "block",
}

Types

type KVStore

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

func NewStore

func NewStore(ctx context.Context, dsnString string) (*KVStore, error)

func (*KVStore) Close

func (s *KVStore) Close() error

func (*KVStore) FetchABI

func (s *KVStore) FetchABI(ctx context.Context, prefixKey, keyStart, keyEnd string) (rowKey string, rawABI []byte, err error)

func (*KVStore) FetchIndex

func (s *KVStore) FetchIndex(ctx context.Context, tableKey, prefixKey, keyStart string) (rowKey string, rawIndex []byte, err error)

func (*KVStore) FetchLastWrittenBlock

func (s *KVStore) FetchLastWrittenBlock(ctx context.Context, key string) (out bstream.BlockRef, err error)

func (*KVStore) FetchTabletRow

func (s *KVStore) FetchTabletRow(ctx context.Context, key string, onTabletRow store.OnTabletRow) error

func (*KVStore) FetchTabletRows

func (s *KVStore) FetchTabletRows(ctx context.Context, keys []string, onTabletRow store.OnTabletRow) error

func (*KVStore) HasTabletRow

func (s *KVStore) HasTabletRow(ctx context.Context, keyPrefix string) (exists bool, err error)

func (*KVStore) NewBatch

func (s *KVStore) NewBatch(logger *zap.Logger) store.Batch

func (*KVStore) ScanLastShardsWrittenBlock

func (s *KVStore) ScanLastShardsWrittenBlock(ctx context.Context, keyPrefix string, onBlockRef store.OnBlockRef) error

func (*KVStore) ScanTabletRows

func (s *KVStore) ScanTabletRows(ctx context.Context, keyStart, keyEnd string, onTabletRow store.OnTabletRow) error