mocks

package
v0.1.0-beta Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2017 License: MIT Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExecutionManager 

type ExecutionManager struct {
	mock.Mock
}

ExecutionManager is an autogenerated mock type for the ExecutionManager type

func (*ExecutionManager) CompleteTimerTask 

func (_m *ExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTransferTask 

func (_m *ExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) CreateWorkflowExecution 

func (_m *ExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteWorkflowExecution 

func (_m *ExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetCurrentExecution 

func (_m *ExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

GetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetTimerIndexTasks 

func (_m *ExecutionManager) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

GetTimerIndexTasks provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTasks 

func (_m *ExecutionManager) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)

GetTransferTasks provides a mock function with given fields: request

func (*ExecutionManager) GetWorkflowExecution 

func (_m *ExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

GetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) UpdateWorkflowExecution 

func (_m *ExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) error

UpdateWorkflowExecution provides a mock function with given fields: request

type ExecutionManagerFactory 

type ExecutionManagerFactory struct {
	mock.Mock
}

ExecutionManagerFactory is an autogenerated mock type for the ExecutionManagerFactory type

func (*ExecutionManagerFactory) CreateExecutionManager 

func (_m *ExecutionManagerFactory) CreateExecutionManager(shardID int) (persistence.ExecutionManager, error)

CreateExecutionManager provides a mock function with given fields: shardID

type HistoryClient 

type HistoryClient struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*HistoryClient) GetWorkflowExecutionNextEventID 

func (_m *HistoryClient) GetWorkflowExecutionNextEventID(ctx thrift.Context, getRequest *history.GetWorkflowExecutionNextEventIDRequest) (*history.GetWorkflowExecutionNextEventIDResponse, error)

GetWorkflowExecutionNextEventID provides a mock function with given fields: ctx, getRequest

func (*HistoryClient) RecordActivityTaskHeartbeat 

func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx thrift.Context, heartbeatRequest *history.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat provides a mock function with given fields: ctx, heartbeatRequest

func (*HistoryClient) RecordActivityTaskStarted 

func (_m *HistoryClient) RecordActivityTaskStarted(ctx thrift.Context, addRequest *history.RecordActivityTaskStartedRequest) (*history.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted provides a mock function with given fields: ctx, addRequest

func (*HistoryClient) RecordChildExecutionCompleted 

func (_m *HistoryClient) RecordChildExecutionCompleted(ctx thrift.Context, request *history.RecordChildExecutionCompletedRequest) error

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

func (*HistoryClient) RecordDecisionTaskStarted 

func (_m *HistoryClient) RecordDecisionTaskStarted(ctx thrift.Context, addRequest *history.RecordDecisionTaskStartedRequest) (*history.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted provides a mock function with given fields: ctx, addRequest

func (*HistoryClient) RequestCancelWorkflowExecution 

func (_m *HistoryClient) RequestCancelWorkflowExecution(ctx thrift.Context, request *history.RequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution is mock implementation for RequestCancelWorkflowExecution of HistoryEngine

func (*HistoryClient) RespondActivityTaskCanceled 

func (_m *HistoryClient) RespondActivityTaskCanceled(ctx thrift.Context, canceledRequest *history.RespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled provides a mock function with given fields: ctx, canceledRequest

func (*HistoryClient) RespondActivityTaskCompleted 

func (_m *HistoryClient) RespondActivityTaskCompleted(ctx thrift.Context, completeRequest *history.RespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted provides a mock function with given fields: ctx, completeRequest

func (*HistoryClient) RespondActivityTaskFailed 

func (_m *HistoryClient) RespondActivityTaskFailed(ctx thrift.Context, failRequest *history.RespondActivityTaskFailedRequest) error

RespondActivityTaskFailed provides a mock function with given fields: ctx, failRequest

func (*HistoryClient) RespondDecisionTaskCompleted 

func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx thrift.Context, completeRequest *history.RespondDecisionTaskCompletedRequest) error

RespondDecisionTaskCompleted provides a mock function with given fields: ctx, completeRequest

func (*HistoryClient) ScheduleDecisionTask 

func (_m *HistoryClient) ScheduleDecisionTask(ctx thrift.Context, request *history.ScheduleDecisionTaskRequest) error

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

func (*HistoryClient) SignalWorkflowExecution 

func (_m *HistoryClient) SignalWorkflowExecution(ctx thrift.Context, signalRequest *history.SignalWorkflowExecutionRequest) error

SignalWorkflowExecution provides a mock function with given fields: ctx, signalRequest

func (*HistoryClient) StartWorkflowExecution 

func (_m *HistoryClient) StartWorkflowExecution(ctx thrift.Context, startRequest *history.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

StartWorkflowExecution provides a mock function with given fields: ctx, startRequest

func (*HistoryClient) TerminateWorkflowExecution 

func (_m *HistoryClient) TerminateWorkflowExecution(ctx thrift.Context, terminateRequest *history.TerminateWorkflowExecutionRequest) error

TerminateWorkflowExecution provides a mock function with given fields: ctx, terminateRequest

type HistoryManager 

type HistoryManager struct {
	mock.Mock
}

ExecutionManager is an autogenerated mock type for the ExecutionManager type

func (*HistoryManager) AppendHistoryEvents 

func (_m *HistoryManager) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) error

AppendHistoryEvents provides a mock function with given fields: request

func (*HistoryManager) DeleteWorkflowExecutionHistory 

func (_m *HistoryManager) DeleteWorkflowExecutionHistory(request *persistence.DeleteWorkflowExecutionHistoryRequest) error

DeleteWorkflowExecutionHistory provides a mock function with given fields: request

func (*HistoryManager) GetWorkflowExecutionHistory 

func (_m *HistoryManager) GetWorkflowExecutionHistory(
	request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryResponse, error)

GetWorkflowExecutionHistory provides a mock function with given fields: request

type MatchingClient 

type MatchingClient struct {
	mock.Mock
}

MatchingClient is an autogenerated mock type for the Client type

func (*MatchingClient) AddActivityTask 

func (_m *MatchingClient) AddActivityTask(ctx thrift.Context, addRequest *matching.AddActivityTaskRequest) error

AddActivityTask provides a mock function with given fields: ctx, addRequest

func (*MatchingClient) AddDecisionTask 

func (_m *MatchingClient) AddDecisionTask(ctx thrift.Context, addRequest *matching.AddDecisionTaskRequest) error

AddDecisionTask provides a mock function with given fields: ctx, addRequest

func (*MatchingClient) PollForActivityTask 

func (_m *MatchingClient) PollForActivityTask(ctx thrift.Context,
	pollRequest *matching.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)

PollForActivityTask provides a mock function with given fields: ctx, pollRequest

func (*MatchingClient) PollForDecisionTask 

func (_m *MatchingClient) PollForDecisionTask(ctx thrift.Context,
	pollRequest *matching.PollForDecisionTaskRequest) (*matching.PollForDecisionTaskResponse, error)

PollForDecisionTask provides a mock function with given fields: ctx, pollRequest

type MetadataManager 

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the MetadataManager type

func (*MetadataManager) CreateDomain 

func (_m *MetadataManager) CreateDomain(request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)

CreateDomain provides a mock function with given fields: request

func (*MetadataManager) DeleteDomain 

func (_m *MetadataManager) DeleteDomain(request *persistence.DeleteDomainRequest) error

DeleteDomain provides a mock function with given fields: request

func (*MetadataManager) DeleteDomainByName 

func (_m *MetadataManager) DeleteDomainByName(request *persistence.DeleteDomainByNameRequest) error

DeleteDomainByName provides a mock function with given fields: request

func (*MetadataManager) GetDomain 

func (_m *MetadataManager) GetDomain(request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)

GetDomain provides a mock function with given fields: request

func (*MetadataManager) UpdateDomain 

func (_m *MetadataManager) UpdateDomain(request *persistence.UpdateDomainRequest) error

UpdateDomain provides a mock function with given fields: request

type ServiceResolver 

type ServiceResolver struct {
	mock.Mock
}

func (*ServiceResolver) AddListener 

func (_m *ServiceResolver) AddListener(name string, notifyChannel chan<- *membership.ChangedEvent) error

func (*ServiceResolver) Lookup 

func (_m *ServiceResolver) Lookup(key string) (*membership.HostInfo, error)

func (*ServiceResolver) RemoveListener 

func (_m *ServiceResolver) RemoveListener(name string) error

type ShardManager 

type ShardManager struct {
	mock.Mock
}

ShardManager is an autogenerated mock type for the ShardManager type

func (*ShardManager) CreateShard 

func (_m *ShardManager) CreateShard(request *persistence.CreateShardRequest) error

CreateShard provides a mock function with given fields: request

func (*ShardManager) GetShard 

func (_m *ShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

GetShard provides a mock function with given fields: request

func (*ShardManager) UpdateShard 

func (_m *ShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

UpdateShard provides a mock function with given fields: request

type TaskManager 

type TaskManager struct {
	mock.Mock
}

TaskManager is an autogenerated mock type for the TaskManager type

func (*TaskManager) CompleteTask 

func (_m *TaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function with given fields: request

func (*TaskManager) CreateTasks 

func (_m *TaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

CreateTasks provides a mock function with given fields: request

func (*TaskManager) GetTasks 

func (_m *TaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

GetTasks provides a mock function with given fields: request

func (*TaskManager) LeaseTaskList 

func (_m *TaskManager) LeaseTaskList(request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)

LeaseTaskList provides a mock function with given fields: request

func (*TaskManager) UpdateTaskList 

func (_m *TaskManager) UpdateTaskList(request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)

UpdateTaskList provides a mock function with given fields: request

type VisibilityManager 

type VisibilityManager struct {
	mock.Mock
}

VisibilityManager is an autogenerated mock type for the VisibilityManager type

func (*VisibilityManager) ListClosedWorkflowExecutions 

func (_m *VisibilityManager) ListClosedWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByStatus(request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutions 

func (_m *VisibilityManager) ListOpenWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionClosed 

func (_m *VisibilityManager) RecordWorkflowExecutionClosed(request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionStarted 

func (_m *VisibilityManager) RecordWorkflowExecutionStarted(request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted provides a mock function with given fields: request

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.