Documentation
¶
Index ¶
- Constants
- type ShardKeyIndex
- func (idx *ShardKeyIndex) Close() error
- func (idx *ShardKeyIndex) CreateIndex(name []byte, shardKey []byte, sid uint64) error
- func (idx *ShardKeyIndex) GetShardSeriesCount() int
- func (idx *ShardKeyIndex) GetSplitPointsByRowCount(poses []int64, f func(name string, sid uint64) int64) ([]string, error)
- func (idx *ShardKeyIndex) GetSplitPointsWithSeriesCount(poses []int64) ([]string, error)
- func (idx *ShardKeyIndex) Open() error
Constants ¶
View Source
const ShardKeyCache = "shard_key_cache"
View Source
const ShardKeyDirectory = "shard_key_index"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ShardKeyIndex ¶
type ShardKeyIndex struct {
// contains filtered or unexported fields
}
func NewShardKeyIndex ¶
func NewShardKeyIndex(dataPath 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) GetShardSeriesCount ¶
func (idx *ShardKeyIndex) GetShardSeriesCount() int
func (*ShardKeyIndex) GetSplitPointsByRowCount ¶
func (*ShardKeyIndex) GetSplitPointsWithSeriesCount ¶
func (idx *ShardKeyIndex) GetSplitPointsWithSeriesCount(poses []int64) ([]string, error)
func (*ShardKeyIndex) Open ¶
func (idx *ShardKeyIndex) Open() error
Source Files
Click to show internal directories.
Click to hide internal directories.