mocks

package
v0.3.3 Latest Latest
Warning

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

Go to latest
Published: Dec 5, 2017 License: MIT Imports: 8 Imported by: 0

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

func (_m *ExecutionManager) Close()

Close provides a mock function with given fields:

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

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

GetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetTimerIndexTasks

GetTimerIndexTasks provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTasks

GetTransferTasks provides a mock function with given fields: request

func (*ExecutionManager) GetWorkflowExecution

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) Close added in v0.3.2

func (_m *ExecutionManagerFactory) Close()

Close is mock implementation for Close of ExecutionManagerFactory

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) DescribeWorkflowExecution added in v0.3.3

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

func (*HistoryClient) GetWorkflowExecutionNextEventID

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

func (*HistoryClient) RecordActivityTaskHeartbeat

func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx context.Context, heartbeatRequest *history.RecordActivityTaskHeartbeatRequest, opts ...yarpc.CallOption) (*shared.RecordActivityTaskHeartbeatResponse, error)

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

func (*HistoryClient) RecordActivityTaskStarted

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

func (*HistoryClient) RecordChildExecutionCompleted

func (_m *HistoryClient) RecordChildExecutionCompleted(ctx context.Context, request *history.RecordChildExecutionCompletedRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RecordDecisionTaskStarted

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

func (*HistoryClient) RequestCancelWorkflowExecution

func (_m *HistoryClient) RequestCancelWorkflowExecution(ctx context.Context, request *history.RequestCancelWorkflowExecutionRequest, opts ...yarpc.CallOption) error

RequestCancelWorkflowExecution is mock implementation for RequestCancelWorkflowExecution of HistoryEngine

func (*HistoryClient) RespondActivityTaskCanceled

func (_m *HistoryClient) RespondActivityTaskCanceled(ctx context.Context, canceledRequest *history.RespondActivityTaskCanceledRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RespondActivityTaskCompleted

func (_m *HistoryClient) RespondActivityTaskCompleted(ctx context.Context, completeRequest *history.RespondActivityTaskCompletedRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RespondActivityTaskFailed

func (_m *HistoryClient) RespondActivityTaskFailed(ctx context.Context, failRequest *history.RespondActivityTaskFailedRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RespondDecisionTaskCompleted

func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx context.Context, completeRequest *history.RespondDecisionTaskCompletedRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) RespondDecisionTaskFailed added in v0.3.3

func (_m *HistoryClient) RespondDecisionTaskFailed(ctx context.Context, failedRequest *history.RespondDecisionTaskFailedRequest, opts ...yarpc.CallOption) error

RespondDecisionTaskFailed provides a mock function with given fields: ctx, failedRequest

func (*HistoryClient) ScheduleDecisionTask

func (_m *HistoryClient) ScheduleDecisionTask(ctx context.Context, request *history.ScheduleDecisionTaskRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) SignalWorkflowExecution

func (_m *HistoryClient) SignalWorkflowExecution(ctx context.Context, signalRequest *history.SignalWorkflowExecutionRequest, opts ...yarpc.CallOption) error

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

func (*HistoryClient) StartWorkflowExecution

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

func (*HistoryClient) TerminateWorkflowExecution

func (_m *HistoryClient) TerminateWorkflowExecution(ctx context.Context, terminateRequest *history.TerminateWorkflowExecutionRequest, opts ...yarpc.CallOption) 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) Close

func (_m *HistoryManager) Close()

Close provides a mock function with given fields:

func (*HistoryManager) DeleteWorkflowExecutionHistory

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

DeleteWorkflowExecutionHistory provides a mock function with given fields: request

func (*HistoryManager) GetWorkflowExecutionHistory

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 context.Context, addRequest *matching.AddActivityTaskRequest, opts ...yarpc.CallOption) error

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

func (*MatchingClient) AddDecisionTask

func (_m *MatchingClient) AddDecisionTask(ctx context.Context, addRequest *matching.AddDecisionTaskRequest, opts ...yarpc.CallOption) error

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

func (*MatchingClient) CancelOutstandingPoll added in v0.3.2

func (_m *MatchingClient) CancelOutstandingPoll(ctx context.Context,
	request *matching.CancelOutstandingPollRequest, opts ...yarpc.CallOption) error

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

func (*MatchingClient) PollForActivityTask

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

func (*MatchingClient) PollForDecisionTask

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

func (*MatchingClient) QueryWorkflow added in v0.3.2

func (_m *MatchingClient) QueryWorkflow(ctx context.Context,
	queryRequest *matching.QueryWorkflowRequest, opts ...yarpc.CallOption) (*shared.QueryWorkflowResponse, error)

QueryWorkflow provides a mock function with given fields: ctx, queryRequest

func (*MatchingClient) RespondQueryTaskCompleted added in v0.3.2

func (_m *MatchingClient) RespondQueryTaskCompleted(ctx context.Context,
	request *matching.RespondQueryTaskCompletedRequest, opts ...yarpc.CallOption) error

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

type MetadataManager

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the MetadataManager type

func (*MetadataManager) Close

func (_m *MetadataManager) Close()

Close provides a mock function with given fields:

func (*MetadataManager) CreateDomain

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

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

func (_m *ShardManager) Close()

Close provides a mock function with given fields:

func (*ShardManager) CreateShard

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

CreateShard provides a mock function with given fields: request

func (*ShardManager) GetShard

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

func (_m *TaskManager) Close()

Close provides a mock function with given fields:

func (*TaskManager) CompleteTask

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

CompleteTask provides a mock function with given fields: request

func (*TaskManager) CreateTasks

CreateTasks provides a mock function with given fields: request

func (*TaskManager) GetTasks

GetTasks provides a mock function with given fields: request

func (*TaskManager) LeaseTaskList

LeaseTaskList provides a mock function with given fields: request

func (*TaskManager) UpdateTaskList

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

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) GetClosedWorkflowExecution

GetClosedWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutions

ListClosedWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType

ListClosedWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutions

ListOpenWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType

ListOpenWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL