Versions in this module Expand all Collapse all v0 v0.1.0 Aug 7, 2026 Changes in this version + type Coordinator struct + func NewMemory(idemTTL time.Duration) *Coordinator + func Open(ctx context.Context, dsn string, idemTTL time.Duration) (*Coordinator, error) + func (c *Coordinator) Close() + func (c *Coordinator) Idempotency() IdempotencyStore + func (c *Coordinator) Leader() Leader + func (c *Coordinator) Pool() *pgxpool.Pool + type IdempotencyStore interface + Get func(ctx context.Context, key string) (Record, bool, error) + Put func(ctx context.Context, key string, rec Record) error + func NewMemoryIdempotency(ttl time.Duration) IdempotencyStore + type Leader interface + Close func() error + IsLeader func(ctx context.Context) bool + func NewLocalLeader() Leader + type Record struct + Body []byte + ContentType string + Status int
Go to main page