modules

Documentation

Index

• func RegisterPipelinerConsumerModule(module PipelinerConsumerModule) error
• func RegisterPipelinerProcessorModule(module PipelinerProcessorModule) error
• func RegisterPipelinerProducerModule(module PipelinerProducerModule) error
• type GenericConsumerModule
  • func NewGenericConsumerModule(name, version, genericId, specificId string, ...) *GenericConsumerModule
  • func (m *GenericConsumerModule) GetInputChannel() chan<- *datatypes.PipelineItem
  • func (m *GenericConsumerModule) SetConsumerFunc(consumerFunc func(<-chan *datatypes.PipelineItem, *sync.WaitGroup)) error
  • func (m *GenericConsumerModule) Start(waitGroup *sync.WaitGroup) error
• type GenericPipelineModule
  • func NewGenericPipelineModule(name, version, genericId, specificId, moduleType string) *GenericPipelineModule
  • func (m *GenericPipelineModule) Log(err error)
  • func (m *GenericPipelineModule) SetLogChannel(logChannel chan<- *log.LogEntry)
  • func (m *GenericPipelineModule) Stop()
• type GenericProcessorModule
  • func NewGenericProcessorModule(name, version, genericId, specificId string, ...) *GenericProcessorModule
  • func (m *GenericProcessorModule) GetInputChannel() chan<- *datatypes.PipelineItem
  • func (m *GenericProcessorModule) SetOutputChannel(inputChannel chan<- *datatypes.PipelineItem) error
  • func (m *GenericProcessorModule) SetProcessorFunc(processorFunc func(*datatypes.PipelineItem) bool) error
  • func (m *GenericProcessorModule) Start(waitGroup *sync.WaitGroup) error
• type GenericProducerModule
  • func NewGenericProducerModule(name, version, genericId, specificId string, ...) *GenericProducerModule
  • func (m *GenericProducerModule) SetOutputChannel(outputChannel chan<- *datatypes.PipelineItem) error
  • func (m *GenericProducerModule) SetProducerFunc(producerFunc func(chan<- *datatypes.PipelineItem, <-chan struct{})) error
  • func (m *GenericProducerModule) Start(waitGroup *sync.WaitGroup) error
• type PipelinerConsumerModule
• type PipelinerProcessorModule
• type PipelinerProducerModule

Functions

func RegisterPipelinerConsumerModule

func RegisterPipelinerConsumerModule(module PipelinerConsumerModule) error

RegisterPipelinerConsumerModule registers a Pipeliner consumer module.

func RegisterPipelinerProcessorModule

func RegisterPipelinerProcessorModule(module PipelinerProcessorModule) error

RegisterPipelinerProcessorModule registers a Pipeliner processor module.

func RegisterPipelinerProducerModule

func RegisterPipelinerProducerModule(module PipelinerProducerModule) error

RegisterPipelinerProducerModule registers a Pipeliner producer module.

Types

type GenericConsumerModule

type GenericConsumerModule struct {
	*GenericPipelineModule
	// contains filtered or unexported fields
}

func NewGenericConsumerModule

func NewGenericConsumerModule(name, version, genericId, specificId string,
	consumerFunc func(<-chan *datatypes.PipelineItem,
		*sync.WaitGroup)) *GenericConsumerModule

func (*GenericConsumerModule) GetInputChannel

func (m *GenericConsumerModule) GetInputChannel() chan<- *datatypes.PipelineItem

func (*GenericConsumerModule) SetConsumerFunc

func (m *GenericConsumerModule) SetConsumerFunc(
	consumerFunc func(<-chan *datatypes.PipelineItem, *sync.WaitGroup)) error

func (*GenericConsumerModule) Start

func (m *GenericConsumerModule) Start(waitGroup *sync.WaitGroup) error

type GenericPipelineModule

type GenericPipelineModule struct {
	*base_modules.GenericModule
	// contains filtered or unexported fields
}

func NewGenericPipelineModule

func NewGenericPipelineModule(name, version, genericId, specificId,
	moduleType string) *GenericPipelineModule

func (*GenericPipelineModule) Log

func (m *GenericPipelineModule) Log(err error)

func (*GenericPipelineModule) SetLogChannel

func (m *GenericPipelineModule) SetLogChannel(
	logChannel chan<- *log.LogEntry)

func (*GenericPipelineModule) Stop

func (m *GenericPipelineModule) Stop()

type GenericProcessorModule

type GenericProcessorModule struct {
	*GenericPipelineModule
	// contains filtered or unexported fields
}

func NewGenericProcessorModule

func NewGenericProcessorModule(name, version, genericId, specificId string,
	processorFunc func(*datatypes.PipelineItem) bool) *GenericProcessorModule

func (*GenericProcessorModule) GetInputChannel

func (m *GenericProcessorModule) GetInputChannel() chan<- *datatypes.PipelineItem

func (*GenericProcessorModule) SetOutputChannel

func (m *GenericProcessorModule) SetOutputChannel(
	inputChannel chan<- *datatypes.PipelineItem) error

func (*GenericProcessorModule) SetProcessorFunc

func (m *GenericProcessorModule) SetProcessorFunc(
	processorFunc func(*datatypes.PipelineItem) bool) error

func (*GenericProcessorModule) Start

func (m *GenericProcessorModule) Start(waitGroup *sync.WaitGroup) error

type GenericProducerModule

type GenericProducerModule struct {
	*GenericPipelineModule
	// contains filtered or unexported fields
}

func NewGenericProducerModule

func NewGenericProducerModule(name, version, genericId, specificId string,
	producerFunc func(chan<- *datatypes.PipelineItem,
		<-chan struct{})) *GenericProducerModule

func (*GenericProducerModule) SetOutputChannel

func (m *GenericProducerModule) SetOutputChannel(
	outputChannel chan<- *datatypes.PipelineItem) error

func (*GenericProducerModule) SetProducerFunc

func (m *GenericProducerModule) SetProducerFunc(
	producerFunc func(chan<- *datatypes.PipelineItem, <-chan struct{})) error

func (*GenericProducerModule) Start

func (m *GenericProducerModule) Start(waitGroup *sync.WaitGroup) error

type PipelinerConsumerModule

type PipelinerConsumerModule interface {
	// Include methods from the base module interface.
	base_modules.Module

	// include methods required by pipeline output nodes.
	pipeline.ConsumerNode
}

type PipelinerProcessorModule

type PipelinerProcessorModule interface {
	// Include methods from the base module interface.
	base_modules.Module

	// Include methods required by pipeline processor nodes.
	pipeline.ProcessorNode
}

type PipelinerProducerModule

type PipelinerProducerModule interface {
	// Include methods from the base module interface.
	base_modules.Module

	// Include methods required by pipeline input nodes.
	pipeline.ProducerNode
}