filters

Documentation

Index

• type Filter
  • func WrapFilter(w wire.Wire) *Filter
  • func (filter *Filter) AddMiddleware(m Middleware)
  • func (filter *Filter) Decode(msg *message.Message) error
  • func (filter *Filter) Encode(msg *message.Message) error
• type Middleware

Types

type Filter

type Filter struct {
	// the underlying wire
	wire.Wire
	// contains filtered or unexported fields
}

wire filter

func WrapFilter

func WrapFilter(w wire.Wire) *Filter

func (*Filter) AddMiddleware

func (filter *Filter) AddMiddleware(m Middleware)

func (*Filter) Decode

func (filter *Filter) Decode(msg *message.Message) error

func (*Filter) Encode

func (filter *Filter) Encode(msg *message.Message) error

type Middleware

type Middleware interface {
	// modify ingress packet
	Ingress(*message.Packet) (bool, error)
	// modify egress packet
	Egress(*message.Packet) (bool, error)
}

packet middleware