processor

Documentation

Index

• type Processor
  • func New(inputChan, outputChan chan message.Message, apikey, logset string) *Processor
  • func (p *Processor) Start()

Types

type Processor

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

A Processor updates messages from an inputChan and pushes in an outputChan

func New

func New(inputChan, outputChan chan message.Message, apikey, logset string) *Processor

New returns an initialized Processor

func (*Processor) Start

func (p *Processor) Start()

Start starts the Processor