Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrTargetNotFound = errors.New("temporal target not found")
ErrTargetNotFound indicates the referenced TemporalCluster or TemporalDevServer object does not exist.
Functions ¶
This section is empty.
Types ¶
type ResolvedTarget ¶ added in v0.6.0
type ResolvedTarget struct {
// Address is the gRPC frontend address (host:port).
Address string
// TLSConfig is the client TLS config, or nil for plaintext (dev server).
TLSConfig *tls.Config
// Ready reports whether the referenced target's Ready condition is true.
Ready bool
}
ResolvedTarget describes how to reach the Temporal frontend named by a ClusterReference.
type TemporalClusterClientReconciler ¶
TemporalClusterClientReconciler reconciles TemporalClusterClient objects by issuing client certificates from the referenced cluster's mTLS issuer.
func (*TemporalClusterClientReconciler) Reconcile ¶
func (r *TemporalClusterClientReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile issues a client certificate for the TemporalClusterClient.
func (*TemporalClusterClientReconciler) SetupWithManager ¶
func (r *TemporalClusterClientReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalClusterConnectionReconciler ¶ added in v0.9.0
type TemporalClusterConnectionReconciler struct {
client.Client
Scheme *runtime.Scheme
// ClientFactory builds the Temporal remote-cluster client; injectable for tests.
ClientFactory temporal.RemoteClusterClientFactory
}
TemporalClusterConnectionReconciler automates remote-cluster connection registration between the peers of a TemporalClusterConnection. For every local, ready peer it dials the Temporal operator API and upserts the other peers as remote clusters, driving the replication group toward the declared topology.
func (*TemporalClusterConnectionReconciler) Reconcile ¶ added in v0.9.0
func (r *TemporalClusterConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile registers each local, ready peer as a remote cluster on the others.
func (*TemporalClusterConnectionReconciler) SetupWithManager ¶ added in v0.9.0
func (r *TemporalClusterConnectionReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalClusterReconciler ¶
type TemporalClusterReconciler struct {
client.Client
Scheme *runtime.Scheme
Recorder events.EventRecorder
// BackendFactory builds datastore backends and is injectable for testing;
// when nil the default real implementation is used.
BackendFactory persistence.BackendFactory
// OperatorImage is the operator's own image, used for inspector Jobs.
// Populated from OPERATOR_IMAGE env by cmd/main.go.
OperatorImage string
}
TemporalClusterReconciler reconciles a TemporalCluster object.
func (*TemporalClusterReconciler) Reconcile ¶
func (r *TemporalClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile drives the TemporalCluster toward its desired state. At this milestone it reconciles persistence (reachability + schema) and reports the remaining work as not-yet-implemented via the Ready condition.
func (*TemporalClusterReconciler) SetupWithManager ¶
func (r *TemporalClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalDevServerReconciler ¶ added in v0.6.0
TemporalDevServerReconciler reconciles TemporalDevServer objects into a single-pod dev server Deployment + Service (+ optional PVC).
func (*TemporalDevServerReconciler) Reconcile ¶ added in v0.6.0
func (r *TemporalDevServerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile applies the dev server resources and updates status.
func (*TemporalDevServerReconciler) SetupWithManager ¶ added in v0.6.0
func (r *TemporalDevServerReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalNamespaceReconciler ¶
type TemporalNamespaceReconciler struct {
client.Client
Scheme *runtime.Scheme
// ClientFactory builds the Temporal namespace client; injectable for tests.
ClientFactory temporal.NamespaceClientFactory
}
TemporalNamespaceReconciler reconciles TemporalNamespace objects against a running Temporal cluster.
func (*TemporalNamespaceReconciler) Reconcile ¶
func (r *TemporalNamespaceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile registers, updates, or deletes a Temporal namespace.
func (*TemporalNamespaceReconciler) SetupWithManager ¶
func (r *TemporalNamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalScheduleReconciler ¶ added in v0.5.0
type TemporalScheduleReconciler struct {
client.Client
Scheme *runtime.Scheme
// ClientFactory builds the Temporal schedule client; injectable for tests.
ClientFactory temporal.ScheduleClientFactory
}
TemporalScheduleReconciler reconciles TemporalSchedule objects.
func (*TemporalScheduleReconciler) Reconcile ¶ added in v0.5.0
func (r *TemporalScheduleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile creates, updates, pauses, or deletes a Temporal schedule.
func (*TemporalScheduleReconciler) SetupWithManager ¶ added in v0.5.0
func (r *TemporalScheduleReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type TemporalSearchAttributeReconciler ¶
type TemporalSearchAttributeReconciler struct {
client.Client
Scheme *runtime.Scheme
// ClientFactory builds the Temporal search-attribute client; injectable for tests.
ClientFactory temporal.SearchAttributeClientFactory
}
TemporalSearchAttributeReconciler reconciles TemporalSearchAttribute objects.
func (*TemporalSearchAttributeReconciler) Reconcile ¶
func (r *TemporalSearchAttributeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile registers or removes a custom search attribute.
func (*TemporalSearchAttributeReconciler) SetupWithManager ¶
func (r *TemporalSearchAttributeReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files
¶
- apply.go
- target.go
- temporal_tls.go
- temporalcluster_controller.go
- temporalcluster_monitoring.go
- temporalcluster_mtls.go
- temporalcluster_persistence.go
- temporalcluster_services.go
- temporalcluster_ui.go
- temporalcluster_upgrade.go
- temporalclusterclient_controller.go
- temporalclusterconnection_controller.go
- temporaldevserver_controller.go
- temporalnamespace_controller.go
- temporalschedule_controller.go
- temporalsearchattribute_controller.go