kube

package
v1.15.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 44 Imported by: 22

Documentation

Overview

Copyright The Velero Contributors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Velero Contributors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	KubeAnnBindCompleted          = "pv.kubernetes.io/bind-completed"
	KubeAnnBoundByController      = "pv.kubernetes.io/bound-by-controller"
	KubeAnnDynamicallyProvisioned = "pv.kubernetes.io/provisioned-by"
	KubeAnnMigratedTo             = "pv.kubernetes.io/migrated-to"
	KubeAnnSelectedNode           = "volume.kubernetes.io/selected-node"
)

These annotations are taken from the Kubernetes persistent volume/persistent volume claim controller. They cannot be directly importing because they are part of the kubernetes/kubernetes package, and importing that package is unsupported. Their values are well-known and slow changing. They're duplicated here as constants to provide compile-time checking. Originals can be found in kubernetes/kubernetes/pkg/controller/volume/persistentvolume/util/util.go.

Variables

View Source 
var ErrorPodVolumeIsNotPVC = errors.New("pod volume is not a PVC")

Functions

func AddAnnotations added in v1.14.0 

func AddAnnotations(o *metav1.ObjectMeta, vals map[string]string)

AddAnnotations adds the supplied key-values to the annotations on the object

func AddLabels added in v1.14.0 

func AddLabels(o *metav1.ObjectMeta, vals map[string]string)

AddLabels adds the supplied key-values to the labels on the object

func CollectPodLogs 

func CollectPodLogs(ctx context.Context, podGetter corev1client.CoreV1Interface, pod string, namespace string, container string, output io.Writer) error

CollectPodLogs collects logs of the specified container of a pod and write to the output

func DeletePVAndPVCIfAny added in v1.12.3 

func DeletePVAndPVCIfAny(ctx context.Context, client corev1client.CoreV1Interface, pvcName, pvcNamespace string, ensureTimeout time.Duration, log logrus.FieldLogger)

DeletePVAndPVCIfAny deletes PVC and delete the bound PV if it exists and log an error when the deletion fails. It first sets the reclaim policy of the PV to Delete, then PV will be deleted automatically when PVC is deleted. If ensureTimeout is not 0, it waits until the PVC is deleted or timeout.

func DeletePVIfAny added in v1.12.0 

func DeletePVIfAny(ctx context.Context, pvGetter corev1client.CoreV1Interface, pvName string, log logrus.FieldLogger)

DeletePVIfAny deletes a PV by name if it exists, and log an error when the deletion fails

func DeletePodIfAny added in v1.12.0 

func DeletePodIfAny(ctx context.Context, podGetter corev1client.CoreV1Interface, podName string, podNamespace string, log logrus.FieldLogger)

DeletePodIfAny deletes a pod by name if it exists, and log an error when the deletion fails

func EnqueueRequestsFromMapUpdateFunc added in v1.11.0 

func EnqueueRequestsFromMapUpdateFunc(fn MapUpdateFunc) handler.EventHandler

EnqueueRequestsFromMapUpdateFunc has the same purpose with handler.EnqueueRequestsFromMapFunc. MapUpdateFunc is simpler on Update event because mapAndEnqueue is called once with the new object. EnqueueRequestsFromMapFunc is called twice with the old and new object.

func EnsureDeletePVC added in v1.12.0 

func EnsureDeletePVC(ctx context.Context, pvcGetter corev1client.CoreV1Interface, pvc string, namespace string, timeout time.Duration) error

EnsureDeletePVC asserts the existence of a PVC by name, deletes it and waits for its disappearance and returns errors on any failure If timeout is 0, it doesn't wait and return nil

func EnsureDeletePod added in v1.12.0 

func EnsureDeletePod(ctx context.Context, podGetter corev1client.CoreV1Interface, pod string, namespace string, timeout time.Duration) error

EnsureDeletePod asserts the existence of a pod by name, deletes it and waits for its disappearance and returns errors on any failure

func EnsureNamespaceExistsAndIsReady added in v0.11.0 

func EnsureNamespaceExistsAndIsReady(namespace *corev1api.Namespace, client corev1client.NamespaceInterface, timeout time.Duration) (ready bool, nsCreated bool, err error)

EnsureNamespaceExistsAndIsReady attempts to create the provided Kubernetes namespace. It returns three values:

  • a bool indicating whether or not the namespace is ready,
  • a bool indicating whether or not the namespace was created
  • an error if one occurred.

examples: 

namespace already exists and is not ready, this function will return (false, false, nil).
If the namespace exists and is marked for deletion, this function will wait up to the timeout for it to fully delete.

func GetPVCForPodVolume added in v1.14.0 

