MCPcopy
hub / github.com/frain-dev/convoy

github.com/frain-dev/convoy @v26.6.0 sqlite

repository ↗ · DeepWiki ↗ · release v26.6.0 ↗
9,232 symbols 45,533 edges 1,146 files 2,257 documented · 24%
README

convoy image

golangci-lint Build and run all tests

Convoy is an open source high-performance webhooks gateway used to securely ingest, persist, debug, deliver and manage millions of events reliably with rich features such as retries, rate limiting, static ips, circuit breaking, rolling secrets and more.

Convoy provides several key features:

  • Webhooks Gateway: As a webhooks gateway, Convoy lives at the edge of your network to stream webhooks from your microservices, and send them out to your users as well as receive webhooks from your providers and route them to the required services. With this your internal systems are never exposed to the public internet.

  • Scalability: Convoy acts as a dedicated message queue for webhooks, and was designed to be horizontally scalable. It includes several components like the api server, workers, scheduler, and socket server which can be scaled independently to fit the need.

  • Security: Convoy ships with several security features for webhooks, such as payload signing to ensure message integrity, bearer token authentication for authenticated webhook endpoints, and static ips for network environments with strict firewall rules.

  • Fan Out: Convoy is able to route an event to multiple endpoints based on the event type or payload structure.

  • Rate Limiting: While Convoy is able to ingest events at a massive rate, it throttles the delivery of these events to the endpoints at a configurable rate per endpoint.

  • Retries & Batch Retries: Convoy supports two retry algorithms; constant time and exponential backoff with jitter. Where automatic retries are not sufficient, convoy provides batch retries for endpoints are consecutively failed to process retried events.

  • Customer-Facing Dashboards: Convoy allows you to generate customer facing webhooks dashboard to embed into your applications using an iframe. On this dashboard, users can debug webhooks, retry events, add endpoints, and configure each endpoint's subscription.

  • Endpoint Failure Notifications: When endpoints consecutively fails to process events, convoy disables the endpoint and sends out a notification. Two types of notifications are supported: Email and Slack Notifications.

Installation

Contributing

Thank you for your interest in contributing! Please refer to CONTRIBUTING.md for guidance. For contributions to the Convoy dashboard, please refer to the web/ui directory.

License

Elastic License v2.0

Extension points exported contracts — how you extend this code

Cache (Interface)
Cache is a minimal cache interface. Get must return nil (not an error) on cache miss. [8 implementers]
pkg/cachedrepo/cachedrepo.go
OrganisationRepository (Interface)
OrganisationRepository defines the interface for organisation operations using SQLc [5 implementers]
datastore/repository.go
Queuer (Interface)
Queuer enqueues asynq tasks. The driver injects the active OTel trace context from ctx into the task's headers so worker [5 …
queue/queue.go
Cache (Interface)
(no doc) [8 implementers]
cache/cache.go
Verifier (Interface)
(no doc) [7 implementers]
pkg/verifier/verifier.go
Licenser (Interface)
Licenser interface provides methods to determine whether the specified license can utilise certain features in convoy. [4 …
internal/pkg/license/license.go
Realm (Interface)
(no doc) [5 implementers]
auth/realm.go
Clock (Interface)
A Clock is an object that can tell you the current time. This interface allows decoupling code that uses time from the [2 …
pkg/clock/clock.go

Core symbols most depended-on inside this repo

Error
called by 1348
pkg/logger/logger.go
EXPECT
called by 1038
mocks/cache.go
Render
called by 926
util/response.go
Helper
called by 849
testenv/testing.go
Errorf
called by 832
pkg/logger/logger.go
Now
called by 770
pkg/clock/clock.go
String
called by 619
type.go
Close
called by 584
database/database.go

Shape

Method 4,698
Function 2,664
Struct 1,160
Class 424
Interface 182
TypeAlias 80
FuncType 24

Languages

Go80%
TypeScript20%

Modules by API surface

mocks/repository.go474 symbols
datastore/repository.go213 symbols
datastore/models.go208 symbols
api/dashboard_integration_test.go186 symbols
api/public_integration_test.go147 symbols
web/ui/dashboard/src/app/private/pages/settings/billing/billing-page.component.ts101 symbols
datastore/cached/repos.go91 symbols
internal/pkg/billing/client.go88 symbols
config/config.go75 symbols
mocks/license.go72 symbols
internal/event_deliveries/repo/queries.sql.go51 symbols
internal/pkg/license/service/licenser.go50 symbols

Dependencies from manifests, versioned

cloud.google.com/gov0.121.6 · 1×
cloud.google.com/go/auth/oauth2adaptv0.2.8 · 1×
cloud.google.com/go/compute/metadatav0.9.0 · 1×
cloud.google.com/go/pubsubv1.50.1 · 1×
cloud.google.com/go/pubsub/v2v2.0.0 · 1×
dario.cat/mergov1.0.2 · 1×
github.com/Azure/azure-sdk-for-go/sdk/azcorev1.20.0 · 1×
github.com/Azure/azure-sdk-for-go/sdk/internalv1.11.2 · 1×
github.com/Azure/azure-sdk-for-go/sdk/storage/azblobv1.6.4 · 1×
github.com/Azure/go-ansitermv0.0.0-2025010203350 · 1×

Datastores touched

(mongodb)Database · 1 repos
testdbDatabase · 1 repos
convoyDatabase · 1 repos
dbDatabase · 1 repos

For agents

$ claude mcp add convoy \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact