Documentation ¶
Index ¶
- Variables
- func GVK() schema.GroupVersionKind
- func GVR() schema.GroupVersionResource
- func Group() string
- func Kind() string
- func Resource() string
- func Version() string
- type Handler
- func (h *Handler) Apply(obj interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) ApplyFromBytes(data []byte) (rc *corev1.ReplicationController, err error)
- func (h *Handler) ApplyFromFile(filename string) (rc *corev1.ReplicationController, err error)
- func (h *Handler) ApplyFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) ApplyFromObject(obj runtime.Object) (*corev1.ReplicationController, error)
- func (h *Handler) ApplyFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
- func (h *Handler) Clientset() *kubernetes.Clientset
- func (h *Handler) Create(obj interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) CreateFromBytes(data []byte) (*corev1.ReplicationController, error)
- func (h *Handler) CreateFromFile(filename string) (*corev1.ReplicationController, error)
- func (h *Handler) CreateFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) CreateFromObject(obj runtime.Object) (*corev1.ReplicationController, error)
- func (h *Handler) CreateFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
- func (in *Handler) DeepCopy() *Handler
- func (h *Handler) Delete(obj interface{}) error
- func (h *Handler) DeleteByName(name string) error
- func (h *Handler) DeleteFromBytes(data []byte) error
- func (h *Handler) DeleteFromFile(filename string) error
- func (h *Handler) DeleteFromMap(u map[string]interface{}) error
- func (h *Handler) DeleteFromObject(obj runtime.Object) error
- func (h *Handler) DeleteFromUnstructured(u *unstructured.Unstructured) error
- func (h *Handler) DiscoveryClient() *discovery.DiscoveryClient
- func (h *Handler) DynamicClient() dynamic.Interface
- func (h *Handler) Get(obj interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) GetAge(object interface{}) (time.Duration, error)
- func (h *Handler) GetByName(name string) (*corev1.ReplicationController, error)
- func (h *Handler) GetFromBytes(data []byte) (*corev1.ReplicationController, error)
- func (h *Handler) GetFromFile(filename string) (*corev1.ReplicationController, error)
- func (h *Handler) GetFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) GetFromObject(obj runtime.Object) (*corev1.ReplicationController, error)
- func (h *Handler) GetFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
- func (h *Handler) GetPV(object interface{}) ([]string, error)
- func (h *Handler) GetPVC(object interface{}) ([]string, error)
- func (h *Handler) GetPods(object interface{}) ([]*corev1.Pod, error)
- func (h *Handler) Informer() cache.SharedIndexInformer
- func (h *Handler) InformerFactory() informers.SharedInformerFactory
- func (h *Handler) IsReady(name string) bool
- func (h *Handler) List() ([]*corev1.ReplicationController, error)
- func (h *Handler) ListAll() ([]*corev1.ReplicationController, error)
- func (h *Handler) ListByField(field string) ([]*corev1.ReplicationController, error)
- func (h *Handler) ListByLabel(labels string) ([]*corev1.ReplicationController, error)
- func (h *Handler) ListByNamespace(namespace string) ([]*corev1.ReplicationController, error)
- func (h *Handler) Lister() listerscore.ReplicationControllerLister
- func (h *Handler) RESTClient() *rest.RESTClient
- func (h *Handler) RESTConfig() *rest.Config
- func (h *Handler) ReplicationControllerInformer() informerscore.ReplicationControllerInformer
- func (h *Handler) RunInformer(stopCh <-chan struct{}, addFunc func(obj interface{}), ...)
- func (h *Handler) Scale(obj interface{}, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleByName(name string, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleFromBytes(data []byte, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleFromFile(filename string, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleFromMap(u map[string]interface{}, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleFromObject(obj runtime.Object, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) ScaleFromUnstructured(u *unstructured.Unstructured, replicas int32) (*corev1.ReplicationController, error)
- func (h *Handler) SetForceDelete(force bool)
- func (h *Handler) SetInformerResyncPeriod(resyncPeriod time.Duration)
- func (h *Handler) SetLimit(limit int64)
- func (h *Handler) SetTimeout(timeout int64)
- func (h *Handler) StartInformer(stopCh <-chan struct{}, addFunc func(obj interface{}), ...)
- func (h *Handler) Update(obj interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) UpdateFromBytes(data []byte) (*corev1.ReplicationController, error)
- func (h *Handler) UpdateFromFile(filename string) (*corev1.ReplicationController, error)
- func (h *Handler) UpdateFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
- func (h *Handler) UpdateFromObject(obj runtime.Object) (*corev1.ReplicationController, error)
- func (h *Handler) UpdateFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
- func (h *Handler) WaitReady(name string) error
- func (h *Handler) Watch(name string, addFunc, modifyFunc, deleteFunc func(x interface{}), ...) (err error)
- func (h *Handler) WatchByLabel(labels string, addFunc, modifyFunc, deleteFunc func(x interface{}), ...) (err error)
- func (h *Handler) WatchByName(name string, addFunc, modifyFunc, deleteFunc func(x interface{}), ...) (err error)
- func (h *Handler) WithDryRun() *Handler
- func (h *Handler) WithNamespace(namespace string) *Handler
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidToolsType = fmt.Errorf("type must be string, *corev1.ReplicationController, or corev1.ReplicationController") ErrInvalidCreateType = fmt.Errorf("type must be string, []byte, *corev1.ReplicationController, corev1.ReplicationController, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}") ErrInvalidUpdateType = ErrInvalidCreateType ErrInvalidApplyType = ErrInvalidCreateType ErrInvalidDeleteType = ErrInvalidCreateType ErrInvalidGetType = ErrInvalidCreateType ErrInvalidScaleType = ErrInvalidCreateType )
Functions ¶
func GVK ¶ added in v0.6.1
func GVK() schema.GroupVersionKind
GVK returns the name of Group, Version, Kind of replicationcontroller resource.
func GVR ¶ added in v0.5.0
func GVR() schema.GroupVersionResource
GVR returns the name of Group, Version, Resource of replicationcontroller resource.
func Group ¶ added in v0.5.0
func Group() string
Group returns the Group name of replicationcontroller resource.
func Kind ¶ added in v0.6.1
func Kind() string
Kind returns the Kind name of replicationcontroller resource.
Types ¶
type Handler ¶
type Handler struct { Options *types.HandlerOptions // contains filtered or unexported fields }
func New ¶
New returns a replicationcontroller handler from kubeconfig or in-cluster config. 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 NewOrDie ¶ added in v0.3.0
NewOrDie simply call New() to get a replicationcontroller handler. panic if there is any error occurs.
func (*Handler) Apply ¶
func (h *Handler) Apply(obj interface{}) (*corev1.ReplicationController, error)
Apply applies replicationcontroller from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.
func (*Handler) ApplyFromBytes ¶
func (h *Handler) ApplyFromBytes(data []byte) (rc *corev1.ReplicationController, err error)
ApplyFromBytes pply replicationcontroller from bytes.
func (*Handler) ApplyFromFile ¶
func (h *Handler) ApplyFromFile(filename string) (rc *corev1.ReplicationController, err error)
ApplyFromFile applies replicationcontroller from yaml file.
func (*Handler) ApplyFromMap ¶ added in v0.5.0
func (h *Handler) ApplyFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
ApplyFromMap applies replicationcontroller from map[string]interface{}.
func (*Handler) ApplyFromObject ¶ added in v0.3.0
ApplyFromObject applies replicationcontroller from runtime.Object.
func (*Handler) ApplyFromUnstructured ¶ added in v0.3.0
func (h *Handler) ApplyFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
ApplyFromUnstructured applies replicationcontroller 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{}) (*corev1.ReplicationController, error)
Create creates replicationcontroller from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.
func (*Handler) CreateFromBytes ¶
func (h *Handler) CreateFromBytes(data []byte) (*corev1.ReplicationController, error)
CreateFromBytes creates replicationcontroller from bytes.
func (*Handler) CreateFromFile ¶
func (h *Handler) CreateFromFile(filename string) (*corev1.ReplicationController, error)
CreateFromFile creates replicationcontroller from yaml file.
func (*Handler) CreateFromMap ¶ added in v0.5.0
func (h *Handler) CreateFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
CreateFromMap creates replicationcontroller from map[string]interface{}.
func (*Handler) CreateFromObject ¶ added in v0.3.0
CreateFromObject creates replicationcontroller from runtime.Object.
func (*Handler) CreateFromUnstructured ¶ added in v0.3.0
func (h *Handler) CreateFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
CreateFromUnstructured creates replicationcontroller from *unstructured.Unstructured.
func (*Handler) Delete ¶
Delete deletes replicationcontroller from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, 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 replicationcontroller from file path.
func (*Handler) DeleteByName ¶
DeleteByName deletes replicationcontroller by name.
func (*Handler) DeleteFromBytes ¶
DeleteFromBytes deletes replicationcontroller from bytes.
func (*Handler) DeleteFromFile ¶
DeleteFromFile deletes replicationcontroller from yaml file.
func (*Handler) DeleteFromMap ¶ added in v0.5.0
DeleteFromMap deletes replicationcontroller from map[string]interface{}.
func (*Handler) DeleteFromObject ¶ added in v0.3.0
DeleteFromObject deletes replicationcontroller from runtime.Object.
func (*Handler) DeleteFromUnstructured ¶ added in v0.3.0
func (h *Handler) DeleteFromUnstructured(u *unstructured.Unstructured) error
DeleteFromUnstructured deletes replicationcontroller 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
DynamicClient returns underlying dynamic client.
func (*Handler) Get ¶
func (h *Handler) Get(obj interface{}) (*corev1.ReplicationController, error)
Get gets replicationcontroller from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, 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 replicationcontroller from file path.
func (*Handler) GetByName ¶
func (h *Handler) GetByName(name string) (*corev1.ReplicationController, error)
GetByName gets replicationcontroller by name.
func (*Handler) GetFromBytes ¶
func (h *Handler) GetFromBytes(data []byte) (*corev1.ReplicationController, error)
GetFromBytes gets replicationcontroller from bytes.
func (*Handler) GetFromFile ¶
func (h *Handler) GetFromFile(filename string) (*corev1.ReplicationController, error)
GetFromFile gets replicationcontroller from yaml file.
func (*Handler) GetFromMap ¶ added in v0.5.0
func (h *Handler) GetFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
GetFromMap gets replicationcontroller from map[string]interface{}.
func (*Handler) GetFromObject ¶ added in v0.3.0
GetFromObject gets replicationcontroller from runtime.Object.
func (*Handler) GetFromUnstructured ¶ added in v0.3.0
func (h *Handler) GetFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
GetFromUnstructured gets replicationcontroller from *unstructured.Unstructured.
func (*Handler) GetPV ¶ added in v0.10.0
GetPV get all persistentvolumes mounted by the replicationcontroller.
func (*Handler) GetPVC ¶ added in v0.10.0
GetPVC get all persistentvolumeclaims mounted by the replicationcontroller.
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) List ¶
func (h *Handler) List() ([]*corev1.ReplicationController, error)
List list all replicationcontrollers in the k8s cluster, it simply call `ListAll`.
func (*Handler) ListAll ¶
func (h *Handler) ListAll() ([]*corev1.ReplicationController, error)
ListAll list all replicationcontrollers in the k8s cluster.
func (*Handler) ListByField ¶ added in v0.7.0
func (h *Handler) ListByField(field string) ([]*corev1.ReplicationController, error)
ListByField list replicationcontrollers by field, work like `kubectl get xxx --field-selector=xxx`.
func (*Handler) ListByLabel ¶
func (h *Handler) ListByLabel(labels string) ([]*corev1.ReplicationController, error)
ListByLabel list replicationcontrollers by labels. Multiple labels separated by comma(",") eg: "name=myapp,role=devops", and there is an "And" relationship between multiple labels.
func (*Handler) ListByNamespace ¶
func (h *Handler) ListByNamespace(namespace string) ([]*corev1.ReplicationController, error)
ListByNamespace list all replicationcontrollers in the specified namespace.
func (*Handler) Lister ¶ added in v0.5.0
func (h *Handler) Lister() listerscore.ReplicationControllerLister
Lister returns underlying ReplicationControllerLister which helps list replicationcontrollers.
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
RESTConfig returns underlying rest config.
func (*Handler) ReplicationControllerInformer ¶ added in v0.5.0
func (h *Handler) ReplicationControllerInformer() informerscore.ReplicationControllerInformer
ReplicationControllerInformer returns underlying ReplicationControllerInformer which provides access to a shared informer and lister for replicationcontroller.
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 replicationcontroller resource, respectively.
func (*Handler) Scale ¶ added in v0.10.0
func (h *Handler) Scale(obj interface{}, replicas int32) (*corev1.ReplicationController, error)
Scale set replicationcontroller replicas from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.
If passed parameter type is string, it will simply call ScaleByName instead of ScaleFromFile. You should always explicitly call ScaleFromFile to set replicationcontroller replicas from file path.
func (*Handler) ScaleByName ¶ added in v0.10.0
ScaleByName scale replicationcontroller by name.
func (*Handler) ScaleFromBytes ¶ added in v0.10.0
func (h *Handler) ScaleFromBytes(data []byte, replicas int32) (*corev1.ReplicationController, error)
ScaleFromBytes scale replicationcontroller from bytes.
func (*Handler) ScaleFromFile ¶ added in v0.10.0
func (h *Handler) ScaleFromFile(filename string, replicas int32) (*corev1.ReplicationController, error)
ScaleFromFile scale replicationcontroller from yaml file.
func (*Handler) ScaleFromMap ¶ added in v0.10.0
func (h *Handler) ScaleFromMap(u map[string]interface{}, replicas int32) (*corev1.ReplicationController, error)
ScaleFromMap scale replicationcontroller from map[string]interface{}.
func (*Handler) ScaleFromObject ¶ added in v0.10.0
func (h *Handler) ScaleFromObject(obj runtime.Object, replicas int32) (*corev1.ReplicationController, error)
ScaleFromObject scale replicationcontroller from runtime.Object.
func (*Handler) ScaleFromUnstructured ¶ added in v0.10.0
func (h *Handler) ScaleFromUnstructured(u *unstructured.Unstructured, replicas int32) (*corev1.ReplicationController, error)
ScaleFromUnstructured scale replicationcontroller from *unstructured.Unstructured.
func (*Handler) SetForceDelete ¶
func (*Handler) SetInformerResyncPeriod ¶ added in v0.5.0
SetInformerResyncPeriod will set informer resync period.
func (*Handler) SetTimeout ¶
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{}) (*corev1.ReplicationController, error)
Update updates replicationcontroller from type string, []byte, *corev1.ReplicationController, corev1.ReplicationController, runtime.Object, *unstructured.Unstructured, unstructured.Unstructured or map[string]interface{}.
func (*Handler) UpdateFromBytes ¶
func (h *Handler) UpdateFromBytes(data []byte) (*corev1.ReplicationController, error)
UpdateFromBytes updates replicationcontroller from bytes.
func (*Handler) UpdateFromFile ¶
func (h *Handler) UpdateFromFile(filename string) (*corev1.ReplicationController, error)
UpdateFromFile updates replicationcontroller from yaml file.
func (*Handler) UpdateFromMap ¶ added in v0.5.0
func (h *Handler) UpdateFromMap(u map[string]interface{}) (*corev1.ReplicationController, error)
UpdateFromMap updates replicationcontroller from map[string]interface{}.
func (*Handler) UpdateFromObject ¶ added in v0.3.0
UpdateFromObject updates replicationcontroller from runtime.Object.
func (*Handler) UpdateFromUnstructured ¶ added in v0.3.0
func (h *Handler) UpdateFromUnstructured(u *unstructured.Unstructured) (*corev1.ReplicationController, error)
UpdateFromUnstructured updates replicationcontroller from *unstructured.Unstructured.
func (*Handler) WaitReady ¶
WaitReady waiting for the replicationcontroller 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 replicationcontrollers by name, alias to "WatchByName"
func (*Handler) WatchByLabel ¶
func (h *Handler) WatchByLabel(labels string, addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)
WatchByLabel watch replicationcontrollers by labels
func (*Handler) WatchByName ¶
func (h *Handler) WatchByName(name string, addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)
WatchByName watch replicationcontrollers by name.
func (*Handler) WithDryRun ¶
WithDryRun deep copies a new handler and prints the create/update/apply/delete operations, without sending it to apiserver.
func (*Handler) WithNamespace ¶
WithNamespace deep copies a new handler, but set the handler.namespace to the provided namespace.