ingressclass

package
v0.11.3 Latest Latest
Warning

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

Go to latest
Published: Sep 11, 2022 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidToolsType  = errors.New("type must be string, *networkingv1.IngressClass, networkingv1.IngressClass or runtime.Object")
	ErrInvalidCreateType = errors.New("type must be string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}")
	ErrInvalidUpdateType = ErrInvalidCreateType
	ErrInvalidApplyType  = ErrInvalidCreateType
	ErrInvalidDeleteType = ErrInvalidCreateType
	ErrInvalidGetType    = ErrInvalidCreateType
	ErrInvalidPathType   = errors.New("path data type must be string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}")
)

Functions

func GVK added in v0.6.1

GVK returns the name of Group, Version, Kind of ingressclass resource.

func GVR added in v0.5.0

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

func Group added in v0.5.0

func Group() string

Group returns the Group name of ingressclass resource.

func Kind added in v0.6.1

func Kind() string

Kind returns the Kind name of ingressclass resource.

func Resource added in v0.5.0

func Resource() string

Resource returns the Resource name of ingressclass resource.

func Version added in v0.5.0

func Version() string

Version returns the Version name of ingressclass resource.

Types

type Handler

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

func New

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

New returns a ingressclass 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 ingressclass handler. panic if there is any error occurs. The kubeconfig precedence is: * kubeconfig variable passed. * KUBECONFIG environment variable pointing at a file. * $HOME/.kube/config if exists. * In-cluster config if running in cluster.

func (*Handler) Apply

func (h *Handler) Apply(obj interface{}) (*networkingv1.IngressClass, error)

Apply applies ingressclass from type string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) ApplyFromBytes

func (h *Handler) ApplyFromBytes(data []byte) (ingc *networkingv1.IngressClass, err error)

ApplyFromBytes pply ingressclass from bytes.

func (*Handler) ApplyFromFile

func (h *Handler) ApplyFromFile(filename string) (ingc *networkingv1.IngressClass, err error)

ApplyFromFile applies ingressclass from yaml file.

func (*Handler) ApplyFromMap added in v0.5.0

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

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

func (*Handler) ApplyFromObject added in v0.3.0

func (h *Handler) ApplyFromObject(obj runtime.Object) (*networkingv1.IngressClass, error)

ApplyFromObject applies ingressclass from runtime.Object.

func (*Handler) ApplyFromUnstructured added in v0.3.0

func (h *Handler) ApplyFromUnstructured(u *unstructured.Unstructured) (*networkingv1.IngressClass, error)

ApplyFromUnstructured applies ingressclass 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{}) (*networkingv1.IngressClass, error)

Create creates ingressclass from type string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) CreateFromBytes

func (h *Handler) CreateFromBytes(data []byte) (*networkingv1.IngressClass, error)

CreateFromBytes creates ingressclass from bytes.

func (*Handler) CreateFromFile

func (h *Handler) CreateFromFile(filename string) (*networkingv1.IngressClass, error)

CreateFromFile creates ingressclass from yaml file.

func (*Handler) CreateFromMap added in v0.5.0

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

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

func (*Handler) CreateFromObject added in v0.3.0

func (h *Handler) CreateFromObject(obj runtime.Object) (*networkingv1.IngressClass, error)

CreateFromObject creates ingressclass from runtime.Object.

func (*Handler) CreateFromUnstructured added in v0.3.0

func (h *Handler) CreateFromUnstructured(u *unstructured.Unstructured) (*networkingv1.IngressClass, error)

CreateFromUnstructured creates ingressclass from *unstructured.Unstructured.

func (*Handler) DeepCopy

func (in *Handler) DeepCopy() *Handler

func (*Handler) Delete

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

Delete deletes ingressclass from type string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

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

func (*Handler) DeleteByName

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

DeleteByName deletes ingressclass by name.

func (*Handler) DeleteFromBytes

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

DeleteFromBytes deletes ingressclass from bytes.

func (*Handler) DeleteFromFile

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

DeleteFromFile deletes ingressclass from yaml file.

func (*Handler) DeleteFromMap added in v0.5.0

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

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

func (*Handler) DeleteFromObject added in v0.3.0

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

DeleteFromObject deletes ingressclass from runtime.Object.

func (*Handler) DeleteFromUnstructured added in v0.3.0

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

DeleteFromUnstructured deletes ingressclass 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{}) (*networkingv1.IngressClass, error)

Get gets ingressclass from type string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

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

func (*Handler) GetAge added in v0.2.0

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

GetAge

func (*Handler) GetByName

func (h *Handler) GetByName(name string) (*networkingv1.IngressClass, error)

GetByName gets ingressclass by name.

func (*Handler) GetFromBytes

func (h *Handler) GetFromBytes(data []byte) (*networkingv1.IngressClass, error)

GetFromBytes gets ingressclass from bytes.

func (*Handler) GetFromFile

func (h *Handler) GetFromFile(filename string) (*networkingv1.IngressClass, error)

GetFromFile gets ingressclass from yaml file.

func (*Handler) GetFromMap added in v0.5.0

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

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

func (*Handler) GetFromObject added in v0.3.0

func (h *Handler) GetFromObject(obj runtime.Object) (*networkingv1.IngressClass, error)

GetFromObject gets ingressclass from runtime.Object.

func (*Handler) GetFromUnstructured added in v0.3.0

func (h *Handler) GetFromUnstructured(u *unstructured.Unstructured) (*networkingv1.IngressClass, error)

GetFromUnstructured gets ingressclass from *unstructured.Unstructured.

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

func (h *Handler) IngressClassInformer() informersnetworking.IngressClassInformer

IngressClassInformer returns underlying IngressClassInformer which provides access to a shared informer and lister for ingressclass.

func (*Handler) List

func (h *Handler) List() ([]*networkingv1.IngressClass, error)

List list all ingressclasses in the k8s cluster, it simply call `ListAll`.

func (*Handler) ListAll

func (h *Handler) ListAll() ([]*networkingv1.IngressClass, error)

ListAll list all ingressclasses in the k8s cluster.

func (*Handler) ListByField added in v0.7.0

func (h *Handler) ListByField(field string) ([]*networkingv1.IngressClass, error)

ListByField list ingressclasses by field, work like `kubectl get xxx --field-selector=xxx`.

func (*Handler) ListByLabel

func (h *Handler) ListByLabel(labels string) ([]*networkingv1.IngressClass, error)

ListByLabel list ingressclasses by labels. Multiple labels separated by comma(",") eg: "name=myapp,role=devops", and there is an "And" relationship between multiple labels.

func (*Handler) Lister added in v0.5.0

Lister returns underlying IngressClassLister which helps list ingressclasses.

func (*Handler) Patch added in v0.11.1

func (h *Handler) Patch(original *networkingv1.IngressClass, patch interface{}, patchOptions ...types.PatchType) (*networkingv1.IngressClass, error)

Patch use the default patch type(Strategic Merge Patch) to patch ingressclass. Supported patch types are: "StrategicMergePatchType", "MergePatchType", "JSONPatchType".

For further more Strategic Merge patch, see:

https://kubernetes.io/docs/tasks/manage-kubernetes-objects/update-api-object-kubectl-patch/#before-you-begin

For a comparison of JSON patch and JSON merge patch, see:

https://erosb.github.io/post/json-patch-vs-merge-patch/

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(
	stopCh <-chan struct{},
	addFunc func(obj interface{}),
	updateFunc func(oldObj, newObj interface{}),
	deleteFunc func(obj interface{}))

RunInformer start and run the shared informer, returning after it stops. The informer will be stopped when stopCh is closed.

AddFunc, updateFunc, and deleteFunc are used to handle add, update, and delete event of k8s ingressclass resource, respectively.

func (*Handler) SetForceDelete

func (h *Handler) SetForceDelete(force bool)

func (*Handler) SetInformerFactoryNamespace added in v0.10.4

func (h *Handler) SetInformerFactoryNamespace(namespace string)

SetInformerFactoryNamespace limit the scope of informer list-and-watch k8s resource. informer list-and-watch all namespace k8s resource by default.

func (*Handler) SetInformerFactoryResyncPeriod added in v0.10.4

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

SetInformerFactoryResyncPeriod will set informer resync period.

func (*Handler) SetInformerFactoryTweakListOptions added in v0.10.4

func (h *Handler) SetInformerFactoryTweakListOptions(tweakListOptions internalinterfaces.TweakListOptionsFunc)

SetInformerFactoryTweakListOptions sets a custom filter on all listers of the configured SharedInformerFactory.

func (*Handler) SetLimit

func (h *Handler) SetLimit(limit int64)

