analysisengine

Documentation

Index

• type AnalysisEngine
  • func NewLoggingAnalysisEngine() AnalysisEngine
• type LoggingAnalysisEngine
  • func (eng *LoggingAnalysisEngine) ProcessMessage(delivery amqp.Delivery) (err error)

Types

type AnalysisEngine

type AnalysisEngine interface {
	ProcessMessage(amqp.Delivery) (err error)
}

AnalysisEngine is the interface all Analysis Engines share

func NewLoggingAnalysisEngine

func NewLoggingAnalysisEngine() AnalysisEngine

NewLoggingAnalysisEngine constructs a new Analysis Engine.

type LoggingAnalysisEngine

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

LoggingAnalysisEngine is an Analysis Engine that just logs to the Logger.

func (*LoggingAnalysisEngine) ProcessMessage

func (eng *LoggingAnalysisEngine) ProcessMessage(delivery amqp.Delivery) (err error)

ProcessMessage logs the marshaled contents of the AMQP message.