processor

Documentation

Index

• type Processor
  • func New(opts *options.Options) (*Processor, error)
  • func (s *Processor) Start() error
  • func (s *Processor) Stop() error

Types

type Processor

type Processor struct {
	// Protocol is the name of the processor protocol
	Protocol *protocol.Protocol
	// Connector is the name of the processor connector
	Connector connector.Connector
	// Opts is the name of the processor options
	Opts *options.Options
	// ProducerConfConnector is the name of the producer configuration
	ProducerConfConnector cc.ProducerConfConnector
	// ProducerConnector is the name of the processor configuration
	ProcessorConfConnector cc.ProcessorConfConnector
}

Processor is a server of the event

func New

func New(opts *options.Options) (*Processor, error)

New creates a new Processor

func (*Processor) Start

func (s *Processor) Start() error

Start initialize some operations

func (*Processor) Stop

func (s *Processor) Stop() error

Stop stops the processor gracefully.