persistentvolume

package
v0.4.5 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2022 License: Apache-2.0 Imports: 25 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ERR_TYPE_TOOLS  = fmt.Errorf("type must be string *corev1.PersistentVolume, or corev1.PersistentVolume")
	ERR_TYPE_CREATE = fmt.Errorf("type must be string, []byte, *corev1.PersistentVolume, corev1.PersistentVolume, runtime.Object or map[string]interface{}")
	ERR_TYPE_UPDATE = ERR_TYPE_CREATE
	ERR_TYPE_APPLY  = ERR_TYPE_CREATE
	ERR_TYPE_DELETE = ERR_TYPE_CREATE
	ERR_TYPE_GET    = ERR_TYPE_CREATE
)
View Source 
var ERR_TYPE = fmt.Errorf("type must be *corev1.PersistentVolume, corev1.PersistentVolume or string")

Functions

This section is empty.

Types

type Handler 

type Handler struct {
	Options *types.HandlerOptions
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, kubeconfig string) (handler *Handler, err error)

New returns a persistentvolume handler from kubeconfig or in-cluster config.

func NewOrDie added in v0.3.0 

func NewOrDie(ctx context.Context, kubeconfig string) *Handler

NewOrDie simply call New() to get a persistentvolume handler. panic if there is any error occurs.

func (*Handler) Apply 

func (h *Handler) Apply(obj interface{}) (*corev1.PersistentVolume, error)

Apply applies persistentvolume from type string, []byte, *corev1.PersistentVolume, corev1.PersistentVolume, runtime.Object or map[string]interface{}.

func (*Handler) ApplyFromBytes 

func (h *Handler) ApplyFromBytes(data []byte) (pv *corev1.PersistentVolume, err error)

ApplyFromBytes pply persistentvolume from bytes.

func (*Handler) ApplyFromFile 

func (h *Handler) ApplyFromFile(filename string) (pv *corev1.PersistentVolume, err error)

ApplyFromFile applies persistentvolume from yaml file.

func (*Handler) ApplyFromObject added in v0.3.0 

func (h *Handler) ApplyFromObject(obj runtime.Object) (*corev1.PersistentVolume, error)

ApplyFromObject applies persistentvolume from runtime.Object.

func (*Handler) ApplyFromUnstructured added in v0.3.0 

func (h *Handler) ApplyFromUnstructured(u map[string]interface{}) (*corev1.PersistentVolume, error)

ApplyFromUnstructured applies persistentvolume from map[string]interface{}.

func (*Handler) Clientset added in v0.2.0 

func (h *Handler) Clientset() *kubernetes.Clientset

Clientset returns underlying clientset.

func (*Handler) Create 

func (h *Handler) Create(obj interface{}) (*corev1.PersistentVolume, error)

Create creates persistentvolume from type string, []byte, *corev1.PersistentVolume, corev1.PersistentVolume, runtime.Object or map[string]interface{}.

func (*Handler) CreateFromBytes 

func (h *Handler) CreateFromBytes(data []byte) (*corev1.PersistentVolume, error)

CreateFromBytes creates persistentvolume from bytes.

func (*Handler) CreateFromFile 

func (h *Handler) CreateFromFile(filename string) (*corev1.PersistentVolume, error)

CreateFromFile creates persistentvolume from yaml file.

func (*Handler) CreateFromObject added in v0.3.0 

func (h *Handler) CreateFromObject(obj runtime.Object) (*corev1.PersistentVolume, error)

CreateFromObject creates persistentvolume from runtime.Object.

func (*Handler) CreateFromUnstructured added in v0.3.0 

func (h *Handler) CreateFromUnstructured(u map[string]interface{}) (*corev1.PersistentVolume, error)

CreateFromUnstructured creates persistentvolume from map[string]interface{}.

func (*Handler) DeepCopy 

func (in *Handler) DeepCopy() *Handler

func (*Handler) Delete 

func (h *Handler) Delete(obj interface{}) error

