grpc

Documentation

Index

• type GrpcBackend
  • func NewGrpcBackend(domain string, client grpccereal.CerealServiceClient) *GrpcBackend
  • func NewGrpcBackendFromConn(domain string, conn *grpc.ClientConn) *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

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 (g *GrpcBackend) CancelWorkflow(ctx context.Context, instanceName string, workflowName string) error

func (*GrpcBackend) Close

func (g *GrpcBackend) Close() error

func (*GrpcBackend) CreateWorkflowSchedule

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

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 (g *GrpcBackend) GetWorkflowScheduleByName(ctx context.Context, instanceName string, workflowName string) (*cereal.Schedule, error)

func (*GrpcBackend) Init

func (*GrpcBackend) Init() error

func (*GrpcBackend) KillWorkflow

func (g *GrpcBackend) KillWorkflow(ctx context.Context, instanceName string, workflowName string) error

func (*GrpcBackend) ListWorkflowInstances

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

func (*GrpcBackend) ListWorkflowSchedules

func (g *GrpcBackend) ListWorkflowSchedules(ctx context.Context) ([]*cereal.Schedule, error)

func (*GrpcBackend) UpdateWorkflowScheduleByName

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