mocks

package
v1.31.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 10, 2024 License: MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient added in v1.26.0 

func NewClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *Client

NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Client) CancelWorkflow 

func (_m *Client) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

CancelWorkflow provides a mock function with given fields: ctx, workflowID, runID

func (*Client) CheckHealth added in v1.15.0 

func (_m *Client) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)

CheckHealth provides a mock function with given fields: ctx, request

func (*Client) Close 

func (_m *Client) Close()

Close provides a mock function with given fields:

func (*Client) CompleteActivity 

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

CompleteActivity provides a mock function with given fields: ctx, taskToken, result, err

func (*Client) CompleteActivityByID 

func (_m *Client) CompleteActivityByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, result interface{}, err error) error

CompleteActivityByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, result, err

func (*Client) CountWorkflow 

func (_m *Client) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

CountWorkflow provides a mock function with given fields: ctx, request

func (*Client) DescribeTaskQueue 

func (_m *Client) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

DescribeTaskQueue provides a mock function with given fields: ctx, taskqueue, taskqueueType

func (*Client) DescribeTaskQueueEnhanced added in v1.27.0 

func (_m *Client) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)

DescribeTaskQueueEnhanced provides a mock function with given fields: ctx, options

func (*Client) DescribeWorkflowExecution 

func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution provides a mock function with given fields: ctx, workflowID, runID

func (*Client) ExecuteWorkflow 

func (_m *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) (client.WorkflowRun, error)

ExecuteWorkflow provides a mock function with given fields: ctx, options, workflow, args

func (*Client) GetSearchAttributes 

func (_m *Client) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

GetSearchAttributes provides a mock function with given fields: ctx

func (*Client) GetWorkerBuildIdCompatibility added in v1.22.0 

func (_m *Client) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)

GetWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options

func (*Client) GetWorkerTaskReachability added in v1.25.0 

func (_m *Client) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)

GetWorkerTaskReachability provides a mock function with given fields: ctx, options

func (*Client) GetWorkerVersioningRules added in v1.27.0 

func (_m *Client) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)

GetWorkerVersioningRules provides a mock function with given fields: ctx, options

func (*Client) GetWorkflow 

func (_m *Client) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun

GetWorkflow provides a mock function with given fields: ctx, workflowID, runID

func (*Client) GetWorkflowHistory 

func (_m *Client) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) client.HistoryEventIterator

GetWorkflowHistory provides a mock function with given fields: ctx, workflowID, runID, isLongPoll, filterType

func (*Client) GetWorkflowUpdateHandle added in v1.22.2 

func (_m *Client) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle

GetWorkflowUpdateHandle provides a mock function with given fields: ref

func (*Client) ListArchivedWorkflow 

func (_m *Client) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflow provides a mock function with given fields: ctx, request

func (*Client) ListClosedWorkflow 

func (_m *Client) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflow provides a mock function with given fields: ctx, request

func (*Client) ListOpenWorkflow 

func (_m *Client) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflow provides a mock function with given fields: ctx, request

func (*Client) ListWorkflow 

func (_m *Client) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

ListWorkflow provides a mock function with given fields: ctx, request

func (*Client) NewWithStartWorkflowOperation added in v1.31.0 

func (_m *Client) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) client.WithStartWorkflowOperation

NewWithStartWorkflowOperation provides a mock function with given fields: options, workflow, args

func (*Client) OperatorService added in v1.17.0 

func (_m *Client) OperatorService() operatorservice.OperatorServiceClient

OperatorService provides a mock function with given fields:

func (*Client) QueryWorkflow 

func (_m *Client) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, args ...interface{}) (converter.EncodedValue, error)

QueryWorkflow provides a mock function with given fields: ctx, workflowID, runID, queryType, args

func (*Client) QueryWorkflowWithOptions 

func (_m *Client) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)

QueryWorkflowWithOptions provides a mock function with given fields: ctx, request

func (*Client) RecordActivityHeartbeat 

func (_m *Client) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

RecordActivityHeartbeat provides a mock function with given fields: ctx, taskToken, details

func (*Client) RecordActivityHeartbeatByID 

func (_m *Client) RecordActivityHeartbeatByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, details ...interface{}) error

RecordActivityHeartbeatByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, details

func (*Client) ResetWorkflowExecution added in v1.6.0 

func (_m *Client) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution provides a mock function with given fields: ctx, request

func (*Client) ScanWorkflow 

func (_m *Client) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

ScanWorkflow provides a mock function with given fields: ctx, request

func (*Client) ScheduleClient added in v1.18.0 

func (_m *Client) ScheduleClient() client.ScheduleClient

ScheduleClient provides a mock function with given fields:

func (*Client) SignalWithStartWorkflow 

