pod

Documentation

Index

• Variables
• func NewClient(cs kubernetes.Interface, ns string) client.Client
• func NewMonitor(publisher Publisher, handler Handler) (kcache.Monitor, error)
• func NodeFilter(names ...string) filter.ComparableFilter
• type BaseHandler
• type CacheController
• type CacheReader
• type Controller
  • func BuildController(ctx context.Context, log logutil.Log, client client.Client) (Controller, error)
  • func NewController(ctx context.Context, log logutil.Log, cs kubernetes.Interface, ns string) (Controller, error)
• type Event
• type FilterController
• type FilterSubscription
• type Handler
  • func ToUnitary(log logutil.Log, delegate UnitaryHandler) Handler
• type HandlerBuilder
  • func BuildHandler() HandlerBuilder
• type Publisher
• type Subscription
• type UnitaryHandler
• type UnitaryHandlerBuilder
  • func BuildUnitaryHandler() UnitaryHandlerBuilder

Variables

var (
	ErrInvalidType = fmt.Errorf("invalid type")
)

Functions

func NewClient

func NewClient(cs kubernetes.Interface, ns string) client.Client

func NewMonitor

func NewMonitor(publisher Publisher, handler Handler) (kcache.Monitor, error)

func NodeFilter

func NodeFilter(names ...string) filter.ComparableFilter

Types

type BaseHandler

type BaseHandler interface {
	OnCreate(*corev1.Pod)
	OnUpdate(*corev1.Pod)
	OnDelete(*corev1.Pod)
}

type CacheController

type CacheController interface {
	Cache() CacheReader
	Ready() <-chan struct{}
}

type CacheReader

type CacheReader interface {
	Get(ns string, name string) (*corev1.Pod, error)
	List() ([]*corev1.Pod, error)
}

type Controller

type Controller interface {
	CacheController
	Publisher
	Done() <-chan struct{}
	Close()
	Error() error
}

func BuildController

func BuildController(ctx context.Context, log logutil.Log, client client.Client) (Controller, error)

func NewController

func NewController(ctx context.Context, log logutil.Log, cs kubernetes.Interface, ns string) (Controller, error)

type Event

type Event interface {
	Type() kcache.EventType
	Resource() *corev1.Pod
}

type FilterController

type FilterController interface {
	Controller
	Refilter(filter.Filter) error
}

type FilterSubscription

type FilterSubscription interface {
	Subscription
	Refilter(filter.Filter) error
}

type Handler

type Handler interface {
	BaseHandler
	OnInitialize([]*corev1.Pod)
}

func ToUnitary

func ToUnitary(log logutil.Log, delegate UnitaryHandler) Handler

type HandlerBuilder

type HandlerBuilder interface {
	OnInitialize(func([]*corev1.Pod)) HandlerBuilder
	OnCreate(func(*corev1.Pod)) HandlerBuilder
	OnUpdate(func(*corev1.Pod)) HandlerBuilder
	OnDelete(func(*corev1.Pod)) HandlerBuilder
	Create() Handler
}

func BuildHandler

func BuildHandler() HandlerBuilder

type Publisher

type Publisher interface {
	Subscribe() (Subscription, error)
	SubscribeWithFilter(filter.Filter) (FilterSubscription, error)
	SubscribeForFilter() (FilterSubscription, error)
	Clone() (Controller, error)
	CloneWithFilter(filter.Filter) (FilterController, error)
	CloneForFilter() (FilterController, error)
}

type Subscription

type Subscription interface {
	CacheController
	Events() <-chan Event
	Close()
	Done() <-chan struct{}
}

type UnitaryHandler

type UnitaryHandler interface {
	BaseHandler
	OnInitialize(*corev1.Pod)
}

type UnitaryHandlerBuilder

type UnitaryHandlerBuilder interface {
	OnInitialize(func(*corev1.Pod)) UnitaryHandlerBuilder
	OnCreate(func(*corev1.Pod)) UnitaryHandlerBuilder
	OnUpdate(func(*corev1.Pod)) UnitaryHandlerBuilder
	OnDelete(func(*corev1.Pod)) UnitaryHandlerBuilder
	Create() UnitaryHandler
}

func BuildUnitaryHandler

func BuildUnitaryHandler() UnitaryHandlerBuilder