Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Routine ¶
type Routine interface {
// contains filtered or unexported methods
}
Routine defines an interface that consumes a channel of idrf.Rows and and writes them to a TimescaleDB
type TSIngestor ¶
type TSIngestor struct {
Config *config.IngestorConfig
DbConn connections.PgxWrap
IngestionRoutine Routine
SchemaManager schemamanagement.SchemaManager
// contains filtered or unexported fields
}
TSIngestor implements a TimescaleDB ingestor
func (*TSIngestor) ID ¶
func (i *TSIngestor) ID() string
ID returns a string identifying the ingestor instance in logs
func (*TSIngestor) Prepare ¶
func (i *TSIngestor) Prepare(bundle *idrf.Bundle) error
Prepare creates or validates the output tables in Timescale
func (*TSIngestor) Start ¶
func (i *TSIngestor) Start(errChan chan error) error
Start consumes a data channel of idrf.Row(s) and inserts them into a TimescaleDB hypertable
Source Files
Click to show internal directories.
Click to hide internal directories.