Documentation
¶
Index ¶
- type GrpcBackend
- func (g *GrpcBackend) CancelWorkflow(ctx context.Context, instanceName string, workflowName string) error
- func (g *GrpcBackend) Close() error
- func (g *GrpcBackend) CreateWorkflowSchedule(ctx context.Context, instanceName string, workflowName string, ...) error
- func (g *GrpcBackend) DefaultTaskPollInterval() time.Duration
- func (g *GrpcBackend) DefaultWorkflowPollInterval() time.Duration
- func (g *GrpcBackend) DequeueTask(ctx context.Context, taskName string) (*cereal.TaskData, cereal.TaskCompleter, error)
- func (g *GrpcBackend) DequeueWorkflow(ctx context.Context, workflowNames []string) (*cereal.WorkflowEvent, cereal.WorkflowCompleter, error)
- func (g *GrpcBackend) EnqueueWorkflow(ctx context.Context, workflow *cereal.WorkflowInstanceData) error
- func (g *GrpcBackend) GetWorkflowInstanceByName(ctx context.Context, instanceName string, workflowName string) (*cereal.WorkflowInstanceData, error)
- func (g *GrpcBackend) GetWorkflowScheduleByName(ctx context.Context, instanceName string, workflowName string) (*cereal.Schedule, error)
- func (*GrpcBackend) Init() error
- func (g *GrpcBackend) KillWorkflow(ctx context.Context, instanceName string, workflowName string) error
- func (g *GrpcBackend) ListWorkflowInstances(ctx context.Context, opts cereal.ListWorkflowOpts) ([]*cereal.WorkflowInstanceData, error)
- func (g *GrpcBackend) ListWorkflowSchedules(ctx context.Context) ([]*cereal.Schedule, error)
- func (g *GrpcBackend) UpdateWorkflowScheduleByName(ctx context.Context, instanceName string, workflowName string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GrpcBackend ¶
type GrpcBackend struct {
// contains filtered or unexported fields
}
func NewGrpcBackend ¶
func NewGrpcBackend(domain string, client grpccereal.CerealServiceClient) *GrpcBackend
func NewGrpcBackendFromConn ¶
func NewGrpcBackendFromConn(domain string, conn *grpc.ClientConn) *GrpcBackend
func (*GrpcBackend) CancelWorkflow ¶
func (*GrpcBackend) Close ¶
func (g *GrpcBackend) Close() error
func (*GrpcBackend) CreateWorkflowSchedule ¶
func (*GrpcBackend) DefaultTaskPollInterval ¶
func (g *GrpcBackend) DefaultTaskPollInterval() time.Duration
func (*GrpcBackend) DefaultWorkflowPollInterval ¶
func (g *GrpcBackend) DefaultWorkflowPollInterval() time.Duration
func (*GrpcBackend) DequeueTask ¶
func (g *GrpcBackend) DequeueTask(ctx context.Context, taskName string) (*cereal.TaskData, cereal.TaskCompleter, error)
func (*GrpcBackend) DequeueWorkflow ¶
func (g *GrpcBackend) DequeueWorkflow(ctx context.Context, workflowNames []string) (*cereal.WorkflowEvent, cereal.WorkflowCompleter, error)
func (*GrpcBackend) EnqueueWorkflow ¶
func (g *GrpcBackend) EnqueueWorkflow(ctx context.Context, workflow *cereal.WorkflowInstanceData) error
func (*GrpcBackend) GetWorkflowInstanceByName ¶
func (g *GrpcBackend) GetWorkflowInstanceByName(ctx context.Context, instanceName string, workflowName string) (*cereal.WorkflowInstanceData, error)
func (*GrpcBackend) GetWorkflowScheduleByName ¶
func (*GrpcBackend) Init ¶
func (*GrpcBackend) Init() error
func (*GrpcBackend) KillWorkflow ¶
func (*GrpcBackend) ListWorkflowInstances ¶
func (g *GrpcBackend) ListWorkflowInstances(ctx context.Context, opts cereal.ListWorkflowOpts) ([]*cereal.WorkflowInstanceData, error)
func (*GrpcBackend) ListWorkflowSchedules ¶
func (*GrpcBackend) UpdateWorkflowScheduleByName ¶
func (g *GrpcBackend) UpdateWorkflowScheduleByName(ctx context.Context, instanceName string, workflowName string, opts cereal.WorkflowScheduleUpdateOptions) error
Source Files
Click to show internal directories.
Click to hide internal directories.