membroker

package

v0.2.3 Latest Latest Go to latest Published: Jun 8, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Package membroker provides an in-memory broker adapter for runtime/contracts.

This section is empty.

This section is empty.

This section is empty.

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

Broker stores published events in memory and exposes them as worker batches. It is intended for tests, local development, and single-process apps.

func New(options ...Option) *Broker

New creates an in-memory broker.

func (broker *Broker) Len() int

Len returns the queued event count.

func (broker *Broker) PublishEvents(ctx context.Context, events []contracts.EventEnvelope) error

PublishEvents appends events to the broker queue.

func (broker *Broker) ReceiveEventBatch(ctx context.Context) (contracts.EventBatch, error)

ReceiveEventBatch returns the next queued batch. Ack removes the delivered records; Nack leaves them queued for retry.

type Option func(*Broker)

Option configures a Broker.

func WithBatchSize(size int) Option

WithBatchSize sets the maximum events returned by one worker batch.