MCPcopy Create free account
hub / github.com/Mnexa-AI/e2a / Enabled

Method Enabled

internal/webhookpub/outbox.go:80–80  ·  view source on GitHub ↗

Enabled reports whether the outbox is the durable fan-out path for this deployment. When true, trigger sites (relay + the publishPendingApproval/publishRejected/publishSent/publishApproved helpers) MUST skip the legacy `go publisher.Publish(...)` goroutine — both paths inserting into webhook_subscri

()

Source from the content-addressed store, hash-verified

78 // multi-replica outbox workers, cannot dedupe legacy-vs-outbox
79 // rows — they look like distinct deliveries.
80 Enabled() bool
81}
82
83// outboxExecutor is the subset of pgx.Tx and pgxpool.Pool needed by

Callers 8

mainFunction · 0.95
NewEventsAPIHarnessFunction · 0.65
PublishTxMethod · 0.65
EnabledMethod · 0.65
PublishBestEffortTxMethod · 0.65
deliverToAgentMethod · 0.65
shouldFireLegacyMethod · 0.65
agentAuthReadyMethod · 0.65

Implementers 3

outboxinternal/webhookpub/outbox.go
fakeOutboxinternal/relay/server_outbox_test.go
fakeAgentOutboxinternal/agent/webhooks_events_test.go

Calls

no outgoing calls

Tested by

no test coverage detected