db

Jun 28, 2019

Changes in this version

+ const BlacklistReadType

type Pruner

+ DeleteRecord func(shard int, deathdate int64, recordID int64) error

+ GetRecordsToDelete func(shard int, limit int, deathDate int64) ([]RecordToDelete, error)

+ type RecordToDelete struct

+ DeathDate int64

+ RecordID int64

Jun 17, 2019

Changes in this version

+ const DeleteType

+ const InsertType

+ const ListReadType

+ const PingType

+ const ReadType

+ const TypeLabel

Jun 10, 2019

Changes in this version

type Connection

+ func (db *Connection) GetRecordIDs(shard int, limit int, deathDate int64) ([]int, error)

type Option

+ func WithIntervalMultiplier(mult time.Duration) Option

type Pruner

+ GetRecordIDs func(shard int, limit int, deathDate int64) ([]int, error)

type RetryUpdateService

+ func (ru RetryUpdateService) GetRecordIDs(shard int, limit int, deathDate int64) ([]int, error)

May 9, 2019

Changes in this version

+ const SQLDeletedRecordsCounter

+ const SQLInsertedRecordsCounter

+ const SQLQueryEndCounter

+ const SQLReadRecordsCounter

type Measures

+ SQLDeletedRecords metrics.Counter

+ SQLInsertedRecords metrics.Counter

+ SQLQueryEndCount metrics.Counter

+ SQLReadRecords metrics.Counter

Apr 26, 2019

Changes in this version

+ type Option func(r *retryConfig)

+ func WithInterval(interval time.Duration) Option

+ func WithMeasures(p provider.Provider) Option

+ func WithRetries(retries int) Option

+ func WithSleep(sleep func(time.Duration)) Option

Apr 17, 2019

Changes in this version

type Record

+ Alg string

+ KID string

Apr 15, 2019

Changes in this version

+ type EventType int

+ const Default

+ const State

+ func ParseEventType(event string) EventType

+ func (i EventType) String() string

type Record

+ Nonce []byte

Apr 11, 2019

Changes in this version

type Connection

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

+ type RetryListGService struct

+ func CreateRetryListGService(listGetter blacklist.Updater, retries int, interval time.Duration, ...) RetryListGService

+ func (ltg RetryListGService) GetBlacklist() (list []blacklist.BlackListedItem, err error)

Apr 9, 2019

Changes in this version

type Config

+ PruneLimit int

Mar 15, 2019

Changes in this version

+ const SQLDeletedRowsCounter

+ const SQLQueryFailureCounter

+ const SQLQueryRetryCounter

+ const SQLQuerySuccessCounter

type Measures

+ SQLDeletedRows metrics.Counter

+ SQLQueryFailureCount metrics.Counter

+ SQLQueryRetryCount metrics.Counter

+ SQLQuerySuccessCount metrics.Counter

Mar 12, 2019

Changes in this version

type Connection

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

type Inserter

+ InsertRecords func(records ...Record) error

type RetryInsertService

+ func (ri RetryInsertService) InsertRecords(records ...Record) error

Feb 26, 2019

Changes in this version

+ const ConnectionStatusGauge

+ const EventDefault

+ const EventState

+ const PoolIdleConnectionsGauge

+ const PoolInUseConnectionsGauge

+ const PoolOpenConnectionsGauge

+ const RetryCounter

+ const SQLMaxIdleClosedCounter

+ const SQLMaxLifetimeClosedCounter

+ const SQLWaitCounter

+ const SQLWaitDurationCounter

+ func MarshalEvent(event int) string

+ func Metrics() []xmetrics.Metric

+ func UnmarshalEvent(event string) int

+ type Config struct

+ ConnectTimeout time.Duration

+ Database string

+ MaxIdleConns int

+ MaxOpenConns int

+ NumRetries int

+ OpTimeout time.Duration

+ PingInterval time.Duration

+ SSLCert string

+ SSLKey string

+ SSLRootCert string

+ Server string

+ Username string

+ WaitTimeMult time.Duration

type Connection

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

+ func (db *Connection) Close() error

