client

package
v1.6.7 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2021 License: MIT Imports: 20 Imported by: 0

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(namespaceIDToName NamespaceIDToNameFunc) (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, clusterMetadata cluster.Metadata) (Bean, error)

NewClientBean provides a collection of clients

type Factory 

type Factory interface {
	NewHistoryClient() (history.Client, error)
	NewMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (matching.Client, error)
	NewFrontendClient(rpcAddress string) (frontend.Client, error)

	NewHistoryClientWithTimeout(timeout time.Duration) (history.Client, error)
	NewMatchingClientWithTimeout(namespaceIDToName NamespaceIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration) (matching.Client, error)
	NewFrontendClientWithTimeout(rpcAddress string, timeout time.Duration, longPollTimeout time.Duration) (frontend.Client, error)
	NewAdminClientWithTimeout(rpcAddress string, timeout time.Duration, largeTimeout time.Duration) (admin.Client, error)
}

Factory can be used to create RPC clients for temporal services

func NewRPCClientFactory added in v0.3.2 

func NewRPCClientFactory(
	rpcFactory common.RPCFactory,
	monitor membership.Monitor,
	metricsClient metrics.Client,
	dc *dynamicconfig.Collection,
	numberOfHistoryShards int32,
	logger log.Logger,
) Factory

NewRPCClientFactory creates an instance of client factory that knows how to dispatch RPC calls.

type MockBean added in v0.27.0 

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

MockBean is a mock of Bean interface.

func NewMockBean added in v0.27.0 

func NewMockBean(ctrl *gomock.Controller) *MockBean

NewMockBean creates a new mock instance.

func (*MockBean) EXPECT added in v0.27.0 

func (m *MockBean) EXPECT() *MockBeanMockRecorder

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

func (*MockBean) GetFrontendClient added in v0.27.0 

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

GetFrontendClient mocks base method.

func (*MockBean) GetHistoryClient added in v0.27.0 

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

GetHistoryClient mocks base method.

func (*MockBean) GetMatchingClient added in v0.27.0 

func (m *MockBean) GetMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (matching.Client, error)

GetMatchingClient mocks base method.

func (*MockBean) GetRemoteAdminClient added in v0.27.0 

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

GetRemoteAdminClient mocks base method.

func (*MockBean) GetRemoteFrontendClient added in v0.27.0 

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

GetRemoteFrontendClient mocks base method.

func (*MockBean) SetFrontendClient added in v0.27.0 

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

SetFrontendClient mocks base method.

func (*MockBean) SetHistoryClient added in v0.27.0 

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

SetHistoryClient mocks base method.

func (*MockBean) SetMatchingClient added in v0.27.0 

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

SetMatchingClient mocks base method.

func (*MockBean) SetRemoteAdminClient added in v0.27.0 

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

SetRemoteAdminClient mocks base method.

func (*MockBean) SetRemoteFrontendClient added in v0.27.0 

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

SetRemoteFrontendClient mocks base method.

type MockBeanMockRecorder added in v0.27.0 

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

MockBeanMockRecorder is the mock recorder for MockBean.

func (*MockBeanMockRecorder) GetFrontendClient added in v0.27.0 

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

GetFrontendClient indicates an expected call of GetFrontendClient.

func (*MockBeanMockRecorder) GetHistoryClient added in v0.27.0 

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

GetHistoryClient indicates an expected call of GetHistoryClient.

func (*MockBeanMockRecorder) GetMatchingClient added in v0.27.0 

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

GetMatchingClient indicates an expected call of GetMatchingClient.

func (*MockBeanMockRecorder) GetRemoteAdminClient added in v0.27.0 

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

GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.

func (*MockBeanMockRecorder) GetRemoteFrontendClient added in v0.27.0 

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

GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient.

func (*MockBeanMockRecorder) SetFrontendClient added in v0.27.0 

func (mr *MockBeanMockRecorder) SetFrontendClient(client interface{}) *gomock.Call

SetFrontendClient indicates an expected call of SetFrontendClient.

func (*MockBeanMockRecorder) SetHistoryClient added in v0.27.0 

func (mr *MockBeanMockRecorder) SetHistoryClient(client interface{}) *gomock.Call

SetHistoryClient indicates an expected call of SetHistoryClient.

func (*MockBeanMockRecorder) SetMatchingClient added in v0.27.0 

func (mr *MockBeanMockRecorder) SetMatchingClient(client interface{}) *gomock.Call

SetMatchingClient indicates an expected call of SetMatchingClient.

func (*MockBeanMockRecorder) SetRemoteAdminClient added in v0.27.0 

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

SetRemoteAdminClient indicates an expected call of SetRemoteAdminClient.

func (*MockBeanMockRecorder) SetRemoteFrontendClient added in v0.27.0 

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

SetRemoteFrontendClient indicates an expected call of SetRemoteFrontendClient.

type NamespaceIDToNameFunc added in v0.27.0 

type NamespaceIDToNameFunc func(string) (string, error)

NamespaceIDToNameFunc maps a namespaceID to namespace name. Returns error when mapping is not possible.

Source Files

View all Source files

Directories

Path Synopsis

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.