controllers

package
v0.0.0-...-1046db7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

* * @Author: guohb65 * @Date: 2022-3-18 16:39

* * @Author: guohb65 * @Date: 2022-3-17 16:33

* * @Author: guohb65 * @Date: 2022-3-17 16:33

* * @Author: herbguo * @Date: 2022-3-14 15:51

* * @Author: herbguo * @Date: 2022-3-14 15:51

Index

Constants

View Source 
const (
	CsmEgressDefaultConfigName      = "default.conf"
	CsmEgressNginxConfigName        = "nginx.conf"
	CsmEgressStreamConfigName       = "stream.conf"
	DefaultMountName                = "config"
	CsmEgressDefaultConfigMountPath = "/etc/nginx/conf.d/default.conf"
	CsmEgressNginxConfigMountPath   = "/etc/nginx/nginx.conf"
	CsmEgressStreamConfigMountPath  = "/etc/nginx/stream.d/stream.conf"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type EnqueueEgressWorkLoad 

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

func (EnqueueEgressWorkLoad) Create 

func (e EnqueueEgressWorkLoad) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (EnqueueEgressWorkLoad) Delete 

func (e EnqueueEgressWorkLoad) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (EnqueueEgressWorkLoad) Generic 

func (e EnqueueEgressWorkLoad) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (EnqueueEgressWorkLoad) Update 

func (e EnqueueEgressWorkLoad) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type EnqueueServiceEntry 

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

func (EnqueueServiceEntry) Create 

func (e EnqueueServiceEntry) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (EnqueueServiceEntry) Delete 

func (e EnqueueServiceEntry) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (EnqueueServiceEntry) Generic 

func (e EnqueueServiceEntry) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (EnqueueServiceEntry) Update 

func (e EnqueueServiceEntry) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type LazySidecarReconciler 

type LazySidecarReconciler struct {
	client.Client
	IstioClient *versionedclient.Clientset
	Scheme      *runtime.Scheme
}

LazySidecarReconciler reconciles a LazySidecar object

func (*LazySidecarReconciler) ConvertJson2Struct 

func (r *LazySidecarReconciler) ConvertJson2Struct(ctx context.Context, str string, v interface{}) error

GetStructDataFromString define read the Yaml configuration file and structure it

func (*LazySidecarReconciler) CreateCsmEgressConfigMap 

func (r *LazySidecarReconciler) CreateCsmEgressConfigMap(ctx context.Context)

func (*LazySidecarReconciler) CreateCsmEgressDeployment 

func (r *LazySidecarReconciler) CreateCsmEgressDeployment(ctx context.Context)

func (*LazySidecarReconciler) CreateCsmEgressService 

func (r *LazySidecarReconciler) CreateCsmEgressService(ctx context.Context)

func (*LazySidecarReconciler) CreateCsmSa 

func (r *LazySidecarReconciler) CreateCsmSa(ctx context.Context)

func (*LazySidecarReconciler) GetCsmEgressConfigMap 

func (r *LazySidecarReconciler) GetCsmEgressConfigMap() *corev1.ConfigMap

func (*LazySidecarReconciler) GetCsmEgressDeployment 

func (r *LazySidecarReconciler) GetCsmEgressDeployment() *appv1.Deployment

func (*LazySidecarReconciler) GetCsmEgressService 

func (r *LazySidecarReconciler) GetCsmEgressService() *corev1.Service

func (*LazySidecarReconciler) GetNewHosts 

func (r *LazySidecarReconciler) GetNewHosts(instance *v1.LazySidecar, hosts []string) (newHosts []string)

func (*LazySidecarReconciler) GetResources 

func (r *LazySidecarReconciler) GetResources() corev1.ResourceRequirements

func (*LazySidecarReconciler) Init 

func (r *LazySidecarReconciler) Init()

func (*LazySidecarReconciler) ListAllCsmLazySidecar 

func (r *LazySidecarReconciler) ListAllCsmLazySidecar(ctx context.Context) *v1.LazySidecarList

func (*LazySidecarReconciler) ListAllServiceEntryHosts 

func (r *LazySidecarReconciler) ListAllServiceEntryHosts(ctx context.Context) []string

func (*LazySidecarReconciler) Reconcile 

func (r *LazySidecarReconciler) 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.12.2/pkg/reconcile

func (*LazySidecarReconciler) ReconcileCsmEgressWorkLoad 

func (r *LazySidecarReconciler) ReconcileCsmEgressWorkLoad(ctx context.Context)

func (*LazySidecarReconciler) ReconcileCsmLazySidecarAddHosts 

func (r *LazySidecarReconciler) ReconcileCsmLazySidecarAddHosts(ctx context.Context, namespace string, hosts []string)

func (*LazySidecarReconciler) ReconcileCsmLazySidecarRemoveHosts 

func (r *LazySidecarReconciler) ReconcileCsmLazySidecarRemoveHosts(ctx context.Context, namespace string, hosts []string)

func (*LazySidecarReconciler) ReconcileEnvoyFilter 

func (r *LazySidecarReconciler) ReconcileEnvoyFilter(ctx context.Context, lazySidecar *v1.LazySidecar) error

func (*LazySidecarReconciler) ReconcileSidecar 

func (r *LazySidecarReconciler) ReconcileSidecar(ctx context.Context, lazySidecar *v1.LazySidecar) error

func (*LazySidecarReconciler) RemoveDeriveSidecarHosts 

func (r *LazySidecarReconciler) RemoveDeriveSidecarHosts(ctx context.Context, instance v1.LazySidecar, hosts []string)

func (*LazySidecarReconciler) RewriteCsmLazySidecarStatus 

func (r *LazySidecarReconciler) RewriteCsmLazySidecarStatus(ctx context.Context, instancesNamespacedName types.NamespacedName, instance *v1.LazySidecar)

func (*LazySidecarReconciler) RewriteSeHostsToCsmLazySidecar 

func (r *LazySidecarReconciler) RewriteSeHostsToCsmLazySidecar(ctx context.Context, instance *v1.LazySidecar)

func (*LazySidecarReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*LazySidecarReconciler) UpdateStatus 

func (r *LazySidecarReconciler) UpdateStatus(ctx context.Context, instance *v1.LazySidecar)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.