bigt

README

Native Bigtable implementation of the FluxDB storage model

This is deprecated, in favor of the kv backend, which supports more key-value backends.

Documentation

Index

• type KVStore
  • func NewKVStore(ctx context.Context, dsnString string, opts ...option.ClientOption) (*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) (bstream.BlockRef, 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

Types

type KVStore

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

func NewKVStore

func NewKVStore(ctx context.Context, dsnString string, opts ...option.ClientOption) (*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) (bstream.BlockRef, 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