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

icingadb

package

Go to main page

Versions in this module

v1

v1.2.0

Apr 11, 2024

Changes in this version

+ const MySQL

+ const PostgreSQL

+ type InitConnFunc func(context.Context, driver.Conn) error

+ type MysqlFuncLogger func(v ...interface{})

+ func (log MysqlFuncLogger) Print(v ...interface{})

type Options

+ WsrepSyncWait int

+ type RetryConnector struct

+ func NewConnector(c driver.Connector, logger *logging.Logger, init InitConnFunc) *RetryConnector

+ func (c RetryConnector) Connect(ctx context.Context) (driver.Conn, error)

+ func (c RetryConnector) Driver() driver.Driver

v1.1.1

Aug 8, 2023

v1.1.0

Nov 9, 2022

Changes in this version

type DB

+ func (db *DB) CheckSchema(ctx context.Context) error

+ func (db *DB) CreateIgnoreStreamed(ctx context.Context, entities <-chan contracts.Entity, ...) error

v1.0.0

Jun 29, 2022

Changes in this version

+ func IsRetryable(err error) bool

+ type CleanupStmt struct

+ Column string

+ PK string

+ Table string

+ func (stmt *CleanupStmt) Build(driverName string, limit uint64) string

+ type DB struct

+ Options *Options

+ func NewDb(db *sqlx.DB, logger *logging.Logger, options *Options) *DB

+ func (db *DB) BatchSizeByPlaceholders(n int) int

+ func (db *DB) BuildColumns(subject interface{}) []string

+ func (db *DB) BuildDeleteStmt(from interface{}) string

+ func (db *DB) BuildInsertIgnoreStmt(into interface{}) (string, int)

+ func (db *DB) BuildInsertStmt(into interface{}) (string, int)

+ func (db *DB) BuildSelectStmt(table interface{}, columns interface{}) string

+ func (db *DB) BuildUpdateStmt(update interface{}) (string, int)

+ func (db *DB) BuildUpsertStmt(subject interface{}) (stmt string, placeholders int)

+ func (db *DB) BuildWhere(subject interface{}) (string, int)

+ func (db *DB) BulkExec(ctx context.Context, query string, count int, sem *semaphore.Weighted, ...) error

+ func (db *DB) CleanupOlderThan(ctx context.Context, stmt CleanupStmt, envId types.Binary, count uint64, ...) (uint64, error)

+ func (db *DB) CreateStreamed(ctx context.Context, entities <-chan contracts.Entity, ...) error

+ func (db *DB) Delete(ctx context.Context, entityType contracts.Entity, ids []interface{}, ...) error

+ func (db *DB) DeleteStreamed(ctx context.Context, entityType contracts.Entity, ids <-chan interface{}, ...) error

+ func (db *DB) GetSemaphoreForTable(table string) *semaphore.Weighted

+ func (db *DB) NamedBulkExec(ctx context.Context, query string, count int, sem *semaphore.Weighted, ...) error

+ func (db *DB) NamedBulkExecTx(ctx context.Context, query string, count int, sem *semaphore.Weighted, ...) error

+ func (db *DB) UpdateStreamed(ctx context.Context, entities <-chan contracts.Entity) error

+ func (db *DB) UpsertStreamed(ctx context.Context, entities <-chan contracts.Entity, ...) error

+ func (db *DB) YieldAll(ctx context.Context, factoryFunc contracts.EntityFactoryFunc, query string, ...) (<-chan contracts.Entity, <-chan error)

+ type Delta struct

+ Create EntitiesById

+ Delete EntitiesById

+ Subject *common.SyncSubject

+ Update EntitiesById

+ func NewDelta(ctx context.Context, actual, desired <-chan contracts.Entity, ...) *Delta

+ func (delta *Delta) Wait() error

+ type DumpSignals struct

+ func NewDumpSignals(redis *icingaredis.Client, logger *logging.Logger) *DumpSignals

+ func (s *DumpSignals) Done(key string) <-chan struct{}

+ func (s *DumpSignals) InProgress() <-chan struct{}

+ func (s *DumpSignals) Listen(ctx context.Context) error

+ type EntitiesById map[string]contracts.Entity

+ func (ebi EntitiesById) Entities(ctx context.Context) <-chan contracts.Entity

+ func (ebi EntitiesById) IDs() []interface{}

+ func (ebi EntitiesById) Keys() []string

+ type HA struct

+ func NewHA(ctx context.Context, db *DB, heartbeat *icingaredis.Heartbeat, ...) *HA

+ func (h *HA) Close(ctx context.Context) error

+ func (h *HA) Done() <-chan struct{}

+ func (h *HA) Environment() *v1.Environment

+ func (h *HA) Err() error

+ func (h *HA) Handover() chan struct{}

+ func (h *HA) State() (responsibleTsMilli int64, responsible, otherResponsible bool)

+ func (h *HA) Takeover() chan struct{}

+ type OnSuccess func(ctx context.Context, affectedRows []T) (err error)

+ func OnSuccessIncrement(counter *com.Counter) OnSuccess[T]

+ func OnSuccessSendTo(ch chan<- T) OnSuccess[T]

+ type Options struct

+ MaxConnections int

+ MaxConnectionsPerTable int

+ MaxPlaceholdersPerStatement int

+ MaxRowsPerTransaction int

+ func (o *Options) Validate() error

+ type RuntimeUpdates struct

+ func NewRuntimeUpdates(db *DB, redis *icingaredis.Client, logger *logging.Logger) *RuntimeUpdates

+ func (r *RuntimeUpdates) ClearStreams(ctx context.Context) (config, state icingaredis.Streams, err error)

+ func (r *RuntimeUpdates) Sync(ctx context.Context, factoryFuncs []contracts.EntityFactoryFunc, ...) error

+ type ScopedEntity struct

+ func NewScopedEntity(entity contracts.Entity, scope interface{}) *ScopedEntity

+ func (e ScopedEntity) Scope() interface{}

+ func (e ScopedEntity) TableName() string

+ type Sync struct

+ func NewSync(db *DB, redis *icingaredis.Client, logger *logging.Logger) *Sync

+ func (s Sync) ApplyDelta(ctx context.Context, delta *Delta) error

+ func (s Sync) Sync(ctx context.Context, subject *common.SyncSubject) error

+ func (s Sync) SyncAfterDump(ctx context.Context, subject *common.SyncSubject, dump *DumpSignals) error

+ func (s Sync) SyncCustomvars(ctx context.Context) error

v1.0.0-rc2

Nov 12, 2021