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

core

package

Go to main page

Versions in this module

v0

v0.0.8

Apr 10, 2022

Changes in this version

+ const DeleteAtAnnotationKey

+ const GracefulDrainPrefix

+ const OriginalLabelsAnnotationKey

+ const TargetHealthPodConditionTypePrefix

+ const WaitLabelKey

+ func DidPodHaveServicesTargetTypeIP(ctx context.Context, client client.Client, pod *corev1.Pod) (bool, error)

+ func IsPodInDrainingNode(ctx context.Context, client client.Client, pod *corev1.Pod) (bool, error)

+ func IsPodReady(pod *corev1.Pod) bool

+ type AdmissionResponse struct

+ Allow bool

+ Reason string

+ func (r AdmissionResponse) GetAdmissionResponse() admission.Response

+ type DelayedTask interface

+ GetDuration func() time.Duration

+ GetId func() DelayedTaskId

+ RunAsync func()

+ RunWait func(ctx context.Context) error

+ type DelayedTaskId int64

+ type Delayer interface

+ NewTask func(duration time.Duration, task func(context.Context, bool) error) DelayedTask

+ Stop func(drain time.Duration, cleanup time.Duration)

+ func NewDelayer(logger logr.Logger) Delayer

+ type EvictionResponse struct

+ Operations []jsonpatch.Operation

+ func NewEvictionResponse(eviction *policyv1.Eviction) (EvictionResponse, error)

+ func (r EvictionResponse) GetAdmissionResponse() admission.Response

+ type InterceptedAdmissionResponse interface

+ GetAdmissionResponse func() admission.Response

+ type Interceptor struct

+ func NewInterceptor(drain *PodGracefulDrain, k8sClient client.Client) Interceptor

+ func (i *Interceptor) InterceptPodDeletion(ctx context.Context, req *admission.Request, pod *corev1.Pod) (InterceptedAdmissionResponse, error)

+ func (i *Interceptor) InterceptPodEviction(ctx context.Context, req *admission.Request, eviction *policyv1.Eviction) (InterceptedAdmissionResponse, error)

+ type PodDeletionDelayInfo struct

+ DeleteAtUTC time.Time

+ Isolated bool

+ Wait bool

+ func GetPodDeletionDelayInfo(pod *corev1.Pod) (PodDeletionDelayInfo, error)

+ func (i *PodDeletionDelayInfo) GetRemainingTime(now time.Time) time.Duration

+ type PodGracefulDrain struct

+ func NewPodGracefulDrain(k8sClient client.Client, logger logr.Logger, config *PodGracefulDrainConfig) PodGracefulDrain

+ func (d *PodGracefulDrain) DelayPodDeletion(ctx context.Context, pod *corev1.Pod) (InterceptedAdmissionResponse, error)

+ func (d *PodGracefulDrain) DelayPodEviction(ctx context.Context, eviction *policyv1.Eviction) (bool, error)

+ func (d *PodGracefulDrain) Start(ctx context.Context) error

+ type PodGracefulDrainConfig struct

+ DeleteAfter time.Duration

+ IgnoreError bool

+ NoDenyAdmission bool

+ func (c *PodGracefulDrainConfig) BindFlags(fs *flag.FlagSet)

+ func (c *PodGracefulDrainConfig) Validate() error

+ type PodMutator struct

+ func NewPodMutator(client client.Client, pod *corev1.Pod) *PodMutator

+ func (m *PodMutator) DisableWaitLabelAndDelete(ctx context.Context) error

+ func (m *PodMutator) Isolate(ctx context.Context, deleteAt time.Time) error

+ func (m *PodMutator) WithLogger(logger logr.Logger) *PodMutator

v0.0.8-beta.1

Apr 6, 2022

v0.0.6

Feb 5, 2021

v0.0.5

Feb 4, 2021

v0.0.4

Feb 4, 2021

v0.0.3

Feb 3, 2021

v0.0.2

Feb 3, 2021

v0.0.1

Feb 3, 2021