func (_m *Client) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, signalArg interface{}, options client.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{}) (client.WorkflowRun, error)

SignalWithStartWorkflow provides a mock function with given fields: ctx, workflowID, signalName, signalArg, options, workflow, workflowArgs

func (*Client) SignalWorkflow 

func (_m *Client) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error

SignalWorkflow provides a mock function with given fields: ctx, workflowID, runID, signalName, arg

func (*Client) TerminateWorkflow 

func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error

TerminateWorkflow provides a mock function with given fields: ctx, workflowID, runID, reason, details

func (*Client) UpdateWithStartWorkflow added in v1.31.0 

func (_m *Client) UpdateWithStartWorkflow(ctx context.Context, options client.UpdateWithStartWorkflowOptions) (client.WorkflowUpdateHandle, error)

UpdateWithStartWorkflow provides a mock function with given fields: ctx, options

func (*Client) UpdateWorkerBuildIdCompatibility added in v1.22.0 

func (_m *Client) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error

UpdateWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options

func (*Client) UpdateWorkerVersioningRules added in v1.27.0 

func (_m *Client) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)

UpdateWorkerVersioningRules provides a mock function with given fields: ctx, options

func (*Client) UpdateWorkflow added in v1.20.0 

func (_m *Client) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)

UpdateWorkflow provides a mock function with given fields: ctx, options

func (*Client) WorkflowService added in v1.12.0 

func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient

WorkflowService provides a mock function with given fields:

type HistoryEventIterator 

type HistoryEventIterator struct {
	mock.Mock
}

HistoryEventIterator is an autogenerated mock type for the HistoryEventIterator type

func NewHistoryEventIterator added in v1.26.0 

func NewHistoryEventIterator(t interface {
	mock.TestingT
	Cleanup(func())
}) *HistoryEventIterator

NewHistoryEventIterator creates a new instance of HistoryEventIterator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*HistoryEventIterator) HasNext 

func (_m *HistoryEventIterator) HasNext() bool

HasNext provides a mock function with given fields:

func (*HistoryEventIterator) Next 

func (_m *HistoryEventIterator) Next() (*historypb.HistoryEvent, error)

Next provides a mock function with given fields:

type NamespaceClient 

type NamespaceClient struct {
	mock.Mock
}

NamespaceClient is an autogenerated mock type for the NamespaceClient type

func NewNamespaceClient added in v1.26.0 

func NewNamespaceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *NamespaceClient

NewNamespaceClient creates a new instance of NamespaceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*NamespaceClient) Close 

func (_m *NamespaceClient) Close()

Close provides a mock function with given fields:

func (*NamespaceClient) Describe 

func (_m *NamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)

Describe provides a mock function with given fields: ctx, name

func (*NamespaceClient) Register 

