controllers

Documentation

Index

• type InjectProxyReconciler
  • func NewInjectProxyReconciler(client client.Client, log loggerutil.OSOKLogger, ...) *InjectProxyReconciler
  • func (r *InjectProxyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *InjectProxyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ServiceReconciler
  • func NewServiceReconciler(log loggerutil.OSOKLogger, handler serviceupdate.ResourceHandler) *ServiceReconciler
  • func (r *ServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type UpdateConfigMapController
  • func NewUpdateConfigMapController(client client.Client, handler updateconfigmap.ResourceHandler, ...) *UpdateConfigMapController
  • func (c *UpdateConfigMapController) PollServiceMeshProxyDetailEndpoint(ctx context.Context) error
  • func (c *UpdateConfigMapController) SetupWithManager(mgr ctrl.Manager) error
  • func (c *UpdateConfigMapController) UpdateClientHostEndpoints(ctx context.Context)
• type UpgradeProxyReconciler
  • func NewUpgradeProxyReconciler(client client.Client, log loggerutil.OSOKLogger, ...) *UpgradeProxyReconciler
  • func (r *UpgradeProxyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *UpgradeProxyReconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type InjectProxyReconciler

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

func NewInjectProxyReconciler

func NewInjectProxyReconciler(
	client client.Client,
	log loggerutil.OSOKLogger,
	handler injectproxy.ResourceHandler,
) *InjectProxyReconciler

func (*InjectProxyReconciler) Reconcile

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

Reconcile will keep a watch on namespaces with proxy injection label present and inject proxies initially by evicting the pods

func (*InjectProxyReconciler) SetupWithManager

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

type ServiceReconciler

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

ServiceReconciler reconciles a Service object

func NewServiceReconciler

func NewServiceReconciler(
	log loggerutil.OSOKLogger,
	handler serviceupdate.ResourceHandler) *ServiceReconciler

func (*ServiceReconciler) Reconcile

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

This reconcile is to handle a case where label selectors on the service are changed if existing pods appear to have matched the VDBs for the updated service this controller will evict such pods

func (*ServiceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type UpdateConfigMapController

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

UpdateConfigMapController helps in updating the ConfigMap with latest proxy details

func NewUpdateConfigMapController

func NewUpdateConfigMapController(
	client client.Client,
	handler updateconfigmap.ResourceHandler,
	log loggerutil.OSOKLogger,
	namespace string) *UpdateConfigMapController

func (*UpdateConfigMapController) PollServiceMeshProxyDetailEndpoint

func (c *UpdateConfigMapController) PollServiceMeshProxyDetailEndpoint(ctx context.Context) error

PollServiceMeshProxyDetailEndpoint polls the proxy detail endpoint via the resource handler

func (*UpdateConfigMapController) SetupWithManager

func (c *UpdateConfigMapController) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager. Triggers a function to poll the mesh control plane every ten minutes to check for the latest proxy version Additionally trigger functions to check service mesh configmap for updated CP endpoints and set them in the clients

func (*UpdateConfigMapController) UpdateClientHostEndpoints

func (c *UpdateConfigMapController) UpdateClientHostEndpoints(ctx context.Context)

UpdateClientHostEndpoints polls the global configmap and updates the CP and MDS client hosts if endpoints have changed

type UpgradeProxyReconciler

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

func NewUpgradeProxyReconciler

func NewUpgradeProxyReconciler(
	client client.Client,
	log loggerutil.OSOKLogger,
	handler upgradeproxy.ResourceHandler,
	namespace string,
) *UpgradeProxyReconciler

func (*UpgradeProxyReconciler) Reconcile

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

Reconcile will keep a watch on mesh configmap for the proxy version update and evicts pods that has older proxy versions Polls data plane endpoint for latest proxy versions, and updates the configmap if there is a version mismatch If configmap is deleted, it recreates it.

func (*UpgradeProxyReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.