mocks

Jul 30, 2019

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

Jul 24, 2019

Changes in this version

type AdminClient

+ func (_m *AdminClient) AddSearchAttribute(ctx context.Context, Request *admin.AddSearchAttributeRequest, ...) error

type VisibilityManager

+ func (_m *VisibilityManager) UpsertWorkflowExecution(request *persistence.UpsertWorkflowExecutionRequest) error

Jun 17, 2019

Changes in this version

type FrontendClient

+ func (_m *FrontendClient) GetSearchAttributes(ctx context.Context, opts ...yarpc.CallOption) (*shared.GetSearchAttributesResponse, error)

May 14, 2019

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

type ExecutionManager

+ func (_m *ExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

type FrontendClient

+ func (_m *FrontendClient) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest, ...) (*shared.CountWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, ...) (*shared.ListWorkflowExecutionsResponse, error)

type VisibilityManager

+ func (_m *VisibilityManager) CountWorkflowExecutions(request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ScanWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

May 8, 2019

Changes in this version

type BlobstoreClient

+ func (_m *BlobstoreClient) BucketExists(ctx context.Context, bucket string) (bool, error)

+ func (_m *BlobstoreClient) GetRetryPolicy() backoff.RetryPolicy

+ func (_m *BlobstoreClient) GetTags(ctx context.Context, bucket string, key blob.Key) (map[string]string, error)

+ func (_m *BlobstoreClient) IsRetryableError(err error) bool

type FrontendClient

+ func (_m *FrontendClient) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, ...) (*shared.ListWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest, ...) (*shared.ResetWorkflowExecutionResponse, error)

type TaskManager

+ func (_m *TaskManager) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

+ func (_m *TaskManager) DeleteTaskList(request *persistence.DeleteTaskListRequest) error

+ func (_m *TaskManager) ListTaskList(request *persistence.ListTaskListRequest) (*persistence.ListTaskListResponse, error)

type VisibilityManager

+ func (_m *VisibilityManager) DeleteWorkflowExecution(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

+ func (_m *VisibilityManager) ListWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

Mar 8, 2019

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) ArchivalConfig() *cluster.ArchivalConfig

Feb 12, 2019

Changes in this version

+ type BlobstoreClient struct

+ func (_m *BlobstoreClient) BucketMetadata(ctx context.Context, bucket string) (*blobstore.BucketMetadataResponse, error)

+ func (_m *BlobstoreClient) Delete(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ func (_m *BlobstoreClient) Download(ctx context.Context, bucket string, key blob.Key) (*blob.Blob, error)

+ func (_m *BlobstoreClient) Exists(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ func (_m *BlobstoreClient) ListByPrefix(ctx context.Context, bucket string, prefix string) ([]blob.Key, error)

+ func (_m *BlobstoreClient) Upload(ctx context.Context, bucket string, key blob.Key, _a3 *blob.Blob) error

type ExecutionManager

+ func (_m *ExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

type HistoryClient

+ func (_m *HistoryClient) ResetWorkflowExecution(ctx context.Context, resetRequest *history.ResetWorkflowExecutionRequest, ...) (*shared.ResetWorkflowExecutionResponse, error)

type HistoryV2Manager

+ func (_m *HistoryV2Manager) CompleteForkBranch(request *persistence.CompleteForkBranchRequest) error

type MessagingClient

+ func (c *MessagingClient) NewConsumerWithClusterName(currentCluster, sourceCluster, consumerName string, concurrency int) (messaging.Consumer, error)

Jan 7, 2019

Changes in this version

+ type AdminClient struct

+ func (_m *AdminClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, ...) (*shared.DescribeHistoryHostResponse, error)

+ func (_m *AdminClient) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest, ...) (*admin.DescribeWorkflowExecutionResponse, error)

+ func (_m *AdminClient) GetWorkflowExecutionRawHistory(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryRequest, ...) (*admin.GetWorkflowExecutionRawHistoryResponse, error)

+ type ArchivalClient struct

+ func (_m *ArchivalClient) Archive(_a0 *sysworkflow.ArchiveRequest) error

+ func (_m *ArchivalClient) Backfill(_a0 *sysworkflow.BackfillRequest) error

+ type Client struct

+ func (_m *Client) BucketMetadata(ctx context.Context, bucket string) (*blobstore.BucketMetadataResponse, error)

+ func (_m *Client) DownloadBlob(ctx context.Context, bucket string, path string) (*blobstore.Blob, error)

+ func (_m *Client) UploadBlob(ctx context.Context, bucket string, path string, blob *blobstore.Blob) error

type ClusterMetadata

+ func (_m *ClusterMetadata) GetAllClientAddress() map[string]config.Address

+ func (_m *ClusterMetadata) GetDefaultArchivalBucket() string

+ func (_m *ClusterMetadata) GetDeploymentGroup() string

+ func (_m *ClusterMetadata) IsArchivalEnabled() bool

type ExecutionManager

+ func (_m *ExecutionManager) GetShardID() int

+ type FrontendClient struct

+ func (_m *FrontendClient) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest, ...) error

+ func (_m *FrontendClient) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest, ...) (*shared.DescribeDomainResponse, error)

+ func (_m *FrontendClient) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest, ...) (*shared.DescribeTaskListResponse, error)

+ func (_m *FrontendClient) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest, ...) (*shared.DescribeWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest, ...) (*shared.GetWorkflowExecutionHistoryResponse, error)

+ func (_m *FrontendClient) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest, ...) (*shared.ListClosedWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ListDomains(ctx context.Context, request *shared.ListDomainsRequest, ...) (*shared.ListDomainsResponse, error)

+ func (_m *FrontendClient) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest, ...) (*shared.ListOpenWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest, ...) (*shared.PollForActivityTaskResponse, error)

