api

package
v2.0.0-...-1574041 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package api is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertError 

func ConvertError(err error) error

func DurationFromProto 

func DurationFromProto(d *types.Duration) time.Duration

func DurationToProto 

func DurationToProto(d time.Duration) *types.Duration

func SecondsFromProto 

func SecondsFromProto(d *types.Duration) int32

func SecondsPtrToProto 

func SecondsPtrToProto(s *int32) *types.Duration

func SecondsToProto 

func SecondsToProto(s int32) *types.Duration

func TimeFromProto 

func TimeFromProto(t *types.Timestamp) time.Time

func TimeToProto 

func TimeToProto(t time.Time) *types.Timestamp

Types

type AccessDeniedError 

type AccessDeniedError struct {
	Message string
}

func (AccessDeniedError) Error 

func (err AccessDeniedError) Error() string

type BadRequestError 

type BadRequestError struct {
	Message string
}

func (BadRequestError) Error 

func (err BadRequestError) Error() string

type CancellationAlreadyRequestedError 

type CancellationAlreadyRequestedError struct {
	Message string
}

func (CancellationAlreadyRequestedError) Error 

func (err CancellationAlreadyRequestedError) Error() string

type ClientVersionNotSupportedError 

type ClientVersionNotSupportedError struct {
	FeatureVersion    string
	ClientImpl        string
	SupportedVersions string
}

func (ClientVersionNotSupportedError) Error 

func (err ClientVersionNotSupportedError) Error() string

type DomainAlreadyExistsError 

type DomainAlreadyExistsError struct {
	Message string
}

func (DomainAlreadyExistsError) Error 

func (err DomainAlreadyExistsError) Error() string

type DomainNotActiveError 

type DomainNotActiveError struct {
	Message        string
	Domain         string
	CurrentCluster string
	ActiveCluster  string
}

func (DomainNotActiveError) Error 

func (err DomainNotActiveError) Error() string

type EntityNotExistsError 

type EntityNotExistsError struct {
	Message        string
	CurrentCluster string
	ActiveCluster  string
}

func (EntityNotExistsError) Error 

func (err EntityNotExistsError) Error() string

type EventAlreadyStartedError 

type EventAlreadyStartedError struct {
	Message string
}

func (EventAlreadyStartedError) Error 

func (err EventAlreadyStartedError) Error() string

type Interface 

type Interface interface {
	apiv1.DomainAPIYARPCClient
	apiv1.VisibilityAPIYARPCClient
	apiv1.WorkflowAPIYARPCClient
	apiv1.WorkerAPIYARPCClient
}

type InternalServiceError 

type InternalServiceError struct {
	Message string
}

func (InternalServiceError) Error 

func (err InternalServiceError) Error() string

type LimitExceededError 

type LimitExceededError struct {
	Message string
}

func (LimitExceededError) Error 

func (err LimitExceededError) Error() string

type MockInterface 

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

MockInterface is a mock of Interface interface.

func NewMockInterface 

func NewMockInterface(ctrl *gomock.Controller) *MockInterface

NewMockInterface creates a new mock instance.

func (*MockInterface) CountWorkflowExecutions 

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

CountWorkflowExecutions mocks base method.

func (*MockInterface) DeprecateDomain 

func (m *MockInterface) DeprecateDomain(arg0 context.Context, arg1 *apiv1.DeprecateDomainRequest, arg2 ...yarpc.CallOption) (*apiv1.DeprecateDomainResponse, error)

DeprecateDomain mocks base method.

func (*MockInterface) DescribeDomain 

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

DescribeDomain mocks base method.

func (*MockInterface) DescribeTaskList 

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

DescribeTaskList mocks base method.

func (*MockInterface) DescribeWorkflowExecution 

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

DescribeWorkflowExecution mocks base method.

func (*MockInterface) EXPECT 

func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder

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

func (*MockInterface) GetClusterInfo 

func (m *MockInterface) GetClusterInfo(arg0 context.Context, arg1 *apiv1.GetClusterInfoRequest, arg2 ...yarpc.CallOption) (*apiv1.GetClusterInfoResponse, error)

GetClusterInfo mocks base method.

func (*MockInterface) GetSearchAttributes 

func (m *MockInterface) GetSearchAttributes(arg0 context.Context, arg1 *apiv1.GetSearchAttributesRequest, arg2 ...yarpc.CallOption) (*apiv1.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockInterface) GetWorkflowExecutionHistory 

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

GetWorkflowExecutionHistory mocks base method.

func (*MockInterface) ListArchivedWorkflowExecutions 

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

ListArchivedWorkflowExecutions mocks base method.

func (*MockInterface) ListClosedWorkflowExecutions 

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

ListClosedWorkflowExecutions mocks base method.

func (*MockInterface) ListDomains 

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

ListDomains mocks base method.

func (*MockInterface) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions mocks base method.

func (*MockInterface) ListTaskListPartitions 

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

ListTaskListPartitions mocks base method.

func (*MockInterface) ListWorkflowExecutions 

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

ListWorkflowExecutions mocks base method.

func (*MockInterface) PollForActivityTask 

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

PollForActivityTask mocks base method.

