v1

package
v0.0.0-...-18d89d2 Latest Latest
Warning

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

Go to latest
Published: Mar 12, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromAddonHandlerToHandler

func FromAddonHandlerToHandler(sync AddonHandler) generic.Handler

func RegisterAddonGeneratingHandler

func RegisterAddonGeneratingHandler(ctx context.Context, controller AddonController, apply apply.Apply,
	condition condition.Cond, name string, handler AddonGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterAddonStatusHandler

func RegisterAddonStatusHandler(ctx context.Context, controller AddonController, condition condition.Cond, name string, handler AddonStatusHandler)

func UpdateAddonDeepCopyOnChange

func UpdateAddonDeepCopyOnChange(client AddonClient, obj *v1.Addon, handler func(obj *v1.Addon) (*v1.Addon, error)) (*v1.Addon, error)

Types

type AddonCache

type AddonCache interface {
	Get(namespace, name string) (*v1.Addon, error)
	List(namespace string, selector labels.Selector) ([]*v1.Addon, error)

	AddIndexer(indexName string, indexer AddonIndexer)
	GetByIndex(indexName, key string) ([]*v1.Addon, error)
}

type AddonClient

type AddonClient interface {
	Create(*v1.Addon) (*v1.Addon, error)
	Update(*v1.Addon) (*v1.Addon, error)
	UpdateStatus(*v1.Addon) (*v1.Addon, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1.Addon, error)
	List(namespace string, opts metav1.ListOptions) (*v1.AddonList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Addon, err error)
}

type AddonController

type AddonController interface {
	generic.ControllerMeta
	AddonClient

	OnChange(ctx context.Context, name string, sync AddonHandler)
	OnRemove(ctx context.Context, name string, sync AddonHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() AddonCache
}

func NewAddonController

func NewAddonController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.AddonsGetter, informer informers.AddonInformer) AddonController

type AddonGeneratingHandler

type AddonGeneratingHandler func(obj *v1.Addon, status v1.AddonStatus) ([]runtime.Object, v1.AddonStatus, error)

type AddonHandler

type AddonHandler func(string, *v1.Addon) (*v1.Addon, error)

type AddonIndexer

type AddonIndexer func(obj *v1.Addon) ([]string, error)

type AddonStatusHandler

type AddonStatusHandler func(obj *v1.Addon, status v1.AddonStatus) (v1.AddonStatus, error)

type Interface

type Interface interface {
	Addon() AddonController
}

func New

func New(controllerManager *generic.ControllerManager, client clientset.K3sV1Interface,
	informers informers.Interface) Interface

Jump to

Keyboard shortcuts

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