core

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 8, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConnMarkBlockList uint32 = 0x100000 << iota
	ConnMarkTrustList
)
View Source
const MedsChainName = "MEDS"

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue

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

func NewQueue

func NewQueue(cfg *config.Config, filters []filter.Filter, logger *logger.Logger) *Queue

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Load

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

func (*Queue) Run

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

func (*Queue) Update

func (q *Queue) Update(ctx context.Context, timeout, interval time.Duration)

type Reader added in v0.6.0

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

func NewReader added in v0.6.0

func NewReader(qnum uint16, qlen uint32, logger *logger.Logger) *Reader

func (*Reader) Close added in v0.6.0

func (r *Reader) Close() error

func (*Reader) Run added in v0.6.0

func (r *Reader) Run(ctx context.Context) error

type Worker

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

func NewWorker

func NewWorker(filters []filter.Filter, logger *logger.Logger) *Worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context, nfq *nfqueue.Nfqueue, rch <-chan nfqueue.Attribute) error

Directories

Path Synopsis
asn
geo
ip
ja3

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL