analyzer

Documentation

Index

• type Analyzer
  • func New(chIn chan consumer.Message, chOut chan spec.MessageSpec, database db.Database) *Analyzer
  • func (a *Analyzer) Watch()
• type JSONAnalyzer
  • func (a JSONAnalyzer) GetPayloadSpec(payload []byte) (spec.PayloadSpec, error)
• type PayloadAnalyzer

Types

type Analyzer

type Analyzer struct {
	ChIn  chan consumer.Message
	ChOut chan spec.MessageSpec
	// contains filtered or unexported fields
}

Analyzer analyzes incoming messages and pipes the result through

func New

func New(chIn chan consumer.Message, chOut chan spec.MessageSpec, database db.Database) *Analyzer

New creates a new Analyzer

func (*Analyzer) Watch

func (a *Analyzer) Watch()

Watch for incoming messages

type JSONAnalyzer

type JSONAnalyzer struct{}

JSONAnalyzer analyzes json payloads to build a spec

func (JSONAnalyzer) GetPayloadSpec

func (a JSONAnalyzer) GetPayloadSpec(payload []byte) (spec.PayloadSpec, error)

GetPayloadSpec analyzes a payload and returns the spec

type PayloadAnalyzer

type PayloadAnalyzer interface {
	GetPayloadSpec([]byte) (spec.PayloadSpec, error)
}

PayloadAnalyzer objects analyze payloads