controllers

Documentation

Index

• Constants
• type GlobalServiceReconciler
  • func (r *GlobalServiceReconciler) InitializeAzureClient() error
  • func (r *GlobalServiceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *GlobalServiceReconciler) Run(stop <-chan struct{})
  • func (r *GlobalServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KubeClusterManager
  • func (mgr *KubeClusterManager) Run() error
• type KubeClusterReconciler
  • func (r *KubeClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *KubeClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KubeServiceWatcher
  • func (r *KubeServiceWatcher) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *KubeServiceWatcher) SetupWithManager(mgr ctrl.Manager) error
• type RegionalIPConfig
• type ServiceEndpoint

Constants

const (
	// FrontendIPConfigIDTemplate is the template of the frontend IP configuration
	FrontendIPConfigIDTemplate = "/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/loadBalancers/%s/frontendIPConfigurations/%s"
	// BackendPoolIDTemplate is the template of the backend pool
	BackendPoolIDTemplate = "/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/loadBalancers/%s/backendAddressPools/%s"
	// LoadBalancerProbeIDTemplate is the template of the load balancer probe
	LoadBalancerProbeIDTemplate = "/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/loadBalancers/%s/probes/%s"
)

Types

type GlobalServiceReconciler

type GlobalServiceReconciler struct {
	client.Client
	azureclients.AzureConfig
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	LoadBalancerClient    loadbalancerclient.Interface
	PublicIPClient        publicipclient.Interface
	KubeClusterReconciler *KubeClusterReconciler
	AzureConfigSecret     string
	AzureConfigNamespace  string

	JitterPeriod time.Duration
	WorkQueue    workqueue.RateLimitingInterface
}

GlobalServiceReconciler reconciles a GlobalService object

func (*GlobalServiceReconciler) InitializeAzureClient

func (r *GlobalServiceReconciler) InitializeAzureClient() error

func (*GlobalServiceReconciler) Reconcile

func (r *GlobalServiceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*GlobalServiceReconciler) Run

func (r *GlobalServiceReconciler) Run(stop <-chan struct{})

func (*GlobalServiceReconciler) SetupWithManager

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

type KubeClusterManager

type KubeClusterManager struct {
	manager.Manager

	StopChan chan struct{}
}

func (*KubeClusterManager) Run

func (mgr *KubeClusterManager) Run() error

type KubeClusterReconciler

type KubeClusterReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	WorkQueue           workqueue.RateLimitingInterface
	Lock                sync.Mutex
	KubeClusterManagers map[string]*KubeClusterManager
}

KubeClusterReconciler reconciles a KubeCluster object

func (*KubeClusterReconciler) Reconcile

func (r *KubeClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*KubeClusterReconciler) SetupWithManager

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

type KubeServiceWatcher

type KubeServiceWatcher struct {
	client.Client
	Name   string
	Log    logr.Logger
	Scheme *runtime.Scheme

	WorkQueue workqueue.RateLimitingInterface
}

KubeServiceWatcher reconciles a KubeServiceWatcher object

func (*KubeServiceWatcher) Reconcile

func (r *KubeServiceWatcher) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*KubeServiceWatcher) SetupWithManager

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

type RegionalIPConfig

type RegionalIPConfig struct {
	IP       string
	ConfigID string
}

type ServiceEndpoint

type ServiceEndpoint struct {
	Cluster        string
	Namespace      string
	Service        types.NamespacedName
	LoadBalancerIP string
}