func GetPVCForPodVolume(vol *corev1api.Volume, pod *corev1api.Pod, crClient crclient.Client) (*corev1api.PersistentVolumeClaim, error)

func GetPVForPVC added in v1.14.0 

func GetPVForPVC(
	pvc *corev1api.PersistentVolumeClaim,
	crClient crclient.Client,
) (*corev1api.PersistentVolume, error)

func GetPodContainerTerminateMessage 

func GetPodContainerTerminateMessage(pod *corev1api.Pod, container string) string

GetPodContainerTerminateMessage returns the terminate message for a specific container of a pod

func GetPodPVCVolume added in v1.12.1 

func GetPodPVCVolume(ctx context.Context, log logrus.FieldLogger, pod *corev1api.Pod, volumeName string, cli client.Client) (
	*corev1api.PersistentVolumeClaim, *corev1api.PersistentVolume, *corev1api.Volume, error)

GetPodPVCVolume gets the PVC, PV and volume for a pod volume name. Returns pod volume in case of ErrorPodVolumeIsNotPVC error

func GetPodTerminateMessage 

func GetPodTerminateMessage(pod *corev1api.Pod) string

GetPodTerminateMessage returns the terminate message for all containers of a pod

func GetSecret added in v1.6.0 

func GetSecret(client kbclient.Client, namespace, name string) (*corev1api.Secret, error)

func GetSecretKey added in v1.6.0 

func GetSecretKey(client kbclient.Client, namespace string, selector *corev1api.SecretKeySelector) ([]byte, error)

func GetVolumeDirectory added in v0.9.0 

func GetVolumeDirectory(ctx context.Context, log logrus.FieldLogger, pod *corev1api.Pod, volumeName string, cli client.Client) (string, error)

GetVolumeDirectory gets the name of the directory on the host, under /var/lib/kubelet/pods/<podUID>/volumes/, where the specified volume lives. For volumes with a CSIVolumeSource, append "/mount" to the directory name.

func GetVolumeMode added in v1.12.1 

func GetVolumeMode(ctx context.Context, log logrus.FieldLogger, pod *corev1api.Pod, volumeName string, cli client.Client) (
	uploader.PersistentVolumeMode, error)

GetVolumeMode gets the uploader.PersistentVolumeMode of the volume.

func HasBackupLabel added in v1.14.0 

func HasBackupLabel(o *metav1.ObjectMeta, backupName string) bool

func IsCRDReady added in v1.3.0 

func IsCRDReady(crd *unstructured.Unstructured) (bool, error)

IsCRDReady triggers IsV1Beta1CRDReady/IsV1CRDReady according to the version of the input param

func IsPVCBound added in v1.12.0 

func IsPVCBound(pvc *corev1api.PersistentVolumeClaim) bool

IsPVCBound returns true if the specified PVC has been bound

func IsPodRunning added in v1.10.0 

func IsPodRunning(pod *corev1api.Pod) error

IsPodRunning does a well-rounded check to make sure the specified pod is running stably. If not, return the error found

func IsPodScheduled added in v1.11.0 

func IsPodScheduled(pod *corev1api.Pod) error

IsPodScheduled does a well-rounded check to make sure the specified pod has been scheduled into a node and in a stable status. If not, return the error found

func IsPodUnrecoverable added in v1.13.0 

func IsPodUnrecoverable(pod *corev1api.Pod, log logrus.FieldLogger) (bool, string)

IsPodUnrecoverable checks if the pod is in an abnormal state and could not be recovered It could not cover all the cases but we could add more cases in the future

func IsV1Beta1CRDReady added in v1.6.3 

func IsV1Beta1CRDReady(crd *apiextv1beta1.CustomResourceDefinition) bool

IsV1Beta1CRDReady checks a v1beta1 CRD to see if it's ready, with both the Established and NamesAccepted conditions.

func IsV1CRDReady added in v1.6.3 

func IsV1CRDReady(crd *apiextv1.CustomResourceDefinition) bool

IsV1CRDReady checks a v1 CRD to see if it's ready, with both the Established and NamesAccepted conditions.

func MakePodPVCAttachment added in v1.12.1 

func MakePodPVCAttachment(volumeName string, volumeMode *corev1api.PersistentVolumeMode, readOnly bool) ([]corev1api.VolumeMount, []corev1api.VolumeDevice, string)

MakePodPVCAttachment returns the volume mounts and devices for a pod needed to attach a PVC

func NamespaceAndName added in v0.4.0 

func NamespaceAndName(objMeta metav1.Object) string

NamespaceAndName returns a string in the format <namespace>/<name>

func NewAllEventPredicate added in v1.10.0 

func NewAllEventPredicate(f func(object client.Object) bool) predicate.Predicate

NewAllEventPredicate creates a new Predicate that checks all the events with the provided func

