cassandra

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2020 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL