README
¶
dapper-orchestrator-contrib
A set of processes and inputs which can be used to provide pipelines as managed by the dapper orchestrator.
Webhooks
import github.com/dapper-data/dapper-orchestrator-contrib/webhooks
Webhooks provides both an Input and a Process; the Input exposes a webhook which listens for well formed orchestrator.Events which it then passes, more or less as it finds it, for processing, whereas the Process will send an orchestrator.Events to a specified webhook.
See the documentation in webhooks/ and the included example code in webhooks/example for more.
Locking Postgres
import github.com/dapper-data/dapper-orchestrator-contrib/locking-postgres
Locking Postgres provides a postgres Input which can be used across a cluster of orchestrators; the sample Postgres Input is unsuitable for this task, as a database operation may be handled multiple times by virtue of each orchestrator in a cluster receiving each notification
See the documentation in locking-postgres/ and the example code in locking-postgres/example for more.
Directories