cassandra

Documentation

Index

• Variables
• func ConfigProcess()
• func ConfigSetup() *flag.FlagSet
• type Config
  • func NewConfig() *Config
  • func (cfg *Config) Validate() error
• type MetaRecordIdx
  • func NewCassandraMetaRecordIdx(cfg *Config, memoryIdx idx.MetaRecordIdx) *MetaRecordIdx
  • func (m *MetaRecordIdx) Init() error
  • func (m *MetaRecordIdx) MetaTagRecordList(orgId uint32) []tagquery.MetaTagRecord
  • func (m *MetaRecordIdx) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) error
  • func (m *MetaRecordIdx) MetaTagRecordUpsert(orgId uint32, record tagquery.MetaTagRecord) error
  • func (m *MetaRecordIdx) Start()
  • func (m *MetaRecordIdx) Stop()

Variables

var CliConfig = NewConfig()

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

Functions

func ConfigProcess

func ConfigProcess()

ConfigProcess calls MetaRecordIdxConfig.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 Config

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

Config stores configuration settings for a cassandra meta record index

func NewConfig

func NewConfig() *Config

NewConfig returns MetaRecordIdxConfig with default values set.

func (*Config) Validate

func (cfg *Config) Validate() error

Validate validates MetaRecordIdxConfig settings

type MetaRecordIdx

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

func NewCassandraMetaRecordIdx

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

func (*MetaRecordIdx) Init

func (m *MetaRecordIdx) Init() error

func (*MetaRecordIdx) MetaTagRecordList

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

func (*MetaRecordIdx) MetaTagRecordSwap

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

func (*MetaRecordIdx) MetaTagRecordUpsert

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

func (*MetaRecordIdx) Start

func (m *MetaRecordIdx) Start()

func (*MetaRecordIdx) Stop

func (m *MetaRecordIdx) Stop()