Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v1

v1.31.0

Oct 7, 2024

v1.31.0-dev

Oct 7, 2024

v1.30.5

Oct 10, 2024

v1.30.0

Aug 13, 2024

v1.29.0

May 28, 2024

Changes in this version

+ func LocalStoragePodFilter(p apiv1.Pod) (bool, error)

+ func MirrorPodFilter(p apiv1.Pod) (bool, error)

+ func UnreplicatedPodFilter(p apiv1.Pod) (bool, error)

+ type ClientConfig interface

+ GetAPIServerURL func() string

+ GetDeletionTimeout func() time.Duration

+ GetKubeConfig func() string

+ GetMaxGracePeriod func() time.Duration

+ GetNodeReadyTimeout func() time.Duration

+ GetRequestTimeout func() time.Duration

+ type ClientGenerator interface

+ AnnoteNode func(nodeName string, annotations map[string]string) error

+ ApiExtentionClient func() (apiextension.Interface, error)

+ CordonNode func(nodeName string) error

+ DeleteNode func(nodeName string) error

+ DeleteSecret func(secretName, namespace string) error

+ DrainNode func(nodeName string, ignoreDaemonSet, deleteLocalData bool) error

+ GetNode func(nodeName string) (*apiv1.Node, error)

+ GetSecret func(secretName, namespace string) (*apiv1.Secret, error)

+ KubeClient func() (kubernetes.Interface, error)

+ LabelNode func(nodeName string, labels map[string]string) error

+ MarkDrainNode func(nodeName string) error

+ NodeList func() (*apiv1.NodeList, error)

+ NodeManagerClient func() (managednodeClientset.Interface, error)

+ PodList func(nodeName string, podFilter PodFilterFunc) ([]apiv1.Pod, error)

+ SetProviderID func(nodeName, providerID string) error

+ TaintNode func(nodeName string, taints ...apiv1.Taint) error

+ UncordonNode func(nodeName string) error

+ WaitNodeToBeReady func(nodeName string) error

+ func NewClientGenerator(cfg ClientConfig) ClientGenerator

+ type PodFilterFunc func(p apiv1.Pod) (bool, error)

+ func NewDaemonSetPodFilter(ctx context.Context, client kubernetes.Interface) PodFilterFunc

+ func NewPodFilters(filters ...PodFilterFunc) PodFilterFunc

+ func NewStatefulSetPodFilter(ctx context.Context, client kubernetes.Interface) PodFilterFunc

+ func UnprotectedPodFilter(annotations ...string) PodFilterFunc