broker

README

broker

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

Documentation

Index

• type Broker
  • func New(batchWindow int) *Broker
  • func (b *Broker) Clear()
  • func (b *Broker) Enqueue(key string, data []byte)
  • func (b *Broker) FlushNow()
  • func (b *Broker) QueueLength() int
  • func (b *Broker) SetOnFlush(fn func([]Item))
• type Item

Types

type Broker

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

Broker handles batching of items for efficient processing

func New

func New(batchWindow int) *Broker

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

func (*Broker) Clear

func (b *Broker) Clear()

Clear cleans the queue without triggering a flush

func (*Broker) Enqueue

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

Enqueue adds data to the queue, consolidating by key

func (*Broker) FlushNow

func (b *Broker) FlushNow()

FlushNow forces an immediate flush

func (*Broker) QueueLength

func (b *Broker) QueueLength() int

QueueLength returns the current number of unique keys in the queue

func (*Broker) SetOnFlush

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

SetOnFlush configures the callback for when the batch window expires

type Item

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

Item represents a consolidated group of data