LocalDb

Dec 20, 2023

Changes in this version

+ func InfluxBatchNumbLinss(batch string) int

+ type Config interface

+ Enabled func() bool

+ Path func() string

+ type DisabledLocalDb struct

+ func (d *DisabledLocalDb) InfluxAggregateBacklog(client string, batchSize uint) error

+ func (d *DisabledLocalDb) InfluxBacklogAdd(client, batch string) error

+ func (d *DisabledLocalDb) InfluxBacklogDelete(id int) error

+ func (d *DisabledLocalDb) InfluxBacklogGet(client string) (id int, batch string, err error)

+ func (d *DisabledLocalDb) InfluxBacklogSize(client string) (numbBatches, numbLines uint, err error)

+ func (d DisabledLocalDb) Enabled() bool

+ func (d DisabledLocalDb) Shutdown()

+ type LocalDb interface

+ Enabled func() bool

+ InfluxAggregateBacklog func(client string, batchSize uint) error

+ InfluxBacklogAdd func(client, batch string) error

+ InfluxBacklogDelete func(id int) error

+ InfluxBacklogGet func(client string) (id int, batch string, err error)

+ InfluxBacklogSize func(client string) (numbBatches, numbLines uint, err error)

+ Shutdown func()

+ func Run(config Config) LocalDb

+ type SqliteLocalDb struct

+ func (d *SqliteLocalDb) InfluxAggregateBacklog(client string, batchSize uint) error

+ func (d *SqliteLocalDb) InfluxBacklogAdd(client, batch string) error

+ func (d *SqliteLocalDb) InfluxBacklogDelete(id int) error

+ func (d *SqliteLocalDb) InfluxBacklogGet(client string) (id int, batch string, err error)

+ func (d *SqliteLocalDb) InfluxBacklogSize(client string) (numbBatches, numbLines uint, err error)

+ func (d SqliteLocalDb) Enabled() bool

+ func (d SqliteLocalDb) Shutdown()