+ func (db *Connection) GetRecords(deviceID string) ([]Record, error)

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

+ func (db *Connection) InsertRecord(record Record) error

+ func (db *Connection) Ping() error

+ func (db *Connection) PruneRecords(t time.Time) error

+ type Inserter interface

+ InsertRecord func(record Record) error

+ type Measures struct

+ ConnectionStatus metrics.Gauge

+ PoolIdleConnections metrics.Gauge

+ PoolInUseConnections metrics.Gauge

+ PoolOpenConnections metrics.Gauge

+ Retry xmetrics.Incrementer

+ SQLMaxIdleClosed metrics.Counter

+ SQLMaxLifetimeClosed metrics.Counter

+ SQLWaitCount metrics.Counter

+ SQLWaitDuration metrics.Counter

+ func NewMeasures(p provider.Provider) Measures

+ type Pruner interface

+ PruneRecords func(t time.Time) error

+ type Record struct

+ BirthDate time.Time

+ Data []byte

+ DeathDate time.Time

+ DeviceID string

+ ID int

+ Type int

+ func (Record) TableName() string

+ type RecordGetter interface

+ GetRecords func(deviceID string) ([]Record, error)

+ GetRecordsOfType func(deviceID string, eventType int) ([]Record, error)

+ type RetryInsertService struct

+ func CreateRetryInsertService(inserter Inserter, retries int, interval time.Duration) RetryInsertService

+ func (ri RetryInsertService) InsertRecord(record Record) error

+ type RetryRGService struct

+ func CreateRetryRGService(recordGetter RecordGetter, retries int, interval time.Duration) RetryRGService

+ func (rtg RetryRGService) GetRecords(deviceID string) ([]Record, error)

+ func (rtg RetryRGService) GetRecordsOfType(deviceID string, eventType int) ([]Record, error)

+ type RetryUpdateService struct

+ func CreateRetryUpdateService(pruner Pruner, retries int, interval time.Duration) RetryUpdateService

+ func (ru RetryUpdateService) PruneRecords(t time.Time) error

Jan 17, 2019

Changes in this version

+ type Connection struct

+ Bucket string

+ NumRetries int

+ Password string

+ Server string

+ Timeout time.Duration

+ Username string

+ func (db *Connection) GetHistory(deviceID string) (History, error)

+ func (db *Connection) GetTombstone(deviceID string) (map[string]Event, error)

+ func (db *Connection) Initialize() error

+ func (db *Connection) InsertEvent(deviceID string, event Event, tombstoneMapKey string) error

+ func (db *Connection) RemoveAll() error

+ func (db *Connection) UpdateHistory(deviceID string, events []Event) error

type Event

+ ID string

+ type History struct

+ Events []Event

type Interface

+ UpdateHistory func(deviceID string, events []Event) error

Jan 11, 2019

Changes in this version

+ type DbConnection struct

+ Bucket string

+ NumRetries int

+ Password string

+ Server string

+ Timeout time.Duration

+ Username string

+ func (db *DbConnection) GetHistory(deviceId string) ([]Event, error)

+ func (db *DbConnection) GetTombstone(deviceId string) (map[string]Event, error)

+ func (db *DbConnection) Initialize() error

+ func (db *DbConnection) InsertEvent(deviceId string, event Event, tombstoneMapKey string) error

+ func (db *DbConnection) RemoveAll() error

+ func (db *DbConnection) RemoveHistory(deviceId string, numToRemove int) error

+ type Event struct

+ Destination string

+ Details map[string]interface{}

+ Id string

+ PartnerIDs []string

+ Payload []byte

+ Source string

+ Time int64

+ TransactionUUID string

+ type Interface interface

+ GetHistory func(deviceId string) ([]Event, error)

+ GetTombstone func(deviceId string) (map[string]Event, error)

+ Initialize func() error

+ InsertEvent func(deviceId string, event Event, tombstoneKey string) error

+ RemoveAll func() error

+ RemoveHistory func(deviceId string, numToRemove int) error

+ type Tombstone struct

+ Events map[string]Event