extraction

Documentation

Index

• type Extractor
• type ExtractorService
  • func NewExtractorService(schemaManagerService schemamanagement.SchemaManagerService) ExtractorService

Types

type Extractor

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

Extractor defines an interface for pulling data out of a database. When Prepare is called a data channel with a description of the data is returned. On Start the data channel is populated.

type ExtractorService

type ExtractorService interface {
	InfluxExtractor(influx.Client, *config.ExtractionConfig) (Extractor, error)
}

ExtractorService defines methods for creating extractor instances

func NewExtractorService

func NewExtractorService(schemaManagerService schemamanagement.SchemaManagerService) ExtractorService

NewExtractorService creates a new instance of the service that can create extractors