controllers

Documentation

Index

• Variables
• func GetImage(apiReader client.Reader, key client.ObjectKey) (string, error)
• func SetupCRBReconciler(mgr manager.Manager) error
• func SetupPodWatcher(mgr ctrl.Manager, ns, name string, ft founat.FoUTunnel, encapSportAuto bool, ...) error
• type AddressBlockReconciler
  • func (r *AddressBlockReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AddressBlockReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AddressPoolReconciler
  • func (r *AddressPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AddressPoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BlockRequestReconciler
  • func (r *BlockRequestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BlockRequestReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BlockRequestWatcher
  • func (r *BlockRequestWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BlockRequestWatcher) SetupWithManager(mgr ctrl.Manager) error
• type EgressReconciler
  • func (r *EgressReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EgressReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EgressWatcher
  • func (r *EgressWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EgressWatcher) SetupWithManager(mgr ctrl.Manager) error

Variables

var (
	ClientPods = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: constants.MetricsNS,
			Subsystem: "egress",
			Name:      "client_pod_count",
			Help:      "the number of client pods which use this egress",
		},
		[]string{"namespace", "egress"},
	)

	ClientPodInfo = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: constants.MetricsNS,
			Subsystem: "egress",
			Name:      "client_pod_info",
			Help:      "information of a client pod which uses this egress",
		},
		[]string{"namespace", "pod", "pod_ip", "interface", "egress", "egress_namespace"},
	)
)

Functions

func GetImage

func GetImage(apiReader client.Reader, key client.ObjectKey) (string, error)

GetImage returns the current pod's container image. This is intended to prepare the image name for EgressReconciler.

func SetupCRBReconciler

func SetupCRBReconciler(mgr manager.Manager) error

SetupCRBReconciler setups ClusterResourceBinding reconciler for coil-controller.

func SetupPodWatcher

func SetupPodWatcher(mgr ctrl.Manager, ns, name string, ft founat.FoUTunnel, encapSportAuto bool, eg founat.Egress, cfg *rest.Config) error

SetupPodWatcher registers pod watching reconciler to mgr.

Types

type AddressBlockReconciler

type AddressBlockReconciler struct {
	Notify chan<- struct{}
}

AddressBlockReconciler watches AddressBlocks and notifies a channel

func (*AddressBlockReconciler) Reconcile

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

Reconcile implements Reconciler interface.

func (*AddressBlockReconciler) SetupWithManager

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

SetupWithManager registers this with the manager.

type AddressPoolReconciler

type AddressPoolReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	Manager ipam.PoolManager
}

AddressPoolReconciler watches child AddressBlocks and pool itself for deletion.

func (*AddressPoolReconciler) Reconcile

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

Reconcile implements Reconciler interface. https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile?tab=doc#Reconciler

func (*AddressPoolReconciler) SetupWithManager

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

SetupWithManager registers this with the manager.

type BlockRequestReconciler

type BlockRequestReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	Manager ipam.PoolManager
}

BlockRequestReconciler reconciles a BlockRequest object

func (*BlockRequestReconciler) Reconcile

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

Reconcile implements Reconciler interface. https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile?tab=doc#Reconciler

func (*BlockRequestReconciler) SetupWithManager

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

SetupWithManager registers this with the manager.

type BlockRequestWatcher

type BlockRequestWatcher struct {
	client.Client
	NodeIPAM ipam.NodeIPAM
	NodeName string
}

BlockRequestWatcher watches BlockRequest status on each node.

func (*BlockRequestWatcher) Reconcile

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

Reconcile implements Reconcile interface. https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile?tab=doc#Watcher

func (*BlockRequestWatcher) SetupWithManager

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

SetupWithManager registers this with the manager.

type EgressReconciler

type EgressReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Image  string
	Port   int32
}

EgressReconciler reconciles a Egress object

func (*EgressReconciler) Reconcile

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

Reconcile implements Reconciler interface. - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*EgressReconciler) SetupWithManager

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

SetupWithManager registers this with the manager.

type EgressWatcher

type EgressWatcher struct {
	client.Client
	NodeName   string
	PodNet     nodenet.PodNetwork
	EgressPort int
}

func (*EgressWatcher) Reconcile

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

Reconcile implements Reconciler interface. - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*EgressWatcher) SetupWithManager

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

SetupWithManager registers this with the manager.