k8sutil

Documentation

Index

• func CreateIfNotExists(ctx context.Context, client client.Client, obj runtime.Object, ...) error
• func CreateOrUpdateRbdComponent(clientset rainbondversiond.Interface, cpt *rainbondv1alpha1.RbdComponent) error
• func EventsForPersistentVolumeClaim(pvc *corev1.PersistentVolumeClaim) (*corev1.EventList, error)
• func GetClientSet() kubernetes.Interface
• func GetFoobarPVC(ctx context.Context, client client.Client, ns string) (*corev1.PersistentVolumeClaim, error)
• func HostPath(hostpath corev1.HostPathType) *corev1.HostPathType
• func InClusterConfig() (*rest.Config, error)
• func IsPodCompleted(pod *corev1.Pod) bool
• func IsPodReady(pod *corev1.Pod) bool
• func ListNodes(ctx context.Context, c client.Client) ([]corev1.Node, error)
• func MaterRoleLabel(key string) map[string]string
• func MountPropagationMode(moundPropagationMode corev1.MountPropagationMode) *corev1.MountPropagationMode
• func MustNewKubeConfig(kubeconfigPath string) *rest.Config
• func NewKubeConfig() (*rest.Config, error)
• func PersistentVolumeClaimForGrdata(ns, claimName string, accessModes []corev1.PersistentVolumeAccessMode, ...) *corev1.PersistentVolumeClaim
• func PersistentVolumeReclaimPolicy(persistentVolumeReclaimPolicy corev1.PersistentVolumeReclaimPolicy) *corev1.PersistentVolumeReclaimPolicy
• func UpdateCRStatus(client client.Client, obj runtime.Object) error

Functions

func CreateIfNotExists

func CreateIfNotExists(ctx context.Context, client client.Client, obj runtime.Object, meta metav1.Object) error

CreateIfNotExists -

func CreateOrUpdateRbdComponent

func CreateOrUpdateRbdComponent(clientset rainbondversiond.Interface, cpt *rainbondv1alpha1.RbdComponent) error

CreateOrUpdateRbdComponent -

func EventsForPersistentVolumeClaim

func EventsForPersistentVolumeClaim(pvc *corev1.PersistentVolumeClaim) (*corev1.EventList, error)

EventsForPersistentVolumeClaim -

func GetClientSet

func GetClientSet() kubernetes.Interface

func GetFoobarPVC

func GetFoobarPVC(ctx context.Context, client client.Client, ns string) (*corev1.PersistentVolumeClaim, error)

func HostPath

func HostPath(hostpath corev1.HostPathType) *corev1.HostPathType

HostPath returns a pointer to the HostPathType value passed in.

func InClusterConfig

func InClusterConfig() (*rest.Config, error)

func IsPodCompleted

func IsPodCompleted(pod *corev1.Pod) bool

IsPodCompleted checks if the given pod is ready or not.

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

IsPodReady checks if the given pod is ready or not.

func ListNodes

func ListNodes(ctx context.Context, c client.Client) ([]corev1.Node, error)

ListNodes returns all nodes.

func MaterRoleLabel

func MaterRoleLabel(key string) map[string]string

func MountPropagationMode

func MountPropagationMode(moundPropagationMode corev1.MountPropagationMode) *corev1.MountPropagationMode

MountPropagationMode returns a pointer to the MountPropagationMode value passed in.

func MustNewKubeConfig

func MustNewKubeConfig(kubeconfigPath string) *rest.Config

func NewKubeConfig

func NewKubeConfig() (*rest.Config, error)

func PersistentVolumeClaimForGrdata

func PersistentVolumeClaimForGrdata(ns, claimName string, accessModes []corev1.PersistentVolumeAccessMode, labels map[string]string, storageClassName string, storageRequest int64) *corev1.PersistentVolumeClaim

func PersistentVolumeReclaimPolicy

func PersistentVolumeReclaimPolicy(persistentVolumeReclaimPolicy corev1.PersistentVolumeReclaimPolicy) *corev1.PersistentVolumeReclaimPolicy

PersistentVolumeReclaimPolicy returns a pointer to the PersistentVolumeReclaimPolicy value passed in.

func UpdateCRStatus

func UpdateCRStatus(client client.Client, obj runtime.Object) error