Documentation ¶
Index ¶
- Variables
- func ConfigProcess()
- func ConfigSetup() *flag.FlagSet
- type CasIdx
- func (c *CasIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)
- func (c *CasIdx) ArchiveDefs(defs []schema.MetricDefinition) (int, error)
- func (c *CasIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)
- func (c *CasIdx) EnsureTableExists(session *gocql.Session, schemaFile, entryName, tableName string) error
- func (c *CasIdx) Find(orgId uint32, pattern string, from int64) ([]idx.Node, 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) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) error
- func (c *CasIdx) MetaTagRecordUpsert(orgId uint32, record tagquery.MetaTagRecord) error
- 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
Constants ¶
This section is empty.
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 ¶
ConfigSetup sets up and registers a FlagSet in globalconf for cassandra index and returns it
Types ¶
type CasIdx ¶
type CasIdx struct { memory.MemoryIndex Config *IdxConfig Session *gocql.Session // contains filtered or unexported fields }
CasIdx implements the the "MetricIndex" interface
func (*CasIdx) AddOrUpdate ¶
func (*CasIdx) ArchiveDefs ¶ added in v0.12.0
func (c *CasIdx) ArchiveDefs(defs []schema.MetricDefinition) (int, error)
ArchiveDefs writes each of the provided defs to the archive table and then deletes the defs from the metric index table.
func (*CasIdx) EnsureTableExists ¶ added in v0.13.1
func (c *CasIdx) EnsureTableExists(session *gocql.Session, schemaFile, entryName, tableName string) error
EnsureTableExists checks if the specified table exists or not. If it does not exist and the create-keyspace flag is true, then it will create it, if it doesn't exist and the create-keyspace flag is false, then it will return an error. If the table exists then it just returns nil session: cassandra session schemaFile: file containing table definition entryName: identifier of the schema within the file tableName: name of the table in cassandra
func (*CasIdx) Init ¶
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 ¶
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
LoadPartitions appends MetricDefinitions from the given partitions to defs and returns the modified defs, honoring pruning settings relative to now
func (*CasIdx) MetaTagRecordSwap ¶ added in v0.13.1
func (c *CasIdx) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) error
func (*CasIdx) MetaTagRecordUpsert ¶ added in v0.13.1
func (c *CasIdx) MetaTagRecordUpsert(orgId uint32, record tagquery.MetaTagRecord) error
type IdxConfig ¶
type IdxConfig struct { Enabled bool SSL bool Auth bool HostVerification bool CreateKeyspace bool SchemaFile string Keyspace string Table string ArchiveTable string MetaRecordTable string MetaRecordBatchTable string MetaRecordPollInterval time.Duration MetaRecordPruneInterval time.Duration MetaRecordPruneAge time.Duration Hosts string CaPath string Username string Password string Consistency string Timeout time.Duration NumConns int ProtoVer int DisableInitialHostLookup bool InitLoadConcurrency int // 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.