controllers

Documentation

Index

• func ComputeHash(template *v1alpha1.InstanceTemplate, collisionCount *int32) string
• func GetTargetNodeName(inst *v1alpha1.Instance) (string, error)
• func ReplaceDaemonSetInstanceNodeNameNodeAffinity(affinity *v1alpha1.Affinity, nodeName string) *v1alpha1.Affinity
• type CertificateApprovalReconciler
  • func (r *CertificateApprovalReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CertificateApprovalReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DaemonSetReconciler
  • func (r *DaemonSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DaemonSetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type IPAddressGCReconciler
  • func (r *IPAddressGCReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *IPAddressGCReconciler) SetupWithManager(mgr ctrl.Manager) error
• type LoadBalancerReconciler
  • func (r *LoadBalancerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LoadBalancerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NATGatewayAutoscalerReconciler
  • func (r *NATGatewayAutoscalerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NATGatewayAutoscalerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NATGatewayReconciler
  • func (r *NATGatewayReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NATGatewayReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NetworkIDGCReconciler
  • func (r *NetworkIDGCReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NetworkIDGCReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NetworkInterfaceNATReleaseReconciler
  • func (r *NetworkInterfaceNATReleaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NetworkInterfaceNATReleaseReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NetworkPolicyReconciler
  • func (r *NetworkPolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NetworkPolicyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SchedulerReconciler
  • func (r *SchedulerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SchedulerReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func ComputeHash

func ComputeHash(template *v1alpha1.InstanceTemplate, collisionCount *int32) string

ComputeHash returns a hash value calculated from pod template and a collisionCount to avoid hash collision. The hash will be safe encoded to avoid bad words.

func GetTargetNodeName

func GetTargetNodeName(inst *v1alpha1.Instance) (string, error)

func ReplaceDaemonSetInstanceNodeNameNodeAffinity

func ReplaceDaemonSetInstanceNodeNameNodeAffinity(affinity *v1alpha1.Affinity, nodeName string) *v1alpha1.Affinity

ReplaceDaemonSetInstanceNodeNameNodeAffinity replaces the RequiredDuringSchedulingIgnoredDuringExecution NodeAffinity of the given affinity with a new NodeAffinity that selects the given nodeName. Note that this function assumes that no NodeAffinity conflicts with the selected nodeName.

Types

type CertificateApprovalReconciler

type CertificateApprovalReconciler struct {
	client.Client

	Recognizers []generic.CertificateSigningRequestRecognizer
}

func (*CertificateApprovalReconciler) Reconcile

func (r *CertificateApprovalReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*CertificateApprovalReconciler) SetupWithManager

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

type DaemonSetReconciler

type DaemonSetReconciler struct {
	client.Client
	Expectations *expectations.Expectations
}

func (*DaemonSetReconciler) Reconcile

func (r *DaemonSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*DaemonSetReconciler) SetupWithManager

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

type IPAddressGCReconciler

type IPAddressGCReconciler struct {
	client.Client
	APIReader client.Reader

	AbsenceCache *lru.Cache
}

func (*IPAddressGCReconciler) Reconcile

func (r *IPAddressGCReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*IPAddressGCReconciler) SetupWithManager

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

type LoadBalancerReconciler

type LoadBalancerReconciler struct {
	client.Client
}

func (*LoadBalancerReconciler) Reconcile

func (r *LoadBalancerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LoadBalancerReconciler) SetupWithManager

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

type NATGatewayAutoscalerReconciler

type NATGatewayAutoscalerReconciler struct {
	client.Client
}

func (*NATGatewayAutoscalerReconciler) Reconcile

func (r *NATGatewayAutoscalerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NATGatewayAutoscalerReconciler) SetupWithManager

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

type NATGatewayReconciler

type NATGatewayReconciler struct {
	client.Client
	record.EventRecorder
}

func (*NATGatewayReconciler) Reconcile

func (r *NATGatewayReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NATGatewayReconciler) SetupWithManager

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

type NetworkIDGCReconciler

type NetworkIDGCReconciler struct {
	client.Client
	APIReader client.Reader

	AbsenceCache *lru.Cache
}

func (*NetworkIDGCReconciler) Reconcile

func (r *NetworkIDGCReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkIDGCReconciler) SetupWithManager

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

type NetworkInterfaceNATReleaseReconciler

type NetworkInterfaceNATReleaseReconciler struct {
	client.Client
	APIReader client.Reader

	AbsenceCache *lru.Cache
}

func (*NetworkInterfaceNATReleaseReconciler) Reconcile

func (r *NetworkInterfaceNATReleaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkInterfaceNATReleaseReconciler) SetupWithManager

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

type NetworkPolicyReconciler

type NetworkPolicyReconciler struct {
	client.Client
}

func (*NetworkPolicyReconciler) Reconcile

func (r *NetworkPolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkPolicyReconciler) SetupWithManager

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

type SchedulerReconciler

type SchedulerReconciler struct {
	client.Client
	record.EventRecorder
	Cache *scheduler.Cache
	// contains filtered or unexported fields
}

func (*SchedulerReconciler) Reconcile

func (r *SchedulerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SchedulerReconciler) SetupWithManager

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