assembly

Documentation

Index

• type Config
  • func (c Config) Close(ctx context.Context) error
• type StreamEntityFactory
  • func NewStreamEntityFactory(config Config) *StreamEntityFactory
  • func (s *StreamEntityFactory) CreateExtractor(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Extractor, error)
  • func (s *StreamEntityFactory) CreateLoader(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Loader, error)
  • func (s *StreamEntityFactory) CreateSinkExtractor(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Extractor, error)
  • func (s *StreamEntityFactory) CreateTransformer(ctx context.Context, spec *entity.Spec) (igeist.Transformer, error)
  • func (s *StreamEntityFactory) Entities() map[string]map[string]bool
  • func (s *StreamEntityFactory) SetAdminLoader(loader entity.Loader)

Types

type Config

type Config struct {
	Loaders    entity.LoaderFactories
	Extractors entity.ExtractorFactories
	NotifyChan entity.NotifyChan `json:"-"`
	Log        bool
}

func (Config) Close

func (c Config) Close(ctx context.Context) error

type StreamEntityFactory

type StreamEntityFactory struct {
	// contains filtered or unexported fields
}

StreamEntityFactory creates stream entities based on Stream Spec config and is a singleton, created by the Service, and operated by the StreamBuilder (also a singleton), which is given to the Supervisor during creation.

func NewStreamEntityFactory

func NewStreamEntityFactory(config Config) *StreamEntityFactory

func (*StreamEntityFactory) CreateExtractor

func (s *StreamEntityFactory) CreateExtractor(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Extractor, error)

func (*StreamEntityFactory) CreateLoader

func (s *StreamEntityFactory) CreateLoader(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Loader, error)

func (*StreamEntityFactory) CreateSinkExtractor

func (s *StreamEntityFactory) CreateSinkExtractor(ctx context.Context, spec *entity.Spec, instanceId string) (entity.Extractor, error)

CreateSinkExtractor creates an extractor belonging to a specific sink loader, enabling reading data that the loader has written to the sink.

func (*StreamEntityFactory) CreateTransformer

func (s *StreamEntityFactory) CreateTransformer(ctx context.Context, spec *entity.Spec) (igeist.Transformer, error)

func (*StreamEntityFactory) Entities

func (s *StreamEntityFactory) Entities() map[string]map[string]bool

func (*StreamEntityFactory) SetAdminLoader

func (s *StreamEntityFactory) SetAdminLoader(loader entity.Loader)