interfaces

Documentation

Index

• type ConsoleFunc
• type Handler
• type InsertTcpDataFunc
• type SavePcapDataFunc
• type SlackFunc
• type Spout
  • func NewSpout(clients *infra.Clients, options ...SpoutOption) *Spout
• type SpoutOption
  • func WithConsole(f ConsoleFunc) SpoutOption
  • func WithInsertTcpData(f InsertTcpDataFunc) SpoutOption
  • func WithSavePcapData(f SavePcapDataFunc) SpoutOption
  • func WithSlack(f SlackFunc) SpoutOption
  • func WithWritePacket(f WritePacketFunc) SpoutOption
• type WritePacketFunc

Types

type ConsoleFunc

type ConsoleFunc func(msg string)

type Handler

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

type InsertTcpDataFunc

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

type SavePcapDataFunc

type SavePcapDataFunc func([]gopacket.Packet)

type SlackFunc

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

type Spout

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

func NewSpout

func NewSpout(clients *infra.Clients, options ...SpoutOption) *Spout

type SpoutOption

type SpoutOption func(*Spout)

func WithConsole

func WithConsole(f ConsoleFunc) SpoutOption

func WithInsertTcpData

func WithInsertTcpData(f InsertTcpDataFunc) SpoutOption

func WithSavePcapData

func WithSavePcapData(f SavePcapDataFunc) SpoutOption

func WithSlack

func WithSlack(f SlackFunc) SpoutOption

func WithWritePacket

func WithWritePacket(f WritePacketFunc) SpoutOption

type WritePacketFunc

type WritePacketFunc func([]byte)