ingestion

Documentation

Index

• type Ingestor
• type IngestorService
  • func NewIngestorService() IngestorService

Types

type Ingestor

type Ingestor interface {
	ID() string
	Prepare(conn *idrf.Bundle) error
	Start(chan error) error
}

Ingestor takes a data channel of idrf rows and inserts them in a target database

type IngestorService

type IngestorService interface {
	NewTimescaleIngestor(dbConn connections.PgxWrap, config *config.IngestorConfig) Ingestor
}

IngestorService exposes methods to create new ingestors

func NewIngestorService

func NewIngestorService() IngestorService

NewIngestorService creates an instance of the IngestorService