hidalgo

README

This was a native Hidalgo implementation. It never made it into more than tests.

This is deprecated in favor of the kv implementation.

Documentation

Index

• type KVStore
  • func NewKVStore(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
• type KVStoreDsn

Types

type KVStore

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

func NewKVStore

func NewKVStore(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

type KVStoreDsn

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