core

package

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

Details

View Source

const (
	ConnMarkBlockList uint32 = 0x100000 << iota
	ConnMarkTrustList
)

View Source

const MedsChainName = "MEDS"

This section is empty.

This section is empty.

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

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

func (q *Queue) Close() error

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

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

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

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

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

func (r *Reader) Close() error

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

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

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

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