controllers

package
v0.0.0-...-beacd72 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const NetworkStatusAnnotation = "k8s.v1.cni.cncf.io/network-status"

Variables

This section is empty.

Functions

func GetAnnotationMap 

func GetAnnotationMap() map[string]string

func GetAnnotationMapForPod 

func GetAnnotationMapForPod(orig map[string]string, multinicName *string) map[string]string

func GetControllerLabels 

func GetControllerLabels(objcache *trlv1alpha1.ObjcacheCsiDriver) map[string]string

func GetControllerName 

func GetControllerName(objcache *trlv1alpha1.ObjcacheCsiDriver) string

func GetNodeLabels 

func GetNodeLabels(objcache *trlv1alpha1.ObjcacheCsiDriver) map[string]string

func GetNodeName 

func GetNodeName(name string) string

func GetStorageClassParameters 

func GetStorageClassParameters(objcache *trlv1alpha1.ObjcacheCluster) map[string]string

func GetWorkerLabels 

func GetWorkerLabels(objcache *trlv1alpha1.ObjcacheCluster, groupId string) map[string]string

Types

type MyRandString 

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

func (*MyRandString) Get 

func (r *MyRandString) Get(digit int64) string

type NetworkStatus 

type NetworkStatus struct {
	Name   string   `json:"name"`
	IFName string   `json:"interface"`
	IPs    []string `json:"ips"`
}

type ObjcacheClusterReconciler 

type ObjcacheClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ObjcacheClusterReconciler reconciles a ObjcacheCluster object

func (*ObjcacheClusterReconciler) DeleteCluster 

func (r *ObjcacheClusterReconciler) DeleteCluster(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (requeue bool, err error)

func (*ObjcacheClusterReconciler) DeleteConfigMap 

func (r *ObjcacheClusterReconciler) DeleteConfigMap(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) error

func (*ObjcacheClusterReconciler) DeleteService 

func (r *ObjcacheClusterReconciler) DeleteService(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (bool, error)

func (*ObjcacheClusterReconciler) DeleteStatefulSet 

func (r *ObjcacheClusterReconciler) DeleteStatefulSet(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger, groupIndex int) error

func (*ObjcacheClusterReconciler) DeleteStatefulSetVolume 

func (r *ObjcacheClusterReconciler) DeleteStatefulSetVolume(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger, groupIndex int, raftIndex int) error

func (*ObjcacheClusterReconciler) DeleteStorageClass 

func (r *ObjcacheClusterReconciler) DeleteStorageClass(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (bool, error)

func (*ObjcacheClusterReconciler) GetGroupId 

func (r *ObjcacheClusterReconciler) GetGroupId(seed int64, groupIndex int) (str string)

func (*ObjcacheClusterReconciler) Reconcile 

func (r *ObjcacheClusterReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the ObjcacheCluster object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*ObjcacheClusterReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*ObjcacheClusterReconciler) UpdateCluster 

func (r *ObjcacheClusterReconciler) UpdateCluster(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (requeue bool, err error)

func (*ObjcacheClusterReconciler) UpdateConfigMap 

func (r *ObjcacheClusterReconciler) UpdateConfigMap(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (bool, error)

func (*ObjcacheClusterReconciler) UpdateService 

func (r *ObjcacheClusterReconciler) UpdateService(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (requeue bool, err error)

func (*ObjcacheClusterReconciler) UpdateStatefulSet 

func (r *ObjcacheClusterReconciler) UpdateStatefulSet(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger, groupIndex int) (err error)

func (*ObjcacheClusterReconciler) UpdateStorageClass 

func (r *ObjcacheClusterReconciler) UpdateStorageClass(ctx context.Context, objcache *trlv1alpha1.ObjcacheCluster, l logr.Logger) (bool, error)

type ObjcacheCsiDriverReconciler 

type ObjcacheCsiDriverReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ObjcacheCsiDriverReconciler reconciles a ObjcacheCsiDriver object

func (*ObjcacheCsiDriverReconciler) DeleteCluster 

func (r *ObjcacheCsiDriverReconciler) DeleteCluster(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (requeue bool, err error)

func (*ObjcacheCsiDriverReconciler) DeleteConfigMap 

func (r *ObjcacheCsiDriverReconciler) DeleteConfigMap(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) error

func (*ObjcacheCsiDriverReconciler) DeleteControllerDeployment 

func (r *ObjcacheCsiDriverReconciler) DeleteControllerDeployment(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) error

func (*ObjcacheCsiDriverReconciler) DeleteCsiDriver 

func (r *ObjcacheCsiDriverReconciler) DeleteCsiDriver(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (bool, error)

func (*ObjcacheCsiDriverReconciler) DeleteNodes 

func (r *ObjcacheCsiDriverReconciler) DeleteNodes(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (requeue bool, err error)

func (*ObjcacheCsiDriverReconciler) Reconcile 

func (r *ObjcacheCsiDriverReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the ObjcacheCsiDriver object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*ObjcacheCsiDriverReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*ObjcacheCsiDriverReconciler) UpdateCluster 

func (r *ObjcacheCsiDriverReconciler) UpdateCluster(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (requeue bool, err error)

func (*ObjcacheCsiDriverReconciler) UpdateConfigMap 

func (r *ObjcacheCsiDriverReconciler) UpdateConfigMap(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (bool, error)

func (*ObjcacheCsiDriverReconciler) UpdateControllerDeployment 

func (r *ObjcacheCsiDriverReconciler) UpdateControllerDeployment(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (bool, error)

func (*ObjcacheCsiDriverReconciler) UpdateCsiDriver 

func (r *ObjcacheCsiDriverReconciler) UpdateCsiDriver(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (bool, error)

func (*ObjcacheCsiDriverReconciler) UpdateNodes 

func (r *ObjcacheCsiDriverReconciler) UpdateNodes(ctx context.Context, objcache *trlv1alpha1.ObjcacheCsiDriver, l logr.Logger) (bool, error)

func (*ObjcacheCsiDriverReconciler) WaitAndGetPodIp 

func (r *ObjcacheCsiDriverReconciler) WaitAndGetPodIp(ctx context.Context, namespace string, podName string, iFName string, l logr.Logger) (externalIp string, notReady bool, err error)

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.