frontend

package
v1.2.5 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2023 License: MIT Imports: 15 Imported by: 5

Documentation

Overview

Package frontend is a generated GoMock package.

Index

Constants

View Source 
const (
	// DefaultTimeout is the default timeout used to make calls
	DefaultTimeout = 10 * time.Second
	// DefaultLongPollTimeout is the long poll default timeout used to make calls
	DefaultLongPollTimeout = time.Minute * 3
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	CountWorkflowExecutions(context.Context, *types.CountWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.CountWorkflowExecutionsResponse, error)
	DeprecateDomain(context.Context, *types.DeprecateDomainRequest, ...yarpc.CallOption) error
	DescribeDomain(context.Context, *types.DescribeDomainRequest, ...yarpc.CallOption) (*types.DescribeDomainResponse, error)
	DescribeTaskList(context.Context, *types.DescribeTaskListRequest, ...yarpc.CallOption) (*types.DescribeTaskListResponse, error)
	DescribeWorkflowExecution(context.Context, *types.DescribeWorkflowExecutionRequest, ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error)
	GetClusterInfo(context.Context, ...yarpc.CallOption) (*types.ClusterInfo, error)
	GetSearchAttributes(context.Context, ...yarpc.CallOption) (*types.GetSearchAttributesResponse, error)
	GetWorkflowExecutionHistory(context.Context, *types.GetWorkflowExecutionHistoryRequest, ...yarpc.CallOption) (*types.GetWorkflowExecutionHistoryResponse, error)
	ListArchivedWorkflowExecutions(context.Context, *types.ListArchivedWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.ListArchivedWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(context.Context, *types.ListClosedWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.ListClosedWorkflowExecutionsResponse, error)
	ListDomains(context.Context, *types.ListDomainsRequest, ...yarpc.CallOption) (*types.ListDomainsResponse, error)
	ListOpenWorkflowExecutions(context.Context, *types.ListOpenWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.ListOpenWorkflowExecutionsResponse, error)
	ListTaskListPartitions(context.Context, *types.ListTaskListPartitionsRequest, ...yarpc.CallOption) (*types.ListTaskListPartitionsResponse, error)
	GetTaskListsByDomain(context.Context, *types.GetTaskListsByDomainRequest, ...yarpc.CallOption) (*types.GetTaskListsByDomainResponse, error)
	RefreshWorkflowTasks(context.Context, *types.RefreshWorkflowTasksRequest, ...yarpc.CallOption) error
	ListWorkflowExecutions(context.Context, *types.ListWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.ListWorkflowExecutionsResponse, error)
	PollForActivityTask(context.Context, *types.PollForActivityTaskRequest, ...yarpc.CallOption) (*types.PollForActivityTaskResponse, error)
	PollForDecisionTask(context.Context, *types.PollForDecisionTaskRequest, ...yarpc.CallOption) (*types.PollForDecisionTaskResponse, error)
	QueryWorkflow(context.Context, *types.QueryWorkflowRequest, ...yarpc.CallOption) (*types.QueryWorkflowResponse, error)
	RecordActivityTaskHeartbeat(context.Context, *types.RecordActivityTaskHeartbeatRequest, ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskHeartbeatByID(context.Context, *types.RecordActivityTaskHeartbeatByIDRequest, ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)
	RegisterDomain(context.Context, *types.RegisterDomainRequest, ...yarpc.CallOption) error
	RequestCancelWorkflowExecution(context.Context, *types.RequestCancelWorkflowExecutionRequest, ...yarpc.CallOption) error
	ResetStickyTaskList(context.Context, *types.ResetStickyTaskListRequest, ...yarpc.CallOption) (*types.ResetStickyTaskListResponse, error)
	ResetWorkflowExecution(context.Context, *types.ResetWorkflowExecutionRequest, ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error)
	RespondActivityTaskCanceled(context.Context, *types.RespondActivityTaskCanceledRequest, ...yarpc.CallOption) error
	RespondActivityTaskCanceledByID(context.Context, *types.RespondActivityTaskCanceledByIDRequest, ...yarpc.CallOption) error
	RespondActivityTaskCompleted(context.Context, *types.RespondActivityTaskCompletedRequest, ...yarpc.CallOption) error
	RespondActivityTaskCompletedByID(context.Context, *types.RespondActivityTaskCompletedByIDRequest, ...yarpc.CallOption) error
	RespondActivityTaskFailed(context.Context, *types.RespondActivityTaskFailedRequest, ...yarpc.CallOption) error
	RespondActivityTaskFailedByID(context.Context, *types.RespondActivityTaskFailedByIDRequest, ...yarpc.CallOption) error
	RespondDecisionTaskCompleted(context.Context, *types.RespondDecisionTaskCompletedRequest, ...yarpc.CallOption) (*types.RespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *types.RespondDecisionTaskFailedRequest, ...yarpc.CallOption) error
	RespondQueryTaskCompleted(context.Context, *types.RespondQueryTaskCompletedRequest, ...yarpc.CallOption) error
	RestartWorkflowExecution(context.Context, *types.RestartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.RestartWorkflowExecutionResponse, error)
	ScanWorkflowExecutions(context.Context, *types.ListWorkflowExecutionsRequest, ...yarpc.CallOption) (*types.ListWorkflowExecutionsResponse, error)
	SignalWithStartWorkflowExecution(context.Context, *types.SignalWithStartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *types.SignalWorkflowExecutionRequest, ...yarpc.CallOption) error
	StartWorkflowExecution(context.Context, *types.StartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
	TerminateWorkflowExecution(context.Context, *types.TerminateWorkflowExecutionRequest, ...yarpc.CallOption) error
	UpdateDomain(context.Context, *types.UpdateDomainRequest, ...yarpc.CallOption) (*types.UpdateDomainResponse, error)
}

Client is the interface exposed by frontend service client

func NewClient 

func NewClient(
	timeout time.Duration,
	longPollTimeout time.Duration,
	client Client,
) Client

NewClient creates a new frontend service TChannel client

func NewErrorInjectionClient added in v0.18.0 

func NewErrorInjectionClient(
	client Client,
	errorRate float64,
	logger log.Logger,
) Client

NewErrorInjectionClient creates a new instance of Client that injects fake error

func NewGRPCClient added in v0.21.0 

func NewGRPCClient(
	domain apiv1.DomainAPIYARPCClient,
	workflow apiv1.WorkflowAPIYARPCClient,
	worker apiv1.WorkerAPIYARPCClient,
	visibility apiv1.VisibilityAPIYARPCClient,
) Client

func NewMetricClient added in v0.5.0 

func NewMetricClient(
	client Client,
	metricsClient metrics.Client,
) Client

NewMetricClient creates a new instance of Client that emits metrics

func NewRetryableClient added in v0.5.0 

func NewRetryableClient(
	client Client,
	policy backoff.RetryPolicy,
	isRetryable backoff.IsRetryable,
) Client

NewRetryableClient creates a new instance of retryableClient with retry policy

func NewThriftClient added in v0.17.0 

func NewThriftClient(c workflowserviceclient.Interface) Client

NewThriftClient creates a new instance of Client with thrift protocol

type MockClient added in v0.17.0 

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient is a mock of Client interface.

func NewMockClient added in v0.17.0 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) CountWorkflowExecutions added in v0.17.0 

func (m *MockClient) CountWorkflowExecutions(arg0 context.Context, arg1 *types.CountWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockClient) DeprecateDomain added in v0.17.0 

func (m *MockClient) DeprecateDomain(arg0 context.Context, arg1 *types.DeprecateDomainRequest, arg2 ...yarpc.CallOption) error

DeprecateDomain mocks base method.

func (*MockClient) DescribeDomain added in v0.17.0 

func (m *MockClient) DescribeDomain(arg0 context.Context, arg1 *types.DescribeDomainRequest, arg2 ...yarpc.CallOption) (*types.DescribeDomainResponse, error)

DescribeDomain mocks base method.

func (*MockClient) DescribeTaskList added in v0.17.0 

func (m *MockClient) DescribeTaskList(arg0 context.Context, arg1 *types.DescribeTaskListRequest, arg2 ...yarpc.CallOption) (*types.DescribeTaskListResponse, error)

DescribeTaskList mocks base method.

func (*MockClient) DescribeWorkflowExecution added in v0.17.0 

func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.DescribeWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockClient) EXPECT added in v0.17.0 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClient) GetClusterInfo added in v0.17.0 

