temporal

Documentation

Index

• func GetClusterClient(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster, ...) (temporalclient.Client, error)
• func GetClusterClientTLSConfig(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster) (*tls.Config, error)
• func GetClusterNamespaceClient(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster, ...) (temporalclient.NamespaceClient, error)
• func GetTlSConfigFromSecret(secret *corev1.Secret) (*tls.Config, error)
• func NamespaceToDeleteNamespaceRequest(namespace *v1beta1.TemporalNamespace) *operatorservice.DeleteNamespaceRequest
• func NamespaceToRegisterNamespaceRequest(cluster *v1beta1.TemporalCluster, namespace *v1beta1.TemporalNamespace) *workflowservice.RegisterNamespaceRequest
• func NamespaceToUpdateNamespaceRequest(cluster *v1beta1.TemporalCluster, namespace *v1beta1.TemporalNamespace) *workflowservice.UpdateNamespaceRequest
• type ClientOption
  • func WithHostPort(hostPort string) ClientOption
  • func WithTLSConfig(cfg *tls.Config) ClientOption

Functions

func GetClusterClient

func GetClusterClient(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster, overrides ...ClientOption) (temporalclient.Client, error)

GetClusterClient returns a temporal sdk client for the provider temporal cluster.

func GetClusterClientTLSConfig

func GetClusterClientTLSConfig(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster) (*tls.Config, error)

GetClusterClientTLSConfig returns the tls configuration for the provided temporal cluster.

func GetClusterNamespaceClient

func GetClusterNamespaceClient(ctx context.Context, client client.Client, cluster *v1beta1.TemporalCluster, overrides ...ClientOption) (temporalclient.NamespaceClient, error)

GetClusterNamespaceClient returns a temporal sdk namespace client for the provider temporal cluster.

func GetTlSConfigFromSecret

func GetTlSConfigFromSecret(secret *corev1.Secret) (*tls.Config, error)

GetTlSConfigFromSecret returns a tls.Config from the provided secret. The secret should contain 3 keys: ca.crt, tls.crt and tls.key.

func NamespaceToDeleteNamespaceRequest

func NamespaceToDeleteNamespaceRequest(namespace *v1beta1.TemporalNamespace) *operatorservice.DeleteNamespaceRequest

func NamespaceToRegisterNamespaceRequest

func NamespaceToRegisterNamespaceRequest(cluster *v1beta1.TemporalCluster, namespace *v1beta1.TemporalNamespace) *workflowservice.RegisterNamespaceRequest

func NamespaceToUpdateNamespaceRequest

func NamespaceToUpdateNamespaceRequest(cluster *v1beta1.TemporalCluster, namespace *v1beta1.TemporalNamespace) *workflowservice.UpdateNamespaceRequest

Types

type ClientOption

type ClientOption func(opts *temporalclient.Options)

ClientOption is an override option for temporal sdk client.

func WithHostPort

func WithHostPort(hostPort string) ClientOption

WithHostPort is overriding the client host port.

func WithTLSConfig

func WithTLSConfig(cfg *tls.Config) ClientOption

WithTLSConfig is overriding the client tls config.