Documentation ¶
Index ¶
- type TChanWorkflowService
- func (_m *TChanWorkflowService) DeprecateDomain(ctx thrift.Context, deprecateRequest *shared.DeprecateDomainRequest) error
- func (_m *TChanWorkflowService) DescribeDomain(ctx thrift.Context, describeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (_m *TChanWorkflowService) GetWorkflowExecutionHistory(ctx thrift.Context, getRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
- func (_m *TChanWorkflowService) ListClosedWorkflowExecutions(ctx thrift.Context, listRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
- func (_m *TChanWorkflowService) ListOpenWorkflowExecutions(ctx thrift.Context, listRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
- func (_m *TChanWorkflowService) PollForActivityTask(ctx thrift.Context, pollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
- func (_m *TChanWorkflowService) PollForDecisionTask(ctx thrift.Context, pollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
- func (_m *TChanWorkflowService) QueryWorkflow(ctx thrift.Context, queryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
- func (_m *TChanWorkflowService) RecordActivityTaskHeartbeat(ctx thrift.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)
- func (_m *TChanWorkflowService) RegisterDomain(ctx thrift.Context, registerRequest *shared.RegisterDomainRequest) error
- func (_m *TChanWorkflowService) RequestCancelWorkflowExecution(ctx thrift.Context, ...) error
- func (_m *TChanWorkflowService) RespondActivityTaskCanceled(ctx thrift.Context, canceledRequest *shared.RespondActivityTaskCanceledRequest) error
- func (_m *TChanWorkflowService) RespondActivityTaskCompleted(ctx thrift.Context, ...) error
- func (_m *TChanWorkflowService) RespondActivityTaskFailed(ctx thrift.Context, failRequest *shared.RespondActivityTaskFailedRequest) error
- func (_m *TChanWorkflowService) RespondDecisionTaskCompleted(ctx thrift.Context, ...) error
- func (_m *TChanWorkflowService) RespondQueryTaskCompleted(ctx thrift.Context, completeRequest *shared.RespondQueryTaskCompletedRequest) error
- func (_m *TChanWorkflowService) SignalWorkflowExecution(ctx thrift.Context, signalRequest *shared.SignalWorkflowExecutionRequest) error
- func (_m *TChanWorkflowService) StartWorkflowExecution(ctx thrift.Context, startRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
- func (_m *TChanWorkflowService) TerminateWorkflowExecution(ctx thrift.Context, terminateRequest *shared.TerminateWorkflowExecutionRequest) error
- func (_m *TChanWorkflowService) UpdateDomain(ctx thrift.Context, updateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TChanWorkflowService ¶
TChanWorkflowService is an autogenerated mock type for the TChanWorkflowService type
func (*TChanWorkflowService) DeprecateDomain ¶
func (_m *TChanWorkflowService) DeprecateDomain(ctx thrift.Context, deprecateRequest *shared.DeprecateDomainRequest) error
DeprecateDomain provides a mock function with given fields: ctx, deprecateRequest
func (*TChanWorkflowService) DescribeDomain ¶
func (_m *TChanWorkflowService) DescribeDomain(ctx thrift.Context, describeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
DescribeDomain provides a mock function with given fields: ctx, describeRequest
func (*TChanWorkflowService) GetWorkflowExecutionHistory ¶
func (_m *TChanWorkflowService) GetWorkflowExecutionHistory(ctx thrift.Context, getRequest *shared.GetWorkflowExecutionHistoryRequest) (*shared.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory provides a mock function with given fields: ctx, getRequest
func (*TChanWorkflowService) ListClosedWorkflowExecutions ¶
func (_m *TChanWorkflowService) ListClosedWorkflowExecutions(ctx thrift.Context, listRequest *shared.ListClosedWorkflowExecutionsRequest) (*shared.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions provides a mock function with given fields: ctx, listRequest
func (*TChanWorkflowService) ListOpenWorkflowExecutions ¶
func (_m *TChanWorkflowService) ListOpenWorkflowExecutions(ctx thrift.Context, listRequest *shared.ListOpenWorkflowExecutionsRequest) (*shared.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions provides a mock function with given fields: ctx, listRequest
func (*TChanWorkflowService) PollForActivityTask ¶
func (_m *TChanWorkflowService) PollForActivityTask(ctx thrift.Context, pollRequest *shared.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)
PollForActivityTask provides a mock function with given fields: ctx, pollRequest
func (*TChanWorkflowService) PollForDecisionTask ¶
func (_m *TChanWorkflowService) PollForDecisionTask(ctx thrift.Context, pollRequest *shared.PollForDecisionTaskRequest) (*shared.PollForDecisionTaskResponse, error)
PollForDecisionTask provides a mock function with given fields: ctx, pollRequest
func (*TChanWorkflowService) QueryWorkflow ¶ added in v0.3.2
func (_m *TChanWorkflowService) QueryWorkflow(ctx thrift.Context, queryRequest *shared.QueryWorkflowRequest) (*shared.QueryWorkflowResponse, error)
UpdateDomain provides a mock function with given fields: ctx, updateRequest
func (*TChanWorkflowService) RecordActivityTaskHeartbeat ¶
func (_m *TChanWorkflowService) RecordActivityTaskHeartbeat(ctx thrift.Context, heartbeatRequest *shared.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat provides a mock function with given fields: ctx, heartbeatRequest
func (*TChanWorkflowService) RegisterDomain ¶
func (_m *TChanWorkflowService) RegisterDomain(ctx thrift.Context, registerRequest *shared.RegisterDomainRequest) error
RegisterDomain provides a mock function with given fields: ctx, registerRequest
func (*TChanWorkflowService) RequestCancelWorkflowExecution ¶
func (_m *TChanWorkflowService) RequestCancelWorkflowExecution(ctx thrift.Context, cancelRequest *shared.RequestCancelWorkflowExecutionRequest) error
RequestCancelWorkflowExecution provides a mock function with given fields: ctx, cancelRequest
func (*TChanWorkflowService) RespondActivityTaskCanceled ¶
func (_m *TChanWorkflowService) RespondActivityTaskCanceled(ctx thrift.Context, canceledRequest *shared.RespondActivityTaskCanceledRequest) error
RespondActivityTaskCanceled provides a mock function with given fields: ctx, canceledRequest
func (*TChanWorkflowService) RespondActivityTaskCompleted ¶
func (_m *TChanWorkflowService) RespondActivityTaskCompleted(ctx thrift.Context, completeRequest *shared.RespondActivityTaskCompletedRequest) error
RespondActivityTaskCompleted provides a mock function with given fields: ctx, completeRequest
func (*TChanWorkflowService) RespondActivityTaskFailed ¶
func (_m *TChanWorkflowService) RespondActivityTaskFailed(ctx thrift.Context, failRequest *shared.RespondActivityTaskFailedRequest) error
RespondActivityTaskFailed provides a mock function with given fields: ctx, failRequest
func (*TChanWorkflowService) RespondDecisionTaskCompleted ¶
func (_m *TChanWorkflowService) RespondDecisionTaskCompleted(ctx thrift.Context, completeRequest *shared.RespondDecisionTaskCompletedRequest) error
RespondDecisionTaskCompleted provides a mock function with given fields: ctx, completeRequest
func (*TChanWorkflowService) RespondQueryTaskCompleted ¶ added in v0.3.2
func (_m *TChanWorkflowService) RespondQueryTaskCompleted(ctx thrift.Context, completeRequest *shared.RespondQueryTaskCompletedRequest) error
RespondQueryTaskCompleted provides a mock function with given fields: ctx, completeRequest
func (*TChanWorkflowService) SignalWorkflowExecution ¶
func (_m *TChanWorkflowService) SignalWorkflowExecution(ctx thrift.Context, signalRequest *shared.SignalWorkflowExecutionRequest) error
SignalWorkflowExecution provides a mock function with given fields: ctx, signalRequest
func (*TChanWorkflowService) StartWorkflowExecution ¶
func (_m *TChanWorkflowService) StartWorkflowExecution(ctx thrift.Context, startRequest *shared.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)
StartWorkflowExecution provides a mock function with given fields: ctx, startRequest
func (*TChanWorkflowService) TerminateWorkflowExecution ¶
func (_m *TChanWorkflowService) TerminateWorkflowExecution(ctx thrift.Context, terminateRequest *shared.TerminateWorkflowExecutionRequest) error
TerminateWorkflowExecution provides a mock function with given fields: ctx, terminateRequest
func (*TChanWorkflowService) UpdateDomain ¶
func (_m *TChanWorkflowService) UpdateDomain(ctx thrift.Context, updateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
UpdateDomain provides a mock function with given fields: ctx, updateRequest