func NewCreateEventPredicate added in v1.11.0 

func NewCreateEventPredicate(f func(client.Object) bool) predicate.Predicate

func NewGenericEventPredicate added in v1.10.0 

func NewGenericEventPredicate(f func(object client.Object) bool) predicate.Predicate

NewGenericEventPredicate creates a new Predicate that checks the Generic event with the provided func

func NewUpdateEventPredicate added in v1.11.0 

func NewUpdateEventPredicate(f func(client.Object, client.Object) bool) predicate.Predicate

NewUpdateEventPredicate creates a new Predicate that checks the update events with the provided func and ignore others

func ParseResourceRequirements added in v1.0.1 

func ParseResourceRequirements(cpuRequest, memRequest, cpuLimit, memLimit string) (corev1.ResourceRequirements, error)

ParseResourceRequirements takes a set of CPU and memory requests and limit string values and returns a ResourceRequirements struct to be used in a Container. An error is returned if we cannot parse the request/limit.

func ParseSecurityContext added in v1.5.0 

func ParseSecurityContext(runAsUser string, runAsGroup string, allowPrivilegeEscalation string, secCtx string) (corev1.SecurityContext, error)

func PatchResource added in v1.11.0 

func PatchResource(original, updated client.Object, kbClient client.Client) error

func PatchResourceWithRetries 

func PatchResourceWithRetries(maxDuration time.Duration, original, updated client.Object, kbClient client.Client, retriable func(error) bool) error

PatchResourceWithRetries patches the original resource with the updated resource, retrying when the provided retriable function returns true.

func PatchResourceWithRetriesOnErrors 

func PatchResourceWithRetriesOnErrors(maxDuration time.Duration, original, updated client.Object, kbClient client.Client) error

PatchResourceWithRetriesOnErrors patches the original resource with the updated resource, retrying when the operation returns an error.

func RebindPVC added in v1.12.0 

func RebindPVC(ctx context.Context, pvcGetter corev1client.CoreV1Interface,
	pvc *corev1api.PersistentVolumeClaim, pv string) (*corev1api.PersistentVolumeClaim, error)

RebindPVC rebinds a PVC by modifying its VolumeName to the specific PV

func ResetPVBinding added in v1.12.0 

func ResetPVBinding(ctx context.Context, pvGetter corev1client.CoreV1Interface, pv *corev1api.PersistentVolume,
	labels map[string]string, pvc *corev1api.PersistentVolumeClaim) (*corev1api.PersistentVolume, error)

ResetPVBinding resets the binding info of a PV and adds the required labels so as to make it ready for binding

func SetPVReclaimPolicy added in v1.12.0 

func SetPVReclaimPolicy(ctx context.Context, pvGetter corev1client.CoreV1Interface, pv *corev1api.PersistentVolume,
	policy corev1api.PersistentVolumeReclaimPolicy) (*corev1api.PersistentVolume, error)

SetPVReclaimPolicy sets the specified reclaim policy to a PV

func SinglePathMatch added in v1.9.1 

func SinglePathMatch(path string, fs filesystem.Interface, log logrus.FieldLogger) (string, error)

SinglePathMatch checks whether pass-in volume path is valid. Check whether there is only one match by the path's pattern.

func ToSystemAffinity 

func ToSystemAffinity(loadAffinities []*LoadAffinity) *corev1api.Affinity

func WaitPVBound added in v1.12.0 

func WaitPVBound(ctx context.Context, pvGetter corev1client.CoreV1Interface, pvName string, pvcName string, pvcNamespace string, timeout time.Duration) (*corev1api.PersistentVolume, error)

WaitPVBound wait for binding of a PV specified by name and returns the bound PV object

func WaitPVCBound added in v1.12.0 

func WaitPVCBound(ctx context.Context, pvcGetter corev1client.CoreV1Interface,
	pvGetter corev1client.CoreV1Interface, pvc string, namespace string, timeout time.Duration) (*corev1api.PersistentVolume, error)

WaitPVCBound wait for binding of a PVC specified by name and returns the bound PV object

func WaitPVCConsumed added in v1.12.0 

func WaitPVCConsumed(ctx context.Context, pvcGetter corev1client.CoreV1Interface, pvc string, namespace string,
	storageClient storagev1.StorageV1Interface, timeout time.Duration) (string, *corev1api.PersistentVolumeClaim, error)

WaitPVCConsumed waits for a PVC to be consumed by a pod so that the selected node is set by the pod scheduling; or does nothing if the consuming doesn't affect the PV provision. The latest PVC and the selected node will be returned.

Types

type Client 

