interfaces

type ConsoleFunc func(msg string)

type Handler interface {
	Handle(ctx *types.Context, pkt gopacket.Packet, spouts *Spout) error
	Tick(ctx *types.Context, spouts *Spout) error
}

type InsertTcpDataFunc func(ctx *types.Context, data *model.SchemaTcpData)

type SavePcapDataFunc func([]gopacket.Packet)

type SlackFunc func(ctx *types.Context, msg *slack.WebhookMessage)

type Spout struct {
	Console       ConsoleFunc
	WritePacket   WritePacketFunc
	SavePcapData  SavePcapDataFunc
	Slack         SlackFunc
	InsertTcpData InsertTcpDataFunc
}

type SpoutOption func(*Spout)

type WritePacketFunc func([]byte)