source

Documentation

Index

• Constants
• func NewHAProxySPOE(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewPCap(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• type HAProxySPOE
  • func (m *HAProxySPOE) Output() <-chan mirror.Request
  • func (m *HAProxySPOE) SetInput(c <-chan mirror.Request)
• type HAProxySPOEConfig
• type PCap
  • func (m *PCap) Output() <-chan mirror.Request
  • func (m *PCap) SetInput(c <-chan mirror.Request)
• type PCapConfig

Constants

const (
	HAProxySPOEName = "source.haproxy_spoe"
)

const (
	PCapName = "source.pcap"
)

Functions

func NewHAProxySPOE

func NewHAProxySPOE(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewPCap

func NewPCap(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)

Types

type HAProxySPOE

type HAProxySPOE struct {
	// contains filtered or unexported fields
}

func (*HAProxySPOE) Output

func (m *HAProxySPOE) Output() <-chan mirror.Request

func (*HAProxySPOE) SetInput

func (m *HAProxySPOE) SetInput(c <-chan mirror.Request)

type HAProxySPOEConfig

type HAProxySPOEConfig struct {
	ListenAddr string `json:"listen_addr"`
}

type PCap

type PCap struct {
	// contains filtered or unexported fields
}

func (*PCap) Output

func (m *PCap) Output() <-chan mirror.Request

func (*PCap) SetInput

func (m *PCap) SetInput(c <-chan mirror.Request)

type PCapConfig

type PCapConfig struct {
	Interface string `json:"interface,omitempty"`
	Port      int    `json:"port,omitempty"`
}