type Client interface {
	client.Reader
	client.Writer
	client.StatusClient
	client.SubResourceClientConstructor

	// Scheme returns the scheme this client is using.
	Scheme() *runtime.Scheme
	// RESTMapper returns the rest this client is using.
	RESTMapper() meta.RESTMapper
	// GroupVersionKindFor returns the GroupVersionKind for the given object.
	GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
	// IsObjectNamespaced returns true if the GroupVersionKind of the object is namespaced.
	IsObjectNamespaced(obj runtime.Object) (bool, error)
}

Client knows how to perform CRUD operations on Kubernetes objects. go:generate mockery --name=Client

type EventRecorder 

type EventRecorder interface {
	Event(object runtime.Object, warning bool, reason string, message string, a ...any)
	EndingEvent(object runtime.Object, warning bool, reason string, message string, a ...any)
	Shutdown()
}

func NewEventRecorder 

func NewEventRecorder(kubeClient kubernetes.Interface, scheme *runtime.Scheme, eventSource string, eventNode string, log logrus.FieldLogger) EventRecorder

type FalsePredicate added in v1.10.0 

type FalsePredicate struct{}

FalsePredicate always returns false for all kinds of events

func (FalsePredicate) Create added in v1.10.0 

func (f FalsePredicate) Create(event.CreateEvent) bool

Create always returns false

func (FalsePredicate) Delete added in v1.10.0 

func (f FalsePredicate) Delete(event.DeleteEvent) bool

Delete always returns false

func (FalsePredicate) Generic added in v1.10.0 

func (f FalsePredicate) Generic(event.GenericEvent) bool

Generic always returns false

func (FalsePredicate) Update added in v1.10.0 

func (f FalsePredicate) Update(event.UpdateEvent) bool

Update always returns false

type InternalLW added in v1.12.0 

type InternalLW struct {
	Client     kbclient.WithWatch
	Namespace  string
	ObjectList kbclient.ObjectList
}

func (*InternalLW) List added in v1.12.0 

func (lw *InternalLW) List(options metav1.ListOptions) (runtime.Object, error)

func (*InternalLW) Watch added in v1.12.0 

func (lw *InternalLW) Watch(options metav1.ListOptions) (watch.Interface, error)

type LoadAffinity 

type LoadAffinity struct {
	// NodeSelector specifies the label selector to match nodes
	NodeSelector metav1.LabelSelector `json:"nodeSelector"`
}

type MapUpdateFunc added in v1.11.0 

type MapUpdateFunc func(context.Context, client.Object) []reconcile.Request

type PeriodicalEnqueueSource added in v1.9.0 

type PeriodicalEnqueueSource struct {
	client.Client
	// contains filtered or unexported fields
}

PeriodicalEnqueueSource is an implementation of interface sigs.k8s.io/controller-runtime/pkg/source/Source It reads the specific resources from Kubernetes/cache and enqueues them into the queue to trigger the reconcile logic periodically

func NewPeriodicalEnqueueSource added in v1.9.0 

func NewPeriodicalEnqueueSource(
	logger logrus.FieldLogger,
	client client.Client,
	objList client.ObjectList,
	period time.Duration,
	option PeriodicalEnqueueSourceOption) *PeriodicalEnqueueSource

func (*PeriodicalEnqueueSource) Start added in v1.9.0 

func (p *PeriodicalEnqueueSource) Start(ctx context.Context, h handler.EventHandler, q workqueue.RateLimitingInterface, predicates ...predicate.Predicate) error

Start enqueue items periodically. The predicates only apply to the GenericEvent

func (*PeriodicalEnqueueSource) String added in v1.9.3 

func (p *PeriodicalEnqueueSource) String() string

type PeriodicalEnqueueSourceOption added in v1.10.0 

type PeriodicalEnqueueSourceOption struct {
	OrderFunc func(objList client.ObjectList) client.ObjectList
}

type PodResources 

type PodResources struct {
	CPURequest    string `json:"cpuRequest,omitempty"`
	MemoryRequest string `json:"memoryRequest,omitempty"`
	CPULimit      string `json:"cpuLimit,omitempty"`
	MemoryLimit   string `json:"memoryLimit,omitempty"`
}

type SpecChangePredicate added in v1.9.1 

type SpecChangePredicate struct {
	predicate.Funcs
}

SpecChangePredicate implements a default update predicate function on Spec change As Velero doesn't enable subresource in CRDs, we cannot use the object's metadata.generation field to check the spec change More details about the generation field refer to https://github.com/kubernetes-sigs/controller-runtime/blob/v0.12.2/pkg/predicate/predicate.go#L156

func (SpecChangePredicate) Update added in v1.9.1 

func (SpecChangePredicate) Update(e event.UpdateEvent) bool

Source Files

View all Source files

Directories

Path Synopsis

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.