Documentation
¶
Overview ¶
Package controllers implements controllers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type APIServerConnectionReconciler ¶ added in v0.8.0
type APIServerConnectionReconciler struct {
client.Client
Scheme *runtime.Scheme
// ConnectionManager manages the API server connections
ConnectionManager *ConnectionManager
}
APIServerConnectionReconciler reconciles a APIServerConnection object
func (*APIServerConnectionReconciler) SetupWithManager ¶ added in v0.8.0
func (r *APIServerConnectionReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ConnectionManager ¶ added in v0.8.0
ConnectionManager manages API connections
func NewConnectionManager ¶ added in v0.8.0
func NewConnectionManager(client client.Client) *ConnectionManager
NewConnectionManager creates a new connection manager
func (*ConnectionManager) Close ¶ added in v0.8.0
func (m *ConnectionManager) Close() error
Close closes all connections
func (*ConnectionManager) CloseConnection ¶ added in v0.8.0
func (m *ConnectionManager) CloseConnection(name string) error
CloseConnection closes and removes a connection
func (*ConnectionManager) GetOrCreateConnection ¶ added in v0.8.0
func (m *ConnectionManager) GetOrCreateConnection( apiConn *resourcev1alpha1.StreamNativeCloudConnection, creds *resourcev1alpha1.ServiceAccountCredentials, ) (*controllers2.APIConnection, error)
GetOrCreateConnection gets or creates a connection
type FlinkDeploymentReconciler ¶ added in v0.8.0
type FlinkDeploymentReconciler struct {
client.Client
Scheme *runtime.Scheme
ConnectionManager *ConnectionManager
// contains filtered or unexported fields
}
FlinkDeploymentReconciler reconciles a FlinkDeployment object
func (*FlinkDeploymentReconciler) Reconcile ¶ added in v0.8.0
func (r *FlinkDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile handles the reconciliation of FlinkDeployment objects
func (*FlinkDeploymentReconciler) SetupWithManager ¶ added in v0.8.0
func (r *FlinkDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type NotInitializedError ¶ added in v0.8.0
type NotInitializedError struct {
// contains filtered or unexported fields
}
NotInitializedError represents an error when the connection is not fully initialized
func (*NotInitializedError) Error ¶ added in v0.8.0
func (e *NotInitializedError) Error() string
type PulsarConnectionReconciler ¶
type PulsarConnectionReconciler struct {
client.Client
Scheme *runtime.Scheme
Log logr.Logger
Recorder record.EventRecorder
PulsarAdminCreator admin.PulsarAdminCreator
Retryer *utils.ReconcileRetryer
}
PulsarConnectionReconciler reconciles a PulsarConnection object
func (*PulsarConnectionReconciler) Reconcile ¶
func (r *PulsarConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the PulsarConnection object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile
func (*PulsarConnectionReconciler) SetupWithManager ¶
func (r *PulsarConnectionReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
SetupWithManager sets up the controller with the Manager.
type PulsarConnectionRefMapper ¶
type PulsarConnectionRefMapper struct {
}
PulsarConnectionRefMapper maps resource requests to PulsarConnection
type WorkspaceReconciler ¶ added in v0.8.0
type WorkspaceReconciler struct {
client.Client
Scheme *runtime.Scheme
ConnectionManager *ConnectionManager
// contains filtered or unexported fields
}
WorkspaceReconciler reconciles a Workspace object
func (*WorkspaceReconciler) Reconcile ¶ added in v0.8.0
Reconcile handles the reconciliation of Workspace objects
func (*WorkspaceReconciler) SetupWithManager ¶ added in v0.8.0
func (r *WorkspaceReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files