If passed parameter type is string, it will simply call DeleteByName instead of DeleteFromFile. You should always explicitly call DeleteFromFile to delete a persistentvolume from file path.

func (*Handler) DeleteByName 

func (h *Handler) DeleteByName(name string) error

DeleteByName deletes persistentvolume by name.

func (*Handler) DeleteFromBytes 

func (h *Handler) DeleteFromBytes(data []byte) error

DeleteFromBytes deletes persistentvolume from bytes.

func (*Handler) DeleteFromFile 

func (h *Handler) DeleteFromFile(filename string) error

DeleteFromFile deletes persistentvolume from yaml file.

func (*Handler) DeleteFromObject added in v0.3.0 

func (h *Handler) DeleteFromObject(obj runtime.Object) error

DeleteFromObject deletes persistentvolume from runtime.Object.

func (*Handler) DeleteFromUnstructured added in v0.3.0 

func (h *Handler) DeleteFromUnstructured(u map[string]interface{}) error

DeleteFromUnstructured deletes persistentvolume from map[string]interface{}.

func (*Handler) DiscoveryClient added in v0.2.0 

func (h *Handler) DiscoveryClient() *discovery.DiscoveryClient

DiscoveryClient returns underlying discovery client.

func (*Handler) DynamicClient added in v0.2.0 

func (h *Handler) DynamicClient() dynamic.Interface

DynamicClient returns underlying dynamic client.

func (*Handler) Get 

func (h *Handler) Get(obj interface{}) (*corev1.PersistentVolume, error)

If passed parameter type is string, it will simply call GetByName instead of GetFromFile. You should always explicitly call GetFromFile to get a persistentvolume from file path.

func (*Handler) GetAccessModes 

func (h *Handler) GetAccessModes(object interface{}) (accessModes []string, err error)

GetAccessModes get the accessModes of the persistentvolume.

func (*Handler) GetAge added in v0.2.0 

func (h *Handler) GetAge(object interface{}) (time.Duration, error)

GetAge returns age of the persistentvolume.

func (*Handler) GetByName 

func (h *Handler) GetByName(name string) (*corev1.PersistentVolume, error)

GetByName gets persistentvolume by name.

func (*Handler) GetCapacity 

func (h *Handler) GetCapacity(object interface{}) (int64, error)

GetCapacity get the the storage capacity of the persistentvolume.

func (*Handler) GetClaim added in v0.2.0 

func (h *Handler) GetClaim(object interface{}) (string, error)

GetClaim simply calls GetPVC.

func (*Handler) GetFromBytes 

func (h *Handler) GetFromBytes(data []byte) (*corev1.PersistentVolume, error)

GetFromBytes gets persistentvolume from bytes.

func (*Handler) GetFromFile 

func (h *Handler) GetFromFile(filename string) (*corev1.PersistentVolume, error)

GetFromFile gets persistentvolume from yaml file.

func (*Handler) GetFromObject added in v0.3.0 

func (h *Handler) GetFromObject(obj runtime.Object) (*corev1.PersistentVolume, error)

GetFromObject gets persistentvolume from runtime.Object.

func (*Handler) GetFromUnstructured added in v0.3.0 

func (h *Handler) GetFromUnstructured(u map[string]interface{}) (*corev1.PersistentVolume, error)

GetFromUnstructured gets persistentvolume from map[string]interface{}.

func (*Handler) GetPVC 

func (h *Handler) GetPVC(object interface{}) (string, error)

GetPVC get the pvc name of the persistentvolume.

func (*Handler) GetReclaimPolicy 

func (h *Handler) GetReclaimPolicy(object interface{}) (string, error)

GetReclaimPolicy get the reclaim policy of the persistentvolume.

func (*Handler) GetStatus added in v0.2.0 

func (h *Handler) GetStatus(object interface{}) (string, error)

