statefulset

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2022 License: Apache-2.0 Imports: 31 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ERR_TYPE_TOOLS  = fmt.Errorf("type must be string *appsv1.StatefulSet, or appsv1.StatefulSet")
	ERR_TYPE_CREATE = fmt.Errorf("type must be string, []byte, *appsv1.StatefulSet, appsv1.StatefulSet, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured 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 *appsv1.StatefulSet, appsv1.StatefulSet or string")

Functions

func GVR added in v0.5.0 

func GVR() schema.GroupVersionResource

GVR returns the name of Group, Version, Resource of statefulset resource.

func Group added in v0.5.0 

func Group() string

Group returns the Group name of statefulset resource.

func Resource added in v0.5.0 

func Resource() string

Resource returns the Resource name of statefulset resource.

func Version added in v0.5.0 

func Version() string

Version returns the Version name of statefulset resource.

Types

type Handler 

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

func New 

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

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

func NewOrDie added in v0.3.0 

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

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

func (*Handler) Apply 

func (h *Handler) Apply(obj interface{}) (*appsv1.StatefulSet, error)

Apply applies statefulset from type string, []byte, *appsv1.StatefulSet, appsv1.StatefulSet, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) ApplyFromBytes 

func (h *Handler) ApplyFromBytes(data []byte) (sts *appsv1.StatefulSet, err error)

ApplyFromBytes pply statefulset from bytes.

func (*Handler) ApplyFromFile 

func (h *Handler) ApplyFromFile(filename string) (sts *appsv1.StatefulSet, err error)

ApplyFromFile applies statefulset from yaml file.

func (*Handler) ApplyFromMap added in v0.5.0 

func (h *Handler) ApplyFromMap(u map[string]interface{}) (*appsv1.StatefulSet, error)

ApplyFromMap applies statefulset from map[string]interface{}.

func (*Handler) ApplyFromObject added in v0.3.0 

func (h *Handler) ApplyFromObject(obj runtime.Object) (*appsv1.StatefulSet, error)

ApplyFromObject applies statefulset from runtime.Object.

func (*Handler) ApplyFromUnstructured added in v0.3.0 

func (h *Handler) ApplyFromUnstructured(u *unstructured.Unstructured) (*appsv1.StatefulSet, error)

ApplyFromUnstructured applies statefulset from *unstructured.Unstructured.

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{}) (*appsv1.StatefulSet, error)

Create creates statefulset from type string, []byte, *appsv1.StatefulSet, appsv1.StatefulSet, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) CreateFromBytes 

func (h *Handler) CreateFromBytes(data []byte) (*appsv1.StatefulSet, error)

CreateFromBytes creates statefulset from bytes.

func (*Handler) CreateFromFile 

func (h *Handler) CreateFromFile(filename string) (*appsv1.StatefulSet, error)

CreateFromFile creates statefulset from yaml file.

func (*Handler) CreateFromMap added in v0.5.0 

func (h *Handler) CreateFromMap(u map[string]interface{}) (*appsv1.StatefulSet, error)

CreateFromMap creates statefulset from map[string]interface{}.

func (*Handler) CreateFromObject added in v0.3.0 

func (h *Handler) CreateFromObject(obj runtime.Object) (*appsv1.StatefulSet, error)

CreateFromObject creates statefulset from runtime.Object.

func (*Handler) CreateFromUnstructured added in v0.3.0 

func (h *Handler) CreateFromUnstructured(u *unstructured.Unstructured) (*appsv1.StatefulSet, error)

CreateFromUnstructured creates statefulset from *unstructured.Unstructured.

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 statefulset from file path.

func (*Handler) DeleteByName 

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

DeleteByName deletes statefulset by name.

func (*Handler) DeleteFromBytes 

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

DeleteFromBytes deletes statefulset from bytes.

func (*Handler) DeleteFromFile 

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

DeleteFromFile deletes statefulset from yaml file.

func (*Handler) DeleteFromMap added in v0.5.0 

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

DeleteFromMap deletes statefulset from map[string]interface{}.

func (*Handler) DeleteFromObject added in v0.3.0 

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

DeleteFromObject deletes statefulset from runtime.Object.

func (*Handler) DeleteFromUnstructured added in v0.3.0 

func (h *Handler) DeleteFromUnstructured(u *unstructured.Unstructured) error

DeleteFromUnstructured deletes statefulset from *unstructured.Unstructured.

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{}) (*appsv1.StatefulSet, error)

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

func (*Handler) GetAge 

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

GetAge returns the statefulset age.

func (*Handler) GetByName 

func (h *Handler) GetByName(name string) (*appsv1.StatefulSet, error)

GetByName gets statefulset by name.

func (*Handler) GetContainers added in v0.2.0 

func (h *Handler) GetContainers(object interface{}) ([]string, error)

GetContainers get all container of this statefulset.

func (*Handler) GetFromBytes 

func (h *Handler) GetFromBytes(data []byte) (*appsv1.StatefulSet, error)

GetFromBytes gets statefulset from bytes.

func (*Handler) GetFromFile 

func (h *Handler) GetFromFile(filename string) (*appsv1.StatefulSet, error)

