partmgr

Documentation

Index

• func TimeToDHM(tmilli int64) (int, int)
• type DBPartition
  • func NewDBPartition(pmgr *PartitionManager, startTime int64, path string) (*DBPartition, error)
  • func (p *DBPartition) AggrBuckets() int
  • func (p *DBPartition) AggrType() aggregate.AggrType
  • func (p *DBPartition) ChunkID2Attr(col string, id int) string
  • func (p *DBPartition) CyclicMinTime(mint, maxt int64) int64
  • func (p *DBPartition) GetChunkMint(t int64) int64
  • func (p *DBPartition) GetEndTime() int64
  • func (p *DBPartition) GetHashingBuckets() int
  • func (p *DBPartition) GetMetricPath(name string, hash uint64) string
  • func (p *DBPartition) GetPartitionRange(maxt int64) (int64, int64)
  • func (p *DBPartition) GetShardingKeys(name string) []string
  • func (p *DBPartition) GetStartTime() int64
  • func (p *DBPartition) GetTablePath() string
  • func (p *DBPartition) InChunkRange(mint, t int64) bool
  • func (p *DBPartition) InRange(t int64) bool
  • func (p *DBPartition) IsAheadOfChunk(mint, t int64) bool
  • func (p *DBPartition) IsCyclic() bool
  • func (p *DBPartition) NextPart(t int64) (*DBPartition, error)
  • func (p *DBPartition) Range2Attrs(col string, mint, maxt int64) ([]string, []int)
  • func (p *DBPartition) Range2Cids(mint, maxt int64) []int
  • func (p *DBPartition) RollupTime() int64
  • func (p *DBPartition) Time2Bucket(t int64) int
  • func (p *DBPartition) TimePerChunk() int64
  • func (p *DBPartition) TimeToChunkId(tmilli int64) (int, error)
• type PartitionManager
  • func NewPartitionMngr(cfg *config.Schema, partPath string, cont *v3io.Container) (*PartitionManager, error)
  • func (p *PartitionManager) GetConfig() *config.Schema
  • func (p *PartitionManager) GetPartitionsPaths() []string
  • func (p *PartitionManager) Init() error
  • func (p *PartitionManager) IsCyclic() bool
  • func (p *PartitionManager) PartsForRange(mint, maxt int64) []*DBPartition
  • func (p *PartitionManager) ReadAndUpdateSchema() error
  • func (p *PartitionManager) TimeToPart(t int64) (*DBPartition, error)

Functions

func TimeToDHM

func TimeToDHM(tmilli int64) (int, int)

Convert time in milisec to Day index and hour

Types

type DBPartition

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

func NewDBPartition

func NewDBPartition(pmgr *PartitionManager, startTime int64, path string) (*DBPartition, error)

Create and Init a new Partition

func (*DBPartition) AggrBuckets

func (p *DBPartition) AggrBuckets() int

func (*DBPartition) AggrType

func (p *DBPartition) AggrType() aggregate.AggrType

func (*DBPartition) ChunkID2Attr

func (p *DBPartition) ChunkID2Attr(col string, id int) string

Attribute name of a chunk

func (*DBPartition) CyclicMinTime

func (p *DBPartition) CyclicMinTime(mint, maxt int64) int64

return the valid minimum time in a cyclic partition based on max time

func (*DBPartition) GetChunkMint

func (p *DBPartition) GetChunkMint(t int64) int64

get nearest chunk start

func (*DBPartition) GetEndTime

func (p *DBPartition) GetEndTime() int64

func (*DBPartition) GetHashingBuckets

func (p *DBPartition) GetHashingBuckets() int

func (*DBPartition) GetMetricPath

func (p *DBPartition) GetMetricPath(name string, hash uint64) string

return metric object full path

func (*DBPartition) GetPartitionRange

func (p *DBPartition) GetPartitionRange(maxt int64) (int64, int64)

return the mint and maxt for this partition, may need maxt for cyclic partition

func (*DBPartition) GetShardingKeys

func (p *DBPartition) GetShardingKeys(name string) []string

return list of Sharding Keys matching the name

func (*DBPartition) GetStartTime

func (p *DBPartition) GetStartTime() int64

func (*DBPartition) GetTablePath

func (p *DBPartition) GetTablePath() string

return path to metrics table

func (*DBPartition) InChunkRange

func (p *DBPartition) InChunkRange(mint, t int64) bool

is the time t in the range of the chunk starting at mint

func (*DBPartition) InRange

func (p *DBPartition) InRange(t int64) bool

is t covered by this partition

func (*DBPartition) IsAheadOfChunk

func (p *DBPartition) IsAheadOfChunk(mint, t int64) bool

is the time t ahead of the range of the chunk starting at mint

func (*DBPartition) IsCyclic

func (p *DBPartition) IsCyclic() bool

func (*DBPartition) NextPart

func (p *DBPartition) NextPart(t int64) (*DBPartition, error)

func (*DBPartition) Range2Attrs

func (p *DBPartition) Range2Attrs(col string, mint, maxt int64) ([]string, []int)

Return the attributes that need to be retrieved for a given time range

func (*DBPartition) Range2Cids

func (p *DBPartition) Range2Cids(mint, maxt int64) []int

All the chunk IDs which match the time range

func (*DBPartition) RollupTime

func (p *DBPartition) RollupTime() int64

func (*DBPartition) Time2Bucket

func (p *DBPartition) Time2Bucket(t int64) int

get aggregator bucket id

func (*DBPartition) TimePerChunk

func (p *DBPartition) TimePerChunk() int64

Time covered by a single chunk

func (*DBPartition) TimeToChunkId

func (p *DBPartition) TimeToChunkId(tmilli int64) (int, error)

Get ID of the Chunk covering time t

type PartitionManager

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

func NewPartitionMngr

func NewPartitionMngr(cfg *config.Schema, partPath string, cont *v3io.Container) (*PartitionManager, error)

Create new Partition Manager

func (*PartitionManager) GetConfig

func (p *PartitionManager) GetConfig() *config.Schema

func (*PartitionManager) GetPartitionsPaths

func (p *PartitionManager) GetPartitionsPaths() []string

func (*PartitionManager) Init

func (p *PartitionManager) Init() error

func (*PartitionManager) IsCyclic

func (p *PartitionManager) IsCyclic() bool

func (*PartitionManager) PartsForRange

func (p *PartitionManager) PartsForRange(mint, maxt int64) []*DBPartition

func (*PartitionManager) ReadAndUpdateSchema

func (p *PartitionManager) ReadAndUpdateSchema() error

func (*PartitionManager) TimeToPart

func (p *PartitionManager) TimeToPart(t int64) (*DBPartition, error)