+ func (_m *FrontendClient) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest, ...) (*shared.PollForDecisionTaskResponse, error)

+ func (_m *FrontendClient) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest, ...) (*shared.QueryWorkflowResponse, error)

+ func (_m *FrontendClient) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *FrontendClient) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *FrontendClient) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest, ...) error

+ func (_m *FrontendClient) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest, ...) (*shared.ResetStickyTaskListResponse, error)

+ func (_m *FrontendClient) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest, ...) error

+ func (_m *FrontendClient) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest, ...) (*shared.RespondDecisionTaskCompletedResponse, error)

+ func (_m *FrontendClient) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest, ...) error

+ func (_m *FrontendClient) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest, ...) error

+ func (_m *FrontendClient) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest, ...) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest, ...) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest, ...) (*shared.UpdateDomainResponse, error)

type HistoryClient

+ func (_m *HistoryClient) ReplicateRawEvents(ctx context.Context, request *history.ReplicateRawEventsRequest, ...) error

type HistoryManager

+ func (_m *HistoryManager) GetWorkflowExecutionHistoryByBatch(request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryByBatchResponse, error)

+ type HistoryV2Manager struct

+ func (_m *HistoryV2Manager) AppendHistoryNodes(request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

+ func (_m *HistoryV2Manager) Close()

+ func (_m *HistoryV2Manager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

+ func (_m *HistoryV2Manager) ForkHistoryBranch(request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

+ func (_m *HistoryV2Manager) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

+ func (_m *HistoryV2Manager) GetName() string

+ func (_m *HistoryV2Manager) ReadHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

+ func (_m *HistoryV2Manager) ReadHistoryBranchByBatch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

type MessagingClient

+ func (c *MessagingClient) NewProducerWithClusterName(sourceCluster string) (messaging.Producer, error)

Oct 19, 2018

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) GetName() string

+ func (_m *ExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

+ func (_m *ExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

type ExecutionManagerFactory

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

type HistoryClient

+ func (_m *HistoryClient) SyncActivity(ctx context.Context, request *history.SyncActivityRequest, ...) error

type HistoryManager

+ func (_m *HistoryManager) GetName() string

type MetadataManager

+ func (_m *MetadataManager) GetName() string

type ShardManager

+ func (_m *ShardManager) GetName() string

type TaskManager

+ func (_m *TaskManager) GetName() string

type VisibilityManager

+ func (_m *VisibilityManager) GetName() string

Jul 24, 2018

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool

type HistoryClient

+ func (_m *HistoryClient) SyncShardStatus(ctx context.Context, request *history.SyncShardStatusRequest, ...) error

type MetadataManager

+ func (_m *MetadataManager) ListDomains(request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)

Jun 9, 2018

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, ...) (*shared.DescribeHistoryHostResponse, error)

+ func (_m *HistoryClient) DescribeMutableState(ctx context.Context, request *history.DescribeMutableStateRequest, ...) (*history.DescribeMutableStateResponse, error)

type MetadataManager

+ func (_m *MetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)

+ func (_m *MetadataManager) ListDomain(request *persistence.ListDomainRequest) (*persistence.ListDomainResponse, error)

May 26, 2018

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) ResetMutableState(request *persistence.ResetMutableStateRequest) error

Apr 16, 2018

Changes in this version

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

+ type ClusterMetadata struct

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

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

+ func (_m *ClusterMetadata) GetCurrentClusterName() string

+ func (_m *ClusterMetadata) GetMasterClusterName() string

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

+ func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

+ func (_m *ClusterMetadata) IsMasterCluster() bool

type ExecutionManager

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

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

type HistoryClient

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

+ func (_m *HistoryClient) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*shared.StartWorkflowExecutionResponse, error)

+ type MessagingClient struct

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

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

Mar 12, 2018

Changes in this version

type HistoryClient

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

+ type KafkaProducer struct

+ func (_m *KafkaProducer) Close() error

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

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

Jan 30, 2018

Changes in this version

type HistoryClient

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

Jan 12, 2018

Changes in this version

type HistoryClient

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

type MatchingClient

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

Dec 5, 2017

Changes in this version

type HistoryClient

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

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

Sep 29, 2017

Changes in this version

type ExecutionManagerFactory

+ func (_m *ExecutionManagerFactory) Close()

type MatchingClient

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

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

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

Jun 30, 2017

Changes in this version

+ type ExecutionManager struct

+ func (_m *ExecutionManager) Close()

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

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

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

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

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

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

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

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

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

+ type ExecutionManagerFactory struct

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

+ type HistoryClient struct

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

+ func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx thrift.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

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

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

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

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

+ func (_m *HistoryClient) RespondActivityTaskCanceled(ctx thrift.Context, ...) error

+ func (_m *HistoryClient) RespondActivityTaskCompleted(ctx thrift.Context, ...) error

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

+ func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx thrift.Context, ...) error

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

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

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

+ func (_m *HistoryClient) TerminateWorkflowExecution(ctx thrift.Context, ...) error

+ type HistoryManager struct

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

+ func (_m *HistoryManager) Close()

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

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

+ type MatchingClient struct

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

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

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

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

+ type MetadataManager struct

+ func (_m *MetadataManager) Close()

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

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

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

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

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

+ type ServiceResolver struct

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

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

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

+ type ShardManager struct

+ func (_m *ShardManager) Close()

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

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

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

+ type TaskManager struct

+ func (_m *TaskManager) Close()

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

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

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

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

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

+ type VisibilityManager struct

+ func (_m *VisibilityManager) Close()

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

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

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

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

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

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

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

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

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

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