core

package

v0.2.0 Latest Latest Go to latest Published: Sep 21, 2025 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewQueue(qcount uint, 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 Worker struct {
	// contains filtered or unexported fields
}

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

func (w *Worker) Close() error

func (w *Worker) Run(ctx context.Context) error