kubernetes

Documentation

Index

• Constants
• func GetPodLabels(cluster *v1alpha1.RedisCluster) labels.Set
• func GetStatefulSetLabels(cluster *v1alpha1.RedisCluster) labels.Set
• type KubernetesManager
  • func NewKubernetesManager(client client.Client) *KubernetesManager
  • func (km *KubernetesManager) CreateConfigMap(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.ConfigMap, error)
  • func (km *KubernetesManager) CreateService(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.Service, error)
  • func (km *KubernetesManager) CreateStatefulsets(ctx context.Context, cluster *v1alpha1.RedisCluster) (*appsv1.StatefulSet, []*appsv1.StatefulSet, error)
  • func (km *KubernetesManager) FetchConfigmap(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.ConfigMap, error)
  • func (km *KubernetesManager) FetchRedisCluster(ctx context.Context, namespacedName types.NamespacedName) (*redisclusterv1alpha1.RedisCluster, error)
  • func (km *KubernetesManager) FetchRedisPods(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.PodList, error)
  • func (km *KubernetesManager) FetchService(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.Service, error)
  • func (km *KubernetesManager) FetchStatefulsets(ctx context.Context, cluster *v1alpha1.RedisCluster) (*appsv1.StatefulSet, []*appsv1.StatefulSet, error)
  • func (km *KubernetesManager) UpdateResource(ctx context.Context, obj client.Object) error

Constants

const (
	RedisNodeNameStatefulsetLabel = "rediscluster.kuro.io/cluster-name"
	RedisNodeComponentLabel       = "rediscluster.kuro.io/cluster-component"
)

Functions

func GetPodLabels

func GetPodLabels(cluster *v1alpha1.RedisCluster) labels.Set

GetPodLabels is a function that returns the labels for a Pod object.

func GetStatefulSetLabels

func GetStatefulSetLabels(cluster *v1alpha1.RedisCluster) labels.Set

GetStatefulSetLabels is a function that returns the labels for a StatefulSet object.

Types

type KubernetesManager

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

KubernetesManager is a struct that holds a Kubernetes client, which also satisfies the IKubernetesManager interface.

func NewKubernetesManager

func NewKubernetesManager(client client.Client) *KubernetesManager

NewKubernetesManager is a function that returns a new KubernetesManager.

func (*KubernetesManager) CreateConfigMap

func (km *KubernetesManager) CreateConfigMap(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.ConfigMap, error)

CreateConfigMap is a function that creates a ConfigMap object in the Kubernetes API server.

func (*KubernetesManager) CreateService

func (km *KubernetesManager) CreateService(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.Service, error)

CreateService is a function that creates a Service object in the Kubernetes API server.

func (*KubernetesManager) CreateStatefulsets

func (km *KubernetesManager) CreateStatefulsets(ctx context.Context, cluster *v1alpha1.RedisCluster) (*appsv1.StatefulSet, []*appsv1.StatefulSet, error)

CreateStatefulsets is a function that creates StatefulSet objects in the Kubernetes API server.

func (*KubernetesManager) FetchConfigmap

func (km *KubernetesManager) FetchConfigmap(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.ConfigMap, error)

FetchConfigmap is a function that fetches a ConfigMap object from the Kubernetes API server.

func (*KubernetesManager) FetchRedisCluster

func (km *KubernetesManager) FetchRedisCluster(ctx context.Context, namespacedName types.NamespacedName) (*redisclusterv1alpha1.RedisCluster, error)

FetchRedisCluster is a function that fetches a RedisCluster object from the Kubernetes API server.

func (*KubernetesManager) FetchRedisPods

func (km *KubernetesManager) FetchRedisPods(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.PodList, error)

FetchRedisPods is a function that fetches a list of Pods from the Kubernetes API server.

func (*KubernetesManager) FetchService

func (km *KubernetesManager) FetchService(ctx context.Context, cluster *v1alpha1.RedisCluster) (*v1.Service, error)

FetchService is a function that fetches a Service object from the Kubernetes API server.

func (*KubernetesManager) FetchStatefulsets

func (km *KubernetesManager) FetchStatefulsets(ctx context.Context, cluster *v1alpha1.RedisCluster) (*appsv1.StatefulSet, []*appsv1.StatefulSet, error)

FetchExistingStatefulsets is a function that fetches the existing StatefulSet objects from the Kubernetes API server.

func (*KubernetesManager) UpdateResource

func (km *KubernetesManager) UpdateResource(ctx context.Context, obj client.Object) error

UpdateResource updates the given Kubernetes resource.