Documentation ¶
Index ¶
- func LookupServiceEndpointDescriptor(ctx context.Context, mappings []sed.SEDMapping, ...) ([]v1alpha1.ServiceEndpointDefinitionItem, *v1.Secret, error)
- func PrepareRegisteredService(ctx context.Context, serviceClass v1alpha1.ServiceClass, ...) (v1alpha1.RegisteredService, *v1.Secret, error)
- func ServiceEndpointDefinitionMapping(cli client.Client, obj unstructured.Unstructured, ...) ([]sed.SEDMapping, error)
- type AgentServiceReconciler
- type HandleFunc
- type ServiceClassReconciler
- func (r *ServiceClassReconciler) CreateOrUpdateRegisteredService(ctx context.Context, obj unstructured.Unstructured, ...) error
- func (r *ServiceClassReconciler) DeleteRegisteredService(ctx context.Context, serviceClass v1alpha1.ServiceClass) error
- func (r *ServiceClassReconciler) GetResources(ctx context.Context, serviceClass *v1alpha1.ServiceClass) (*unstructured.UnstructuredList, error)
- func (r *ServiceClassReconciler) HandleRegisteredServices(ctx context.Context, serviceClass *v1alpha1.ServiceClass, ...) error
- func (r *ServiceClassReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ServiceClassReconciler) RunInformer(ctx context.Context, resource schema.GroupVersionResource, ...) error
- func (r *ServiceClassReconciler) SetWatchersForResources(ctx context.Context, serviceClass v1alpha1.ServiceClass) error
- func (r *ServiceClassReconciler) SetupWithManager(mgr ctrl.Manager) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LookupServiceEndpointDescriptor ¶
func LookupServiceEndpointDescriptor(ctx context.Context, mappings []sed.SEDMapping, service unstructured.Unstructured) ([]v1alpha1.ServiceEndpointDefinitionItem, *v1.Secret, error)
func PrepareRegisteredService ¶
func PrepareRegisteredService( ctx context.Context, serviceClass v1alpha1.ServiceClass, mappings []sed.SEDMapping, data unstructured.Unstructured, target_namespace string, ) (v1alpha1.RegisteredService, *v1.Secret, error)
func ServiceEndpointDefinitionMapping ¶
func ServiceEndpointDefinitionMapping(cli client.Client, obj unstructured.Unstructured, serviceClass v1alpha1.ServiceClass) ([]sed.SEDMapping, error)
Types ¶
type AgentServiceReconciler ¶
Agent Service Reconciler reconciles a Agent Service object
func NewAgentServiceReconciler ¶
func NewAgentServiceReconciler(mgr ctrl.Manager) *AgentServiceReconciler
func (*AgentServiceReconciler) SetupWithManager ¶
func (r *AgentServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type HandleFunc ¶
type ServiceClassReconciler ¶
type ServiceClassReconciler struct { client.Client dynamic.Interface // contains filtered or unexported fields }
ServiceClassReconciler reconciles a ServiceClass object
func NewServiceClassReconciler ¶
func NewServiceClassReconciler(mgr ctrl.Manager, strategy primazaiov1alpha1.SynchronizationStrategy) *ServiceClassReconciler
func (*ServiceClassReconciler) CreateOrUpdateRegisteredService ¶
func (r *ServiceClassReconciler) CreateOrUpdateRegisteredService(ctx context.Context, obj unstructured.Unstructured, serviceClass v1alpha1.ServiceClass) error
func (*ServiceClassReconciler) DeleteRegisteredService ¶
func (r *ServiceClassReconciler) DeleteRegisteredService(ctx context.Context, serviceClass v1alpha1.ServiceClass) error
func (*ServiceClassReconciler) GetResources ¶
func (r *ServiceClassReconciler) GetResources(ctx context.Context, serviceClass *v1alpha1.ServiceClass) (*unstructured.UnstructuredList, error)
func (*ServiceClassReconciler) HandleRegisteredServices ¶
func (r *ServiceClassReconciler) HandleRegisteredServices(ctx context.Context, serviceClass *v1alpha1.ServiceClass, services unstructured.UnstructuredList, handleFunc HandleFunc) error
func (*ServiceClassReconciler) Reconcile ¶
func (r *ServiceClassReconciler) 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 ServiceClass 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.0/pkg/reconcile
func (*ServiceClassReconciler) RunInformer ¶
func (r *ServiceClassReconciler) RunInformer(ctx context.Context, resource schema.GroupVersionResource, serviceClass v1alpha1.ServiceClass) error
func (*ServiceClassReconciler) SetWatchersForResources ¶
func (r *ServiceClassReconciler) SetWatchersForResources(ctx context.Context, serviceClass v1alpha1.ServiceClass) error
func (*ServiceClassReconciler) SetupWithManager ¶
func (r *ServiceClassReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.