Documentation
¶
Index ¶
- func GetUpdateSyncGroup(conduit *meridiov1.Conduit) string
- type ConduitReconciler
- func (r *ConduitReconciler) GetUpdateLocks() map[string]string
- func (r *ConduitReconciler) GetUpdateSyncGroups() map[string]string
- func (r *ConduitReconciler) HandleConduitDeletion(name, namespace string)
- func (r *ConduitReconciler) HasLock(updateSyncGroup, owner string) bool
- func (r *ConduitReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ConduitReconciler) SetupWithManager(mgr ctrl.Manager) error
- type Proxy
- type ProxyModelLoader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetUpdateSyncGroup ¶ added in v1.1.7
Types ¶
type ConduitReconciler ¶
type ConduitReconciler struct {
client.Client
APIReader client.Reader // reader contacting the API server directly bypassing the local cache
Log logr.Logger
Scheme *runtime.Scheme
ProxyModelLoader ProxyModelLoader // optional; change how proxy loads its model
// contains filtered or unexported fields
}
ConduitReconciler reconciles a Conduit object
func (*ConduitReconciler) GetUpdateLocks ¶ added in v1.1.7
func (r *ConduitReconciler) GetUpdateLocks() map[string]string
GetUpdateLocks returns a new map of update sync group names to lock owners
func (*ConduitReconciler) GetUpdateSyncGroups ¶ added in v1.1.7
func (r *ConduitReconciler) GetUpdateSyncGroups() map[string]string
GetUpdateSyncGroups returns a new map of conduit names to update sync groups
func (*ConduitReconciler) HandleConduitDeletion ¶ added in v1.1.7
func (r *ConduitReconciler) HandleConduitDeletion(name, namespace string)
HandleConduitDeletion wraps cleanupLock making it available for unit tests
func (*ConduitReconciler) HasLock ¶ added in v1.1.7
func (r *ConduitReconciler) HasLock(updateSyncGroup, owner string) bool
Check if owner has locked the update sync group
func (*ConduitReconciler) Reconcile ¶
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 Conduit 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.8.3/pkg/reconcile
func (*ConduitReconciler) SetupWithManager ¶
func (r *ConduitReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files