GetStatus get the status phase of the persistentvolume. All supported pv status are: Pending, Available, Bound, Released, Failed. Pending used for PersistentVolumes that are not available. Available used for PersistentVolumes that are not yet bound. Bound used for PersistentVolumes that are bound. Released used for PersistentVolumes where the bound PersistentVolumeClaim was deleted. Failed used for PersistentVolumes that failed to be correctly recycled or deleted after being released from a claim.

func (*Handler) GetStorageClass 

func (h *Handler) GetStorageClass(object interface{}) (string, error)

GetStorageClass get the storageclass name of the persistentvolume.

func (*Handler) GetVolumeMode added in v0.2.0 

func (h *Handler) GetVolumeMode(object interface{}) (string, error)

GetVolumeMode get volume mode of the persistentvolume. volumeMode defines what type of volume is required by the claim. Value of Filesystem is implied when not included in claim spec.

func (*Handler) GetVolumeSource added in v0.2.0 

func (h *Handler) GetVolumeSource(object interface{}) (string, error)

func (*Handler) List 

func (h *Handler) List(labels string) (*corev1.PersistentVolumeList, error)

List list persistentvolumes by labels, alias to "ListByLabel".

func (*Handler) ListAll 

func (h *Handler) ListAll() (*corev1.PersistentVolumeList, error)

ListAll list all persistentvolumes in the k8s cluster.

func (*Handler) ListByLabel 

func (h *Handler) ListByLabel(labels string) (*corev1.PersistentVolumeList, error)

ListByLabel list persistentvolumes by labels.

func (*Handler) RESTClient added in v0.2.0 

func (h *Handler) RESTClient() *rest.RESTClient

RESTClient returns underlying rest client.

func (*Handler) RESTConfig added in v0.3.0 

func (h *Handler) RESTConfig() *rest.Config

RESTConfig returns underlying rest config.

func (*Handler) RunInformer 

func (h *Handler) RunInformer(
	addFunc func(obj interface{}),
	updateFunc func(oldObj, newObj interface{}),
	deleteFunc func(obj interface{}),
	stopCh chan struct{})

RunInformer

func (*Handler) SetForceDelete 

func (h *Handler) SetForceDelete(force bool)

func (*Handler) SetLimit 

func (h *Handler) SetLimit(limit int64)

func (*Handler) SetTimeout 

func (h *Handler) SetTimeout(timeout int64)

func (*Handler) Update 

func (h *Handler) Update(obj interface{}) (*corev1.PersistentVolume, error)

Update updates persistentvolume from type string, []byte, *corev1.PersistentVolume, corev1.PersistentVolume, runtime.Object or map[string]interface{}.

func (*Handler) UpdateFromBytes 

func (h *Handler) UpdateFromBytes(data []byte) (*corev1.PersistentVolume, error)

UpdateFromBytes updates persistentvolume from bytes.

func (*Handler) UpdateFromFile 

func (h *Handler) UpdateFromFile(filename string) (*corev1.PersistentVolume, error)

UpdateFromFile updates persistentvolume from yaml file.

func (*Handler) UpdateFromObject added in v0.3.0 

func (h *Handler) UpdateFromObject(obj runtime.Object) (*corev1.PersistentVolume, error)

UpdateFromObject updates persistentvolume from runtime.Object.

func (*Handler) UpdateFromUnstructured added in v0.3.0 

func (h *Handler) UpdateFromUnstructured(u map[string]interface{}) (*corev1.PersistentVolume, error)

UpdateFromUnstructured updates persistentvolume from map[string]interface{}.

func (*Handler) Watch 

func (h *Handler) Watch(name string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

Watch watch persistentvolume by name, alias to "WatchByName".

func (*Handler) WatchByLabel 

func (h *Handler) WatchByLabel(labelSelector string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

WatchByLabel watch persistentvolume by label.

func (*Handler) WatchByName 

func (h *Handler) WatchByName(name string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

WatchByName watch persistentvolume by name.

func (*Handler) WithDryRun 

func (h *Handler) WithDryRun() *Handler

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.