cassandra

Jan 29, 2020

Changes in this version

type Config

+ MaxConnsPerHost int

+ NumRetries int

+ WaitTimeMult time.Duration

Jan 21, 2020

Changes in this version

type Connection

+ func (c *Connection) GetStateHash(records []db.Record) (string, error)

Oct 1, 2019

Changes in this version

+ const CountLabel

+ const PoolIdleConnectionsGauge

+ const PoolInUseConnectionsGauge

+ const PoolOpenConnectionsGauge

+ const RetryCounter

+ const SQLDeletedRecordsCounter

+ const SQLDurationSeconds

+ const SQLInsertedRecordsCounter

+ const SQLMaxIdleClosedCounter

+ const SQLMaxLifetimeClosedCounter

+ const SQLQueryFailureCounter

+ const SQLQuerySuccessCounter

+ const SQLReadRecordsCounter

+ const SQLWaitCounter

+ const SQLWaitDurationCounter

+ func Metrics() []xmetrics.Metric

+ type Config struct

+ Database string

+ EnableHostVerification bool

+ Hosts []string

+ OpTimeout time.Duration

+ Password string

+ SSLCert string

+ SSLKey string

+ SSLRootCert string

+ Username string

+ type Connection struct

+ func CreateDbConnection(config Config, provider provider.Provider, health *health.Health) (*Connection, error)

+ func (c *Connection) Close() error

+ func (c *Connection) GetBlacklist() (list []blacklist.BlackListedItem, err error)

+ func (c *Connection) GetDeviceList(offset string, limit int) ([]string, error)

+ func (c *Connection) GetRecords(deviceID string, limit int) ([]db.Record, error)

+ func (c *Connection) GetRecordsOfType(deviceID string, limit int, eventType db.EventType) ([]db.Record, error)

+ func (c *Connection) InsertRecords(records ...db.Record) error

+ func (c *Connection) Ping() error

+ type Measures struct

+ PoolInUseConnections metrics.Gauge

+ SQLDeletedRecords metrics.Counter

+ SQLDuration metrics.Histogram

+ SQLInsertedRecords metrics.Counter

+ SQLQueryFailureCount metrics.Counter

+ SQLQuerySuccessCount metrics.Counter

+ SQLReadRecords metrics.Counter

+ func NewMeasures(p provider.Provider) Measures