client

package
v1.12.3 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 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() 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
	SetRemoteAdminClient(cluster string, client adminservice.AdminServiceClient)
	GetRemoteFrontendClient(cluster string) workflowservice.WorkflowServiceClient
	SetRemoteFrontendClient(cluster string, client workflowservice.WorkflowServiceClient)
}

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() (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, error)
	NewAdminClientWithTimeout(rpcAddress string, 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,
		metricsClient metrics.Client,
		dc *dynamicconfig.Collection,
		numberOfHistoryShards int32,
		logger 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

GetRemoteAdminClient mocks base method.

func (*MockBean) GetRemoteFrontendClient added in v0.27.0 

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

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.

func (*MockBean) SetRemoteFrontendClient added in v0.27.0 

func (m *MockBean) SetRemoteFrontendClient(cluster string, client v1.WorkflowServiceClient)

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.