kv

Documentation

Index

• 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

Variables

var TableMapper = map[byte]string{}

var TblPrefixName = map[byte]string{
	// contains filtered or unexported fields
}

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