mocks

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Code generated by mockery v1.0.0. DO NOT EDIT.

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0. DO NOT EDIT.

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 (*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) 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 enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

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

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) 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 enumspb.HistoryEventFilterType) client.HistoryEventIterator

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

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) 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 

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) 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) 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 (*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 (*NamespaceClient) Close 

func (_m *NamespaceClient) Close()

Close provides a mock function without 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 Value 

type Value struct {
	mock.Mock
}

Value is an autogenerated mock type for the Value type

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 (*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:

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.