client

package
v1.17.3 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: MIT Imports: 22 Imported by: 0

Documentation

Overview

Package client is a generated GoMock package.

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() historyservice.HistoryServiceClient
	SetHistoryClient(client historyservice.HistoryServiceClient)
	GetMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (matchingservice.MatchingServiceClient, error)
	SetMatchingClient(client matchingservice.MatchingServiceClient)
	GetFrontendClient() workflowservice.WorkflowServiceClient
	SetFrontendClient(client workflowservice.WorkflowServiceClient)
	GetRemoteAdminClient(cluster string) (adminservice.AdminServiceClient, error)
	SetRemoteAdminClient(cluster string, client adminservice.AdminServiceClient)
	GetRemoteFrontendClient(cluster string) (workflowservice.WorkflowServiceClient, error)
}

Bean is a 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() (historyservice.HistoryServiceClient, error)
	NewMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (matchingservice.MatchingServiceClient, error)
	NewFrontendClient(rpcAddress string) (workflowservice.WorkflowServiceClient, error)

	NewHistoryClientWithTimeout(timeout time.Duration) (historyservice.HistoryServiceClient, error)
	NewMatchingClientWithTimeout(namespaceIDToName NamespaceIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration) (matchingservice.MatchingServiceClient, error)
	NewFrontendClientWithTimeout(rpcAddress string, timeout time.Duration, longPollTimeout time.Duration) workflowservice.WorkflowServiceClient
	NewAdminClientWithTimeout(rpcAddress string, timeout time.Duration, largeTimeout time.Duration) adminservice.AdminServiceClient
}

Factory can be used to create RPC clients for temporal services

type FactoryProvider added in v1.11.0 

type FactoryProvider interface {
	NewFactory(
		rpcFactory common.RPCFactory,
		monitor membership.Monitor,
		metricsClient metrics.Client,
		dc *dynamicconfig.Collection,
		numberOfHistoryShards int32,
		logger log.Logger,
		throttledLogger log.Logger,
	) Factory
}

FactoryProvider can be used to provide a customized client Factory implementation.

func NewFactoryProvider added in v1.11.0 

func NewFactoryProvider() FactoryProvider

NewFactoryProvider creates a default implementation of FactoryProvider.

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() v1.WorkflowServiceClient

GetFrontendClient mocks base method.

func (*MockBean) GetHistoryClient added in v0.27.0 

func (m *MockBean) GetHistoryClient() v11.HistoryServiceClient

GetHistoryClient mocks base method.

func (*MockBean) GetMatchingClient added in v0.27.0 

func (m *MockBean) GetMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (v12.MatchingServiceClient, error)

GetMatchingClient mocks base method.

func (*MockBean) GetRemoteAdminClient added in v0.27.0 

func (m *MockBean) GetRemoteAdminClient(cluster string) (v10.AdminServiceClient, error)

GetRemoteAdminClient mocks base method.

func (*MockBean) GetRemoteFrontendClient added in v0.27.0 

func (m *MockBean) GetRemoteFrontendClient(cluster string) (v1.WorkflowServiceClient, error)

GetRemoteFrontendClient mocks base method.

func (*MockBean) SetFrontendClient added in v0.27.0 

func (m *MockBean) SetFrontendClient(client v1.WorkflowServiceClient)

SetFrontendClient mocks base method.

func (*MockBean) SetHistoryClient added in v0.27.0 

func (m *MockBean) SetHistoryClient(client v11.HistoryServiceClient)

SetHistoryClient mocks base method.

func (*MockBean) SetMatchingClient added in v0.27.0 

func (m *MockBean) SetMatchingClient(client v12.MatchingServiceClient)

SetMatchingClient mocks base method.

func (*MockBean) SetRemoteAdminClient added in v0.27.0 

func (m *MockBean) SetRemoteAdminClient(cluster string, client v10.AdminServiceClient)

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

type MockFactory added in v1.14.0 

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

MockFactory is a mock of Factory interface.

func NewMockFactory added in v1.14.0 

func NewMockFactory(ctrl *gomock.Controller) *MockFactory

NewMockFactory creates a new mock instance.

func (*MockFactory) EXPECT added in v1.14.0 

func (m *MockFactory) EXPECT() *MockFactoryMockRecorder

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

func (*MockFactory) NewAdminClientWithTimeout added in v1.14.0 

func (m *MockFactory) NewAdminClientWithTimeout(rpcAddress string, timeout, largeTimeout time.Duration) v10.AdminServiceClient

NewAdminClientWithTimeout mocks base method.

