mocks

package
v0.3.11 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockMessagingClient added in v0.3.11 

func NewMockMessagingClient(publisher messaging.Producer, consumer kafka.Consumer) messaging.Client

Types

type ClusterMetadata added in v0.3.11 

type ClusterMetadata struct {
	mock.Mock
}

ClusterMetadata is an autogenerated mock type for the Metadata type

func (*ClusterMetadata) ClusterNameForFailoverVersion added in v0.3.11 

func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

ClusterNameForFailoverVersion provides a mock function with given fields:

func (*ClusterMetadata) GetAllClusterFailoverVersions added in v0.3.11 

func (_m *ClusterMetadata) GetAllClusterFailoverVersions() map[string]int64

GetAllClusterFailoverVersions provides a mock function with given fields:

func (*ClusterMetadata) GetCurrentClusterName added in v0.3.11 

func (_m *ClusterMetadata) GetCurrentClusterName() string

GetCurrentClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetMasterClusterName added in v0.3.11 

func (_m *ClusterMetadata) GetMasterClusterName() string

GetMasterClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetNextFailoverVersion added in v0.3.11 

func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 int64) int64

GetNextFailoverVersion provides a mock function with given fields: _a0

func (*ClusterMetadata) IsGlobalDomainEnabled added in v0.3.11 

func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

IsGlobalDomainEnabled provides a mock function with given fields:

func (*ClusterMetadata) IsMasterCluster added in v0.3.11 

func (_m *ClusterMetadata) IsMasterCluster() bool

IsMasterCluster provides a mock function with given fields:

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) CompleteReplicationTask added in v0.3.11 

func (_m *ExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask provides a mock function with given fields: request

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) GetReplicationTasks added in v0.3.11 

func (_m *ExecutionManager) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)

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

func (_m *HistoryClient) DescribeWorkflowExecution(ctx context.Context, request *history.DescribeWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.DescribeWorkflowExecutionResponse, error)

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

func (*HistoryClient) GetMutableState added in v0.3.5 

func (_m *HistoryClient) GetMutableState(ctx context.Context, getRequest *history.GetMutableStateRequest, opts ...yarpc.CallOption) (*history.GetMutableStateResponse, error)

GetMutableState 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 

func (_m *HistoryClient) RecordActivityTaskStarted(ctx context.Context, addRequest *history.RecordActivityTaskStartedRequest, opts ...yarpc.CallOption) (*history.RecordActivityTaskStartedResponse, error)

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 

func (_m *HistoryClient) RecordDecisionTaskStarted(ctx context.Context, addRequest *history.RecordDecisionTaskStartedRequest, opts ...yarpc.CallOption) (*history.RecordDecisionTaskStartedResponse, error)

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

func (*HistoryClient) RemoveSignalMutableState added in v0.3.6 

func (_m *HistoryClient) RemoveSignalMutableState(ctx context.Context, removeRequest *history.RemoveSignalMutableStateRequest, opts ...yarpc.CallOption) error

RemoveSignalMutableState provides a mock function with given fields: ctx, removeRequest

func (*HistoryClient) ReplicateEvents added in v0.3.11 

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

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

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) ResetStickyTaskList added in v0.3.7 

func (_m *HistoryClient) ResetStickyTaskList(ctx context.Context, request *history.ResetStickyTaskListRequest, opts ...yarpc.CallOption) (*history.ResetStickyTaskListResponse, error)

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

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) SignalWithStartWorkflowExecution added in v0.3.11 

func (_m *HistoryClient) SignalWithStartWorkflowExecution(ctx context.Context,
	signalWithStartRequest *history.SignalWithStartWorkflowExecutionRequest,
	opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution provides a mock function with given fields: ctx, signalWithStartRequest

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 

func (_m *HistoryClient) StartWorkflowExecution(ctx context.Context, startRequest *history.StartWorkflowExecutionRequest, opts ...yarpc.CallOption) (*shared.StartWorkflowExecutionResponse, error)

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 

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

GetWorkflowExecutionHistory provides a mock function with given fields: request

type KafkaProducer added in v0.3.7 

type KafkaProducer struct {
	mock.Mock
}

KafkaProducer is an autogenerated mock type for the KafkaProducer type

func (*KafkaProducer) Close added in v0.3.7 

func (_m *KafkaProducer) Close() error

Close provides a mock function with given fields:

func (*KafkaProducer) Publish added in v0.3.7 

func (_m *KafkaProducer) Publish(msg *replicator.ReplicationTask) error

Publish provides a mock function with given fields: msg

func (*KafkaProducer) PublishBatch added in v0.3.7 

func (_m *KafkaProducer) PublishBatch(msgs []*replicator.ReplicationTask) error

PublishBatch provides a mock function with given fields: msgs

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) DescribeTaskList added in v0.3.5 

func (_m *MatchingClient) DescribeTaskList(ctx context.Context,
	request *matching.DescribeTaskListRequest, opts ...yarpc.CallOption) (*shared.DescribeTaskListResponse, error)

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

func (*MatchingClient) PollForActivityTask 

func (_m *MatchingClient) PollForActivityTask(ctx context.Context,
	pollRequest *matching.PollForActivityTaskRequest, opts ...yarpc.CallOption) (*shared.PollForActivityTaskResponse, error)

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

func (*MatchingClient) PollForDecisionTask 

func (_m *MatchingClient) PollForDecisionTask(ctx context.Context,
	pollRequest *matching.PollForDecisionTaskRequest, opts ...yarpc.CallOption) (*matching.PollForDecisionTaskResponse, error)

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 MessagingClient added in v0.3.11 

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

Service is the mock implementation for Service interface

func (*MessagingClient) NewConsumer added in v0.3.11 

func (c *MessagingClient) NewConsumer(topicName, consumerName string, concurrency int) (kafka.Consumer, error)

GetHostName returns the name of host running the service

func (*MessagingClient) NewProducer added in v0.3.11 

func (c *MessagingClient) NewProducer(topicName string) (messaging.Producer, error)

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 

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

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

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

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) GetClosedWorkflowExecution 

func (_m *VisibilityManager) GetClosedWorkflowExecution(request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)

GetClosedWorkflowExecution provides a mock function with given fields: request

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.