persistentvolume

package
v0.2.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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 *typed.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 (*Handler) Apply

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

Apply apply persistentvolume from yaml file, alias to "ApplyFromFile".

func (*Handler) ApplyFromBytes

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

ApplyFromBytes apply persistentvolume from bytes.

func (*Handler) ApplyFromFile

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

ApplyFromFile apply persistentvolume from yaml file.

func (*Handler) ApplyFromRaw

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

ApplyFromRaw apply persistentvolume from map[string]interface{}.

func (*Handler) Clientset added in v0.2.0

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

func (*Handler) Create

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

Create create persistentvolume from yaml file, alias to "CreateFromFile".

func (*Handler) CreateFromBytes

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

CreateFromBytes create persistentvolume from bytes.

func (*Handler) CreateFromFile

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

CreateFromFile create persistentvolume from yaml file.

func (*Handler) CreateFromRaw

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

CreateFromRaw create persistentvolume from map[string]interface{}.

func (*Handler) DeepCopy

func (in *Handler) DeepCopy() *Handler

func (*Handler) Delete

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

Delete delete persistentvolume by name, alias to "DeleteByName".

func (*Handler) DeleteByName

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

DeleteByName delete persistentvolume by name.

func (*Handler) DeleteFromBytes

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

DeleteFromBytes delete persistentvolume from bytes.

func (*Handler) DeleteFromFile

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

DeleteFromFile delete persistentvolume from yaml file.

func (*Handler) DiscoveryClient added in v0.2.0

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

func (*Handler) DynamicClient added in v0.2.0

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

func (*Handler) Get

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

Get get persistentvolume by name, alias to "GetByName".

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 get 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 get persistentvolume from bytes.

func (*Handler) GetFromFile

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

GetFromFile get persistentvolume from yaml file.

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

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(filename string) (*corev1.PersistentVolume, error)

Update update persistentvolume from yaml file, alias to "UpdateFromFile".

func (*Handler) UpdateFromBytes

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

UpdateFromBytes update persistentvolume from bytes.

func (*Handler) UpdateFromFile

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

UpdateFromFile update persistentvolume from yaml file.

func (*Handler) UpdateFromRaw

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

UpdateFromRaw update 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL