v1

package
v0.0.9 Latest Latest
Warning

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

Go to latest
Published: May 22, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromExecutionHandlerToHandler

func FromExecutionHandlerToHandler(sync ExecutionHandler) generic.Handler

func FromExecutionRunHandlerToHandler

func FromExecutionRunHandlerToHandler(sync ExecutionRunHandler) generic.Handler

func FromModuleHandlerToHandler

func FromModuleHandlerToHandler(sync ModuleHandler) generic.Handler

Types

type ExecutionCache

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

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

type ExecutionClient

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

type ExecutionController

type ExecutionController interface {
	ExecutionClient

	OnChange(ctx context.Context, name string, sync ExecutionHandler)
	OnRemove(ctx context.Context, name string, sync ExecutionHandler)
	Enqueue(namespace, name string)

	Cache() ExecutionCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewExecutionController

func NewExecutionController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ExecutionsGetter, informer informers.ExecutionInformer) ExecutionController

type ExecutionHandler

type ExecutionHandler func(string, *v1.Execution) (*v1.Execution, error)

func UpdateExecutionOnChange

func UpdateExecutionOnChange(updater generic.Updater, handler ExecutionHandler) ExecutionHandler

type ExecutionIndexer

type ExecutionIndexer func(obj *v1.Execution) ([]string, error)

type ExecutionRunCache

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

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

type ExecutionRunClient

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

type ExecutionRunController

type ExecutionRunController interface {
	ExecutionRunClient

	OnChange(ctx context.Context, name string, sync ExecutionRunHandler)
	OnRemove(ctx context.Context, name string, sync ExecutionRunHandler)
	Enqueue(namespace, name string)

	Cache() ExecutionRunCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

type ExecutionRunHandler

type ExecutionRunHandler func(string, *v1.ExecutionRun) (*v1.ExecutionRun, error)

func UpdateExecutionRunOnChange

func UpdateExecutionRunOnChange(updater generic.Updater, handler ExecutionRunHandler) ExecutionRunHandler

type ExecutionRunIndexer

type ExecutionRunIndexer func(obj *v1.ExecutionRun) ([]string, error)

type Interface

type Interface interface {
	Execution() ExecutionController
	ExecutionRun() ExecutionRunController
	Module() ModuleController
}

type ModuleCache

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

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

type ModuleClient

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

type ModuleController

type ModuleController interface {
	ModuleClient

	OnChange(ctx context.Context, name string, sync ModuleHandler)
	OnRemove(ctx context.Context, name string, sync ModuleHandler)
	Enqueue(namespace, name string)

	Cache() ModuleCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewModuleController

func NewModuleController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ModulesGetter, informer informers.ModuleInformer) ModuleController

type ModuleHandler

type ModuleHandler func(string, *v1.Module) (*v1.Module, error)

func UpdateModuleOnChange

func UpdateModuleOnChange(updater generic.Updater, handler ModuleHandler) ModuleHandler

type ModuleIndexer

type ModuleIndexer func(obj *v1.Module) ([]string, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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