client

package
v1.2.13-prerelease10 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2024 License: MIT Imports: 33 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
	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 added in v0.5.0

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

NewClientBean provides a collection of clients

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, 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 added in v0.3.2

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 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) GetHistoryPeers added in v1.2.12

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

GetHistoryPeers 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) SetRemoteAdminClient added in v0.11.0

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

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) GetHistoryPeers added in v1.2.12

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

GetHistoryPeers indicates an expected call of GetHistoryPeers.

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) SetRemoteAdminClient added in v0.11.0

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

SetRemoteAdminClient indicates an expected call of SetRemoteAdminClient.

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.
wrappers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL