queue

package

v0.8.0 Latest Latest Go to latest Published: Nov 18, 2025 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bangunindo/trap2json

Links

Open Source Insights

Documentation ¶

Index ¶

type Counter
type Item
type Queue
- func NewQueue[T Item](logger zerolog.Logger, size int, flushTimeout time.Duration, ...) *Queue[T]

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Counter ¶

type Counter struct {
	Processed   prometheus.Counter
	Drop        prometheus.Counter
	Passthrough prometheus.Counter
	QueueCap    prometheus.Gauge
	QueueLen    prometheus.Gauge
}

type Item ¶

type Item interface {
	Eta() time.Time
}

type Queue ¶

type Queue[T Item] struct {
	// contains filtered or unexported fields
}

func NewQueue ¶

func NewQueue[T Item](
	logger zerolog.Logger,
	size int,
	flushTimeout time.Duration,
	passthroughChan chan<- T,
	counter Counter,
) *Queue[T]

func (*Queue[T]) Close ¶

func (q *Queue[T]) Close()

func (*Queue[T]) Done ¶

func (q *Queue[T]) Done() <-chan struct{}

func (*Queue[T]) Len ¶

func (q *Queue[T]) Len() int

func (*Queue[T]) ReceiveChannel ¶

func (q *Queue[T]) ReceiveChannel() <-chan T

func (*Queue[T]) SendChannel ¶

func (q *Queue[T]) SendChannel() chan<- T

Source Files ¶

View all Source files

queue.go

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