func (*Handler) SetTimeout

func (h *Handler) SetTimeout(timeout int64)

func (*Handler) StartInformer added in v0.10.1

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

StartInformer simply call RunInformer.

func (*Handler) Update

func (h *Handler) Update(obj interface{}) (*networkingv1.IngressClass, error)

Update updates ingressclass from type string, []byte, *networkingv1.IngressClass, networkingv1.IngressClass, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.

func (*Handler) UpdateFromBytes

func (h *Handler) UpdateFromBytes(data []byte) (*networkingv1.IngressClass, error)

UpdateFromBytes updates ingressclass from bytes.

func (*Handler) UpdateFromFile

func (h *Handler) UpdateFromFile(filename string) (*networkingv1.IngressClass, error)

UpdateFromFile updates ingressclass from yaml file.

func (*Handler) UpdateFromMap added in v0.5.0

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

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

func (*Handler) UpdateFromObject added in v0.3.0

func (h *Handler) UpdateFromObject(obj runtime.Object) (*networkingv1.IngressClass, error)

UpdateFromObject updates ingressclass from runtime.Object.

func (*Handler) UpdateFromUnstructured added in v0.3.0

func (h *Handler) UpdateFromUnstructured(u *unstructured.Unstructured) (*networkingv1.IngressClass, error)

UpdateFromUnstructured updates ingressclass from *unstructured.Unstructured.

func (*Handler) Watch

func (h *Handler) Watch(addFunc, modifyFunc, deleteFunc func(obj interface{})) error

Watch watch all ingressclass resources.

Object as the parameter of addFunc, modifyFunc, deleteFunc:

  • If Event.Type is Added or Modified: the new state of the object.
  • If Event.Type is Deleted: the state of the object immediately before deletion.
  • If Event.Type is Bookmark: the object (instance of a type being watched) where only ResourceVersion field is set. On successful restart of watch from a bookmark resourceVersion, client is guaranteed to not get repeat event nor miss any events.
  • If Event.Type is Error: *api.Status is recommended; other types may make sense depending on context.

func (*Handler) WatchByField added in v0.11.1

func (h *Handler) WatchByField(field string, addFunc, modifyFunc, deleteFunc func(obj interface{})) error

WatchByField watch a single or multiple IngressClass resources selected by the field.

Object as the parameter of addFunc, modifyFunc, deleteFunc:

  • If Event.Type is Added or Modified: the new state of the object.
  • If Event.Type is Deleted: the state of the object immediately before deletion.
  • If Event.Type is Bookmark: the object (instance of a type being watched) where only ResourceVersion field is set. On successful restart of watch from a bookmark resourceVersion, client is guaranteed to not get repeat event nor miss any events.
  • If Event.Type is Error: *api.Status is recommended; other types may make sense depending on context.

func (*Handler) WatchByLabel

func (h *Handler) WatchByLabel(labels string, addFunc, modifyFunc, deleteFunc func(obj interface{})) error

WatchByLabel watch a single or multiple IngressClass resources selected by the label. Multiple labels are separated by ",", label key and value conjunctaed by "=".

Object as the parameter of addFunc, modifyFunc, deleteFunc:

  • If Event.Type is Added or Modified: the new state of the object.
  • If Event.Type is Deleted: the state of the object immediately before deletion.
  • If Event.Type is Bookmark: the object (instance of a type being watched) where only ResourceVersion field is set. On successful restart of watch from a bookmark resourceVersion, client is guaranteed to not get repeat event nor miss any events.
  • If Event.Type is Error: *api.Status is recommended; other types may make sense depending on context.

func (*Handler) WatchByName

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

WatchByName watch a single ingressclass reseource.

Object as the parameter of addFunc, modifyFunc, deleteFunc:

  • If Event.Type is Added or Modified: the new state of the object.
  • If Event.Type is Deleted: the state of the object immediately before deletion.
  • If Event.Type is Bookmark: the object (instance of a type being watched) where only ResourceVersion field is set. On successful restart of watch from a bookmark resourceVersion, client is guaranteed to not get repeat event nor miss any events.
  • If Event.Type is Error: *api.Status is recommended; other types may make sense depending on context.

func (*Handler) WithDryRun

func (h *Handler) WithDryRun() *Handler

WithDryRun deep copies a new handler and prints the create/update/apply/delete operations, without sending it to apiserver.

Jump to

Keyboard shortcuts

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