maxdelivery

package

v1.0.0-beta.162 Latest Latest Go to latest Published: Aug 26, 2026 License: MIT Imports: 12 Imported by: 0

Details

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

Repository

github.com/c360studio/semstreams

Links

Open Source Insights

Documentation ¶

Overview ¶

Package maxdelivery owns SemStreams' durable visibility for JetStream MaxDeliver exhaustion occurrences.

It is internal because this is framework boot plumbing, not a component or an adopter-facing configuration surface. NATS publishes the occurrences; the framework provisions one bounded ledger and one fixed durable observer.

Index ¶

func Start(ctx context.Context, client *natsclient.Client, ...) (func(context.Context) error, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Start ¶

func Start(
	ctx context.Context,
	client *natsclient.Client,
	registry *metric.MetricsRegistry,
	logger *slog.Logger,
) (func(context.Context) error, error)

Start binds the fixed durable observer to the already-provisioned capture stream. config.StreamsManager.EnsureStreams must have succeeded earlier in boot. The returned stop function releases only this process's consume context; it deliberately leaves the shared durable consumer and its acknowledgement floor.

Types ¶

This section is empty.

Source Files ¶

View all Source files

observer.go

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