func (m *MockClient) GetClusterInfo(arg0 context.Context, arg1 ...yarpc.CallOption) (*types.ClusterInfo, error)

GetClusterInfo mocks base method.

func (*MockClient) GetSearchAttributes added in v0.17.0 

func (m *MockClient) GetSearchAttributes(arg0 context.Context, arg1 ...yarpc.CallOption) (*types.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockClient) GetTaskListsByDomain added in v0.23.1 

func (m *MockClient) GetTaskListsByDomain(arg0 context.Context, arg1 *types.GetTaskListsByDomainRequest, arg2 ...yarpc.CallOption) (*types.GetTaskListsByDomainResponse, error)

GetTaskListsByDomain mocks base method.

func (*MockClient) GetWorkflowExecutionHistory added in v0.17.0 

func (m *MockClient) GetWorkflowExecutionHistory(arg0 context.Context, arg1 *types.GetWorkflowExecutionHistoryRequest, arg2 ...yarpc.CallOption) (*types.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory mocks base method.

func (*MockClient) ListArchivedWorkflowExecutions added in v0.17.0 

func (m *MockClient) ListArchivedWorkflowExecutions(arg0 context.Context, arg1 *types.ListArchivedWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflowExecutions mocks base method.

func (*MockClient) ListClosedWorkflowExecutions added in v0.17.0 

func (m *MockClient) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *types.ListClosedWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockClient) ListDomains added in v0.17.0 

func (m *MockClient) ListDomains(arg0 context.Context, arg1 *types.ListDomainsRequest, arg2 ...yarpc.CallOption) (*types.ListDomainsResponse, error)

ListDomains mocks base method.

func (*MockClient) ListOpenWorkflowExecutions added in v0.17.0 

func (m *MockClient) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *types.ListOpenWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method.

func (*MockClient) ListTaskListPartitions added in v0.17.0 

func (m *MockClient) ListTaskListPartitions(arg0 context.Context, arg1 *types.ListTaskListPartitionsRequest, arg2 ...yarpc.CallOption) (*types.ListTaskListPartitionsResponse, error)

ListTaskListPartitions mocks base method.

func (*MockClient) ListWorkflowExecutions added in v0.17.0 

func (m *MockClient) ListWorkflowExecutions(arg0 context.Context, arg1 *types.ListWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method.

func (*MockClient) PollForActivityTask added in v0.17.0 

func (m *MockClient) PollForActivityTask(arg0 context.Context, arg1 *types.PollForActivityTaskRequest, arg2 ...yarpc.CallOption) (*types.PollForActivityTaskResponse, error)

PollForActivityTask mocks base method.

func (*MockClient) PollForDecisionTask added in v0.17.0 

func (m *MockClient) PollForDecisionTask(arg0 context.Context, arg1 *types.PollForDecisionTaskRequest, arg2 ...yarpc.CallOption) (*types.PollForDecisionTaskResponse, error)

PollForDecisionTask mocks base method.

func (*MockClient) QueryWorkflow added in v0.17.0 

func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.QueryWorkflowRequest, arg2 ...yarpc.CallOption) (*types.QueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockClient) RecordActivityTaskHeartbeat added in v0.17.0 

func (m *MockClient) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.RecordActivityTaskHeartbeatRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method.

func (*MockClient) RecordActivityTaskHeartbeatByID added in v0.17.0 

func (m *MockClient) RecordActivityTaskHeartbeatByID(arg0 context.Context, arg1 *types.RecordActivityTaskHeartbeatByIDRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeatByID mocks base method.

func (*MockClient) RefreshWorkflowTasks added in v0.24.0 

func (m *MockClient) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.RefreshWorkflowTasksRequest, arg2 ...yarpc.CallOption) error

RefreshWorkflowTasks mocks base method.

func (*MockClient) RegisterDomain added in v0.17.0 

func (m *MockClient) RegisterDomain(arg0 context.Context, arg1 *types.RegisterDomainRequest, arg2 ...yarpc.CallOption) error

RegisterDomain mocks base method.

func (*MockClient) RequestCancelWorkflowExecution added in v0.17.0 

func (m *MockClient) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.RequestCancelWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

RequestCancelWorkflowExecution mocks base method.

func (*MockClient) ResetStickyTaskList added in v0.17.0 

func (m *MockClient) ResetStickyTaskList(arg0 context.Context, arg1 *types.ResetStickyTaskListRequest, arg2 ...yarpc.CallOption) (*types.ResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method.

func (*MockClient) ResetWorkflowExecution added in v0.17.0 

func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *types.ResetWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockClient) RespondActivityTaskCanceled added in v0.17.0 

func (m *MockClient) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.RespondActivityTaskCanceledRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCanceled mocks base method.

func (*MockClient) RespondActivityTaskCanceledByID added in v0.17.0 

func (m *MockClient) RespondActivityTaskCanceledByID(arg0 context.Context, arg1 *types.RespondActivityTaskCanceledByIDRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCanceledByID mocks base method.

func (*MockClient) RespondActivityTaskCompleted added in v0.17.0 

func (m *MockClient) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.RespondActivityTaskCompletedRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCompleted mocks base method.

func (*MockClient) RespondActivityTaskCompletedByID added in v0.17.0 

func (m *MockClient) RespondActivityTaskCompletedByID(arg0 context.Context, arg1 *types.RespondActivityTaskCompletedByIDRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskCompletedByID mocks base method.

func (*MockClient) RespondActivityTaskFailed added in v0.17.0 

func (m *MockClient) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.RespondActivityTaskFailedRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskFailed mocks base method.

func (*MockClient) RespondActivityTaskFailedByID added in v0.17.0 

func (m *MockClient) RespondActivityTaskFailedByID(arg0 context.Context, arg1 *types.RespondActivityTaskFailedByIDRequest, arg2 ...yarpc.CallOption) error

RespondActivityTaskFailedByID mocks base method.

func (*MockClient) RespondDecisionTaskCompleted added in v0.17.0 

func (m *MockClient) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.RespondDecisionTaskCompletedRequest, arg2 ...yarpc.CallOption) (*types.RespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method.

func (*MockClient) RespondDecisionTaskFailed added in v0.17.0 

func (m *MockClient) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.RespondDecisionTaskFailedRequest, arg2 ...yarpc.CallOption) error

RespondDecisionTaskFailed mocks base method.

func (*MockClient) RespondQueryTaskCompleted added in v0.17.0 

func (m *MockClient) RespondQueryTaskCompleted(arg0 context.Context, arg1 *types.RespondQueryTaskCompletedRequest, arg2 ...yarpc.CallOption) error

RespondQueryTaskCompleted mocks base method.

func (*MockClient) RestartWorkflowExecution added in v0.25.0 

func (m *MockClient) RestartWorkflowExecution(arg0 context.Context, arg1 *types.RestartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.RestartWorkflowExecutionResponse, error)

RestartWorkflowExecution mocks base method.

func (*MockClient) ScanWorkflowExecutions added in v0.17.0 

func (m *MockClient) ScanWorkflowExecutions(arg0 context.Context, arg1 *types.ListWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*types.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockClient) SignalWithStartWorkflowExecution added in v0.17.0 

func (m *MockClient) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *types.SignalWithStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockClient) SignalWorkflowExecution added in v0.17.0 

func (m *MockClient) SignalWorkflowExecution(arg0 context.Context, arg1 *types.SignalWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

SignalWorkflowExecution mocks base method.

func (*MockClient) StartWorkflowExecution added in v0.17.0 

func (m *MockClient) StartWorkflowExecution(arg0 context.Context, arg1 *types.StartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method.

func (*MockClient) TerminateWorkflowExecution added in v0.17.0 

func (m *MockClient) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.TerminateWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error

TerminateWorkflowExecution mocks base method.

func (*MockClient) UpdateDomain added in v0.17.0 

func (m *MockClient) UpdateDomain(arg0 context.Context, arg1 *types.UpdateDomainRequest, arg2 ...yarpc.CallOption) (*types.UpdateDomainResponse, error)

UpdateDomain mocks base method.

type MockClientMockRecorder added in v0.17.0 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) CountWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockClientMockRecorder) DeprecateDomain added in v0.17.0 

func (mr *MockClientMockRecorder) DeprecateDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeprecateDomain indicates an expected call of DeprecateDomain.

func (*MockClientMockRecorder) DescribeDomain added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeDomain indicates an expected call of DescribeDomain.

func (*MockClientMockRecorder) DescribeTaskList added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeTaskList indicates an expected call of DescribeTaskList.

func (*MockClientMockRecorder) DescribeWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockClientMockRecorder) GetClusterInfo added in v0.17.0 

