Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cassandra

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 30, 2020

Changes in this version

type CasIdx

+ func (c *CasIdx) DeleteTagged(orgId uint32, query tagquery.Query) ([]idx.Archive, error)

type IdxConfig

+ ConnectionCheckInterval time.Duration

+ ConnectionCheckTimeout time.Duration

v0

v0.13.1

Nov 28, 2019

Changes in this version

type CasIdx

+ 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) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) error

+ func (c *CasIdx) MetaTagRecordUpsert(orgId uint32, record tagquery.MetaTagRecord) error

type IdxConfig

+ MetaRecordBatchTable string

+ MetaRecordPollInterval time.Duration

+ MetaRecordPruneAge time.Duration

+ MetaRecordPruneInterval time.Duration

+ MetaRecordTable string

v0.13.0

Sep 17, 2019

Changes in this version

type CasIdx

+ Config *IdxConfig

+ Session *gocql.Session

type IdxConfig

+ ArchiveTable string

+ Auth bool

+ CaPath string

+ Consistency string

+ CreateKeyspace bool

+ DisableInitialHostLookup bool

+ HostVerification bool

+ Hosts string

+ InitLoadConcurrency int

+ Keyspace string

+ NumConns int

+ Password string

+ ProtoVer int

+ SSL bool

+ SchemaFile string

+ Table string

+ Timeout time.Duration

+ Username string

v0.12.0

May 14, 2019

Changes in this version

type CasIdx

+ func (c *CasIdx) ArchiveDefs(defs []schema.MetricDefinition) (int, error)

+ func (c *CasIdx) EnsureArchiveTableExists(session *gocql.Session) error

v0.11.0

Dec 19, 2018

Changes in this version

+ var CliConfig = NewIdxConfig()

+ func ConfigProcess()

+ func ConfigSetup() *flag.FlagSet

+ type CasIdx struct

+ func New(cfg *IdxConfig) *CasIdx

+ func (c *CasIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)

+ func (c *CasIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, 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) 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 struct

+ Enabled bool

+ func NewIdxConfig() *IdxConfig

+ func (cfg *IdxConfig) Validate() error