func (*MockInterface) PollForDecisionTask 

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

PollForDecisionTask mocks base method.

func (*MockInterface) QueryWorkflow 

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

QueryWorkflow mocks base method.

func (*MockInterface) RecordActivityTaskHeartbeat 

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

RecordActivityTaskHeartbeat mocks base method.

func (*MockInterface) RecordActivityTaskHeartbeatByID 

func (m *MockInterface) RecordActivityTaskHeartbeatByID(arg0 context.Context, arg1 *apiv1.RecordActivityTaskHeartbeatByIDRequest, arg2 ...yarpc.CallOption) (*apiv1.RecordActivityTaskHeartbeatByIDResponse, error)

RecordActivityTaskHeartbeatByID mocks base method.

func (*MockInterface) RegisterDomain 

func (m *MockInterface) RegisterDomain(arg0 context.Context, arg1 *apiv1.RegisterDomainRequest, arg2 ...yarpc.CallOption) (*apiv1.RegisterDomainResponse, error)

RegisterDomain mocks base method.

func (*MockInterface) RequestCancelWorkflowExecution 

func (m *MockInterface) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *apiv1.RequestCancelWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*apiv1.RequestCancelWorkflowExecutionResponse, error)

RequestCancelWorkflowExecution mocks base method.

func (*MockInterface) ResetStickyTaskList 

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

ResetStickyTaskList mocks base method.

func (*MockInterface) ResetWorkflowExecution 

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

ResetWorkflowExecution mocks base method.

func (*MockInterface) RespondActivityTaskCanceled 

func (m *MockInterface) RespondActivityTaskCanceled(arg0 context.Context, arg1 *apiv1.RespondActivityTaskCanceledRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskCanceledResponse, error)

RespondActivityTaskCanceled mocks base method.

func (*MockInterface) RespondActivityTaskCanceledByID 

func (m *MockInterface) RespondActivityTaskCanceledByID(arg0 context.Context, arg1 *apiv1.RespondActivityTaskCanceledByIDRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskCanceledByIDResponse, error)

RespondActivityTaskCanceledByID mocks base method.

func (*MockInterface) RespondActivityTaskCompleted 

func (m *MockInterface) RespondActivityTaskCompleted(arg0 context.Context, arg1 *apiv1.RespondActivityTaskCompletedRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskCompletedResponse, error)

RespondActivityTaskCompleted mocks base method.

func (*MockInterface) RespondActivityTaskCompletedByID 

func (m *MockInterface) RespondActivityTaskCompletedByID(arg0 context.Context, arg1 *apiv1.RespondActivityTaskCompletedByIDRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskCompletedByIDResponse, error)

RespondActivityTaskCompletedByID mocks base method.

func (*MockInterface) RespondActivityTaskFailed 

func (m *MockInterface) RespondActivityTaskFailed(arg0 context.Context, arg1 *apiv1.RespondActivityTaskFailedRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskFailedResponse, error)

RespondActivityTaskFailed mocks base method.

func (*MockInterface) RespondActivityTaskFailedByID 

func (m *MockInterface) RespondActivityTaskFailedByID(arg0 context.Context, arg1 *apiv1.RespondActivityTaskFailedByIDRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondActivityTaskFailedByIDResponse, error)

RespondActivityTaskFailedByID mocks base method.

func (*MockInterface) RespondDecisionTaskCompleted 

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

RespondDecisionTaskCompleted mocks base method.

func (*MockInterface) RespondDecisionTaskFailed 

func (m *MockInterface) RespondDecisionTaskFailed(arg0 context.Context, arg1 *apiv1.RespondDecisionTaskFailedRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondDecisionTaskFailedResponse, error)

RespondDecisionTaskFailed mocks base method.

func (*MockInterface) RespondQueryTaskCompleted 

func (m *MockInterface) RespondQueryTaskCompleted(arg0 context.Context, arg1 *apiv1.RespondQueryTaskCompletedRequest, arg2 ...yarpc.CallOption) (*apiv1.RespondQueryTaskCompletedResponse, error)

RespondQueryTaskCompleted mocks base method.

func (*MockInterface) ScanWorkflowExecutions 

func (m *MockInterface) ScanWorkflowExecutions(arg0 context.Context, arg1 *apiv1.ScanWorkflowExecutionsRequest, arg2 ...yarpc.CallOption) (*apiv1.ScanWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockInterface) SignalWithStartWorkflowExecution 

func (m *MockInterface) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *apiv1.SignalWithStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*apiv1.SignalWithStartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockInterface) SignalWorkflowExecution 

func (m *MockInterface) SignalWorkflowExecution(arg0 context.Context, arg1 *apiv1.SignalWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*apiv1.SignalWorkflowExecutionResponse, error)

SignalWorkflowExecution mocks base method.

func (*MockInterface) StartWorkflowExecution 

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

StartWorkflowExecution mocks base method.

func (*MockInterface) TerminateWorkflowExecution 

func (m *MockInterface) TerminateWorkflowExecution(arg0 context.Context, arg1 *apiv1.TerminateWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*apiv1.TerminateWorkflowExecutionResponse, error)

