testutils

Documentation

Index

• 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
  • 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 (p DummyProcessorContext) Log() processors.Logger
  • func (d *DummyProcessorContext) Memory() processors.Memory
  • func (p DummyProcessorContext) PacketBuilder() processors.PacketBuilder
  • func (p DummyProcessorContext) PacketSender() processors.PacketSender
  • 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
• type Processor
  • 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

Functions

func AssertValuesForPaths

func AssertValuesForPaths(t *testing.T, ctx *DummyProcessorContext, pathValues map[string]interface{})

func NewMemory

func NewMemory(location string) *memory

func NewPacket

func NewPacket(fields map[string]interface{}) processors.IPacket

func NewPacketOld

func NewPacketOld(message string, fields map[string]interface{}) processors.IPacket

Types

type DummyProcessorContext

type DummyProcessorContext struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewProcessorContext

func NewProcessorContext() *DummyProcessorContext

func (*DummyProcessorContext) BuiltPackets

func (d *DummyProcessorContext) BuiltPackets() []processors.IPacket

func (*DummyProcessorContext) BuiltPacketsCount

func (d *DummyProcessorContext) BuiltPacketsCount() int

func (*DummyProcessorContext) ConfigWorkingLocation

func (d *DummyProcessorContext) ConfigWorkingLocation() string

func (*DummyProcessorContext) DataLocation

func (d *DummyProcessorContext) DataLocation() string

func (DummyProcessorContext) Log

func (p DummyProcessorContext) Log() processors.Logger

func (*DummyProcessorContext) Memory

func (d *DummyProcessorContext) Memory() processors.Memory

func (DummyProcessorContext) PacketBuilder

func (p DummyProcessorContext) PacketBuilder() processors.PacketBuilder

func (DummyProcessorContext) PacketSender

func (p DummyProcessorContext) PacketSender() processors.PacketSender

func (*DummyProcessorContext) SentPackets

func (d *DummyProcessorContext) SentPackets(portNumber int) []processors.IPacket

func (*DummyProcessorContext) SentPacketsCount

func (d *DummyProcessorContext) SentPacketsCount(portNumber int) int

func (*DummyProcessorContext) Store

func (d *DummyProcessorContext) Store() processors.IStore

func (*DummyProcessorContext) WebHook

func (d *DummyProcessorContext) WebHook() processors.WebHook

type Processor

type Processor struct {
	processors.Processor
	mock.Mock
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(f func() processors.Processor, conf ...map[string]interface{}) (Processor, error)

func StartNewProcessor

func StartNewProcessor(f func() processors.Processor, conf ...map[string]interface{}) (Processor, error)

func (*Processor) BuiltPackets

func (p *Processor) BuiltPackets() []processors.IPacket

func (*Processor) BuiltPacketsCount

func (p *Processor) BuiltPacketsCount() int

func (*Processor) SentPackets

func (p *Processor) SentPackets(portNumber int) []processors.IPacket

func (*Processor) SentPacketsCount

func (p *Processor) SentPacketsCount(portNumber int) int