statefulset

Documentation

Index

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

Functions

func NewListWatcherAdapter

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

NewListWatcherAdapter instantiates statefulset list watcher adapter

Types

type Handler

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

Handler handles statefulset state updates

func NewHandler

func NewHandler(st Pool) *Handler

NewHandler instantiates statefulset handler

func (*Handler) Created

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

Created handles statefulset creation event

func (*Handler) Deleted

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

Deleted handles statefulset deletion event

func (*Handler) Updated

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

Updated handles statefulset updates event

type Pool

type Pool interface {
	UpdateExpectedSize(size int)
}

Pool models an ordered set of workers