Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

hermod

package module

Go to main page

Versions in this module

v1

v1.9.0

Sep 20, 2026

v1.8.1

Sep 20, 2026

Changes in this version

+ const MetaOrderingKey

+ func BuildOrderingKey(schema, table string, keyValues []string) string

+ func LookupCacheKeyPrefix(sourceID string) string

+ func MetadataValue(msg Message, key string) (string, bool)

+ func OrderingKey(msg Message) string

+ func SourceAllowsDirectQueries(sourceType string, config map[string]string) bool

+ func SourceUsesCDC(config map[string]string) bool

v1.8.0

Sep 3, 2026

retracted

v1.8.0-rc.1

Sep 3, 2026

retracted

v1.7.4

Sep 2, 2026

retracted

Changes in this version

+ const LastTraceSnapshotKey

+ const NodeIDKey

+ const RegistryKey

+ const StateStoreKey

+ const WorkflowIDKey

+ var ErrNotSupported = errors.New("not supported")

+ type BatchSink interface

+ WriteBatch func(ctx context.Context, msgs []Message) error

+ type Browser interface

+ Browse func(ctx context.Context, table string, limit int) ([]Message, error)

+ type ColumnDiscoverer interface

+ DiscoverColumns func(ctx context.Context, table string) ([]ColumnInfo, error)

+ type ColumnInfo struct

+ Default string

+ IsIdentity bool

+ IsNullable bool

+ IsPK bool

+ Name string

+ Type string

+ type Consumer interface

+ Close func() error

+ Consume func(ctx context.Context, handler Handler) error

+ type Discoverer interface

+ DiscoverDatabases func(ctx context.Context) ([]string, error)

+ DiscoverTables func(ctx context.Context) ([]string, error)

+ type Formatter interface

+ Format func(msg Message) ([]byte, error)

+ type Handler func(ctx context.Context, msg Message) error

+ type IdempotencyReporter interface

+ LastWriteIdempotent func() (dedup bool, conflict bool)

+ type LagReporter interface

+ GetLag func(ctx context.Context) (uint64, error)

+ type Loggable interface

+ SetLogger func(Logger)

+ type Logger interface

+ Debug func(msg string, keysAndValues ...any)

+ Error func(msg string, keysAndValues ...any)

+ Info func(msg string, keysAndValues ...any)

+ Warn func(msg string, keysAndValues ...any)

+ type Message interface

+ After func() []byte

+ Before func() []byte

+ ClearPayloads func()

+ Clone func() Message

+ Data func() map[string]any

+ DataRef func() map[string]any

+ ID func() string

+ Metadata func() map[string]string

+ MetadataRef func() map[string]string

+ Operation func() Operation

+ Payload func() []byte

+ Release func()

+ Retain func()

+ Schema func() string

+ SetData func(key string, value any)

+ SetMetadata func(key, value string)

+ Table func() string

+ ToMap func() map[string]any

+ type Operation string

+ const OpCreate

+ const OpDelete

+ const OpSnapshot

+ const OpUpdate

+ type OutboxItem struct

+ Attempts int

+ CreatedAt time.Time

+ ID string

+ LastError string

+ Metadata map[string]string

+ Payload []byte

+ SinkID string

+ Status string

+ WorkflowID string

+ type OutboxStorage interface

+ CreateOutboxItem func(ctx context.Context, item OutboxItem) error

+ DeleteOutboxItem func(ctx context.Context, id string) error

+ ListOutboxItems func(ctx context.Context, status string, limit int) ([]OutboxItem, error)

+ UpdateOutboxItem func(ctx context.Context, item OutboxItem) error

+ type PendingWorkReporter interface

+ PendingWork func() (pending bool, known bool)

+ type Producer interface

+ Close func() error

+ Produce func(ctx context.Context, msg Message) error

+ type PublicationInfo struct

+ AllTables bool

+ Name string

+ Tables []string

+ type ReadyChecker interface

+ IsReady func(ctx context.Context) error

+ type ReplicationDiscoverer interface

+ DiscoverPublications func(ctx context.Context) ([]PublicationInfo, error)

+ DiscoverReplicationSlots func(ctx context.Context) ([]ReplicationSlotInfo, error)

+ type ReplicationSlotInfo struct

+ Active bool

+ Database string

+ Name string

+ Plugin string

+ SlotType string

+ type SQLExecutor interface

+ ExecuteSQL func(ctx context.Context, query string) ([]map[string]any, error)

+ type Sampler interface

+ Sample func(ctx context.Context, table string) (Message, error)

+ type Sink interface

+ Close func() error

+ Ping func(ctx context.Context) error

+ Write func(ctx context.Context, msg Message) error

+ type SinkOperationMode string

+ const SinkOpModeAuto

+ const SinkOpModeDelete

+ const SinkOpModeInsert

+ const SinkOpModeUpdate

+ const SinkOpModeUpsert

+ type Snapshottable interface

+ Snapshot func(ctx context.Context, tables ...string) error

+ type Source interface

+ Ack func(ctx context.Context, msg Message) error

+ Close func() error

+ Ping func(ctx context.Context) error

+ Read func(ctx context.Context) (Message, error)

+ type StateStore interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) ([]byte, error)

+ Set func(ctx context.Context, key string, value []byte) error

+ type Stateful interface

+ GetState func() map[string]string

+ SetState func(state map[string]string)

+ type StreamLivenessReporter interface

+ LastStreamActivity func() time.Time

+ StreamSilenceThreshold func() time.Duration

+ type StringMap map[string]string

+ func (m *StringMap) UnmarshalJSON(data []byte) error

+ type TraceRecorder interface

+ RecordStep func(ctx context.Context, workflowID, messageID string, step TraceStep)

+ type TraceStep struct

+ After map[string]any

+ Before map[string]any

+ Duration time.Duration

+ Error string

+ Lineage string

+ NodeID string

+ Timestamp time.Time

+ type Transactional interface

+ Begin func(ctx context.Context) error

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

+ type TwoPhaseCommit interface

+ CommitPrepared func(ctx context.Context, txID string) error

+ Prepare func(ctx context.Context, txID string) (string, error)

+ RollbackPrepared func(ctx context.Context, txID string) error

+ type TwoPhaseCommitPreflight interface

+ PreflightTwoPhaseCommit func(ctx context.Context) error

+ type ValidatingSink interface

+ Validate func(ctx context.Context, msg Message) error

v1.0.0-rc.2

Sep 7, 2026

v1.0.0-rc.1

Sep 2, 2026

retracted