discoverymanager

Documentation

Overview

Package discoverymanager implements the utility functions for the discovery manager controller

Index

• Constants
• Variables
• type DiscoveryReconciler
  • func (r *DiscoveryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DiscoveryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PCValidator
  • func NewPCValidator(c client.Client) *PCValidator
  • func (v *PCValidator) DecodePeeringCandidate(obj runtime.RawExtension) (pc *advertisementv1alpha1.PeeringCandidate, err error)
  • func (v *PCValidator) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (v *PCValidator) HandleCreate(_ context.Context, req admission.Request) admission.Response
  • func (v *PCValidator) HandleDelete(_ context.Context, req admission.Request) admission.Response
  • func (v *PCValidator) HandleUpdate(_ context.Context, req admission.Request) admission.Response

Constants

const (
	SERVER_ADDR       = "http://localhost:14144/api"
	K8S_TYPE          = "k8s-fluidos"
	DEFAULT_NAMESPACE = "default"
	CLIENT_ID         = "topix.fluidos.eu"
)

Variables

var (
	SERVER_ADDRESSES = []string{"http://localhost:14144/api"}
)

We define different server addresses, much more dynamic and less hardcoded

Types

type DiscoveryReconciler

type DiscoveryReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	Gateway *gateway.Gateway
}

DiscoveryReconciler reconciles a Discovery object.

func (*DiscoveryReconciler) Reconcile

func (r *DiscoveryReconciler) 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.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile

func (*DiscoveryReconciler) SetupWithManager

func (r *DiscoveryReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PCValidator

type PCValidator struct {
	// contains filtered or unexported fields
}

PCValidator is the PeerinCandidate validator.

func NewPCValidator

func NewPCValidator(c client.Client) *PCValidator

NewPCValidator creates a new PCValidator.

func (*PCValidator) DecodePeeringCandidate

func (v *PCValidator) DecodePeeringCandidate(obj runtime.RawExtension) (pc *advertisementv1alpha1.PeeringCandidate, err error)

DecodePeeringCandidate decodes the PeeringCandidate.

func (*PCValidator) Handle

func (v *PCValidator) Handle(ctx context.Context, req admission.Request) admission.Response

Handle manages the validation of the PeeringCandidate.

func (*PCValidator) HandleCreate

func (v *PCValidator) HandleCreate(_ context.Context, req admission.Request) admission.Response

HandleCreate manages the validation of the PeeringCandidate creation.

func (*PCValidator) HandleDelete

func (v *PCValidator) HandleDelete(_ context.Context, req admission.Request) admission.Response

HandleDelete manages the validation of the PeeringCandidate deletion.

func (*PCValidator) HandleUpdate

func (v *PCValidator) HandleUpdate(_ context.Context, req admission.Request) admission.Response

HandleUpdate manages the validation of the PeeringCandidate update.