pkg/

Package conformance provides a shared contract suite that every Hermod source and sink must satisfy.

Package schemaregistry formats a Hermod message as a Confluent-framed record, so that a topic Hermod writes can be read by the consumers an existing Kafka estate already runs.

Package fcm sends messages to devices, topics and conditions through Firebase Cloud Messaging.

Package metis drives a BPMN 2.0 workflow engine from a Hermod pipeline.

Package panmail sends each message as an email through a panmail gateway.

Package txgroup writes to several sinks inside one distributed transaction.

Package metis reads a BPMN 2.0 workflow engine into a Hermod pipeline.

Package twopc coordinates two-phase commit across sinks.

Package ackwatermark turns out-of-order acknowledgements into a cursor that is safe to persist.

Package avrodecode decodes Avro binary records into map[string]any.

Package pgxutil centralizes pgx connection configuration so that every Postgres connection (source metadata, sink pool, pgvector pool, state store) is built consistently and is safe to use behind a transaction/statement pooling proxy such as PgBouncer.

Package schemaregistry speaks the Confluent Schema Registry wire format and REST API.

Package sqlident validates and quotes SQL identifiers.

Package tracing carries trace context on a message rather than in a Go context.