clientpool

package

v1.3.1 Latest Latest Go to latest Published: Mar 20, 2026 License: MIT Imports: 14 Imported by: 0

Documentation ¶

Index ¶

type AuthMode
type ClientAuth
type ClientInfo
type ClientPool
- func New(l log.Logger, c runtimeclient.Client) *ClientPool
type ClientPoolKey
type MTLSAuth
type NewClientOptions

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 New(l log.Logger, c runtimeclient.Client) *ClientPool

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
}

Source Files ¶

View all Source files

clientpool.go

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