replicationcontroller

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2022 License: MIT Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 PodsFilter

func PodsFilter(sources ...*corev1.ReplicationController) filter.ComparableFilter

Types

type BaseHandler

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

type CacheController

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

type CacheReader

type CacheReader interface {
	Get(ns string, name string) (*corev1.ReplicationController, error)
	List() ([]*corev1.ReplicationController, 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.ReplicationController
}

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.ReplicationController)
}

func ToUnitary

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

type HandlerBuilder

type HandlerBuilder interface {
	OnInitialize(func([]*corev1.ReplicationController)) HandlerBuilder
	OnCreate(func(*corev1.ReplicationController)) HandlerBuilder
	OnUpdate(func(*corev1.ReplicationController)) HandlerBuilder
	OnDelete(func(*corev1.ReplicationController)) 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.ReplicationController)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL