bigtable

Documentation

Index

• Variables
• func ConfigProcess()
• func ConfigSetup()
• type Config
  • func NewConfig() *Config
  • func (cfg *Config) Validate() error
• type MetaRecordIdx
  • func NewBigTableMetaRecordIdx(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()

Functions

func ConfigProcess

func ConfigProcess()

func ConfigSetup

func ConfigSetup()

Types

type Config

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

func NewConfig

func NewConfig() *Config

return Config with default values set.

func (*Config) Validate

func (cfg *Config) Validate() error

type MetaRecordIdx

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

func NewBigTableMetaRecordIdx

func NewBigTableMetaRecordIdx(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()