postgres

func (*ArrayMigrationDriver) Close ¶

func (a *ArrayMigrationDriver) Close() error

func (*ArrayMigrationDriver) First ¶

func (a *ArrayMigrationDriver) First() (uint, error)

func (*ArrayMigrationDriver) Next ¶

func (a *ArrayMigrationDriver) Next(version uint) (uint, error)

func (*ArrayMigrationDriver) Open ¶

func (a *ArrayMigrationDriver) Open(_ string) (source.Driver, error)

func (*ArrayMigrationDriver) Prev ¶

func (a *ArrayMigrationDriver) Prev(version uint) (uint, error)

func (*ArrayMigrationDriver) ReadDown ¶

func (a *ArrayMigrationDriver) ReadDown(version uint) (io.ReadCloser, string, error)

func (*ArrayMigrationDriver) ReadUp ¶

func (a *ArrayMigrationDriver) ReadUp(version uint) (io.ReadCloser, string, error)

func (*PostgresBackend) CancelWorkflow ¶

func (pg *PostgresBackend) CancelWorkflow(ctx context.Context, instanceName string, workflowName string) error

func (*PostgresBackend) Close ¶

func (pg *PostgresBackend) Close() error

func (*PostgresBackend) CreateWorkflowSchedule ¶

func (pg *PostgresBackend) CreateWorkflowSchedule(ctx context.Context, instanceName string, workflowName string,
	parameters []byte, enabled bool, recurrence string, nextRunAt time.Time) error

func (*PostgresBackend) DequeueTask ¶

func (pg *PostgresBackend) DequeueTask(ctx context.Context, taskName string) (*cereal.TaskData, cereal.TaskCompleter, error)

func (*PostgresBackend) DequeueWorkflow ¶

func (pg *PostgresBackend) DequeueWorkflow(ctx context.Context, workflowNames []string) (*cereal.WorkflowEvent, cereal.WorkflowCompleter, error)

func (*PostgresBackend) EnqueueWorkflow ¶

func (pg *PostgresBackend) EnqueueWorkflow(ctx context.Context, w *cereal.WorkflowInstanceData) error

func (*PostgresBackend) GetDueScheduledWorkflow ¶

func (pg *PostgresBackend) GetDueScheduledWorkflow(ctx context.Context) (*cereal.Schedule, cereal.ScheduledWorkflowCompleter, error)

func (*PostgresBackend) GetNextScheduledWorkflow ¶

func (pg *PostgresBackend) GetNextScheduledWorkflow(ctx context.Context) (*cereal.Schedule, error)

func (*PostgresBackend) GetWorkflowInstanceByName ¶

func (pg *PostgresBackend) GetWorkflowInstanceByName(ctx context.Context, instanceName string, workflowName string) (*cereal.WorkflowInstanceData, error)

func (*PostgresBackend) GetWorkflowScheduleByName ¶

func (pg *PostgresBackend) GetWorkflowScheduleByName(ctx context.Context, instanceName string, workflowName string) (*cereal.Schedule, error)

func (*PostgresBackend) Init ¶

func (pg *PostgresBackend) Init() error

func (*PostgresBackend) KillWorkflow ¶

func (pg *PostgresBackend) KillWorkflow(ctx context.Context, instanceName string, workflowName string) error

func (*PostgresBackend) ListWorkflowInstances ¶

func (pg *PostgresBackend) ListWorkflowInstances(ctx context.Context, opts cereal.ListWorkflowOpts) ([]*cereal.WorkflowInstanceData, error)

func (*PostgresBackend) ListWorkflowSchedules ¶

func (pg *PostgresBackend) ListWorkflowSchedules(ctx context.Context) ([]*cereal.Schedule, error)

func (*PostgresBackend) UpdateWorkflowScheduleByName ¶

func (pg *PostgresBackend) UpdateWorkflowScheduleByName(
	ctx context.Context, instanceName string, workflowName string, opts cereal.WorkflowScheduleUpdateOptions) error

func (*PostgresScheduledWorkflowCompleter) Close ¶

func (c *PostgresScheduledWorkflowCompleter) Close()

func (*PostgresScheduledWorkflowCompleter) DisableSchedule ¶

func (c *PostgresScheduledWorkflowCompleter) DisableSchedule(s *cereal.Schedule) error

func (*PostgresScheduledWorkflowCompleter) EnqueueAndUpdateScheduledWorkflow ¶

func (c *PostgresScheduledWorkflowCompleter) EnqueueAndUpdateScheduledWorkflow(s *cereal.Schedule) error

TODO(ssd) 2019-05-14: We should probably allow bulk insertion of workflows and tasks

func (*PostgresTaskCompleter) Context ¶

func (taskc *PostgresTaskCompleter) Context() context.Context

func (*PostgresTaskCompleter) Fail ¶

func (taskc *PostgresTaskCompleter) Fail(errMsg string) error

func (*PostgresTaskCompleter) Succeed ¶

func (taskc *PostgresTaskCompleter) Succeed(results []byte) error

TODO(ssd) 2019-05-10: Should this and Fail also take a context from the caller? If so, we'll need to

func (*PostgresWorkflowCompleter) Close ¶

func (workc *PostgresWorkflowCompleter) Close() error

func (*PostgresWorkflowCompleter) Continue ¶

func (workc *PostgresWorkflowCompleter) Continue(payload []byte) error

func (*PostgresWorkflowCompleter) Done ¶

func (workc *PostgresWorkflowCompleter) Done(result []byte) error

func (*PostgresWorkflowCompleter) EnqueueTask ¶

func (workc *PostgresWorkflowCompleter) EnqueueTask(task *cereal.TaskData, opts cereal.TaskEnqueueOptions) error

func (*PostgresWorkflowCompleter) Fail ¶

func (workc *PostgresWorkflowCompleter) Fail(workflowErr error) error