GetFromFile gets statefulset from yaml file.

func (*Handler) GetFromMap added in v0.5.0 

func (h *Handler) GetFromMap(u map[string]interface{}) (*appsv1.StatefulSet, error)

GetFromMap gets statefulset from map[string]interface{}.

func (*Handler) GetFromObject added in v0.3.0 

func (h *Handler) GetFromObject(obj runtime.Object) (*appsv1.StatefulSet, error)

GetFromObject gets statefulset from runtime.Object.

func (*Handler) GetFromUnstructured added in v0.3.0 

func (h *Handler) GetFromUnstructured(u *unstructured.Unstructured) (*appsv1.StatefulSet, error)

GetFromUnstructured gets statefulset from *unstructured.Unstructured.

func (*Handler) GetImages added in v0.2.0 

func (h *Handler) GetImages(object interface{}) ([]string, error)

GetImages get all container images of this statefulset.

func (*Handler) GetPV 

func (h *Handler) GetPV(object interface{}) ([]string, error)

GetPV get all persistentvolumes mounted by the statefulset.

func (*Handler) GetPVC 

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

GetPVC get all persistentvolumeclaims mounted by the statefulset.

func (*Handler) GetPods 

func (h *Handler) GetPods(object interface{}) ([]corev1.Pod, error)

GetPods get all pods created by the statefulset.

func (*Handler) Informer added in v0.5.0 

func (h *Handler) Informer() cache.SharedIndexInformer

Informer returns underlying SharedIndexInformer which provides add and Indexers ability based on SharedInformer.

func (*Handler) InformerFactory added in v0.5.0 

func (h *Handler) InformerFactory() informers.SharedInformerFactory

InformerFactory returns underlying SharedInformerFactory which provides shared informer for resources in all known API group version.

func (*Handler) IsReady 

func (h *Handler) IsReady(name string) bool

IsReady check if the statefulset is ready.

func (*Handler) List 

func (h *Handler) List(labels string) (*appsv1.StatefulSetList, error)

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

func (*Handler) ListAll 

func (h *Handler) ListAll() (*appsv1.StatefulSetList, error)

ListAll list all statefulsets in the k8s cluster.

func (*Handler) ListByLabel 

func (h *Handler) ListByLabel(labels string) (*appsv1.StatefulSetList, error)

ListByLabel list statefulsets by labels.

func (*Handler) ListByNamespace 

func (h *Handler) ListByNamespace(namespace string) (*appsv1.StatefulSetList, error)

ListByNamespace list statefulsets by namespace.

func (*Handler) Lister added in v0.5.0 

func (h *Handler) Lister() listersapps.StatefulSetLister

Lister returns underlying StatefulSetLister which helps list statefulsets.

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) SetInformerResyncPeriod added in v0.5.0 

func (h *Handler) SetInformerResyncPeriod(resyncPeriod time.Duration)

SetInformerResyncPeriod will set informer resync period.

func (*Handler) SetLimit 

func (h *Handler) SetLimit(limit int64)

func (*Handler) SetTimeout 

func (h *Handler) SetTimeout(timeout int64)

func (*Handler) StatefulSetInformer added in v0.5.0 

func (h *Handler) StatefulSetInformer() informersapps.StatefulSetInformer

StatefulSetInformer returns underlying StatefulSetInformer which provides access to a shared informer and lister for statefulset.

func (*Handler) Update 

func (h *Handler) Update(obj interface{}) (*appsv1.StatefulSet, error)

Update updates statefulset from type string, []byte, *appsv1.StatefulSet, appsv1.StatefulSet, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) UpdateFromBytes 

func (h *Handler) UpdateFromBytes(data []byte) (*appsv1.StatefulSet, error)

UpdateFromBytes updates statefulset from bytes.

func (*Handler) UpdateFromFile 

func (h *Handler) UpdateFromFile(filename string) (*appsv1.StatefulSet, error)

UpdateFromFile updates statefulset from yaml file.

func (*Handler) UpdateFromMap added in v0.5.0 

func (h *Handler) UpdateFromMap(u map[string]interface{}) (*appsv1.StatefulSet, error)

UpdateFromMap updates statefulset from map[string]interface{}.

func (*Handler) UpdateFromObject added in v0.3.0 

func (h *Handler) UpdateFromObject(obj runtime.Object) (*appsv1.StatefulSet, error)

UpdateFromObject updates statefulset from runtime.Object.

func (*Handler) UpdateFromUnstructured added in v0.3.0 

func (h *Handler) UpdateFromUnstructured(u *unstructured.Unstructured) (*appsv1.StatefulSet, error)

UpdateFromUnstructured updates statefulset from *unstructured.Unstructured.

func (*Handler) WaitReady 

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

WaitReady waiting for the statefulset to be in the ready status.

func (*Handler) Watch 

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

Watch watch statefulset 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 statefulset by label.

func (*Handler) WatchByName 

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

WatchByName watch statefulset by name.

func (*Handler) WithDryRun 

func (h *Handler) WithDryRun() *Handler

func (*Handler) WithNamespace 

func (h *Handler) WithNamespace(namespace string) *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.