netfilter

Documentation

Index

• func Logger(customLogger zerolog.Logger)
• type Queue
  • func NewQueue(id uint16) *Queue
  • func (q *Queue) Bind() (uint32, error)
  • func (q *Queue) CacheAction(packet gopacket.Packet, rule string, action types.NFQActionType)
  • func (q *Queue) CacheConnection(packet gopacket.Packet)
  • func (q *Queue) Connections() (m map[string]*model.Connection)
  • func (q *Queue) Dropped() (m map[string]*model.Notification)
  • func (q *Queue) Handle(attr nfqueue.Attribute) int
  • func (q *Queue) LockDB()
  • func (q *Queue) Register(ctx context.Context) error
  • func (q *Queue) ResetDB()
  • func (q *Queue) Start() error
  • func (q *Queue) Stop() error
  • func (q *Queue) Unbind() error
  • func (q *Queue) UnlockDB()
  • func (q *Queue) UpdateExceptions(exceptions model.Exceptions)
  • func (q *Queue) UpdatePatterns(patterns model.Patterns)
• type QueueVerdictOpts

Functions

func Logger

func Logger(customLogger zerolog.Logger)

Types

type Queue

type Queue struct {
	ID uint16
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(id uint16) *Queue

func (*Queue) Bind

func (q *Queue) Bind() (uint32, error)

func (*Queue) CacheAction

func (q *Queue) CacheAction(packet gopacket.Packet, rule string, action types.NFQActionType)

func (*Queue) CacheConnection

func (q *Queue) CacheConnection(packet gopacket.Packet)

func (*Queue) Connections

func (q *Queue) Connections() (m map[string]*model.Connection)

Connections will lock the db struct and copy the connection map

func (*Queue) Dropped

func (q *Queue) Dropped() (m map[string]*model.Notification)

Dropped will lock the db struct and copy the dropped map

func (*Queue) Handle

func (q *Queue) Handle(attr nfqueue.Attribute) int

NOTE always return zero otherwise the handler will be closed NOTE removed all logging in favor of performance

func (*Queue) LockDB

func (q *Queue) LockDB()

LockDB will lock the mutex on the internal db struct in case we want to copy the maps savely

func (*Queue) Register

func (q *Queue) Register(ctx context.Context) error

func (*Queue) ResetDB

func (q *Queue) ResetDB()

ResetDB will reset the db struct content which is necessary to release memory

func (*Queue) Start

func (q *Queue) Start() error

func (*Queue) Stop

func (q *Queue) Stop() error

func (*Queue) Unbind

func (q *Queue) Unbind() error

func (*Queue) UnlockDB

func (q *Queue) UnlockDB()

UnlockDB will unlock the mutex on the internal db struct

func (*Queue) UpdateExceptions

func (q *Queue) UpdateExceptions(exceptions model.Exceptions)

UpdateExceptions will skip or add IP and DNS addresses from the blocklist

func (*Queue) UpdatePatterns

func (q *Queue) UpdatePatterns(patterns model.Patterns)

UpdatePatterns will create the blocklists for IP and DNS addresses

type QueueVerdictOpts

type QueueVerdictOpts struct {
	Packet gopacket.Packet
	// remember the action which was taken
	CacheAction   bool
	ActionPattern string
	ActionType    types.NFQActionType
}