NewMetricsReporter creates a new instance of NewMetricsReporter.

NewPersistenceWorker returns a new PersistenceWorker.

DefaultJobBackOff is the default backoff period.

MaxJobBackOff is the max backoff period.

MetricsReporter reports metrics of a workflow to pipeline server.

PersistenceWorker is a generic worker to persist objects from a queue.

ScheduledWorkflowSaver provides a function to persist a workflow to a database.

WorkflowSaver provides a function to persist a workflow to a database.