Documentation ¶
Index ¶
- Constants
- Variables
- type BindingREST
- type EphemeralContainersREST
- func (r *EphemeralContainersREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
- func (r *EphemeralContainersREST) New() runtime.Object
- func (r *EphemeralContainersREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
- type EvictionREST
- type LegacyBindingREST
- type PodStorage
- type REST
- type StatusREST
Constants ¶
const ( // MaxDisruptedPodSize is the max size of PodDisruptionBudgetStatus.DisruptedPods. API server eviction // subresource handler will refuse to evict pods covered by the corresponding PDB // if the size of the map exceeds this value. It means a large number of // evictions have been approved by the API server but not noticed by the PDB controller yet. // This situation should self-correct because the PDB controller removes // entries from the map automatically after the PDB DeletionTimeout regardless. MaxDisruptedPodSize = 2000 )
Variables ¶
var EvictionsRetry = wait.Backoff{ Steps: 20, Duration: 500 * time.Millisecond, Factor: 1.0, Jitter: 0.1, }
EvictionsRetry is the retry for a conflict where multiple clients are making changes to the same resource.
Functions ¶
This section is empty.
Types ¶
type BindingREST ¶
type BindingREST struct {
// contains filtered or unexported fields
}
BindingREST implements the REST endpoint for binding pods to nodes when etcd is in use.
func (*BindingREST) Create ¶
func (r *BindingREST) Create(ctx context.Context, name string, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (out runtime.Object, err error)
Create ensures a pod is bound to a specific host.
func (*BindingREST) NamespaceScoped ¶
func (r *BindingREST) NamespaceScoped() bool
NamespaceScoped fulfill rest.Scoper
func (*BindingREST) New ¶
func (r *BindingREST) New() runtime.Object
New creates a new binding resource
type EphemeralContainersREST ¶
type EphemeralContainersREST struct {
// contains filtered or unexported fields
}
EphemeralContainersREST implements the REST endpoint for adding EphemeralContainers
func (*EphemeralContainersREST) Get ¶
func (r *EphemeralContainersREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
Get of this endpoint will return the list of ephemeral containers in this pod
func (*EphemeralContainersREST) New ¶
func (r *EphemeralContainersREST) New() runtime.Object
New creates a new EphemeralContainers resource
func (*EphemeralContainersREST) Update ¶
func (r *EphemeralContainersREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)
Update alters the EphemeralContainers field in PodSpec
type EvictionREST ¶
type EvictionREST struct {
// contains filtered or unexported fields
}
EvictionREST implements the REST endpoint for evicting pods from nodes
func (*EvictionREST) Create ¶
func (r *EvictionREST) Create(ctx context.Context, name string, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)
Create attempts to create a new eviction. That is, it tries to evict a pod.
func (*EvictionREST) GroupVersionKind ¶
func (r *EvictionREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind
GroupVersionKind specifies a particular GroupVersionKind to discovery
func (*EvictionREST) New ¶
func (r *EvictionREST) New() runtime.Object
New creates a new eviction resource
type LegacyBindingREST ¶
type LegacyBindingREST struct {
// contains filtered or unexported fields
}
LegacyBindingREST implements the REST endpoint for binding pods to nodes when etcd is in use.
func (*LegacyBindingREST) Create ¶
func (r *LegacyBindingREST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (out runtime.Object, err error)
Create ensures a pod is bound to a specific host.
func (*LegacyBindingREST) NamespaceScoped ¶
func (r *LegacyBindingREST) NamespaceScoped() bool
NamespaceScoped fulfill rest.Scoper
func (*LegacyBindingREST) New ¶
func (r *LegacyBindingREST) New() runtime.Object
New creates a new binding resource
type PodStorage ¶
type PodStorage struct { Pod *REST Binding *BindingREST LegacyBinding *LegacyBindingREST Eviction *EvictionREST Status *StatusREST EphemeralContainers *EphemeralContainersREST Log *podrest.LogREST Proxy *podrest.ProxyREST Exec *podrest.ExecREST Attach *podrest.AttachREST PortForward *podrest.PortForwardREST }
PodStorage includes storage for pods and all sub resources
func NewStorage ¶
func NewStorage(optsGetter generic.RESTOptionsGetter, k client.ConnectionInfoGetter, proxyTransport http.RoundTripper, podDisruptionBudgetClient policyclient.PodDisruptionBudgetsGetter) (PodStorage, error)
NewStorage returns a RESTStorage object that will work against pods.
type REST ¶
type REST struct { *genericregistry.Store // contains filtered or unexported fields }
REST implements a RESTStorage for pods
func (*REST) Categories ¶
Categories implements the CategoriesProvider interface. Returns a list of categories a resource is part of.
type StatusREST ¶
type StatusREST struct {
// contains filtered or unexported fields
}
StatusREST implements the REST endpoint for changing the status of a pod.
func (*StatusREST) Get ¶
func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
Get retrieves the object from the storage. It is required to support Patch.
func (*StatusREST) Update ¶
func (r *StatusREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)
Update alters the status subset of an object.