func (mr *MockClientMockRecorder) GetClusterInfo(arg0 interface{}, arg1 ...interface{}) *gomock.Call

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockClientMockRecorder) GetSearchAttributes added in v0.17.0 

func (mr *MockClientMockRecorder) GetSearchAttributes(arg0 interface{}, arg1 ...interface{}) *gomock.Call

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockClientMockRecorder) GetTaskListsByDomain added in v0.23.1 

func (mr *MockClientMockRecorder) GetTaskListsByDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetTaskListsByDomain indicates an expected call of GetTaskListsByDomain.

func (*MockClientMockRecorder) GetWorkflowExecutionHistory added in v0.17.0 

func (mr *MockClientMockRecorder) GetWorkflowExecutionHistory(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.

func (*MockClientMockRecorder) ListArchivedWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) ListArchivedWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.

func (*MockClientMockRecorder) ListClosedWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockClientMockRecorder) ListDomains added in v0.17.0 

func (mr *MockClientMockRecorder) ListDomains(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListDomains indicates an expected call of ListDomains.

func (*MockClientMockRecorder) ListOpenWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockClientMockRecorder) ListTaskListPartitions added in v0.17.0 

func (mr *MockClientMockRecorder) ListTaskListPartitions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListTaskListPartitions indicates an expected call of ListTaskListPartitions.

