client

package
v0.23.1 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2021 License: MIT Imports: 34 Imported by: 9

Documentation

Overview

Package client is a generated GoMock package.

Index

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 {
	GetTChannel(name string, address string) (*yarpc.Dispatcher, error)
	GetGRPC(name string, address string) (*yarpc.Dispatcher, error)
}

DispatcherProvider provides a dispatcher 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 

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, 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, largeTimeout 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 

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

GetFrontendClient mocks base method

func (*MockBean) GetHistoryClient added in v0.11.0 

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

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 

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

GetRemoteAdminClient mocks base method

func (*MockBean) GetRemoteFrontendClient added in v0.11.0 

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

GetRemoteFrontendClient mocks base method

func (*MockBean) SetFrontendClient added in v0.11.0 

func (m *MockBean) SetFrontendClient(client frontend.Client)

SetFrontendClient mocks base method

func (*MockBean) SetHistoryClient added in v0.11.0 

func (m *MockBean) SetHistoryClient(client history.Client)

SetHistoryClient mocks base method

func (*MockBean) SetMatchingClient added in v0.11.0 

func (m *MockBean) SetMatchingClient(client matching.Client)

SetMatchingClient mocks base method

func (*MockBean) SetRemoteAdminClient added in v0.11.0 

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

SetRemoteAdminClient mocks base method

func (*MockBean) SetRemoteFrontendClient added in v0.11.0 

func (m *MockBean) SetRemoteFrontendClient(cluster string, client frontend.Client)

SetRemoteFrontendClient 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

Source Files

View all Source files

Directories

Path Synopsis
Package admin is a generated GoMock package.
 Package admin is a generated GoMock package.
Package frontend is a generated GoMock package.
 Package frontend is a generated GoMock package.
Package history is a generated GoMock package.
 Package history is a generated GoMock package.
Package matching is a generated GoMock package.
 Package matching is a generated GoMock package.

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.