func (*MockFactory) NewFrontendClient added in v1.14.0 

func (m *MockFactory) NewFrontendClient(rpcAddress string) (v1.WorkflowServiceClient, error)

NewFrontendClient mocks base method.

func (*MockFactory) NewFrontendClientWithTimeout added in v1.14.0 

func (m *MockFactory) NewFrontendClientWithTimeout(rpcAddress string, timeout, longPollTimeout time.Duration) v1.WorkflowServiceClient

NewFrontendClientWithTimeout mocks base method.

func (*MockFactory) NewHistoryClient added in v1.14.0 

func (m *MockFactory) NewHistoryClient() (v11.HistoryServiceClient, error)

NewHistoryClient mocks base method.

func (*MockFactory) NewHistoryClientWithTimeout added in v1.14.0 

func (m *MockFactory) NewHistoryClientWithTimeout(timeout time.Duration) (v11.HistoryServiceClient, error)

NewHistoryClientWithTimeout mocks base method.

func (*MockFactory) NewMatchingClient added in v1.14.0 

func (m *MockFactory) NewMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (v12.MatchingServiceClient, error)

NewMatchingClient mocks base method.

func (*MockFactory) NewMatchingClientWithTimeout added in v1.14.0 

func (m *MockFactory) NewMatchingClientWithTimeout(namespaceIDToName NamespaceIDToNameFunc, timeout, longPollTimeout time.Duration) (v12.MatchingServiceClient, error)

NewMatchingClientWithTimeout mocks base method.

type MockFactoryMockRecorder added in v1.14.0 

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

MockFactoryMockRecorder is the mock recorder for MockFactory.

func (*MockFactoryMockRecorder) NewAdminClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewAdminClientWithTimeout(rpcAddress, timeout, largeTimeout interface{}) *gomock.Call

NewAdminClientWithTimeout indicates an expected call of NewAdminClientWithTimeout.

func (*MockFactoryMockRecorder) NewFrontendClient added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewFrontendClient(rpcAddress interface{}) *gomock.Call

NewFrontendClient indicates an expected call of NewFrontendClient.

func (*MockFactoryMockRecorder) NewFrontendClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewFrontendClientWithTimeout(rpcAddress, timeout, longPollTimeout interface{}) *gomock.Call

NewFrontendClientWithTimeout indicates an expected call of NewFrontendClientWithTimeout.

func (*MockFactoryMockRecorder) NewHistoryClient added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewHistoryClient() *gomock.Call

NewHistoryClient indicates an expected call of NewHistoryClient.

func (*MockFactoryMockRecorder) NewHistoryClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewHistoryClientWithTimeout(timeout interface{}) *gomock.Call

NewHistoryClientWithTimeout indicates an expected call of NewHistoryClientWithTimeout.

func (*MockFactoryMockRecorder) NewMatchingClient added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewMatchingClient(namespaceIDToName interface{}) *gomock.Call

NewMatchingClient indicates an expected call of NewMatchingClient.

func (*MockFactoryMockRecorder) NewMatchingClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewMatchingClientWithTimeout(namespaceIDToName, timeout, longPollTimeout interface{}) *gomock.Call

NewMatchingClientWithTimeout indicates an expected call of NewMatchingClientWithTimeout.

type MockFactoryProvider added in v1.14.0 

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

MockFactoryProvider is a mock of FactoryProvider interface.

func NewMockFactoryProvider added in v1.14.0 

func NewMockFactoryProvider(ctrl *gomock.Controller) *MockFactoryProvider

NewMockFactoryProvider creates a new mock instance.

func (*MockFactoryProvider) EXPECT added in v1.14.0 

func (m *MockFactoryProvider) EXPECT() *MockFactoryProviderMockRecorder

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

func (*MockFactoryProvider) NewFactory added in v1.14.0 

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

NewFactory mocks base method.

type MockFactoryProviderMockRecorder added in v1.14.0 

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

MockFactoryProviderMockRecorder is the mock recorder for MockFactoryProvider.

func (*MockFactoryProviderMockRecorder) NewFactory added in v1.14.0 

func (mr *MockFactoryProviderMockRecorder) NewFactory(rpcFactory, monitor, metricsClient, dc, numberOfHistoryShards, logger, throttledLogger interface{}) *gomock.Call

NewFactory indicates an expected call of NewFactory.

type NamespaceIDToNameFunc added in v0.27.0 

type NamespaceIDToNameFunc func(id namespace.ID) (namespace.Name, 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.