mocks

Documentation

Overview

Code generated by mockery v1.0.0. Modified manually for type alias to work correctly. https://github.com/vektra/mockery/issues/236

Code generated by mockery v1.0.0

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

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

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) CountWorkflow(ctx context.Context, request *shared.CountWorkflowExecutionsRequest) (*shared.CountWorkflowExecutionsResponse, 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) GetSearchAttributes(ctx context.Context) (*shared.GetSearchAttributesResponse, error)
  • func (_m *Client) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun
  • 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) ListWorkflow(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, 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 string, workflowID string, runID string, ...) error
  • func (_m *Client) ScanWorkflow(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, error)
  • func (_m *Client) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (*workflow.Execution, 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.DescribeDomainResponse, error)
  • func (_m *DomainClient) Register(ctx context.Context, request *shared.RegisterDomainRequest) error
  • func (_m *DomainClient) Update(ctx context.Context, request *shared.UpdateDomainRequest) error
• type HistoryEventIterator
  • func (_m *HistoryEventIterator) HasNext() bool
  • func (_m *HistoryEventIterator) Next() (*shared.HistoryEvent, error)
• type Value
  • func (_m *Value) Get(valuePtr interface{}) error
  • func (_m *Value) HasValue() bool
• type WorkflowRun
  • func (_m *WorkflowRun) Get(ctx context.Context, valuePtr interface{}) error
  • func (_m *WorkflowRun) GetID() string
  • func (_m *WorkflowRun) GetRunID() string

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

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

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

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

func (_m *Client) GetSearchAttributes(ctx context.Context) (*shared.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 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) ListWorkflow

func (_m *Client) ListWorkflow(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.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{}) (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 string, workflowID string, runID string, activityID string, details ...interface{}) error

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

func (*Client) ScanWorkflow

func (_m *Client) ScanWorkflow(ctx context.Context, request *shared.ListWorkflowExecutionsRequest) (*shared.ListWorkflowExecutionsResponse, 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{}) (*workflow.Execution, 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) 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.DescribeDomainResponse, 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, request *shared.UpdateDomainRequest) error

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

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() (*shared.HistoryEvent, 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 (*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: