broker

package module

v0.0.5 Latest Latest Go to latest Published: Feb 13, 2026 License: MIT Imports: 2 Imported by: 0

Details

A lightweight broker that mediates HTTP requests and responses, handling user context, routing, validation, and service coordination.

Rendered for

This section is empty.

This section is empty.

This section is empty.

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

Broker handles batching of items for efficient processing

func New(batchWindow int) *Broker

New creates a new Broker with the specified batch window in milliseconds

func (b *Broker) Clear()

Clear cleans the queue without triggering a flush

func (b *Broker) Enqueue(key string, data []byte)

Enqueue adds data to the queue, consolidating by key

func (b *Broker) FlushNow()

FlushNow forces an immediate flush

func (b *Broker) QueueLength() int

QueueLength returns the current number of unique keys in the queue

func (b *Broker) SetOnFlush(fn func([]Item))

SetOnFlush configures the callback for when the batch window expires

type Item struct {
	Key  string
	Data [][]byte
}

Item represents a consolidated group of data