Documentation ¶
Overview ¶
Package client is a generated GoMock package.
Index ¶
- type Bean
- type DispatcherProvider
- type DomainIDToNameFunc
- type Factory
- type MockBean
- func (m *MockBean) EXPECT() *MockBeanMockRecorder
- func (m *MockBean) GetFrontendClient() frontend.Client
- func (m *MockBean) GetHistoryClient() history.Client
- func (m *MockBean) GetMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error)
- func (m *MockBean) GetRemoteAdminClient(cluster string) admin.Client
- func (m *MockBean) GetRemoteFrontendClient(cluster string) frontend.Client
- func (m *MockBean) SetFrontendClient(client frontend.Client)
- func (m *MockBean) SetHistoryClient(client history.Client)
- func (m *MockBean) SetMatchingClient(client matching.Client)
- func (m *MockBean) SetRemoteAdminClient(cluster string, client admin.Client)
- func (m *MockBean) SetRemoteFrontendClient(cluster string, client frontend.Client)
- type MockBeanMockRecorder
- func (mr *MockBeanMockRecorder) GetFrontendClient() *gomock.Call
- func (mr *MockBeanMockRecorder) GetHistoryClient() *gomock.Call
- func (mr *MockBeanMockRecorder) GetMatchingClient(domainIDToName interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetFrontendClient(client interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetHistoryClient(client interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetMatchingClient(client interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetRemoteAdminClient(cluster, client interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetRemoteFrontendClient(cluster, client interface{}) *gomock.Call
- type MockDispatcherProvider
- type MockDispatcherProviderMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bean ¶ added in v0.5.0
type Bean interface { GetHistoryClient() history.Client SetHistoryClient(client history.Client) GetMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error) SetMatchingClient(client matching.Client) GetFrontendClient() frontend.Client SetFrontendClient(client frontend.Client) GetRemoteAdminClient(cluster string) admin.Client SetRemoteAdminClient(cluster string, client admin.Client) GetRemoteFrontendClient(cluster string) frontend.Client SetRemoteFrontendClient(cluster string, client frontend.Client) }
Bean in an collection of clients
func NewClientBean ¶ added in v0.5.0
func NewClientBean(factory Factory, dispatcherProvider DispatcherProvider, clusterMetadata cluster.Metadata) (Bean, error)
NewClientBean provides a collection of clients
type DispatcherProvider ¶ added in v0.5.0
type DispatcherProvider interface {
Get(name string, address string) (*yarpc.Dispatcher, error)
}
DispatcherProvider provides a diapatcher to a given address
func NewDNSYarpcDispatcherProvider ¶ added in v0.6.0
func NewDNSYarpcDispatcherProvider(logger log.Logger, interval time.Duration) DispatcherProvider
NewDNSYarpcDispatcherProvider create a dispatcher provider which handles with IP address
type DomainIDToNameFunc ¶ added in v0.7.0
DomainIDToNameFunc maps a domainID to domain name. Returns error when mapping is not possible.
type Factory ¶
type Factory interface { NewHistoryClient() (history.Client, error) NewMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error) NewFrontendClient() (frontend.Client, error) NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, error) NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration) (matching.Client, error) NewFrontendClientWithTimeout(timeout time.Duration, longPollTimeout time.Duration) (frontend.Client, error) NewAdminClientWithTimeoutAndDispatcher(rpcName string, timeout time.Duration, dispatcher *yarpc.Dispatcher) (admin.Client, error) NewFrontendClientWithTimeoutAndDispatcher(rpcName string, timeout time.Duration, longPollTimeout time.Duration, dispatcher *yarpc.Dispatcher) (frontend.Client, error) }
Factory can be used to create RPC clients for cadence services
func NewRPCClientFactory ¶ added in v0.3.2
func NewRPCClientFactory( rpcFactory common.RPCFactory, monitor membership.Monitor, metricsClient metrics.Client, dc *dynamicconfig.Collection, numberOfHistoryShards int, logger log.Logger, ) Factory
NewRPCClientFactory creates an instance of client factory that knows how to dispatch RPC calls.
type MockBean ¶ added in v0.11.0
type MockBean struct {
// contains filtered or unexported fields
}
MockBean is a mock of Bean interface
func NewMockBean ¶ added in v0.11.0
func NewMockBean(ctrl *gomock.Controller) *MockBean
NewMockBean creates a new mock instance
func (*MockBean) EXPECT ¶ added in v0.11.0
func (m *MockBean) EXPECT() *MockBeanMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBean) GetFrontendClient ¶ added in v0.11.0
GetFrontendClient mocks base method
func (*MockBean) GetHistoryClient ¶ added in v0.11.0
GetHistoryClient mocks base method
func (*MockBean) GetMatchingClient ¶ added in v0.11.0
func (m *MockBean) GetMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error)
GetMatchingClient mocks base method
func (*MockBean) GetRemoteAdminClient ¶ added in v0.11.0
GetRemoteAdminClient mocks base method
func (*MockBean) GetRemoteFrontendClient ¶ added in v0.11.0
GetRemoteFrontendClient mocks base method
func (*MockBean) SetFrontendClient ¶ added in v0.11.0
SetFrontendClient mocks base method
func (*MockBean) SetHistoryClient ¶ added in v0.11.0
SetHistoryClient mocks base method
func (*MockBean) SetMatchingClient ¶ added in v0.11.0
SetMatchingClient mocks base method
func (*MockBean) SetRemoteAdminClient ¶ added in v0.11.0
SetRemoteAdminClient mocks base method
type MockBeanMockRecorder ¶ added in v0.11.0
type MockBeanMockRecorder struct {
// contains filtered or unexported fields
}
MockBeanMockRecorder is the mock recorder for MockBean
func (*MockBeanMockRecorder) GetFrontendClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) GetFrontendClient() *gomock.Call
GetFrontendClient indicates an expected call of GetFrontendClient
func (*MockBeanMockRecorder) GetHistoryClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) GetHistoryClient() *gomock.Call
GetHistoryClient indicates an expected call of GetHistoryClient
func (*MockBeanMockRecorder) GetMatchingClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) GetMatchingClient(domainIDToName interface{}) *gomock.Call
GetMatchingClient indicates an expected call of GetMatchingClient
func (*MockBeanMockRecorder) GetRemoteAdminClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient
func (*MockBeanMockRecorder) GetRemoteFrontendClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call
GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient
func (*MockBeanMockRecorder) SetFrontendClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) SetFrontendClient(client interface{}) *gomock.Call
SetFrontendClient indicates an expected call of SetFrontendClient
func (*MockBeanMockRecorder) SetHistoryClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) SetHistoryClient(client interface{}) *gomock.Call
SetHistoryClient indicates an expected call of SetHistoryClient
func (*MockBeanMockRecorder) SetMatchingClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) SetMatchingClient(client interface{}) *gomock.Call
SetMatchingClient indicates an expected call of SetMatchingClient
func (*MockBeanMockRecorder) SetRemoteAdminClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) SetRemoteAdminClient(cluster, client interface{}) *gomock.Call
SetRemoteAdminClient indicates an expected call of SetRemoteAdminClient
func (*MockBeanMockRecorder) SetRemoteFrontendClient ¶ added in v0.11.0
func (mr *MockBeanMockRecorder) SetRemoteFrontendClient(cluster, client interface{}) *gomock.Call
SetRemoteFrontendClient indicates an expected call of SetRemoteFrontendClient
type MockDispatcherProvider ¶ added in v0.11.0
type MockDispatcherProvider struct {
// contains filtered or unexported fields
}
MockDispatcherProvider is a mock of DispatcherProvider interface
func NewMockDispatcherProvider ¶ added in v0.11.0
func NewMockDispatcherProvider(ctrl *gomock.Controller) *MockDispatcherProvider
NewMockDispatcherProvider creates a new mock instance
func (*MockDispatcherProvider) EXPECT ¶ added in v0.11.0
func (m *MockDispatcherProvider) EXPECT() *MockDispatcherProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockDispatcherProvider) Get ¶ added in v0.11.0
func (m *MockDispatcherProvider) Get(name, address string) (*yarpc.Dispatcher, error)
Get mocks base method
type MockDispatcherProviderMockRecorder ¶ added in v0.11.0
type MockDispatcherProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockDispatcherProviderMockRecorder is the mock recorder for MockDispatcherProvider
func (*MockDispatcherProviderMockRecorder) Get ¶ added in v0.11.0
func (mr *MockDispatcherProviderMockRecorder) Get(name, address interface{}) *gomock.Call
Get indicates an expected call of Get