processors

Documentation

Index

• Variables
• type DefaultProcessorFactory
  • func NewDefaultProcessorFactory() *DefaultProcessorFactory
  • func (f *DefaultProcessorFactory) GetProcessor(typeName string) (definitions.Processor, error)
  • func (f *DefaultProcessorFactory) RegisterProcessor(processor definitions.Processor)

Variables

var ErrProcessorTypeNotFound = errors.New("processor type not found")

Types

type DefaultProcessorFactory

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

DefaultProcessorFactory is an implementation of ProcessorFactory.

func NewDefaultProcessorFactory

func NewDefaultProcessorFactory() *DefaultProcessorFactory

NewDefaultProcessorFactory creates a new DefaultProcessorFactory.

func (*DefaultProcessorFactory) GetProcessor

func (f *DefaultProcessorFactory) GetProcessor(typeName string) (definitions.Processor, error)

func (*DefaultProcessorFactory) RegisterProcessor

func (f *DefaultProcessorFactory) RegisterProcessor(processor definitions.Processor)

RegisterProcessor registers a processor type with the factory.