func (_m *NamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error

Register provides a mock function with given fields: ctx, request

func (*NamespaceClient) Update 

func (_m *NamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error

Update provides a mock function with given fields: ctx, request

type ScheduleClient added in v1.24.0 

type ScheduleClient struct {
	mock.Mock
}

ScheduleClient is an autogenerated mock type for the ScheduleClient type

func NewScheduleClient added in v1.24.0 

func NewScheduleClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScheduleClient

NewScheduleClient creates a new instance of ScheduleClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScheduleClient) Create added in v1.24.0 

func (_m *ScheduleClient) Create(ctx context.Context, options client.ScheduleOptions) (client.ScheduleHandle, error)

Create provides a mock function with given fields: ctx, options

func (*ScheduleClient) GetHandle added in v1.24.0 

func (_m *ScheduleClient) GetHandle(ctx context.Context, scheduleID string) client.ScheduleHandle

GetHandle provides a mock function with given fields: ctx, scheduleID

func (*ScheduleClient) List added in v1.24.0 

func (_m *ScheduleClient) List(ctx context.Context, options client.ScheduleListOptions) (client.ScheduleListIterator, error)

List provides a mock function with given fields: ctx, options

type ScheduleHandle added in v1.24.0 

type ScheduleHandle struct {
	mock.Mock
}

ScheduleHandle is an autogenerated mock type for the ScheduleHandle type

func NewScheduleHandle added in v1.24.0 

func NewScheduleHandle(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScheduleHandle

NewScheduleHandle creates a new instance of ScheduleHandle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScheduleHandle) Backfill added in v1.24.0 

func (_m *ScheduleHandle) Backfill(ctx context.Context, options client.ScheduleBackfillOptions) error

Backfill provides a mock function with given fields: ctx, options

func (*ScheduleHandle) Delete added in v1.24.0 

func (_m *ScheduleHandle) Delete(ctx context.Context) error

Delete provides a mock function with given fields: ctx

func (*ScheduleHandle) Describe added in v1.24.0 

func (_m *ScheduleHandle) Describe(ctx context.Context) (*client.ScheduleDescription, error)

Describe provides a mock function with given fields: ctx

func (*ScheduleHandle) GetID added in v1.24.0 

func (_m *ScheduleHandle) GetID() string

GetID provides a mock function with given fields:

func (*ScheduleHandle) Pause added in v1.24.0 

func (_m *ScheduleHandle) Pause(ctx context.Context, options client.SchedulePauseOptions) error

Pause provides a mock function with given fields: ctx, options

func (*ScheduleHandle) Trigger added in v1.24.0 

func (_m *ScheduleHandle) Trigger(ctx context.Context, options client.ScheduleTriggerOptions) error

Trigger provides a mock function with given fields: ctx, options

func (*ScheduleHandle) Unpause added in v1.24.0 

func (_m *ScheduleHandle) Unpause(ctx context.Context, options client.ScheduleUnpauseOptions) error

Unpause provides a mock function with given fields: ctx, options

func (*ScheduleHandle) Update added in v1.24.0 

func (_m *ScheduleHandle) Update(ctx context.Context, options client.ScheduleUpdateOptions) error

Update provides a mock function with given fields: ctx, options

type ScheduleListIterator added in v1.24.0 

type ScheduleListIterator struct {
	mock.Mock
}

ScheduleListIterator is an autogenerated mock type for the ScheduleListIterator type

func NewScheduleListIterator added in v1.24.0 

func NewScheduleListIterator(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScheduleListIterator

NewScheduleListIterator creates a new instance of ScheduleListIterator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScheduleListIterator) HasNext added in v1.24.0 

func (_m *ScheduleListIterator) HasNext() bool

HasNext provides a mock function with given fields:

func (*ScheduleListIterator) Next added in v1.24.0 

func (_m *ScheduleListIterator) Next() (*client.ScheduleListEntry, error)

Next provides a mock function with given fields:

type Value 

type Value struct {
	mock.Mock
}

Value is an autogenerated mock type for the Value type

func NewEncodedValue added in v1.26.0 

func NewEncodedValue(t interface {
	mock.TestingT
	Cleanup(func())
}) *Value

NewEncodedValue creates a new instance of Value. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Value) Get 

func (_m *Value) Get(valuePtr interface{}) error

Get provides a mock function with given fields: valuePtr

func (*Value) HasValue 

func (_m *Value) HasValue() bool

HasValue provides a mock function with given fields:

type WorkflowRun 

type WorkflowRun struct {
	mock.Mock
}

WorkflowRun is an autogenerated mock type for the WorkflowRun type

func NewWorkflowRun added in v1.26.0 

func NewWorkflowRun(t interface {
	mock.TestingT
	Cleanup(func())
}) *WorkflowRun

NewWorkflowRun creates a new instance of WorkflowRun. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*WorkflowRun) Get 

func (_m *WorkflowRun) Get(ctx context.Context, valuePtr interface{}) error

Get provides a mock function with given fields: ctx, valuePtr

func (*WorkflowRun) GetID 

func (_m *WorkflowRun) GetID() string

GetID provides a mock function with given fields:

func (*WorkflowRun) GetRunID 

func (_m *WorkflowRun) GetRunID() string

GetRunID provides a mock function with given fields:

func (*WorkflowRun) GetWithOptions added in v1.15.0 

func (_m *WorkflowRun) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error

GetWithOptions provides a mock function with given fields: ctx, valuePtr, options

type WorkflowUpdateHandle added in v1.24.0 

type WorkflowUpdateHandle struct {
	mock.Mock
}

WorkflowUpdateHandle is an autogenerated mock type for the WorkflowUpdateHandle type

func NewWorkflowUpdateHandle added in v1.24.0 

func NewWorkflowUpdateHandle(t interface {
	mock.TestingT
	Cleanup(func())
}) *WorkflowUpdateHandle

NewWorkflowUpdateHandle creates a new instance of WorkflowUpdateHandle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*WorkflowUpdateHandle) Get added in v1.24.0 

func (_m *WorkflowUpdateHandle) Get(ctx context.Context, valuePtr interface{}) error

Get provides a mock function with given fields: ctx, valuePtr

func (*WorkflowUpdateHandle) RunID added in v1.24.0 

func (_m *WorkflowUpdateHandle) RunID() string

RunID provides a mock function with given fields:

func (*WorkflowUpdateHandle) UpdateID added in v1.24.0 

func (_m *WorkflowUpdateHandle) UpdateID() string

UpdateID provides a mock function with given fields:

func (*WorkflowUpdateHandle) WorkflowID added in v1.24.0 

func (_m *WorkflowUpdateHandle) WorkflowID() string

WorkflowID provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.