func (*MockClientMockRecorder) ListWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockClientMockRecorder) PollForActivityTask added in v0.17.0 

func (mr *MockClientMockRecorder) PollForActivityTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PollForActivityTask indicates an expected call of PollForActivityTask.

func (*MockClientMockRecorder) PollForDecisionTask added in v0.17.0 

func (mr *MockClientMockRecorder) PollForDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PollForDecisionTask indicates an expected call of PollForDecisionTask.

func (*MockClientMockRecorder) QueryWorkflow added in v0.17.0 

func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockClientMockRecorder) RecordActivityTaskHeartbeat added in v0.17.0 

func (mr *MockClientMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockClientMockRecorder) RecordActivityTaskHeartbeatByID added in v0.17.0 

func (mr *MockClientMockRecorder) RecordActivityTaskHeartbeatByID(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID.

func (*MockClientMockRecorder) RefreshWorkflowTasks added in v0.24.0 

func (mr *MockClientMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockClientMockRecorder) RegisterDomain added in v0.17.0 

func (mr *MockClientMockRecorder) RegisterDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RegisterDomain indicates an expected call of RegisterDomain.

func (*MockClientMockRecorder) RequestCancelWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockClientMockRecorder) ResetStickyTaskList added in v0.17.0 

func (mr *MockClientMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockClientMockRecorder) ResetWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockClientMockRecorder) RespondActivityTaskCanceled added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockClientMockRecorder) RespondActivityTaskCanceledByID added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCanceledByID(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID.

func (*MockClientMockRecorder) RespondActivityTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockClientMockRecorder) RespondActivityTaskCompletedByID added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskCompletedByID(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID.

func (*MockClientMockRecorder) RespondActivityTaskFailed added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockClientMockRecorder) RespondActivityTaskFailedByID added in v0.17.0 

func (mr *MockClientMockRecorder) RespondActivityTaskFailedByID(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID.

func (*MockClientMockRecorder) RespondDecisionTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockClientMockRecorder) RespondDecisionTaskFailed added in v0.17.0 

func (mr *MockClientMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockClientMockRecorder) RespondQueryTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.

func (*MockClientMockRecorder) RestartWorkflowExecution added in v0.25.0 

func (mr *MockClientMockRecorder) RestartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RestartWorkflowExecution indicates an expected call of RestartWorkflowExecution.

func (*MockClientMockRecorder) ScanWorkflowExecutions added in v0.17.0 

func (mr *MockClientMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockClientMockRecorder) SignalWithStartWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockClientMockRecorder) SignalWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockClientMockRecorder) StartWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockClientMockRecorder) TerminateWorkflowExecution added in v0.17.0 

func (mr *MockClientMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

func (*MockClientMockRecorder) UpdateDomain added in v0.17.0 

func (mr *MockClientMockRecorder) UpdateDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain.

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.