core

package
v0.6.1 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

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(
	qcount uint,
	wcount uint,
	qlen uint,
	subnetWhiteList *types.SubnetList,
	subnetBlackList *types.SubnetList,
	domainWhiteList *types.DomainList,
	domainBlackList *types.DomainList,
	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(
	subnetWhiteList *types.SubnetList,
	subnetBlackList *types.SubnetList,
	domainWhiteList *types.DomainList,
	domainBlackList *types.DomainList,
	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
ip
ja3

Jump to

Keyboard shortcuts

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