pkg

Implements a go routine that collects topic info periodically outside of the broker.

Package mock implements an in-memory gRPC mock Ensign server that can be connected to using a bufconn.

Package o11y (a numeronym for "observability") exports server-specific metric collectors to Prometheus for monitoring of the service and Ensign nodes.

Ensign maintains two separate storage locations on disk: the event store which is intended to be an append-only fast disk write for incoming events and a meta store which is used to persist operational metadata such as topic and placement information.

Package errors implements standard database read/write errors for the store package.

Package topics provides some helpers for managing topics in memory.

Package authtest provides helper functionality for testing authentication with Quarterdeck as simply as possible.

Package db establishes a connection with a Raft replicated sqlite3 database.

Package keygen provides functionality for generating API client IDs and secrets.

Package health implements health check clients to return server system statuses.

Package services provides an Info and Service data structure that is used for two purposes: loading configuration information from disk and storing status information in the database.

Package keymu provides a map of mutexes that allows users to lock and unlock single keys in the data structure.

metrics tracks request behavior inside tenant (which manages Ensign user accounts, projects, and topics) and quarterdeck (which manages authentication and authorization)

Package mtls has helper functionality for organizing and maintaining key material on disk and establishing connections between servers and clients using mTLS cryptography.

Package probez provides a simple http server that implements Kubernetes readiness probes (e.g.

Package tasks provides functionality for services to run a fixed number of workers to conduct generic asynchronous tasks.

Package service unifies how our HTTP services run to deduplicate code between different microservices.

Package sqlite implements a connect hook around the sqlite3 driver so that the underlying connection can be fetched from the driver for more advanced operations such as backups.

This file ported from net/http/internal/testcert/testcert.go

Package ulid is a lightweight wrapper around the github.com/oklog/ulid package that provides some common functionality (like checking if a ULID is null or is zero) as well as a process-global, cryptographically random, monotonic, and thread-safe ulid generation mechanism that can be used from external packages.