ts

Documentation

Index

• type Routine
  • func NewRoutine() Routine
• type TSIngestor
  • func (i *TSIngestor) ID() string
  • func (i *TSIngestor) Prepare(bundle *idrf.Bundle) error
  • func (i *TSIngestor) Start(errChan chan error) error

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

func NewRoutine

func NewRoutine() Routine

NewRoutine creates a new

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