ski

Documentation

Index

• Constants
• type ShardKeyIndex
  • func NewShardKeyIndex(dataPath string, lockPath *string) (*ShardKeyIndex, error)
  • func (idx *ShardKeyIndex) Close() error
  • func (idx *ShardKeyIndex) CreateIndex(name []byte, shardKey []byte, sid uint64) error
  • func (idx *ShardKeyIndex) ForceFlush()
  • func (idx *ShardKeyIndex) GetShardSeriesCount() int
  • func (idx *ShardKeyIndex) GetSplitPointsByRowCount(poses []int64, f func(name string, sid uint64) (int64, error)) ([]string, error)
  • func (idx *ShardKeyIndex) GetSplitPointsWithSeriesCount(poses []int64) ([]string, error)
  • func (idx *ShardKeyIndex) Open() error

Constants

const ShardKeyCache = "shard_key_cache"

const ShardKeyDirectory = "shard_key_index"

Types

type ShardKeyIndex

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

func NewShardKeyIndex

func NewShardKeyIndex(dataPath string, lockPath *string) (*ShardKeyIndex, error)

func (*ShardKeyIndex) Close

func (idx *ShardKeyIndex) Close() error

func (*ShardKeyIndex) CreateIndex

func (idx *ShardKeyIndex) CreateIndex(name []byte, shardKey []byte, sid uint64) error

func (*ShardKeyIndex) ForceFlush

func (idx *ShardKeyIndex) ForceFlush()

func (*ShardKeyIndex) GetShardSeriesCount

func (idx *ShardKeyIndex) GetShardSeriesCount() int

func (*ShardKeyIndex) GetSplitPointsByRowCount

func (idx *ShardKeyIndex) GetSplitPointsByRowCount(poses []int64, f func(name string, sid uint64) (int64, error)) ([]string, error)

func (*ShardKeyIndex) GetSplitPointsWithSeriesCount

func (idx *ShardKeyIndex) GetSplitPointsWithSeriesCount(poses []int64) ([]string, error)

func (*ShardKeyIndex) Open

func (idx *ShardKeyIndex) Open() error