Documentation
¶
Index ¶
- type CatalogSourceReconciler
- func (r *CatalogSourceReconciler) Filter(ctx context.Context, filter input.Predicate) (input.EntityList, error)
- func (r *CatalogSourceReconciler) Get(ctx context.Context, id deppy.Identifier) *input.Entity
- func (r *CatalogSourceReconciler) GroupBy(ctx context.Context, fn input.GroupByFunction) (input.EntityListMap, error)
- func (r *CatalogSourceReconciler) Iterate(ctx context.Context, fn input.IteratorFunction) error
- func (r *CatalogSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *CatalogSourceReconciler) SetupWithManager(mgr ctrl.Manager) error
- type CatalogSourceReconcilerOption
- type OperatorReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CatalogSourceReconciler ¶
type CatalogSourceReconciler struct {
sync.RWMutex
client.Client
// contains filtered or unexported fields
}
func NewCatalogSourceReconciler ¶
func NewCatalogSourceReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, options ...CatalogSourceReconcilerOption) *CatalogSourceReconciler
func (*CatalogSourceReconciler) Filter ¶
func (r *CatalogSourceReconciler) Filter(ctx context.Context, filter input.Predicate) (input.EntityList, error)
func (*CatalogSourceReconciler) Get ¶
func (r *CatalogSourceReconciler) Get(ctx context.Context, id deppy.Identifier) *input.Entity
func (*CatalogSourceReconciler) GroupBy ¶
func (r *CatalogSourceReconciler) GroupBy(ctx context.Context, fn input.GroupByFunction) (input.EntityListMap, error)
func (*CatalogSourceReconciler) Iterate ¶
func (r *CatalogSourceReconciler) Iterate(ctx context.Context, fn input.IteratorFunction) error
func (*CatalogSourceReconciler) SetupWithManager ¶
func (r *CatalogSourceReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type CatalogSourceReconcilerOption ¶
type CatalogSourceReconcilerOption func(reconciler *CatalogSourceReconciler)
func WithRegistryClient ¶
func WithRegistryClient(registry catalogsource.RegistryClient) CatalogSourceReconcilerOption
func WithUnmanagedCatalogSourceSyncInterval ¶
func WithUnmanagedCatalogSourceSyncInterval(interval time.Duration) CatalogSourceReconcilerOption
type OperatorReconciler ¶
type OperatorReconciler struct {
client.Client
Scheme *runtime.Scheme
Resolver *resolution.OperatorResolver
}
OperatorReconciler reconciles a Operator object
func (*OperatorReconciler) 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 Operator 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.13.1/pkg/reconcile
func (*OperatorReconciler) SetupWithManager ¶
func (r *OperatorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.