Documentation
¶
Index ¶
- Constants
- func GetPodLabels(cluster *v1alpha1.RedisCluster) labels.Set
- func GetStatefulSetLabels(cluster *v1alpha1.RedisCluster) labels.Set
- type 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" )
Variables ¶
This section is empty.
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 ¶
UpdateResource updates the given Kubernetes resource.
Source Files