pod

Documentation

Index

• func NewListWatcherAdapter(c kubernetes.Interface, namespace string) operator.ListWatcher
• type Handler
  • func NewHandler(st Pool) *Handler
  • func (h *Handler) Created(_ context.Context, obj runtime.Object)
  • func (h *Handler) Deleted(_ context.Context, obj runtime.Object)
  • func (h *Handler) Updated(ctx context.Context, new, old runtime.Object)
• type Pool
• type Provider
  • func NewProvider(cl kubernetes.Interface, namespace string) *Provider
  • func (p *Provider) RefreshPod(ctx context.Context, name string) error

Functions

func NewListWatcherAdapter

func NewListWatcherAdapter(c kubernetes.Interface, namespace string) operator.ListWatcher

NewListWatcherAdapter instantiates pod list watcher adapter

Types

type Handler

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

Handler process Pod state variations

func NewHandler

func NewHandler(st Pool) *Handler

NewHandler instantiates pod handler

func (*Handler) Created

func (h *Handler) Created(_ context.Context, obj runtime.Object)

Created on pod creation handler

func (*Handler) Deleted

func (h *Handler) Deleted(_ context.Context, obj runtime.Object)

Deleted on pod deleted handler

func (*Handler) Updated

func (h *Handler) Updated(ctx context.Context, new, old runtime.Object)

Updated on pod updated handler

type Pool

type Pool interface {
	AddWorkerIfNotExists(idx int, name string, IP net.IP) bool
	RemoveWorkerByName(name string)
}

Pool models an ordered set of workers

type Provider

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

Provider deletes pod to force pod fresh recreation

func NewProvider

func NewProvider(cl kubernetes.Interface, namespace string) *Provider

NewProvider instantiates pod refresher provider

func (*Provider) RefreshPod

func (p *Provider) RefreshPod(ctx context.Context, name string) error

RefreshPod deletes pod