Documentation ¶
Overview ¶
Package resource is a generated GoMock package.
Index ¶
- type Impl
- func (h *Impl) GetArchivalMetadata() archiver.ArchivalMetadata
- func (h *Impl) GetArchiverProvider() provider.ArchiverProvider
- func (h *Impl) GetAsyncWorkflowQueueProvider() queue.Provider
- func (h *Impl) GetBlobstoreClient() blobstore.Client
- func (h *Impl) GetClientBean() client.Bean
- func (h *Impl) GetClusterMetadata() cluster.Metadata
- func (h *Impl) GetDispatcher() *yarpc.Dispatcher
- func (h *Impl) GetDomainCache() cache.DomainCache
- func (h *Impl) GetDomainManager() persistence.DomainManager
- func (h *Impl) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
- func (h *Impl) GetDomainReplicationQueue() domain.ReplicationQueue
- func (h *Impl) GetExecutionManager(shardID int) (persistence.ExecutionManager, error)
- func (h *Impl) GetFrontendClient() frontend.Client
- func (h *Impl) GetFrontendRawClient() frontend.Client
- func (h *Impl) GetHistoryClient() history.Client
- func (h *Impl) GetHistoryManager() persistence.HistoryManager
- func (h *Impl) GetHistoryRawClient() history.Client
- func (h *Impl) GetHostInfo() membership.HostInfo
- func (h *Impl) GetHostName() string
- func (h *Impl) GetIsolationGroupState() isolationgroup.State
- func (h *Impl) GetIsolationGroupStore() configstore.Client
- func (h *Impl) GetLogger() log.Logger
- func (h *Impl) GetMatchingClient() matching.Client
- func (h *Impl) GetMatchingRawClient() matching.Client
- func (h *Impl) GetMembershipResolver() membership.Resolver
- func (h *Impl) GetMessagingClient() messaging.Client
- func (h *Impl) GetMetricsClient() metrics.Client
- func (h *Impl) GetPartitioner() partition.Partitioner
- func (h *Impl) GetPayloadSerializer() persistence.PayloadSerializer
- func (h *Impl) GetPersistenceBean() persistenceClient.Bean
- func (h *Impl) GetRatelimiterAggregatorsClient() qrpc.Client
- func (h *Impl) GetRemoteAdminClient(cluster string) admin.Client
- func (h *Impl) GetRemoteFrontendClient(cluster string) frontend.Client
- func (h *Impl) GetSDKClient() workflowserviceclient.Interface
- func (h *Impl) GetServiceName() string
- func (h *Impl) GetShardManager() persistence.ShardManager
- func (h *Impl) GetTaskManager() persistence.TaskManager
- func (h *Impl) GetThrottledLogger() log.Logger
- func (h *Impl) GetTimeSource() clock.TimeSource
- func (h *Impl) GetVisibilityManager() persistence.VisibilityManager
- func (h *Impl) Start()
- func (h *Impl) Stop()
- type MockResource
- func (m *MockResource) EXPECT() *MockResourceMockRecorder
- func (m *MockResource) GetArchivalMetadata() archiver.ArchivalMetadata
- func (m *MockResource) GetArchiverProvider() provider.ArchiverProvider
- func (m *MockResource) GetAsyncWorkflowQueueProvider() queue.Provider
- func (m *MockResource) GetBlobstoreClient() blobstore.Client
- func (m *MockResource) GetClientBean() client.Bean
- func (m *MockResource) GetClusterMetadata() cluster.Metadata
- func (m *MockResource) GetDispatcher() *yarpc.Dispatcher
- func (m *MockResource) GetDomainCache() cache.DomainCache
- func (m *MockResource) GetDomainManager() persistence.DomainManager
- func (m *MockResource) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
- func (m *MockResource) GetDomainReplicationQueue() domain.ReplicationQueue
- func (m *MockResource) GetExecutionManager(arg0 int) (persistence.ExecutionManager, error)
- func (m *MockResource) GetFrontendClient() frontend.Client
- func (m *MockResource) GetFrontendRawClient() frontend.Client
- func (m *MockResource) GetHistoryClient() history.Client
- func (m *MockResource) GetHistoryManager() persistence.HistoryManager
- func (m *MockResource) GetHistoryRawClient() history.Client
- func (m *MockResource) GetHostInfo() membership.HostInfo
- func (m *MockResource) GetHostName() string
- func (m *MockResource) GetIsolationGroupState() isolationgroup.State
- func (m *MockResource) GetIsolationGroupStore() configstore.Client
- func (m *MockResource) GetLogger() log.Logger
- func (m *MockResource) GetMatchingClient() matching.Client
- func (m *MockResource) GetMatchingRawClient() matching.Client
- func (m *MockResource) GetMembershipResolver() membership.Resolver
- func (m *MockResource) GetMessagingClient() messaging.Client
- func (m *MockResource) GetMetricsClient() metrics.Client
- func (m *MockResource) GetPartitioner() partition.Partitioner
- func (m *MockResource) GetPayloadSerializer() persistence.PayloadSerializer
- func (m *MockResource) GetPersistenceBean() client0.Bean
- func (m *MockResource) GetRatelimiterAggregatorsClient() rpc.Client
- func (m *MockResource) GetRemoteAdminClient(cluster string) admin.Client
- func (m *MockResource) GetRemoteFrontendClient(cluster string) frontend.Client
- func (m *MockResource) GetSDKClient() workflowserviceclient.Interface
- func (m *MockResource) GetServiceName() string
- func (m *MockResource) GetShardManager() persistence.ShardManager
- func (m *MockResource) GetTaskManager() persistence.TaskManager
- func (m *MockResource) GetThrottledLogger() log.Logger
- func (m *MockResource) GetTimeSource() clock.TimeSource
- func (m *MockResource) GetVisibilityManager() persistence.VisibilityManager
- func (m *MockResource) Start()
- func (m *MockResource) Stop()
- type MockResourceFactory
- type MockResourceFactoryMockRecorder
- type MockResourceMockRecorder
- func (mr *MockResourceMockRecorder) GetArchivalMetadata() *gomock.Call
- func (mr *MockResourceMockRecorder) GetArchiverProvider() *gomock.Call
- func (mr *MockResourceMockRecorder) GetAsyncWorkflowQueueProvider() *gomock.Call
- func (mr *MockResourceMockRecorder) GetBlobstoreClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetClientBean() *gomock.Call
- func (mr *MockResourceMockRecorder) GetClusterMetadata() *gomock.Call
- func (mr *MockResourceMockRecorder) GetDispatcher() *gomock.Call
- func (mr *MockResourceMockRecorder) GetDomainCache() *gomock.Call
- func (mr *MockResourceMockRecorder) GetDomainManager() *gomock.Call
- func (mr *MockResourceMockRecorder) GetDomainMetricsScopeCache() *gomock.Call
- func (mr *MockResourceMockRecorder) GetDomainReplicationQueue() *gomock.Call
- func (mr *MockResourceMockRecorder) GetExecutionManager(arg0 interface{}) *gomock.Call
- func (mr *MockResourceMockRecorder) GetFrontendClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetFrontendRawClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetHistoryClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetHistoryManager() *gomock.Call
- func (mr *MockResourceMockRecorder) GetHistoryRawClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetHostInfo() *gomock.Call
- func (mr *MockResourceMockRecorder) GetHostName() *gomock.Call
- func (mr *MockResourceMockRecorder) GetIsolationGroupState() *gomock.Call
- func (mr *MockResourceMockRecorder) GetIsolationGroupStore() *gomock.Call
- func (mr *MockResourceMockRecorder) GetLogger() *gomock.Call
- func (mr *MockResourceMockRecorder) GetMatchingClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetMatchingRawClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetMembershipResolver() *gomock.Call
- func (mr *MockResourceMockRecorder) GetMessagingClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetMetricsClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetPartitioner() *gomock.Call
- func (mr *MockResourceMockRecorder) GetPayloadSerializer() *gomock.Call
- func (mr *MockResourceMockRecorder) GetPersistenceBean() *gomock.Call
- func (mr *MockResourceMockRecorder) GetRatelimiterAggregatorsClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call
- func (mr *MockResourceMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call
- func (mr *MockResourceMockRecorder) GetSDKClient() *gomock.Call
- func (mr *MockResourceMockRecorder) GetServiceName() *gomock.Call
- func (mr *MockResourceMockRecorder) GetShardManager() *gomock.Call
- func (mr *MockResourceMockRecorder) GetTaskManager() *gomock.Call
- func (mr *MockResourceMockRecorder) GetThrottledLogger() *gomock.Call
- func (mr *MockResourceMockRecorder) GetTimeSource() *gomock.Call
- func (mr *MockResourceMockRecorder) GetVisibilityManager() *gomock.Call
- func (mr *MockResourceMockRecorder) Start() *gomock.Call
- func (mr *MockResourceMockRecorder) Stop() *gomock.Call
- type Params
- type Resource
- type ResourceFactory
- type Test
- func (s *Test) Finish(t mock.TestingT)
- func (s *Test) GetArchivalMetadata() archiver.ArchivalMetadata
- func (s *Test) GetArchiverProvider() provider.ArchiverProvider
- func (s *Test) GetAsyncWorkflowQueueProvider() queue.Provider
- func (s *Test) GetBlobstoreClient() blobstore.Client
- func (s *Test) GetClientBean() client.Bean
- func (s *Test) GetClusterMetadata() cluster.Metadata
- func (s *Test) GetDispatcher() *yarpc.Dispatcher
- func (s *Test) GetDomainCache() cache.DomainCache
- func (s *Test) GetDomainManager() persistence.DomainManager
- func (s *Test) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
- func (s *Test) GetDomainReplicationQueue() domain.ReplicationQueue
- func (s *Test) GetExecutionManager(shardID int) (persistence.ExecutionManager, error)
- func (s *Test) GetFrontendClient() frontend.Client
- func (s *Test) GetFrontendRawClient() frontend.Client
- func (s *Test) GetHistoryClient() history.Client
- func (s *Test) GetHistoryManager() persistence.HistoryManager
- func (s *Test) GetHistoryRawClient() history.Client
- func (s *Test) GetHostInfo() membership.HostInfo
- func (s *Test) GetHostName() string
- func (s *Test) GetIsolationGroupState() isolationgroup.State
- func (s *Test) GetIsolationGroupStore() configstore.Client
- func (s *Test) GetLogger() log.Logger
- func (s *Test) GetMatchingClient() matching.Client
- func (s *Test) GetMatchingRawClient() matching.Client
- func (s *Test) GetMembershipResolver() membership.Resolver
- func (s *Test) GetMessagingClient() messaging.Client
- func (s *Test) GetMetricsClient() metrics.Client
- func (s *Test) GetPartitioner() partition.Partitioner
- func (s *Test) GetPayloadSerializer() persistence.PayloadSerializer
- func (s *Test) GetPersistenceBean() persistenceClient.Bean
- func (s *Test) GetRatelimiterAggregatorsClient() rpc.Client
- func (s *Test) GetRemoteAdminClient(cluster string) admin.Client
- func (s *Test) GetRemoteFrontendClient(cluster string) frontend.Client
- func (s *Test) GetSDKClient() workflowserviceclient.Interface
- func (s *Test) GetServiceName() string
- func (s *Test) GetShardManager() persistence.ShardManager
- func (s *Test) GetTaskManager() persistence.TaskManager
- func (s *Test) GetTaskValidator() taskvalidator.Checker
- func (s *Test) GetThrottledLogger() log.Logger
- func (s *Test) GetTimeSource() clock.TimeSource
- func (s *Test) GetVisibilityManager() persistence.VisibilityManager
- func (s *Test) Start()
- func (s *Test) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Impl ¶
type Impl struct {
// contains filtered or unexported fields
}
Impl contains all common resources shared across frontend / matching / history / worker
func New ¶
func New( params *Params, serviceName string, serviceConfig *service.Config, ) (impl *Impl, retError error)
New create a new resource containing common dependencies
func (*Impl) GetArchivalMetadata ¶
func (h *Impl) GetArchivalMetadata() archiver.ArchivalMetadata
GetArchivalMetadata return archival metadata
func (*Impl) GetArchiverProvider ¶
func (h *Impl) GetArchiverProvider() provider.ArchiverProvider
GetArchiverProvider return archival provider
func (*Impl) GetAsyncWorkflowQueueProvider ¶ added in v1.2.8
GetAsyncWorkflowQueueProvider returns the async workflow queue provider
func (*Impl) GetBlobstoreClient ¶ added in v0.13.0
GetBlobstoreClient returns blobstore client
func (*Impl) GetClientBean ¶
GetClientBean return RPC client bean
func (*Impl) GetClusterMetadata ¶
GetClusterMetadata return cluster metadata
func (*Impl) GetDispatcher ¶
func (h *Impl) GetDispatcher() *yarpc.Dispatcher
GetDispatcher return YARPC dispatcher, used for registering handlers
func (*Impl) GetDomainCache ¶
func (h *Impl) GetDomainCache() cache.DomainCache
GetDomainCache return domain cache
func (*Impl) GetDomainManager ¶ added in v0.22.0
func (h *Impl) GetDomainManager() persistence.DomainManager
GetMetadataManager return metadata manager
func (*Impl) GetDomainMetricsScopeCache ¶ added in v0.14.0
func (h *Impl) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
GetDomainMetricsScopeCache return domainMetricsScope cache
func (*Impl) GetDomainReplicationQueue ¶
func (h *Impl) GetDomainReplicationQueue() domain.ReplicationQueue
GetDomainReplicationQueue return domain replication queue
func (*Impl) GetExecutionManager ¶
func (h *Impl) GetExecutionManager(shardID int) (persistence.ExecutionManager, error)
GetExecutionManager return execution manager for given shard ID
func (*Impl) GetFrontendClient ¶
GetFrontendClient return frontend client with retry policy
func (*Impl) GetFrontendRawClient ¶
GetFrontendRawClient return frontend client without retry policy
func (*Impl) GetHistoryClient ¶
GetHistoryClient return history client with retry policy
func (*Impl) GetHistoryManager ¶
func (h *Impl) GetHistoryManager() persistence.HistoryManager
GetHistoryManager return history manager
func (*Impl) GetHistoryRawClient ¶
GetHistoryRawClient return history client without retry policy
func (*Impl) GetHostInfo ¶
func (h *Impl) GetHostInfo() membership.HostInfo
GetHostInfo return host info
func (*Impl) GetHostName ¶
func (*Impl) GetIsolationGroupState ¶ added in v1.2.1
func (h *Impl) GetIsolationGroupState() isolationgroup.State
GetIsolationGroupState returns the isolationGroupState
func (*Impl) GetIsolationGroupStore ¶ added in v1.2.1
func (h *Impl) GetIsolationGroupStore() configstore.Client
GetIsolationGroupStore returns the isolation group configuration store or nil
func (*Impl) GetMatchingClient ¶
GetMatchingClient return matching client with retry policy
func (*Impl) GetMatchingRawClient ¶
GetMatchingRawClient return matching client without retry policy
func (*Impl) GetMembershipResolver ¶ added in v0.24.0
func (h *Impl) GetMembershipResolver() membership.Resolver
GetMembershipResolver return the membership resolver
func (*Impl) GetMessagingClient ¶
GetMessagingClient return messaging client
func (*Impl) GetMetricsClient ¶
GetMetricsClient return metrics client
func (*Impl) GetPartitioner ¶ added in v1.2.1
func (h *Impl) GetPartitioner() partition.Partitioner
GetPartitioner returns the partitioner
func (*Impl) GetPayloadSerializer ¶
func (h *Impl) GetPayloadSerializer() persistence.PayloadSerializer
GetPayloadSerializer return binary payload serializer
func (*Impl) GetPersistenceBean ¶
func (h *Impl) GetPersistenceBean() persistenceClient.Bean
GetPersistenceBean return persistence bean
func (*Impl) GetRatelimiterAggregatorsClient ¶ added in v1.2.12
func (*Impl) GetRemoteAdminClient ¶
GetRemoteAdminClient return remote admin client for given cluster name
func (*Impl) GetRemoteFrontendClient ¶
GetRemoteFrontendClient return remote frontend client for given cluster name
func (*Impl) GetSDKClient ¶
func (h *Impl) GetSDKClient() workflowserviceclient.Interface
GetSDKClient return sdk client
func (*Impl) GetServiceName ¶
GetServiceName return service name
func (*Impl) GetShardManager ¶
func (h *Impl) GetShardManager() persistence.ShardManager
GetShardManager return shard manager
func (*Impl) GetTaskManager ¶
func (h *Impl) GetTaskManager() persistence.TaskManager
GetTaskManager return task manager
func (*Impl) GetThrottledLogger ¶
GetThrottledLogger return throttled logger
func (*Impl) GetTimeSource ¶
func (h *Impl) GetTimeSource() clock.TimeSource
GetTimeSource return time source
func (*Impl) GetVisibilityManager ¶
func (h *Impl) GetVisibilityManager() persistence.VisibilityManager
GetVisibilityManager return visibility manager
type MockResource ¶
type MockResource struct {
// contains filtered or unexported fields
}
MockResource is a mock of Resource interface.
func NewMockResource ¶
func NewMockResource(ctrl *gomock.Controller) *MockResource
NewMockResource creates a new mock instance.
func (*MockResource) EXPECT ¶
func (m *MockResource) EXPECT() *MockResourceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockResource) GetArchivalMetadata ¶
func (m *MockResource) GetArchivalMetadata() archiver.ArchivalMetadata
GetArchivalMetadata mocks base method.
func (*MockResource) GetArchiverProvider ¶
func (m *MockResource) GetArchiverProvider() provider.ArchiverProvider
GetArchiverProvider mocks base method.
func (*MockResource) GetAsyncWorkflowQueueProvider ¶
func (m *MockResource) GetAsyncWorkflowQueueProvider() queue.Provider
GetAsyncWorkflowQueueProvider mocks base method.
func (*MockResource) GetBlobstoreClient ¶
func (m *MockResource) GetBlobstoreClient() blobstore.Client
GetBlobstoreClient mocks base method.
func (*MockResource) GetClientBean ¶
func (m *MockResource) GetClientBean() client.Bean
GetClientBean mocks base method.
func (*MockResource) GetClusterMetadata ¶
func (m *MockResource) GetClusterMetadata() cluster.Metadata
GetClusterMetadata mocks base method.
func (*MockResource) GetDispatcher ¶
func (m *MockResource) GetDispatcher() *yarpc.Dispatcher
GetDispatcher mocks base method.
func (*MockResource) GetDomainCache ¶
func (m *MockResource) GetDomainCache() cache.DomainCache
GetDomainCache mocks base method.
func (*MockResource) GetDomainManager ¶
func (m *MockResource) GetDomainManager() persistence.DomainManager
GetDomainManager mocks base method.
func (*MockResource) GetDomainMetricsScopeCache ¶
func (m *MockResource) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
GetDomainMetricsScopeCache mocks base method.
func (*MockResource) GetDomainReplicationQueue ¶
func (m *MockResource) GetDomainReplicationQueue() domain.ReplicationQueue
GetDomainReplicationQueue mocks base method.
func (*MockResource) GetExecutionManager ¶
func (m *MockResource) GetExecutionManager(arg0 int) (persistence.ExecutionManager, error)
GetExecutionManager mocks base method.
func (*MockResource) GetFrontendClient ¶
func (m *MockResource) GetFrontendClient() frontend.Client
GetFrontendClient mocks base method.
func (*MockResource) GetFrontendRawClient ¶
func (m *MockResource) GetFrontendRawClient() frontend.Client
GetFrontendRawClient mocks base method.
func (*MockResource) GetHistoryClient ¶
func (m *MockResource) GetHistoryClient() history.Client
GetHistoryClient mocks base method.
func (*MockResource) GetHistoryManager ¶
func (m *MockResource) GetHistoryManager() persistence.HistoryManager
GetHistoryManager mocks base method.
func (*MockResource) GetHistoryRawClient ¶
func (m *MockResource) GetHistoryRawClient() history.Client
GetHistoryRawClient mocks base method.
func (*MockResource) GetHostInfo ¶
func (m *MockResource) GetHostInfo() membership.HostInfo
GetHostInfo mocks base method.
func (*MockResource) GetHostName ¶
func (m *MockResource) GetHostName() string
GetHostName mocks base method.
func (*MockResource) GetIsolationGroupState ¶
func (m *MockResource) GetIsolationGroupState() isolationgroup.State
GetIsolationGroupState mocks base method.
func (*MockResource) GetIsolationGroupStore ¶
func (m *MockResource) GetIsolationGroupStore() configstore.Client
GetIsolationGroupStore mocks base method.
func (*MockResource) GetLogger ¶
func (m *MockResource) GetLogger() log.Logger
GetLogger mocks base method.
func (*MockResource) GetMatchingClient ¶
func (m *MockResource) GetMatchingClient() matching.Client
GetMatchingClient mocks base method.
func (*MockResource) GetMatchingRawClient ¶
func (m *MockResource) GetMatchingRawClient() matching.Client
GetMatchingRawClient mocks base method.
func (*MockResource) GetMembershipResolver ¶
func (m *MockResource) GetMembershipResolver() membership.Resolver
GetMembershipResolver mocks base method.
func (*MockResource) GetMessagingClient ¶
func (m *MockResource) GetMessagingClient() messaging.Client
GetMessagingClient mocks base method.
func (*MockResource) GetMetricsClient ¶
func (m *MockResource) GetMetricsClient() metrics.Client
GetMetricsClient mocks base method.
func (*MockResource) GetPartitioner ¶
func (m *MockResource) GetPartitioner() partition.Partitioner
GetPartitioner mocks base method.
func (*MockResource) GetPayloadSerializer ¶
func (m *MockResource) GetPayloadSerializer() persistence.PayloadSerializer
GetPayloadSerializer mocks base method.
func (*MockResource) GetPersistenceBean ¶
func (m *MockResource) GetPersistenceBean() client0.Bean
GetPersistenceBean mocks base method.
func (*MockResource) GetRatelimiterAggregatorsClient ¶
func (m *MockResource) GetRatelimiterAggregatorsClient() rpc.Client
GetRatelimiterAggregatorsClient mocks base method.
func (*MockResource) GetRemoteAdminClient ¶
func (m *MockResource) GetRemoteAdminClient(cluster string) admin.Client
GetRemoteAdminClient mocks base method.
func (*MockResource) GetRemoteFrontendClient ¶
func (m *MockResource) GetRemoteFrontendClient(cluster string) frontend.Client
GetRemoteFrontendClient mocks base method.
func (*MockResource) GetSDKClient ¶
func (m *MockResource) GetSDKClient() workflowserviceclient.Interface
GetSDKClient mocks base method.
func (*MockResource) GetServiceName ¶
func (m *MockResource) GetServiceName() string
GetServiceName mocks base method.
func (*MockResource) GetShardManager ¶
func (m *MockResource) GetShardManager() persistence.ShardManager
GetShardManager mocks base method.
func (*MockResource) GetTaskManager ¶
func (m *MockResource) GetTaskManager() persistence.TaskManager
GetTaskManager mocks base method.
func (*MockResource) GetThrottledLogger ¶
func (m *MockResource) GetThrottledLogger() log.Logger
GetThrottledLogger mocks base method.
func (*MockResource) GetTimeSource ¶
func (m *MockResource) GetTimeSource() clock.TimeSource
GetTimeSource mocks base method.
func (*MockResource) GetVisibilityManager ¶
func (m *MockResource) GetVisibilityManager() persistence.VisibilityManager
GetVisibilityManager mocks base method.
type MockResourceFactory ¶
type MockResourceFactory struct {
// contains filtered or unexported fields
}
MockResourceFactory is a mock of ResourceFactory interface.
func NewMockResourceFactory ¶
func NewMockResourceFactory(ctrl *gomock.Controller) *MockResourceFactory
NewMockResourceFactory creates a new mock instance.
func (*MockResourceFactory) EXPECT ¶
func (m *MockResourceFactory) EXPECT() *MockResourceFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockResourceFactory) NewResource ¶
func (m *MockResourceFactory) NewResource(params *Params, serviceName string, serviceConfig *service.Config) (Resource, error)
NewResource mocks base method.
type MockResourceFactoryMockRecorder ¶
type MockResourceFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockResourceFactoryMockRecorder is the mock recorder for MockResourceFactory.
func (*MockResourceFactoryMockRecorder) NewResource ¶
func (mr *MockResourceFactoryMockRecorder) NewResource(params, serviceName, serviceConfig interface{}) *gomock.Call
NewResource indicates an expected call of NewResource.
type MockResourceMockRecorder ¶
type MockResourceMockRecorder struct {
// contains filtered or unexported fields
}
MockResourceMockRecorder is the mock recorder for MockResource.
func (*MockResourceMockRecorder) GetArchivalMetadata ¶
func (mr *MockResourceMockRecorder) GetArchivalMetadata() *gomock.Call
GetArchivalMetadata indicates an expected call of GetArchivalMetadata.
func (*MockResourceMockRecorder) GetArchiverProvider ¶
func (mr *MockResourceMockRecorder) GetArchiverProvider() *gomock.Call
GetArchiverProvider indicates an expected call of GetArchiverProvider.
func (*MockResourceMockRecorder) GetAsyncWorkflowQueueProvider ¶
func (mr *MockResourceMockRecorder) GetAsyncWorkflowQueueProvider() *gomock.Call
GetAsyncWorkflowQueueProvider indicates an expected call of GetAsyncWorkflowQueueProvider.
func (*MockResourceMockRecorder) GetBlobstoreClient ¶
func (mr *MockResourceMockRecorder) GetBlobstoreClient() *gomock.Call
GetBlobstoreClient indicates an expected call of GetBlobstoreClient.
func (*MockResourceMockRecorder) GetClientBean ¶
func (mr *MockResourceMockRecorder) GetClientBean() *gomock.Call
GetClientBean indicates an expected call of GetClientBean.
func (*MockResourceMockRecorder) GetClusterMetadata ¶
func (mr *MockResourceMockRecorder) GetClusterMetadata() *gomock.Call
GetClusterMetadata indicates an expected call of GetClusterMetadata.
func (*MockResourceMockRecorder) GetDispatcher ¶
func (mr *MockResourceMockRecorder) GetDispatcher() *gomock.Call
GetDispatcher indicates an expected call of GetDispatcher.
func (*MockResourceMockRecorder) GetDomainCache ¶
func (mr *MockResourceMockRecorder) GetDomainCache() *gomock.Call
GetDomainCache indicates an expected call of GetDomainCache.
func (*MockResourceMockRecorder) GetDomainManager ¶
func (mr *MockResourceMockRecorder) GetDomainManager() *gomock.Call
GetDomainManager indicates an expected call of GetDomainManager.
func (*MockResourceMockRecorder) GetDomainMetricsScopeCache ¶
func (mr *MockResourceMockRecorder) GetDomainMetricsScopeCache() *gomock.Call
GetDomainMetricsScopeCache indicates an expected call of GetDomainMetricsScopeCache.
func (*MockResourceMockRecorder) GetDomainReplicationQueue ¶
func (mr *MockResourceMockRecorder) GetDomainReplicationQueue() *gomock.Call
GetDomainReplicationQueue indicates an expected call of GetDomainReplicationQueue.
func (*MockResourceMockRecorder) GetExecutionManager ¶
func (mr *MockResourceMockRecorder) GetExecutionManager(arg0 interface{}) *gomock.Call
GetExecutionManager indicates an expected call of GetExecutionManager.
func (*MockResourceMockRecorder) GetFrontendClient ¶
func (mr *MockResourceMockRecorder) GetFrontendClient() *gomock.Call
GetFrontendClient indicates an expected call of GetFrontendClient.
func (*MockResourceMockRecorder) GetFrontendRawClient ¶
func (mr *MockResourceMockRecorder) GetFrontendRawClient() *gomock.Call
GetFrontendRawClient indicates an expected call of GetFrontendRawClient.
func (*MockResourceMockRecorder) GetHistoryClient ¶
func (mr *MockResourceMockRecorder) GetHistoryClient() *gomock.Call
GetHistoryClient indicates an expected call of GetHistoryClient.
func (*MockResourceMockRecorder) GetHistoryManager ¶
func (mr *MockResourceMockRecorder) GetHistoryManager() *gomock.Call
GetHistoryManager indicates an expected call of GetHistoryManager.
func (*MockResourceMockRecorder) GetHistoryRawClient ¶
func (mr *MockResourceMockRecorder) GetHistoryRawClient() *gomock.Call
GetHistoryRawClient indicates an expected call of GetHistoryRawClient.
func (*MockResourceMockRecorder) GetHostInfo ¶
func (mr *MockResourceMockRecorder) GetHostInfo() *gomock.Call
GetHostInfo indicates an expected call of GetHostInfo.
func (*MockResourceMockRecorder) GetHostName ¶
func (mr *MockResourceMockRecorder) GetHostName() *gomock.Call
GetHostName indicates an expected call of GetHostName.
func (*MockResourceMockRecorder) GetIsolationGroupState ¶
func (mr *MockResourceMockRecorder) GetIsolationGroupState() *gomock.Call
GetIsolationGroupState indicates an expected call of GetIsolationGroupState.
func (*MockResourceMockRecorder) GetIsolationGroupStore ¶
func (mr *MockResourceMockRecorder) GetIsolationGroupStore() *gomock.Call
GetIsolationGroupStore indicates an expected call of GetIsolationGroupStore.
func (*MockResourceMockRecorder) GetLogger ¶
func (mr *MockResourceMockRecorder) GetLogger() *gomock.Call
GetLogger indicates an expected call of GetLogger.
func (*MockResourceMockRecorder) GetMatchingClient ¶
func (mr *MockResourceMockRecorder) GetMatchingClient() *gomock.Call
GetMatchingClient indicates an expected call of GetMatchingClient.
func (*MockResourceMockRecorder) GetMatchingRawClient ¶
func (mr *MockResourceMockRecorder) GetMatchingRawClient() *gomock.Call
GetMatchingRawClient indicates an expected call of GetMatchingRawClient.
func (*MockResourceMockRecorder) GetMembershipResolver ¶
func (mr *MockResourceMockRecorder) GetMembershipResolver() *gomock.Call
GetMembershipResolver indicates an expected call of GetMembershipResolver.
func (*MockResourceMockRecorder) GetMessagingClient ¶
func (mr *MockResourceMockRecorder) GetMessagingClient() *gomock.Call
GetMessagingClient indicates an expected call of GetMessagingClient.
func (*MockResourceMockRecorder) GetMetricsClient ¶
func (mr *MockResourceMockRecorder) GetMetricsClient() *gomock.Call
GetMetricsClient indicates an expected call of GetMetricsClient.
func (*MockResourceMockRecorder) GetPartitioner ¶
func (mr *MockResourceMockRecorder) GetPartitioner() *gomock.Call
GetPartitioner indicates an expected call of GetPartitioner.
func (*MockResourceMockRecorder) GetPayloadSerializer ¶
func (mr *MockResourceMockRecorder) GetPayloadSerializer() *gomock.Call
GetPayloadSerializer indicates an expected call of GetPayloadSerializer.
func (*MockResourceMockRecorder) GetPersistenceBean ¶
func (mr *MockResourceMockRecorder) GetPersistenceBean() *gomock.Call
GetPersistenceBean indicates an expected call of GetPersistenceBean.
func (*MockResourceMockRecorder) GetRatelimiterAggregatorsClient ¶
func (mr *MockResourceMockRecorder) GetRatelimiterAggregatorsClient() *gomock.Call
GetRatelimiterAggregatorsClient indicates an expected call of GetRatelimiterAggregatorsClient.
func (*MockResourceMockRecorder) GetRemoteAdminClient ¶
func (mr *MockResourceMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.
func (*MockResourceMockRecorder) GetRemoteFrontendClient ¶
func (mr *MockResourceMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call
GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient.
func (*MockResourceMockRecorder) GetSDKClient ¶
func (mr *MockResourceMockRecorder) GetSDKClient() *gomock.Call
GetSDKClient indicates an expected call of GetSDKClient.
func (*MockResourceMockRecorder) GetServiceName ¶
func (mr *MockResourceMockRecorder) GetServiceName() *gomock.Call
GetServiceName indicates an expected call of GetServiceName.
func (*MockResourceMockRecorder) GetShardManager ¶
func (mr *MockResourceMockRecorder) GetShardManager() *gomock.Call
GetShardManager indicates an expected call of GetShardManager.
func (*MockResourceMockRecorder) GetTaskManager ¶
func (mr *MockResourceMockRecorder) GetTaskManager() *gomock.Call
GetTaskManager indicates an expected call of GetTaskManager.
func (*MockResourceMockRecorder) GetThrottledLogger ¶
func (mr *MockResourceMockRecorder) GetThrottledLogger() *gomock.Call
GetThrottledLogger indicates an expected call of GetThrottledLogger.
func (*MockResourceMockRecorder) GetTimeSource ¶
func (mr *MockResourceMockRecorder) GetTimeSource() *gomock.Call
GetTimeSource indicates an expected call of GetTimeSource.
func (*MockResourceMockRecorder) GetVisibilityManager ¶
func (mr *MockResourceMockRecorder) GetVisibilityManager() *gomock.Call
GetVisibilityManager indicates an expected call of GetVisibilityManager.
func (*MockResourceMockRecorder) Start ¶
func (mr *MockResourceMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockResourceMockRecorder) Stop ¶
func (mr *MockResourceMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type Params ¶ added in v0.24.0
type Params struct { Name string InstanceID string Logger log.Logger ThrottledLogger log.Logger HostName string GetIsolationGroups func() []string MetricScope tally.Scope MembershipResolver membership.Resolver RPCFactory rpc.Factory PProfInitializer common.PProfInitializer PersistenceConfig config.Persistence ClusterMetadata cluster.Metadata ReplicatorConfig config.Replicator MetricsClient metrics.Client MessagingClient messaging.Client BlobstoreClient blobstore.Client ESClient es.GenericClient ESConfig *config.ElasticSearchConfig DynamicConfig dynamicconfig.Client ClusterRedirectionPolicy *config.ClusterRedirectionPolicy PublicClient workflowserviceclient.Interface ArchivalMetadata archiver.ArchivalMetadata ArchiverProvider provider.ArchiverProvider Authorizer authorization.Authorizer // NOTE: this can be nil. If nil, AccessControlledHandlerImpl will initiate one with config.Authorization AuthorizationConfig config.Authorization // NOTE: empty(default) struct will get a authorization.NoopAuthorizer IsolationGroupStore configstore.Client // This can be nil, the default config store will be created if so IsolationGroupState isolationgroup.State // This can be nil, the default state store will be chosen if so Partitioner partition.Partitioner PinotConfig *config.PinotVisibilityConfig KafkaConfig config.KafkaConfig PinotClient pinot.GenericClient OSClient es.GenericClient OSConfig *config.ElasticSearchConfig AsyncWorkflowQueueProvider queue.Provider TimeSource clock.TimeSource // HistoryClientFn is used by integration tests to mock a history client HistoryClientFn func() history.Client // NewPersistenceBeanFn can be used to override the default persistence bean creation in unit tests to avoid DB setup NewPersistenceBeanFn func(persistenceClient.Factory, *persistenceClient.Params, *service.Config) (persistenceClient.Bean, error) }
Params holds the set of parameters needed to initialize common service resources
type Resource ¶
type Resource interface { common.Daemon GetServiceName() string GetHostInfo() membership.HostInfo GetArchivalMetadata() archiver.ArchivalMetadata GetClusterMetadata() cluster.Metadata GetDomainCache() cache.DomainCache GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache GetTimeSource() clock.TimeSource GetPayloadSerializer() persistence.PayloadSerializer GetMetricsClient() metrics.Client GetArchiverProvider() provider.ArchiverProvider GetMessagingClient() messaging.Client GetBlobstoreClient() blobstore.Client GetDomainReplicationQueue() domain.ReplicationQueue // membership infos GetMembershipResolver() membership.Resolver GetSDKClient() workflowserviceclient.Interface GetFrontendRawClient() frontend.Client GetFrontendClient() frontend.Client GetMatchingRawClient() matching.Client GetMatchingClient() matching.Client GetHistoryRawClient() history.Client GetHistoryClient() history.Client GetRatelimiterAggregatorsClient() qrpc.Client GetRemoteAdminClient(cluster string) admin.Client GetRemoteFrontendClient(cluster string) frontend.Client GetClientBean() client.Bean // persistence clients GetDomainManager() persistence.DomainManager GetTaskManager() persistence.TaskManager GetVisibilityManager() persistence.VisibilityManager GetShardManager() persistence.ShardManager GetHistoryManager() persistence.HistoryManager GetExecutionManager(int) (persistence.ExecutionManager, error) GetPersistenceBean() persistenceClient.Bean // GetHostName get host name GetHostName() string // loggers GetLogger() log.Logger GetThrottledLogger() log.Logger // for registering handlers GetDispatcher() *yarpc.Dispatcher // GetIsolationGroupState returns the isolationGroupState GetIsolationGroupState() isolationgroup.State GetPartitioner() partition.Partitioner GetIsolationGroupStore() configstore.Client GetAsyncWorkflowQueueProvider() queue.Provider }
Resource is the interface which expose common resources
type ResourceFactory ¶
type ResourceFactory interface { NewResource(params *Params, serviceName string, serviceConfig *service.Config, ) (resource Resource, err error) }
func NewResourceFactory ¶
func NewResourceFactory() ResourceFactory
type Test ¶
type Test struct { MetricsScope tally.TestScope ClusterMetadata cluster.Metadata DomainCache *cache.MockDomainCache DomainMetricsScopeCache cache.DomainMetricsScopeCache DomainReplicationQueue *domain.MockReplicationQueue TimeSource clock.TimeSource PayloadSerializer persistence.PayloadSerializer MetricsClient metrics.Client ArchivalMetadata *archiver.MockArchivalMetadata ArchiverProvider *provider.MockArchiverProvider BlobstoreClient *blobstore.MockClient MockPayloadSerializer *persistence.MockPayloadSerializer // membership infos MembershipResolver *membership.MockResolver SDKClient *publicservicetest.MockClient FrontendClient *frontend.MockClient MatchingClient *matching.MockClient HistoryClient *history.MockClient RemoteAdminClient *admin.MockClient RemoteFrontendClient *frontend.MockClient ClientBean *client.MockBean MetadataMgr *mocks.MetadataManager TaskMgr *mocks.TaskManager VisibilityMgr *mocks.VisibilityManager ShardMgr *mocks.ShardManager HistoryMgr *mocks.HistoryV2Manager ExecutionMgr *mocks.ExecutionManager PersistenceBean *persistenceClient.MockBean IsolationGroups *isolationgroup.MockState IsolationGroupStore *configstore.MockClient Partitioner *partition.MockPartitioner HostName string Logger log.Logger AsyncWorkflowQueueProvider *queue.MockProvider RatelimiterAggregatorClient rpc.Client // contains filtered or unexported fields }
Test is the test implementation used for testing
func NewTest ¶
func NewTest( t *testing.T, controller *gomock.Controller, serviceMetricsIndex metrics.ServiceIdx, ) *Test
NewTest returns a new test resource instance
func (*Test) GetArchivalMetadata ¶
func (s *Test) GetArchivalMetadata() archiver.ArchivalMetadata
GetArchivalMetadata for testing
func (*Test) GetArchiverProvider ¶
func (s *Test) GetArchiverProvider() provider.ArchiverProvider
GetArchiverProvider for testing
func (*Test) GetAsyncWorkflowQueueProvider ¶ added in v1.2.8
func (*Test) GetBlobstoreClient ¶ added in v0.13.0
GetBlobstoreClient for testing
func (*Test) GetClusterMetadata ¶
GetClusterMetadata for testing
func (*Test) GetDispatcher ¶
func (s *Test) GetDispatcher() *yarpc.Dispatcher
GetDispatcher for testing
func (*Test) GetDomainCache ¶
func (s *Test) GetDomainCache() cache.DomainCache
GetDomainCache for testing
func (*Test) GetDomainManager ¶ added in v0.22.0
func (s *Test) GetDomainManager() persistence.DomainManager
GetMetadataManager for testing
func (*Test) GetDomainMetricsScopeCache ¶ added in v0.14.0
func (s *Test) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache
GetDomainMetricsScopeCache for testing
func (*Test) GetDomainReplicationQueue ¶
func (s *Test) GetDomainReplicationQueue() domain.ReplicationQueue
GetDomainReplicationQueue for testing
func (*Test) GetExecutionManager ¶
func (s *Test) GetExecutionManager( shardID int, ) (persistence.ExecutionManager, error)
GetExecutionManager for testing
func (*Test) GetFrontendClient ¶
GetFrontendClient for testing
func (*Test) GetFrontendRawClient ¶
GetFrontendRawClient for testing
func (*Test) GetHistoryClient ¶
GetHistoryClient for testing
func (*Test) GetHistoryManager ¶
func (s *Test) GetHistoryManager() persistence.HistoryManager
GetHistoryManager for testing
func (*Test) GetHistoryRawClient ¶
GetHistoryRawClient for testing
func (*Test) GetIsolationGroupState ¶ added in v1.2.1
func (s *Test) GetIsolationGroupState() isolationgroup.State
GetIsolationGroupState returns the isolationGroupState for testing
func (*Test) GetIsolationGroupStore ¶ added in v1.2.1
func (s *Test) GetIsolationGroupStore() configstore.Client
GetIsolationGroupStore returns the config store for their isolation-group stores
func (*Test) GetMatchingClient ¶
GetMatchingClient for testing
func (*Test) GetMatchingRawClient ¶
GetMatchingRawClient for testing
func (*Test) GetMembershipResolver ¶ added in v0.24.0
func (s *Test) GetMembershipResolver() membership.Resolver
GetMembershipResolver for testing
func (*Test) GetMessagingClient ¶
GetMessagingClient for testing
func (*Test) GetMetricsClient ¶
GetMetricsClient for testing
func (*Test) GetPartitioner ¶ added in v1.2.1
func (s *Test) GetPartitioner() partition.Partitioner
GetPartitioner returns the partitioner
func (*Test) GetPayloadSerializer ¶
func (s *Test) GetPayloadSerializer() persistence.PayloadSerializer
GetPayloadSerializer for testing
func (*Test) GetPersistenceBean ¶
func (s *Test) GetPersistenceBean() persistenceClient.Bean
GetPersistenceBean for testing
func (*Test) GetRatelimiterAggregatorsClient ¶ added in v1.2.12
func (*Test) GetRemoteAdminClient ¶
GetRemoteAdminClient for testing
func (*Test) GetRemoteFrontendClient ¶
GetRemoteFrontendClient for testing
func (*Test) GetSDKClient ¶
func (s *Test) GetSDKClient() workflowserviceclient.Interface
GetSDKClient for testing
func (*Test) GetShardManager ¶
func (s *Test) GetShardManager() persistence.ShardManager
GetShardManager for testing
func (*Test) GetTaskManager ¶
func (s *Test) GetTaskManager() persistence.TaskManager
GetTaskManager for testing
func (*Test) GetTaskValidator ¶ added in v1.2.6
func (s *Test) GetTaskValidator() taskvalidator.Checker
GetPayloadSerializer for testing
func (*Test) GetThrottledLogger ¶
GetThrottledLogger for testing
func (*Test) GetTimeSource ¶
func (s *Test) GetTimeSource() clock.TimeSource
GetTimeSource for testing
func (*Test) GetVisibilityManager ¶
func (s *Test) GetVisibilityManager() persistence.VisibilityManager
GetVisibilityManager for testing