TerminateWorkflowExecution mocks base method.

func (*MockInterface) UpdateDomain 

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

UpdateDomain mocks base method.

type MockInterfaceMockRecorder 

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

MockInterfaceMockRecorder is the mock recorder for MockInterface.

func (*MockInterfaceMockRecorder) CountWorkflowExecutions 

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

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockInterfaceMockRecorder) DeprecateDomain 

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

DeprecateDomain indicates an expected call of DeprecateDomain.

func (*MockInterfaceMockRecorder) DescribeDomain 

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

DescribeDomain indicates an expected call of DescribeDomain.

func (*MockInterfaceMockRecorder) DescribeTaskList 

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

DescribeTaskList indicates an expected call of DescribeTaskList.

func (*MockInterfaceMockRecorder) DescribeWorkflowExecution 

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

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockInterfaceMockRecorder) GetClusterInfo 

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

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockInterfaceMockRecorder) GetSearchAttributes 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockInterfaceMockRecorder) GetWorkflowExecutionHistory 

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

GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.

func (*MockInterfaceMockRecorder) ListArchivedWorkflowExecutions 

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

ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.

func (*MockInterfaceMockRecorder) ListClosedWorkflowExecutions 

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

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockInterfaceMockRecorder) ListDomains 

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

ListDomains indicates an expected call of ListDomains.

func (*MockInterfaceMockRecorder) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockInterfaceMockRecorder) ListTaskListPartitions 

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

ListTaskListPartitions indicates an expected call of ListTaskListPartitions.

func (*MockInterfaceMockRecorder) ListWorkflowExecutions 

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

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockInterfaceMockRecorder) PollForActivityTask 

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

PollForActivityTask indicates an expected call of PollForActivityTask.

func (*MockInterfaceMockRecorder) PollForDecisionTask 

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

PollForDecisionTask indicates an expected call of PollForDecisionTask.

func (*MockInterfaceMockRecorder) QueryWorkflow 

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

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockInterfaceMockRecorder) RecordActivityTaskHeartbeat 

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

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockInterfaceMockRecorder) RecordActivityTaskHeartbeatByID 

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

RecordActivityTaskHeartbeatByID indicates an expected call of RecordActivityTaskHeartbeatByID.

func (*MockInterfaceMockRecorder) RegisterDomain 

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

RegisterDomain indicates an expected call of RegisterDomain.

func (*MockInterfaceMockRecorder) RequestCancelWorkflowExecution 

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

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockInterfaceMockRecorder) ResetStickyTaskList 

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

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockInterfaceMockRecorder) ResetWorkflowExecution 

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

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockInterfaceMockRecorder) RespondActivityTaskCanceled 

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

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockInterfaceMockRecorder) RespondActivityTaskCanceledByID 

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

RespondActivityTaskCanceledByID indicates an expected call of RespondActivityTaskCanceledByID.

func (*MockInterfaceMockRecorder) RespondActivityTaskCompleted 

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

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockInterfaceMockRecorder) RespondActivityTaskCompletedByID 

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

RespondActivityTaskCompletedByID indicates an expected call of RespondActivityTaskCompletedByID.

func (*MockInterfaceMockRecorder) RespondActivityTaskFailed 

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

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockInterfaceMockRecorder) RespondActivityTaskFailedByID 

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

RespondActivityTaskFailedByID indicates an expected call of RespondActivityTaskFailedByID.

func (*MockInterfaceMockRecorder) RespondDecisionTaskCompleted 

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

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockInterfaceMockRecorder) RespondDecisionTaskFailed 

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

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockInterfaceMockRecorder) RespondQueryTaskCompleted 

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

RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.

func (*MockInterfaceMockRecorder) ScanWorkflowExecutions 

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

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockInterfaceMockRecorder) SignalWithStartWorkflowExecution 

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

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockInterfaceMockRecorder) SignalWorkflowExecution 

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

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockInterfaceMockRecorder) StartWorkflowExecution 

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

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockInterfaceMockRecorder) TerminateWorkflowExecution 

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

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

func (*MockInterfaceMockRecorder) UpdateDomain 

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

UpdateDomain indicates an expected call of UpdateDomain.

type QueryFailedError 

type QueryFailedError struct {
	Message string
}

func (QueryFailedError) Error 

func (err QueryFailedError) Error() string

type ServiceBusyError 

type ServiceBusyError struct {
	Message string
}

func (ServiceBusyError) Error 

func (err ServiceBusyError) Error() string

type WorkflowExecutionAlreadyCompletedError 

type WorkflowExecutionAlreadyCompletedError struct {
	Message string
}

func (WorkflowExecutionAlreadyCompletedError) Error 

func (err WorkflowExecutionAlreadyCompletedError) Error() string

type WorkflowExecutionAlreadyStartedError 

type WorkflowExecutionAlreadyStartedError struct {
	Message        string
	StartRequestID string
	RunID          string
}

func (WorkflowExecutionAlreadyStartedError) Error 

func (err WorkflowExecutionAlreadyStartedError) Error() string

Source Files

View all Source files

Directories

Path Synopsis

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.