Versions in this module Expand all Collapse all v0 v0.4.0 Jun 4, 2026 v0.3.0 Jun 3, 2026 Changes in this version + const EventEmailApproved + const EventEmailPendingApproval + const EventEmailReceived + const EventEmailRejected + const EventEmailSent + var AllEventTypes = []string + func DeterministicEventID(parts ...string) string + func IsValidEventType(name string) bool + func NewDBInserter(pool *pgxpool.Pool) deliveryInserter + type Envelope struct + CreatedAt time.Time + Data any + Event string + ID string + type Event struct + AgentID string + ConversationID string + CreatedAt time.Time + Data any + ID string + Labels []string + MessageID string + Type string + UserID string + func NewEvent(eventType, userID string, data any) Event + func (e Event) AsEnvelope() Envelope + type FeatureFlag interface + Enabled func() bool + type Outbox interface + DeleteExpiredWebhookEvents func(ctx context.Context) (int, error) + PublishBestEffortTx func(ctx context.Context, tx pgx.Tx, e Event) + PublishTx func(ctx context.Context, tx pgx.Tx, e Event) error + func NewOutbox(pool *pgxpool.Pool, flag FeatureFlag) Outbox + type OutboxWorker struct + func NewOutboxWorker(pool *pgxpool.Pool, store identityReader) *OutboxWorker + func (w *OutboxWorker) Start(ctx context.Context) + func (w *OutboxWorker) Tick(ctx context.Context) + func (w *OutboxWorker) WithMetrics(m telemetry.Metrics) *OutboxWorker + type Publisher interface + Publish func(ctx context.Context, e Event) + func New(s store, ins deliveryInserter, flag FeatureFlag) Publisher + type StaticFlag bool + func (f StaticFlag) Enabled() bool
Go to main page