partmgr

Documentation

Index

• func TimeToDHM(tmilli int64) (int, int)
• type DBPartition
  • func NewDBPartition(pmgr *PartitionManager) *DBPartition
  • 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) GetId() int
  • func (p *DBPartition) GetPath() string
  • func (p *DBPartition) HoursInChunk() int
  • 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
  • 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) TimeToChunkId(t int64) int
• type PartitionManager
  • func NewPartitionMngr(cfg *config.DBPartConfig, path string) *PartitionManager
  • func (p *PartitionManager) GetConfig() *config.DBPartConfig
  • func (p *PartitionManager) GetHead() *DBPartition
  • func (p *PartitionManager) Init() error
  • func (p *PartitionManager) IsCyclic() bool
  • func (p *PartitionManager) PartsForRange(mint, maxt int64) []*DBPartition
  • func (p *PartitionManager) TimeToPart(t int64) *DBPartition

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) *DBPartition

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) GetId

func (p *DBPartition) GetId() int

func (*DBPartition) GetPath

func (p *DBPartition) GetPath() string

func (*DBPartition) HoursInChunk

func (p *DBPartition) HoursInChunk() int

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

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) TimeToChunkId

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

Get ID of the Chunk covering time t

type PartitionManager

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

func NewPartitionMngr

func NewPartitionMngr(cfg *config.DBPartConfig, path string) *PartitionManager

Create new Partition Manager, for now confined to one Cyclic partition

func (*PartitionManager) GetConfig

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

func (*PartitionManager) GetHead

func (p *PartitionManager) GetHead() *DBPartition

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) TimeToPart

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