temporal_tester

Jun 28, 2024

Changes in this version

type MockClient

+ func (m *MockClient) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)

+ func (m *MockClient) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)

+ func (m *MockClient) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)

Oct 10, 2023

Changes in this version

type MockClient

+ func (m *MockClient) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)

Aug 9, 2023

Changes in this version

type MockClient

+ func (m *MockClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)

+ func (m *MockClient) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle

+ func (m *MockClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error

Feb 26, 2023

Changes in this version

type MockClient

+ func (m *MockClient) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, ...) (client.WorkflowUpdateHandle, error)

+ func (m *MockClient) UpdateWorkflowWithOptions(ctx context.Context, request *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)

Dec 6, 2022

Changes in this version

type MockClient

+ func (m *MockClient) ScheduleClient() client.ScheduleClient

Nov 28, 2022

Changes in this version

+ func EmptyClientsBuilder(context.Context, string, *client.Options) (client.Client, error)

+ func MockClientsBuilder(mocks ...MockedWorker) func(context.Context, string, *client.Options) (client.Client, error)

+ func MockWorkerBuilder(client client.Client, taskQueue string, options worker.Options) worker.Worker

+ func NewEnvWithWorkflows(wfs ...MockWorkflow) *testsuite.TestWorkflowEnvironment

+ func NewTemporalMockClient(env *testsuite.TestWorkflowEnvironment) client.Client

+ func PatchedService(t syslgo.TestingT, ...) func(context.Context, AppConfig) (ServiceInterface, *core.Hooks, error)

+ type MockBase struct

+ func NewMockWorkflowBase(t syslgo.TestingT) *MockBase[Resp]

+ func (m *MockBase[Resp]) BuildMockActivity() func(context.Context, ...any) (Resp, error)

+ func (m *MockBase[Resp]) BuildMockActivityWithoutReturn() func(context.Context, ...any) error

+ func (m *MockBase[Resp]) BuildMockWorkflow() func(workflow.Context, ...any) (Resp, error)

+ func (m *MockBase[Resp]) BuildMockWorkflowWithoutReturn() func(workflow.Context, ...any) error

+ func (m *MockBase[Resp]) CheckExpectations(actual ...any)

+ func (m *MockBase[Resp]) ExpectOptions(opt client.StartWorkflowOptions)

+ func (m *MockBase[Resp]) ExpectRequest(req ...any)

+ func (m *MockBase[Resp]) IsMocked() bool

+ func (m *MockBase[Resp]) MockErrorOnlyResponse(err error)

+ func (m *MockBase[Resp]) MockResponse(resp Resp, err error)

+ type MockClient struct

+ Env *testsuite.TestWorkflowEnvironment

+ func (m *MockClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

+ func (m *MockClient) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)

+ func (m *MockClient) Close()

+ func (m *MockClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error

+ func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error

+ func (m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

+ func (m *MockClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

+ func (m *MockClient) DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)

+ func (m *MockClient) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error)

+ func (m *MockClient) GetEnv() *testsuite.TestWorkflowEnvironment

+ func (m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

+ func (m *MockClient) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun

+ func (m *MockClient) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) client.HistoryEventIterator

+ func (m *MockClient) ListArchivedWorkflow(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

+ func (m *MockClient) ListClosedWorkflow(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

+ func (m *MockClient) ListOpenWorkflow(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

+ func (m *MockClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

+ func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient

+ func (m *MockClient) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, ...) (converter.EncodedValue, error)

+ func (m *MockClient) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)

+ func (m *MockClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

+ func (m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error

+ func (m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

+ func (m *MockClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

+ func (m *MockClient) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (client.WorkflowRun, error)

+ func (m *MockClient) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, ...) error

+ func (m *MockClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error

+ func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient

+ type MockWorker struct

+ func (mw *MockWorker) GetTestActivityEnv() *testsuite.TestActivityEnvironment

+ func (mw *MockWorker) RegisterActivity(a interface{})

+ func (mw *MockWorker) RegisterActivityWithOptions(a interface{}, options activity.RegisterOptions)

+ func (mw *MockWorker) RegisterWorkflow(w interface{})

+ func (mw *MockWorker) RegisterWorkflowWithOptions(w interface{}, options workflow.RegisterOptions)

+ func (mw *MockWorker) Run(interruptCh <-chan interface{}) error

+ func (mw *MockWorker) Start() error

+ func (mw *MockWorker) Stop()

+ type MockWorkflow struct

+ Option workflow.RegisterOptions

+ Workflow any

+ type MockWorkflowRun struct

+ Env *testsuite.TestWorkflowEnvironment

+ ID string

+ func (m *MockWorkflowRun) Get(ctx context.Context, valuePtr interface{}) error

+ func (m *MockWorkflowRun) GetID() string

+ func (m *MockWorkflowRun) GetRunID() string

+ func (m *MockWorkflowRun) GetWithOptions(ctx context.Context, valuePtr interface{}, ...) error

+ type MockedWorker interface

+ GetName func() string

+ GetWorkflows func() []MockWorkflow

+ type TestFuture struct

+ func ExecuteTestActivity(env *testsuite.TestActivityEnvironment, name string, params ...any) (*TestFuture[Resp], error)

+ func (t *TestFuture[Resp]) Get() (Resp, error)