client

Documentation

Overview

Package client is a generated GoMock package.

Index

• type Bean
  • func NewClientBean(factory Factory, dispatcher *yarpc.Dispatcher, ...) (Bean, error)
• type DomainIDToNameFunc
• type Factory
  • func NewRPCClientFactory(rpcFactory common.RPCFactory, resolver membership.Resolver, ...) Factory
• type MockBean
  • func NewMockBean(ctrl *gomock.Controller) *MockBean
  • func (m *MockBean) EXPECT() *MockBeanMockRecorder
  • func (m *MockBean) GetFrontendClient() frontend.Client
  • func (m *MockBean) GetHistoryClient() history.Client
  • func (m *MockBean) GetHistoryPeers() history.PeerResolver
  • 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) SetRemoteAdminClient(cluster string, client admin.Client)
• type MockBeanMockRecorder
  • func (mr *MockBeanMockRecorder) GetFrontendClient() *gomock.Call
  • func (mr *MockBeanMockRecorder) GetHistoryClient() *gomock.Call
  • func (mr *MockBeanMockRecorder) GetHistoryPeers() *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) SetRemoteAdminClient(cluster, client interface{}) *gomock.Call

Types

type Bean

type Bean interface {
	GetHistoryClient() history.Client
	GetHistoryPeers() history.PeerResolver
	GetMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error)
	GetFrontendClient() frontend.Client
	GetRemoteAdminClient(cluster string) admin.Client
	SetRemoteAdminClient(cluster string, client admin.Client)
	GetRemoteFrontendClient(cluster string) frontend.Client
}

Bean in an collection of clients

func NewClientBean

func NewClientBean(factory Factory, dispatcher *yarpc.Dispatcher, clusterMetadata cluster.Metadata) (Bean, error)

NewClientBean provides a collection of clients

type DomainIDToNameFunc

type DomainIDToNameFunc func(string) (string, error)

DomainIDToNameFunc maps a domainID to domain name. Returns error when mapping is not possible.

type Factory

type Factory interface {
	NewHistoryClient() (history.Client, history.PeerResolver, error)
	NewMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error)

	NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, history.PeerResolver, error)
	NewMatchingClientWithTimeout(domainIDToName DomainIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration) (matching.Client, error)

	NewAdminClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, largeTimeout time.Duration) (admin.Client, error)
	NewFrontendClientWithTimeoutAndConfig(config transport.ClientConfig, timeout time.Duration, longPollTimeout time.Duration) (frontend.Client, error)
}

Factory can be used to create RPC clients for cadence services

func NewRPCClientFactory

func NewRPCClientFactory(
	rpcFactory common.RPCFactory,
	resolver membership.Resolver,
	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

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

MockBean is a mock of Bean interface.

func NewMockBean

func NewMockBean(ctrl *gomock.Controller) *MockBean

NewMockBean creates a new mock instance.

func (*MockBean) EXPECT

func (m *MockBean) EXPECT() *MockBeanMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBean) GetFrontendClient

func (m *MockBean) GetFrontendClient() frontend.Client

GetFrontendClient mocks base method.

func (*MockBean) GetHistoryClient

func (m *MockBean) GetHistoryClient() history.Client

GetHistoryClient mocks base method.

func (*MockBean) GetHistoryPeers

func (m *MockBean) GetHistoryPeers() history.PeerResolver

GetHistoryPeers mocks base method.

func (*MockBean) GetMatchingClient

func (m *MockBean) GetMatchingClient(domainIDToName DomainIDToNameFunc) (matching.Client, error)

GetMatchingClient mocks base method.

func (*MockBean) GetRemoteAdminClient

func (m *MockBean) GetRemoteAdminClient(cluster string) admin.Client

GetRemoteAdminClient mocks base method.

func (*MockBean) GetRemoteFrontendClient

func (m *MockBean) GetRemoteFrontendClient(cluster string) frontend.Client

GetRemoteFrontendClient mocks base method.

func (*MockBean) SetRemoteAdminClient

func (m *MockBean) SetRemoteAdminClient(cluster string, client admin.Client)

SetRemoteAdminClient mocks base method.

type MockBeanMockRecorder

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

MockBeanMockRecorder is the mock recorder for MockBean.

func (*MockBeanMockRecorder) GetFrontendClient

func (mr *MockBeanMockRecorder) GetFrontendClient() *gomock.Call

GetFrontendClient indicates an expected call of GetFrontendClient.

func (*MockBeanMockRecorder) GetHistoryClient

func (mr *MockBeanMockRecorder) GetHistoryClient() *gomock.Call

GetHistoryClient indicates an expected call of GetHistoryClient.

func (*MockBeanMockRecorder) GetHistoryPeers

func (mr *MockBeanMockRecorder) GetHistoryPeers() *gomock.Call

GetHistoryPeers indicates an expected call of GetHistoryPeers.

func (*MockBeanMockRecorder) GetMatchingClient

func (mr *MockBeanMockRecorder) GetMatchingClient(domainIDToName interface{}) *gomock.Call

GetMatchingClient indicates an expected call of GetMatchingClient.

func (*MockBeanMockRecorder) GetRemoteAdminClient

func (mr *MockBeanMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call

GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.

func (*MockBeanMockRecorder) GetRemoteFrontendClient

func (mr *MockBeanMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call

GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient.

func (*MockBeanMockRecorder) SetRemoteAdminClient

func (mr *MockBeanMockRecorder) SetRemoteAdminClient(cluster, client interface{}) *gomock.Call

SetRemoteAdminClient indicates an expected call of SetRemoteAdminClient.