grace

Documentation

Index

• func ServeGfShutdown(addr string) error
• func SinglePodUpgrade(ctx context.Context, client *k8s.K8sClient, name string, recreate bool, ...)
• func TriggerBatchUpgrade(socketPath string, batchConfigName string, batchIndex int) error
• func TriggerShutdown(socketPath string, name string, recreateFlag bool) error
• type BatchUpgrade
  • func NewBatchUpgrade(client *k8s.K8sClient, req upgradeRequest) *BatchUpgrade
  • func (u *BatchUpgrade) BatchUpgrade(ctx context.Context, conn net.Conn)
• type PodUpgrade
  • func NewPodUpgrade(ctx context.Context, client *k8s.K8sClient, name string, recreate bool, ...) (*PodUpgrade, error)

Functions

func ServeGfShutdown

func ServeGfShutdown(addr string) error

func SinglePodUpgrade

func SinglePodUpgrade(ctx context.Context, client *k8s.K8sClient, name string, recreate bool, conn net.Conn)

func TriggerBatchUpgrade

func TriggerBatchUpgrade(socketPath string, batchConfigName string, batchIndex int) error

func TriggerShutdown

func TriggerShutdown(socketPath string, name string, recreateFlag bool) error

Types

type BatchUpgrade

type BatchUpgrade struct {
	// contains filtered or unexported fields
}

func NewBatchUpgrade

func NewBatchUpgrade(client *k8s.K8sClient, req upgradeRequest) *BatchUpgrade

func (*BatchUpgrade) BatchUpgrade

func (u *BatchUpgrade) BatchUpgrade(ctx context.Context, conn net.Conn)

type PodUpgrade

type PodUpgrade struct {
	// contains filtered or unexported fields
}

func NewPodUpgrade

func NewPodUpgrade(ctx context.Context, client *k8s.K8sClient, name string, recreate bool, conn net.Conn) (*PodUpgrade, error)