mocks

Documentation

Overview

Code generated by mockery v1.0.0

Code generated by mockery v1.0.0

Index

• type Client
  • func (_m *Client) CancelWorkflow(ctx context.Context, workflowID string, runID string) error
  • func (_m *Client) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error
  • func (_m *Client) CompleteActivityByID(ctx context.Context, domain string, workflowID string, runID string, ...) error
  • func (_m *Client) DescribeTaskList(ctx context.Context, tasklist string, tasklistType shared.TaskListType) (*shared.DescribeTaskListResponse, error)
  • func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*shared.DescribeWorkflowExecutionResponse, error)
  • func (_m *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error)
  • func (_m *Client) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) client.HistoryEventIterator
  • func (_m *Client) ListClosedWorkflow(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
  • func (_m *Client) ListOpenWorkflow(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
  • func (_m *Client) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, ...) (encoded.Value, error)
  • func (_m *Client) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error
  • func (_m *Client) RecordActivityHeartbeatByID(ctx context.Context, domain, workflowID, runID, activityID string, ...) error
  • func (_m *Client) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, ...) error
  • func (_m *Client) StartWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (*workflow.Execution, error)
  • func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error
• type DomainClient
  • func (_m *DomainClient) Describe(ctx context.Context, name string) (*shared.DomainInfo, *shared.DomainConfiguration, error)
  • func (_m *DomainClient) Register(ctx context.Context, request *shared.RegisterDomainRequest) error
  • func (_m *DomainClient) Update(ctx context.Context, name string, domainInfo *shared.UpdateDomainInfo, ...) error

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) 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, domain string, workflowID string, runID string, activityID string, result interface{}, err error) error

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

func (*Client) DescribeTaskList

func (_m *Client) DescribeTaskList(ctx context.Context, tasklist string, tasklistType shared.TaskListType) (*shared.DescribeTaskListResponse, error)

DescribeTaskList provides a mock function with given fields: ctx, tasklist, tasklistType

func (*Client) DescribeWorkflowExecution

func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*shared.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) GetWorkflowHistory

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

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

func (*Client) ListClosedWorkflow

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

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

func (*Client) ListOpenWorkflow

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

ListOpenWorkflow 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{}) (encoded.Value, error)

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

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, domain, workflowID, runID, activityID string, details ...interface{}) error

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

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

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

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

func (*Client) TerminateWorkflow

func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details []byte) error

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

type DomainClient

type DomainClient struct {
	mock.Mock
}

DomainClient is an autogenerated mock type for the DomainClient type

func (*DomainClient) Describe

func (_m *DomainClient) Describe(ctx context.Context, name string) (*shared.DomainInfo, *shared.DomainConfiguration, error)

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

func (*DomainClient) Register

func (_m *DomainClient) Register(ctx context.Context, request *shared.RegisterDomainRequest) error

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

func (*DomainClient) Update

func (_m *DomainClient) Update(ctx context.Context, name string, domainInfo *shared.UpdateDomainInfo, domainConfig *shared.DomainConfiguration) error

Update provides a mock function with given fields: ctx, name, domainInfo, domainConfig