metrictank: Index | Files

package cassandra

import ""


Package Files

config.go meta_record_idx.go


var CliConfig = NewConfig()

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

func ConfigProcess Uses

func ConfigProcess()

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

func ConfigSetup Uses

func ConfigSetup() *flag.FlagSet

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

type Config Uses

type Config struct {
    Enabled bool
    // contains filtered or unexported fields

Config stores configuration settings for a cassandra meta record index

func NewConfig Uses

func NewConfig() *Config

NewConfig returns MetaRecordIdxConfig with default values set.

func (*Config) Validate Uses

func (cfg *Config) Validate() error

Validate validates MetaRecordIdxConfig settings

type MetaRecordIdx Uses

type MetaRecordIdx struct {
    // contains filtered or unexported fields

func NewCassandraMetaRecordIdx Uses

func NewCassandraMetaRecordIdx(cfg *Config, memoryIdx idx.MetaRecordIdx) *MetaRecordIdx

func (*MetaRecordIdx) Init Uses

func (m *MetaRecordIdx) Init() error

func (*MetaRecordIdx) MetaTagRecordList Uses

func (m *MetaRecordIdx) MetaTagRecordList(orgId uint32) []tagquery.MetaTagRecord

func (*MetaRecordIdx) MetaTagRecordSwap Uses

func (m *MetaRecordIdx) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) error

func (*MetaRecordIdx) MetaTagRecordUpsert Uses

func (m *MetaRecordIdx) MetaTagRecordUpsert(orgId uint32, record tagquery.MetaTagRecord) error

func (*MetaRecordIdx) Start Uses

func (m *MetaRecordIdx) Start()

func (*MetaRecordIdx) Stop Uses

func (m *MetaRecordIdx) Stop()

Package cassandra imports 15 packages (graph). Updated 2020-03-04. Refresh now. Tools for package owners.