clientpool

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Mar 30, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthMode added in v1.1.0

type AuthMode string
const (
	AuthModeTLS           AuthMode = "TLS"
	AuthModeAPIKey        AuthMode = "API_KEY"
	AuthModeNoCredentials AuthMode = "NO_CREDENTIALS"
)

type ClientAuth added in v1.1.0

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

type ClientInfo

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

type ClientPool

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

func New

func (*ClientPool) Close

func (cp *ClientPool) Close()

func (*ClientPool) DialAndUpsertClient added in v1.3.0

func (cp *ClientPool) DialAndUpsertClient(clientOpts sdkclient.Options, clientPoolKey ClientPoolKey, clientAuth ClientAuth) (sdkclient.Client, error)

func (*ClientPool) GetSDKClient

func (cp *ClientPool) GetSDKClient(key ClientPoolKey) (sdkclient.Client, bool)

func (*ClientPool) ParseClientSecret added in v1.3.0

func (cp *ClientPool) ParseClientSecret(
	ctx context.Context,
	secretName string,
	authMode AuthMode,
	opts NewClientOptions,
) (*sdkclient.Options, *ClientPoolKey, *ClientAuth, error)

func (*ClientPool) SetClientForTesting added in v1.3.0

func (cp *ClientPool) SetClientForTesting(key ClientPoolKey, c sdkclient.Client)

SetClientForTesting pre-populates the pool with a stub client, bypassing the network dial. Intended for use in unit tests only.

type ClientPoolKey

type ClientPoolKey struct {
	HostPort   string
	Namespace  string   // Temporal namespace
	SecretName string   // Include secret name in key to invalidate cache when the secret name changes
	AuthMode   AuthMode // Include auth mode in key to invalidate cache when the auth mode changes for the secret
}

type MTLSAuth added in v1.1.0

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

type NewClientOptions

type NewClientOptions struct {
	TemporalNamespace string
	K8sNamespace      string
	Spec              v1alpha1.TemporalConnectionSpec
	Identity          string
}

Jump to

Keyboard shortcuts

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