Documentation
¶
Index ¶
- func InfluxBatchNumbLinss(batch string) int
- type Config
- type DisabledLocalDb
- func (d DisabledLocalDb) Enabled() bool
- 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) Shutdown()
- type LocalDb
- type SqliteLocalDb
- func (d SqliteLocalDb) Enabled() bool
- 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) Shutdown()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InfluxBatchNumbLinss ¶
Types ¶
type DisabledLocalDb ¶
type DisabledLocalDb struct{}
func (DisabledLocalDb) Enabled ¶
func (d DisabledLocalDb) Enabled() bool
func (*DisabledLocalDb) InfluxAggregateBacklog ¶
func (d *DisabledLocalDb) InfluxAggregateBacklog(client string, batchSize uint) error
func (*DisabledLocalDb) InfluxBacklogAdd ¶
func (d *DisabledLocalDb) InfluxBacklogAdd(client, batch string) error
func (*DisabledLocalDb) InfluxBacklogDelete ¶
func (d *DisabledLocalDb) InfluxBacklogDelete(id int) error
func (*DisabledLocalDb) InfluxBacklogGet ¶
func (d *DisabledLocalDb) InfluxBacklogGet(client string) (id int, batch string, err error)
func (*DisabledLocalDb) InfluxBacklogSize ¶
func (d *DisabledLocalDb) InfluxBacklogSize(client string) (numbBatches, numbLines uint, err error)
func (DisabledLocalDb) Shutdown ¶
func (d DisabledLocalDb) Shutdown()
type LocalDb ¶
type LocalDb interface {
Enabled() bool
Shutdown()
InfluxBacklogAdd(client, batch string) error
InfluxBacklogSize(client string) (numbBatches, numbLines uint, err error)
InfluxBacklogGet(client string) (id int, batch string, err error)
InfluxBacklogDelete(id int) error
InfluxAggregateBacklog(client string, batchSize uint) error
}
type SqliteLocalDb ¶
type SqliteLocalDb struct {
// contains filtered or unexported fields
}
func (SqliteLocalDb) Enabled ¶
func (d SqliteLocalDb) Enabled() bool
func (*SqliteLocalDb) InfluxAggregateBacklog ¶
func (d *SqliteLocalDb) InfluxAggregateBacklog(client string, batchSize uint) error
func (*SqliteLocalDb) InfluxBacklogAdd ¶
func (d *SqliteLocalDb) InfluxBacklogAdd(client, batch string) error
func (*SqliteLocalDb) InfluxBacklogDelete ¶
func (d *SqliteLocalDb) InfluxBacklogDelete(id int) error
func (*SqliteLocalDb) InfluxBacklogGet ¶
func (d *SqliteLocalDb) InfluxBacklogGet(client string) (id int, batch string, err error)
func (*SqliteLocalDb) InfluxBacklogSize ¶
func (d *SqliteLocalDb) InfluxBacklogSize(client string) (numbBatches, numbLines uint, err error)
func (SqliteLocalDb) Shutdown ¶
func (d SqliteLocalDb) Shutdown()
Source Files
Click to show internal directories.
Click to hide internal directories.