decoder

Documentation

Index

• type DecoderFunc
• type DecoderParams
• type DoneCallback
• type ErrorCallback
• type Message
• type MessageDecoded
• type Processor
  • func CreateProcessor(numWorkers int, decoderParams DecoderParams, name string) Processor
  • func (p Processor) ProcessMessage(msg Message)
  • func (p Processor) Start()
  • func (p Processor) Stop()
• type Worker
  • func CreateWorker(workerPool chan chan Message, decoderParams DecoderParams, id int, name string) Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Types

type DecoderFunc

type DecoderFunc func(Message interface{}) error

type DecoderParams

type DecoderParams struct {
	DecoderFunc   DecoderFunc
	DoneCallback  DoneCallback
	ErrorCallback ErrorCallback
}

Decoder structure. Define the function to call and the config specific to the type of packets.

type DoneCallback

type DoneCallback func(string, int, time.Time, time.Time)

type ErrorCallback

type ErrorCallback func(string, int, time.Time, time.Time, error)

type Message

type Message interface{}

type MessageDecoded

type MessageDecoded interface{}

type Processor

type Processor struct {
	DecoderParams DecoderParams
	Name          string
	// contains filtered or unexported fields
}

Processor structure

func CreateProcessor

func CreateProcessor(numWorkers int, decoderParams DecoderParams, name string) Processor

Create a message processor which is going to create all the workers and set-up the pool.

func (Processor) ProcessMessage

func (p Processor) ProcessMessage(msg Message)

Send a message to be decoded to the pool.

func (Processor) Start

func (p Processor) Start()

Start message processor

func (Processor) Stop

func (p Processor) Stop()

type Worker

type Worker struct {
	Id            int
	DecoderParams DecoderParams
	WorkerPool    chan chan Message
	Name          string
	InMsg         chan Message
	Quit          chan bool
}

Worker structure

func CreateWorker

func CreateWorker(workerPool chan chan Message, decoderParams DecoderParams, id int, name string) Worker

Create a worker and add it to the pool.

func (Worker) Start

func (w Worker) Start()

Start the worker. Launches a goroutine to process NFv9 messages. The worker will add its input channel of NFv9 messages to decode to the pool.

func (Worker) Stop

func (w Worker) Stop()

Stop the worker.