Documentation ¶
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func NewJob(namespace, name string, obj v1.Job) *v1.Job
- func Resource(resource string) schema.GroupResource
- type Client
- type Interface
- type JobChangeHandlerFunc
- type JobController
- type JobHandlerFunc
- type JobInterface
- type JobLifecycle
- type JobLister
- type JobsGetter
Constants ¶
View Source
const ( GroupName = "batch" Version = "v1" )
Variables ¶
View Source
var ( JobGroupVersionKind = schema.GroupVersionKind{ Version: Version, Group: GroupName, Kind: "Job", } JobResource = metav1.APIResource{ Name: "jobs", SingularName: "job", Namespaced: true, Kind: JobGroupVersionKind.Kind, } JobGroupVersionResource = schema.GroupVersionResource{ Group: GroupName, Version: Version, Resource: "jobs", } )
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: Version}
SchemeGroupVersion is group version used to register these objects
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) Jobs ¶
func (c *Client) Jobs(namespace string) JobInterface
type Interface ¶
type Interface interface { JobsGetter }
func NewFromControllerFactory ¶ added in v0.0.2
func NewFromControllerFactory(factory controller.SharedControllerFactory) (Interface, error)
type JobController ¶
type JobController interface { Generic() controller.GenericController Informer() cache.SharedIndexInformer Lister() JobLister AddHandler(ctx context.Context, name string, handler JobHandlerFunc) AddFeatureHandler(ctx context.Context, enabled func() bool, name string, sync JobHandlerFunc) AddClusterScopedHandler(ctx context.Context, name, clusterName string, handler JobHandlerFunc) AddClusterScopedFeatureHandler(ctx context.Context, enabled func() bool, name, clusterName string, handler JobHandlerFunc) Enqueue(namespace, name string) EnqueueAfter(namespace, name string, after time.Duration) }
type JobHandlerFunc ¶
func NewJobLifecycleAdapter ¶
func NewJobLifecycleAdapter(name string, clusterScoped bool, client JobInterface, l JobLifecycle) JobHandlerFunc
type JobInterface ¶
type JobInterface interface { ObjectClient() *objectclient.ObjectClient Create(*v1.Job) (*v1.Job, error) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*v1.Job, error) Get(name string, opts metav1.GetOptions) (*v1.Job, error) Update(*v1.Job) (*v1.Job, error) Delete(name string, options *metav1.DeleteOptions) error DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error List(opts metav1.ListOptions) (*v1.JobList, error) ListNamespaced(namespace string, opts metav1.ListOptions) (*v1.JobList, error) Watch(opts metav1.ListOptions) (watch.Interface, error) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error Controller() JobController AddHandler(ctx context.Context, name string, sync JobHandlerFunc) AddFeatureHandler(ctx context.Context, enabled func() bool, name string, sync JobHandlerFunc) AddLifecycle(ctx context.Context, name string, lifecycle JobLifecycle) AddFeatureLifecycle(ctx context.Context, enabled func() bool, name string, lifecycle JobLifecycle) AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync JobHandlerFunc) AddClusterScopedFeatureHandler(ctx context.Context, enabled func() bool, name, clusterName string, sync JobHandlerFunc) AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle JobLifecycle) AddClusterScopedFeatureLifecycle(ctx context.Context, enabled func() bool, name, clusterName string, lifecycle JobLifecycle) }
type JobLifecycle ¶
type JobsGetter ¶
type JobsGetter interface {
Jobs(namespace string) JobInterface
}
Source Files ¶
Click to show internal directories.
Click to hide internal directories.