cassandra

Documentation

Index

• Variables
• func ConfigProcess()
• func ConfigSetup() *flag.FlagSet
• type CasIdx
  • func New(cfg *IdxConfig) *CasIdx
  • func (c *CasIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)
  • func (c *CasIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)
  • func (c *CasIdx) Init() error
  • func (c *CasIdx) InitBare() error
  • func (c *CasIdx) Load(defs []schema.MetricDefinition, now time.Time) []schema.MetricDefinition
  • func (c *CasIdx) LoadPartitions(partitions []int32, defs []schema.MetricDefinition, now time.Time) []schema.MetricDefinition
  • func (c *CasIdx) Prune(now time.Time) ([]idx.Archive, error)
  • func (c *CasIdx) Stop()
  • func (c *CasIdx) Update(point schema.MetricPoint, partition int32) (idx.Archive, int32, bool)
• type IdxConfig
  • func NewIdxConfig() *IdxConfig
  • func (cfg *IdxConfig) Validate() error

Variables

var CliConfig = NewIdxConfig()

CliConfig is a cassandra IdxConfig. It is instantiated with default values which can then be changed.

Functions

func ConfigProcess

func ConfigProcess()

ConfigProcess calls IdxConfig.Validate() on CliConfig. If an error is discovered this will exit with status set to 1.

func ConfigSetup

func ConfigSetup() *flag.FlagSet

ConfigSetup sets up and registers a FlagSet in globalconf for cassandra index and returns it

Types

type CasIdx

type CasIdx struct {
	memory.MemoryIdx
	// contains filtered or unexported fields
}

CasIdx implements the the "MetricIndex" interface

func New

func New(cfg *IdxConfig) *CasIdx

func (*CasIdx) AddOrUpdate

func (c *CasIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)

func (*CasIdx) Delete

func (c *CasIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)

func (*CasIdx) Init

func (c *CasIdx) Init() error

Init makes sure the needed keyspace, table, index in cassandra exists, creates the session, rebuilds the in-memory index, sets up write queues, metrics and pruning routines

func (*CasIdx) InitBare

func (c *CasIdx) InitBare() error

InitBare makes sure the keyspace, tables, and index exists in cassandra and creates a session

func (*CasIdx) Load

func (c *CasIdx) Load(defs []schema.MetricDefinition, now time.Time) []schema.MetricDefinition

func (*CasIdx) LoadPartitions

func (c *CasIdx) LoadPartitions(partitions []int32, defs []schema.MetricDefinition, now time.Time) []schema.MetricDefinition

func (*CasIdx) Prune

func (c *CasIdx) Prune(now time.Time) ([]idx.Archive, error)

func (*CasIdx) Stop

func (c *CasIdx) Stop()

func (*CasIdx) Update

func (c *CasIdx) Update(point schema.MetricPoint, partition int32) (idx.Archive, int32, bool)

Update updates an existing archive, if found. It returns whether it was found, and - if so - the (updated) existing archive and its old partition

type IdxConfig

type IdxConfig struct {
	Enabled bool
	// contains filtered or unexported fields
}

IdxConfig stores configuration settings for a cassandra index

func NewIdxConfig

func NewIdxConfig() *IdxConfig

NewIdxConfig returns IdxConfig with default values set.

func (*IdxConfig) Validate

func (cfg *IdxConfig) Validate() error

Validate validates IdxConfig settings