client

package
v1.26.1 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: MIT Imports: 24 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
	GetMatchingClient(namespaceIDToName NamespaceIDToNameFunc) (matchingservice.MatchingServiceClient, error)
	GetFrontendClient() workflowservice.WorkflowServiceClient
	GetRemoteAdminClient(string) (adminservice.AdminServiceClient, error)
	SetRemoteAdminClient(string, adminservice.AdminServiceClient)
	GetRemoteFrontendClient(string) (grpc.ClientConnInterface, 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 {
	NewHistoryClientWithTimeout(timeout time.Duration) (historyservice.HistoryServiceClient, error)
	NewMatchingClientWithTimeout(namespaceIDToName NamespaceIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration) (matchingservice.MatchingServiceClient, error)
	NewRemoteFrontendClientWithTimeout(rpcAddress string, timeout time.Duration, longPollTimeout time.Duration) (grpc.ClientConnInterface, workflowservice.WorkflowServiceClient)
	NewLocalFrontendClientWithTimeout(timeout time.Duration, longPollTimeout time.Duration) (grpc.ClientConnInterface, workflowservice.WorkflowServiceClient, error)
	NewRemoteAdminClientWithTimeout(rpcAddress string, timeout time.Duration, largeTimeout time.Duration) adminservice.AdminServiceClient
	NewLocalAdminClientWithTimeout(timeout time.Duration, largeTimeout time.Duration) (adminservice.AdminServiceClient, error)
}

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,
		metricsHandler metrics.Handler,
		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() workflowservice.WorkflowServiceClient

GetFrontendClient mocks base method.

func (*MockBean) GetHistoryClient added in v0.27.0 

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

GetHistoryClient mocks base method.

func (*MockBean) GetMatchingClient added in v0.27.0 

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

GetMatchingClient mocks base method.

func (*MockBean) GetRemoteAdminClient added in v0.27.0 

func (m *MockBean) GetRemoteAdminClient(arg0 string) (adminservice.AdminServiceClient, error)

GetRemoteAdminClient mocks base method.

func (*MockBean) GetRemoteFrontendClient added in v0.27.0 

func (m *MockBean) GetRemoteFrontendClient(arg0 string) (grpc.ClientConnInterface, workflowservice.WorkflowServiceClient, error)

GetRemoteFrontendClient mocks base method.

func (*MockBean) SetRemoteAdminClient added in v0.27.0 

func (m *MockBean) SetRemoteAdminClient(arg0 string, arg1 adminservice.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 any) *gomock.Call

GetMatchingClient indicates an expected call of GetMatchingClient.

func (*MockBeanMockRecorder) GetRemoteAdminClient added in v0.27.0 

func (mr *MockBeanMockRecorder) GetRemoteAdminClient(arg0 any) *gomock.Call

GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.

func (*MockBeanMockRecorder) GetRemoteFrontendClient added in v0.27.0 

func (mr *MockBeanMockRecorder) GetRemoteFrontendClient(arg0 any) *gomock.Call

GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient.

func (*MockBeanMockRecorder) SetRemoteAdminClient added in v0.27.0 

func (mr *MockBeanMockRecorder) SetRemoteAdminClient(arg0, arg1 any) *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) NewHistoryClientWithTimeout added in v1.14.0 

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

NewHistoryClientWithTimeout mocks base method.

func (*MockFactory) NewLocalAdminClientWithTimeout added in v1.18.0 

func (m *MockFactory) NewLocalAdminClientWithTimeout(timeout, largeTimeout time.Duration) (adminservice.AdminServiceClient, error)

NewLocalAdminClientWithTimeout mocks base method.

func (*MockFactory) NewLocalFrontendClientWithTimeout added in v1.18.0 

func (m *MockFactory) NewLocalFrontendClientWithTimeout(timeout, longPollTimeout time.Duration) (grpc.ClientConnInterface, workflowservice.WorkflowServiceClient, error)

NewLocalFrontendClientWithTimeout mocks base method.

func (*MockFactory) NewMatchingClientWithTimeout added in v1.14.0 

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

NewMatchingClientWithTimeout mocks base method.

func (*MockFactory) NewRemoteAdminClientWithTimeout added in v1.18.0 

func (m *MockFactory) NewRemoteAdminClientWithTimeout(rpcAddress string, timeout, largeTimeout time.Duration) adminservice.AdminServiceClient

NewRemoteAdminClientWithTimeout mocks base method.

func (*MockFactory) NewRemoteFrontendClientWithTimeout added in v1.18.0 

func (m *MockFactory) NewRemoteFrontendClientWithTimeout(rpcAddress string, timeout, longPollTimeout time.Duration) (grpc.ClientConnInterface, workflowservice.WorkflowServiceClient)

NewRemoteFrontendClientWithTimeout 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) NewHistoryClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewHistoryClientWithTimeout(timeout any) *gomock.Call

NewHistoryClientWithTimeout indicates an expected call of NewHistoryClientWithTimeout.

func (*MockFactoryMockRecorder) NewLocalAdminClientWithTimeout added in v1.18.0 

func (mr *MockFactoryMockRecorder) NewLocalAdminClientWithTimeout(timeout, largeTimeout any) *gomock.Call

NewLocalAdminClientWithTimeout indicates an expected call of NewLocalAdminClientWithTimeout.

func (*MockFactoryMockRecorder) NewLocalFrontendClientWithTimeout added in v1.18.0 

func (mr *MockFactoryMockRecorder) NewLocalFrontendClientWithTimeout(timeout, longPollTimeout any) *gomock.Call

NewLocalFrontendClientWithTimeout indicates an expected call of NewLocalFrontendClientWithTimeout.

func (*MockFactoryMockRecorder) NewMatchingClientWithTimeout added in v1.14.0 

func (mr *MockFactoryMockRecorder) NewMatchingClientWithTimeout(namespaceIDToName, timeout, longPollTimeout any) *gomock.Call

NewMatchingClientWithTimeout indicates an expected call of NewMatchingClientWithTimeout.

func (*MockFactoryMockRecorder) NewRemoteAdminClientWithTimeout added in v1.18.0 

func (mr *MockFactoryMockRecorder) NewRemoteAdminClientWithTimeout(rpcAddress, timeout, largeTimeout any) *gomock.Call

NewRemoteAdminClientWithTimeout indicates an expected call of NewRemoteAdminClientWithTimeout.

func (*MockFactoryMockRecorder) NewRemoteFrontendClientWithTimeout added in v1.18.0 

func (mr *MockFactoryMockRecorder) NewRemoteFrontendClientWithTimeout(rpcAddress, timeout, longPollTimeout any) *gomock.Call

NewRemoteFrontendClientWithTimeout indicates an expected call of NewRemoteFrontendClientWithTimeout.

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, metricsHandler metrics.Handler, 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, metricsHandler, dc, numberOfHistoryShards, logger, throttledLogger any) *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
Package history is a generated GoMock package.
 Package history is a generated GoMock package.
historytest
Package historytest contains library test functions for history.NewClient that use ahistory task queue manager.
 Package historytest contains library test functions for history.NewClient that use ahistory task queue manager.

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.