factory

Documentation

Overview

Package factory provides factories for constructing Task components.

Index

• func NewError(dt, detail string, code int, err error) etl.ProcessingError
• type AnnotatorFactory
  • func DefaultAnnotatorFactory() AnnotatorFactory
• type SinkFactory
• type SourceFactory

Functions

func NewError

func NewError(dt, detail string, code int, err error) etl.ProcessingError

NewError creates a new ProcessingError.

Types

type AnnotatorFactory

type AnnotatorFactory interface {
	Get(context.Context, etl.DataPath) (v2.Annotator, etl.ProcessingError)
}

AnnotatorFactory provides Get() which always returns a new or existing Annotator.

func DefaultAnnotatorFactory

func DefaultAnnotatorFactory() AnnotatorFactory

DefaultAnnotatorFactory returns the annotation service annotator.

type SinkFactory

type SinkFactory interface {
	Get(context.Context, etl.DataPath) (row.Sink, etl.ProcessingError)
}

SinkFactory provides Get() which may return a new or existing Sink. If existing Sink, the Commit method must support concurrent calls. Existing Sink may or may not respect the context.

type SourceFactory

type SourceFactory interface {
	Get(context.Context, etl.DataPath) (etl.TestSource, etl.ProcessingError)
}

SourceFactory provides Get() which always produces a new TestSource.