Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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
Click to show internal directories.
Click to hide internal directories.