analysisengine

package
v0.0.0-...-fb9e8e8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 27, 2016 License: MPL-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL