temporal

Documentation

Index

• Constants
• 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
• func ScheduleToCreateScheduleRequest(schedule *v1beta1.TemporalSchedule) (*workflowservice.CreateScheduleRequest, error)
• func ScheduleToDeleteScheduleRequest(schedule *v1beta1.TemporalSchedule) *workflowservice.DeleteScheduleRequest
• func ScheduleToUpdateScheduleRequest(schedule *v1beta1.TemporalSchedule) (*workflowservice.UpdateScheduleRequest, error)
• type ClientOption
  • func WithHostPort(hostPort string) ClientOption
  • func WithTLSConfig(cfg *tls.Config) ClientOption
• type ScheduleRange

Constants

const (
	ScheduleClientIdentity = "temporal-operator.temporal.io"
)

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

func ScheduleToCreateScheduleRequest

func ScheduleToCreateScheduleRequest(schedule *v1beta1.TemporalSchedule) (*workflowservice.CreateScheduleRequest, error)

func ScheduleToDeleteScheduleRequest

func ScheduleToDeleteScheduleRequest(schedule *v1beta1.TemporalSchedule) *workflowservice.DeleteScheduleRequest

func ScheduleToUpdateScheduleRequest

func ScheduleToUpdateScheduleRequest(schedule *v1beta1.TemporalSchedule) (*workflowservice.UpdateScheduleRequest, error)

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.

type ScheduleRange

type ScheduleRange interface {
	GetStart() int32
	GetEnd() int32
	GetStep() int32
}