integration

Documentation

Index

• func WithManagerOpts(opts ...cereal.ManagerOpt) managerOptFunc
• func WithNoStart() managerOptFunc
• func WithTaskExecutor(name cereal.TaskName, executor cereal.TaskExecutor) managerOptFunc
• func WithTaskExecutorF(name cereal.TaskName, ...) managerOptFunc
• func WithWorkflowExecutor(name cereal.WorkflowName, executor cereal.WorkflowExecutor) managerOptFunc
• type CerealTestSuite
  • func NewSuiteForBackend(ctx context.Context, t *testing.T, d cereal.Driver) *CerealTestSuite
  • func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenAllowed()
  • func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenNotAllowed()
  • func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowFail()
  • func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowSuccess()

Functions

func WithManagerOpts

func WithManagerOpts(opts ...cereal.ManagerOpt) managerOptFunc

func WithNoStart

func WithNoStart() managerOptFunc

func WithTaskExecutor

func WithTaskExecutor(name cereal.TaskName, executor cereal.TaskExecutor) managerOptFunc

func WithTaskExecutorF

func WithTaskExecutorF(name cereal.TaskName, f func(context.Context, cereal.Task) (interface{}, error)) managerOptFunc

func WithWorkflowExecutor

func WithWorkflowExecutor(name cereal.WorkflowName, executor cereal.WorkflowExecutor) managerOptFunc

Types

type CerealTestSuite

type CerealTestSuite struct {
	suite.Suite
	// contains filtered or unexported fields
}

func NewSuiteForBackend

func NewSuiteForBackend(ctx context.Context, t *testing.T, d cereal.Driver) *CerealTestSuite

func (*CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenAllowed

func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenAllowed()

func (*CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenNotAllowed

func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowCancelWhenNotAllowed()

func (*CerealTestSuite) TestPatternSingleTaskWorkflowFail

func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowFail()

func (*CerealTestSuite) TestPatternSingleTaskWorkflowSuccess

func (suite *CerealTestSuite) TestPatternSingleTaskWorkflowSuccess()