Versions in this module Expand all Collapse all v0 v0.6.9 Jan 10, 2019 Changes in this version + func AssertValuesForPaths(t *testing.T, ctx *DummyProcessorContext, pathValues map[string]interface{}) + func NewMemory(location string) *memory + func NewPacket(fields map[string]interface{}) processors.IPacket + func NewPacketOld(message string, fields map[string]interface{}) processors.IPacket + type DummyProcessorContext struct + func NewProcessorContext() *DummyProcessorContext + func (d *DummyProcessorContext) BuiltPackets() []processors.IPacket + func (d *DummyProcessorContext) BuiltPacketsCount() int + func (d *DummyProcessorContext) ConfigWorkingLocation() string + func (d *DummyProcessorContext) DataLocation() string + func (d *DummyProcessorContext) Memory() processors.Memory + func (d *DummyProcessorContext) SentPackets(portNumber int) []processors.IPacket + func (d *DummyProcessorContext) SentPacketsCount(portNumber int) int + func (d *DummyProcessorContext) Store() processors.IStore + func (d *DummyProcessorContext) WebHook() processors.WebHook + func (p DummyProcessorContext) Log() processors.Logger + func (p DummyProcessorContext) PacketBuilder() processors.PacketBuilder + func (p DummyProcessorContext) PacketSender() processors.PacketSender + type Processor struct + func NewProcessor(f func() processors.Processor, conf ...map[string]interface{}) (Processor, error) + func StartNewProcessor(f func() processors.Processor, conf ...map[string]interface{}) (Processor, error) + func (p *Processor) BuiltPackets() []processors.IPacket + func (p *Processor) BuiltPacketsCount() int + func (p *Processor) SentPackets(portNumber int) []processors.IPacket + func (p *Processor) SentPacketsCount(portNumber int) int