From 5fbc6424aad48ed8be131692980e640060515a2a Mon Sep 17 00:00:00 2001 From: Mikalai Radchuk Date: Thu, 23 Jan 2020 14:11:00 +0000 Subject: [PATCH] Vendor --- Gopkg.lock | 17 +- Gopkg.toml | 4 + cgmanifest.json | 9 + .../operator/clientset/versioned/clientset.go | 95 +++++++++ .../operator/clientset/versioned/doc.go | 4 + .../clientset/versioned/scheme/doc.go | 4 + .../clientset/versioned/scheme/register.go | 42 ++++ .../typed/operator/v1/authentication.go | 164 ++++++++++++++ .../versioned/typed/operator/v1/console.go | 164 ++++++++++++++ .../versioned/typed/operator/v1/dns.go | 164 ++++++++++++++ .../versioned/typed/operator/v1/doc.go | 4 + .../versioned/typed/operator/v1/etcd.go | 164 ++++++++++++++ .../typed/operator/v1/generated_expansion.go | 33 +++ .../typed/operator/v1/ingresscontroller.go | 175 +++++++++++++++ .../typed/operator/v1/kubeapiserver.go | 164 ++++++++++++++ .../operator/v1/kubecontrollermanager.go | 164 ++++++++++++++ .../typed/operator/v1/kubescheduler.go | 164 ++++++++++++++ .../operator/v1/kubestorageversionmigrator.go | 164 ++++++++++++++ .../versioned/typed/operator/v1/network.go | 164 ++++++++++++++ .../typed/operator/v1/openshiftapiserver.go | 164 ++++++++++++++ .../operator/v1/openshiftcontrollermanager.go | 164 ++++++++++++++ .../typed/operator/v1/operator_client.go | 143 +++++++++++++ .../versioned/typed/operator/v1/serviceca.go | 164 ++++++++++++++ .../operator/v1/servicecatalogapiserver.go | 164 ++++++++++++++ .../v1/servicecatalogcontrollermanager.go | 164 ++++++++++++++ .../versioned/typed/operator/v1alpha1/doc.go | 4 + .../operator/v1alpha1/generated_expansion.go | 5 + .../v1alpha1/imagecontentsourcepolicy.go | 148 +++++++++++++ .../operator/v1alpha1/operator_client.go | 73 +++++++ .../openshift/console-operator/LICENSE | 201 ++++++++++++++++++ .../openshift/console-operator/pkg/api/api.go | 32 +++ 31 files changed, 3288 insertions(+), 1 deletion(-) create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/clientset.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/doc.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/doc.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/register.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/authentication.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/console.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/dns.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/doc.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/etcd.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/generated_expansion.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/ingresscontroller.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubeapiserver.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubecontrollermanager.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubescheduler.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubestorageversionmigrator.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/network.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftapiserver.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftcontrollermanager.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/operator_client.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/serviceca.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogapiserver.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogcontrollermanager.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/doc.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/generated_expansion.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/imagecontentsourcepolicy.go create mode 100644 vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/operator_client.go create mode 100644 vendor/github.com/openshift/console-operator/LICENSE create mode 100644 vendor/github.com/openshift/console-operator/pkg/api/api.go diff --git a/Gopkg.lock b/Gopkg.lock index e7354f06b..8ddf6a7a5 100644 --- a/Gopkg.lock +++ b/Gopkg.lock @@ -773,12 +773,16 @@ [[projects]] branch = "release-4.3" - digest = "1:a0d7f81ca6a56bea17ae0727af08837e52ec368d47a7d259702c762317882546" + digest = "1:389e8899bcd32ef27c6ab649f2fd99153afee3d4f02090625047687e859ebcab" name = "github.com/openshift/client-go" packages = [ "config/clientset/versioned", "config/clientset/versioned/scheme", "config/clientset/versioned/typed/config/v1", + "operator/clientset/versioned", + "operator/clientset/versioned/scheme", + "operator/clientset/versioned/typed/operator/v1", + "operator/clientset/versioned/typed/operator/v1alpha1", ] pruneopts = "UT" revision = "f6563a70e19a12b2f240eaf4e716ef75baf7003e" @@ -832,6 +836,14 @@ pruneopts = "UT" revision = "2336783d460353458477aa9e181eca87e4db5d27" +[[projects]] + branch = "release-4.3" + digest = "1:4221f7b123b05d8ece2b79a3cd6891e3a421c8b2f2e6f2ab8abe3be0f7ef0fee" + name = "github.com/openshift/console-operator" + packages = ["pkg/api"] + pruneopts = "UT" + revision = "cb47e810bee8c56f0738f0723c98cf3192ea7736" + [[projects]] branch = "release-4.3-azure" digest = "1:b1a5f5cfa6e96e8997329fbaccc1c9ab4740a8d70ceae59637d643558604d7c4" @@ -1683,9 +1695,12 @@ "github.com/jim-minter/go-cosmosdb/cmd/gencosmosdb", "github.com/openshift/api/config/v1", "github.com/openshift/api/image/v1", + "github.com/openshift/api/operator/v1", "github.com/openshift/client-go/config/clientset/versioned", + "github.com/openshift/client-go/operator/clientset/versioned", "github.com/openshift/cluster-api/pkg/apis/machine/v1beta1", "github.com/openshift/cluster-api/pkg/client/clientset_generated/clientset/typed/machine/v1beta1", + "github.com/openshift/console-operator/pkg/api", "github.com/openshift/installer/data", "github.com/openshift/installer/pkg/asset", "github.com/openshift/installer/pkg/asset/cluster", diff --git a/Gopkg.toml b/Gopkg.toml index e092a3e43..f33dd4086 100644 --- a/Gopkg.toml +++ b/Gopkg.toml @@ -46,6 +46,10 @@ required = [ name = "github.com/openshift/machine-config-operator" branch = "release-4.3" +[[constraint]] + name = "github.com/openshift/console-operator" + branch = "release-4.3" + [[constraint]] name = "github.com/satori/go.uuid" version = "1.2.0" diff --git a/cgmanifest.json b/cgmanifest.json index fe001a1d8..ea2b0d595 100644 --- a/cgmanifest.json +++ b/cgmanifest.json @@ -675,6 +675,15 @@ } } }, + { + "component": { + "type": "git", + "git": { + "commitHash": "cb47e810bee8c56f0738f0723c98cf3192ea7736", + "repositoryUrl": "https://github.com/openshift/console-operator/" + } + } + }, { "component": { "type": "git", diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/clientset.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/clientset.go new file mode 100644 index 000000000..03e620a02 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/clientset.go @@ -0,0 +1,95 @@ +// Code generated by client-gen. DO NOT EDIT. + +package versioned + +import ( + "fmt" + + operatorv1 "github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1" + operatorv1alpha1 "github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1" + discovery "k8s.io/client-go/discovery" + rest "k8s.io/client-go/rest" + flowcontrol "k8s.io/client-go/util/flowcontrol" +) + +type Interface interface { + Discovery() discovery.DiscoveryInterface + OperatorV1() operatorv1.OperatorV1Interface + OperatorV1alpha1() operatorv1alpha1.OperatorV1alpha1Interface +} + +// Clientset contains the clients for groups. Each group has exactly one +// version included in a Clientset. +type Clientset struct { + *discovery.DiscoveryClient + operatorV1 *operatorv1.OperatorV1Client + operatorV1alpha1 *operatorv1alpha1.OperatorV1alpha1Client +} + +// OperatorV1 retrieves the OperatorV1Client +func (c *Clientset) OperatorV1() operatorv1.OperatorV1Interface { + return c.operatorV1 +} + +// OperatorV1alpha1 retrieves the OperatorV1alpha1Client +func (c *Clientset) OperatorV1alpha1() operatorv1alpha1.OperatorV1alpha1Interface { + return c.operatorV1alpha1 +} + +// Discovery retrieves the DiscoveryClient +func (c *Clientset) Discovery() discovery.DiscoveryInterface { + if c == nil { + return nil + } + return c.DiscoveryClient +} + +// NewForConfig creates a new Clientset for the given config. +// If config's RateLimiter is not set and QPS and Burst are acceptable, +// NewForConfig will generate a rate-limiter in configShallowCopy. +func NewForConfig(c *rest.Config) (*Clientset, error) { + configShallowCopy := *c + if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 { + if configShallowCopy.Burst <= 0 { + return nil, fmt.Errorf("Burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0") + } + configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst) + } + var cs Clientset + var err error + cs.operatorV1, err = operatorv1.NewForConfig(&configShallowCopy) + if err != nil { + return nil, err + } + cs.operatorV1alpha1, err = operatorv1alpha1.NewForConfig(&configShallowCopy) + if err != nil { + return nil, err + } + + cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy) + if err != nil { + return nil, err + } + return &cs, nil +} + +// NewForConfigOrDie creates a new Clientset for the given config and +// panics if there is an error in the config. +func NewForConfigOrDie(c *rest.Config) *Clientset { + var cs Clientset + cs.operatorV1 = operatorv1.NewForConfigOrDie(c) + cs.operatorV1alpha1 = operatorv1alpha1.NewForConfigOrDie(c) + + cs.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c) + return &cs +} + +// New creates a new Clientset for the given RESTClient. +func New(c rest.Interface) *Clientset { + var cs Clientset + cs.operatorV1 = operatorv1.New(c) + cs.operatorV1alpha1 = operatorv1alpha1.New(c) + + cs.DiscoveryClient = discovery.NewDiscoveryClient(c) + return &cs +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/doc.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/doc.go new file mode 100644 index 000000000..0e0c2a890 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/doc.go @@ -0,0 +1,4 @@ +// Code generated by client-gen. DO NOT EDIT. + +// This package has the automatically generated clientset. +package versioned diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/doc.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/doc.go new file mode 100644 index 000000000..14db57a58 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/doc.go @@ -0,0 +1,4 @@ +// Code generated by client-gen. DO NOT EDIT. + +// This package contains the scheme of the automatically generated clientset. +package scheme diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/register.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/register.go new file mode 100644 index 000000000..0a99d662e --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/scheme/register.go @@ -0,0 +1,42 @@ +// Code generated by client-gen. DO NOT EDIT. + +package scheme + +import ( + operatorv1 "github.com/openshift/api/operator/v1" + operatorv1alpha1 "github.com/openshift/api/operator/v1alpha1" + v1 "k8s.io/apimachinery/pkg/apis/meta/v1" + runtime "k8s.io/apimachinery/pkg/runtime" + schema "k8s.io/apimachinery/pkg/runtime/schema" + serializer "k8s.io/apimachinery/pkg/runtime/serializer" + utilruntime "k8s.io/apimachinery/pkg/util/runtime" +) + +var Scheme = runtime.NewScheme() +var Codecs = serializer.NewCodecFactory(Scheme) +var ParameterCodec = runtime.NewParameterCodec(Scheme) +var localSchemeBuilder = runtime.SchemeBuilder{ + operatorv1.AddToScheme, + operatorv1alpha1.AddToScheme, +} + +// AddToScheme adds all types of this clientset into the given scheme. This allows composition +// of clientsets, like in: +// +// import ( +// "k8s.io/client-go/kubernetes" +// clientsetscheme "k8s.io/client-go/kubernetes/scheme" +// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" +// ) +// +// kclientset, _ := kubernetes.NewForConfig(c) +// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) +// +// After this, RawExtensions in Kubernetes types will serialize kube-aggregator types +// correctly. +var AddToScheme = localSchemeBuilder.AddToScheme + +func init() { + v1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"}) + utilruntime.Must(AddToScheme(Scheme)) +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/authentication.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/authentication.go new file mode 100644 index 000000000..195f5a21c --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/authentication.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// AuthenticationsGetter has a method to return a AuthenticationInterface. +// A group's client should implement this interface. +type AuthenticationsGetter interface { + Authentications() AuthenticationInterface +} + +// AuthenticationInterface has methods to work with Authentication resources. +type AuthenticationInterface interface { + Create(*v1.Authentication) (*v1.Authentication, error) + Update(*v1.Authentication) (*v1.Authentication, error) + UpdateStatus(*v1.Authentication) (*v1.Authentication, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.Authentication, error) + List(opts metav1.ListOptions) (*v1.AuthenticationList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Authentication, err error) + AuthenticationExpansion +} + +// authentications implements AuthenticationInterface +type authentications struct { + client rest.Interface +} + +// newAuthentications returns a Authentications +func newAuthentications(c *OperatorV1Client) *authentications { + return &authentications{ + client: c.RESTClient(), + } +} + +// Get takes name of the authentication, and returns the corresponding authentication object, and an error if there is any. +func (c *authentications) Get(name string, options metav1.GetOptions) (result *v1.Authentication, err error) { + result = &v1.Authentication{} + err = c.client.Get(). + Resource("authentications"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of Authentications that match those selectors. +func (c *authentications) List(opts metav1.ListOptions) (result *v1.AuthenticationList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.AuthenticationList{} + err = c.client.Get(). + Resource("authentications"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested authentications. +func (c *authentications) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("authentications"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a authentication and creates it. Returns the server's representation of the authentication, and an error, if there is any. +func (c *authentications) Create(authentication *v1.Authentication) (result *v1.Authentication, err error) { + result = &v1.Authentication{} + err = c.client.Post(). + Resource("authentications"). + Body(authentication). + Do(). + Into(result) + return +} + +// Update takes the representation of a authentication and updates it. Returns the server's representation of the authentication, and an error, if there is any. +func (c *authentications) Update(authentication *v1.Authentication) (result *v1.Authentication, err error) { + result = &v1.Authentication{} + err = c.client.Put(). + Resource("authentications"). + Name(authentication.Name). + Body(authentication). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *authentications) UpdateStatus(authentication *v1.Authentication) (result *v1.Authentication, err error) { + result = &v1.Authentication{} + err = c.client.Put(). + Resource("authentications"). + Name(authentication.Name). + SubResource("status"). + Body(authentication). + Do(). + Into(result) + return +} + +// Delete takes name of the authentication and deletes it. Returns an error if one occurs. +func (c *authentications) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("authentications"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *authentications) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("authentications"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched authentication. +func (c *authentications) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Authentication, err error) { + result = &v1.Authentication{} + err = c.client.Patch(pt). + Resource("authentications"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/console.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/console.go new file mode 100644 index 000000000..73032387b --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/console.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// ConsolesGetter has a method to return a ConsoleInterface. +// A group's client should implement this interface. +type ConsolesGetter interface { + Consoles() ConsoleInterface +} + +// ConsoleInterface has methods to work with Console resources. +type ConsoleInterface interface { + Create(*v1.Console) (*v1.Console, error) + Update(*v1.Console) (*v1.Console, error) + UpdateStatus(*v1.Console) (*v1.Console, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.Console, error) + List(opts metav1.ListOptions) (*v1.ConsoleList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Console, err error) + ConsoleExpansion +} + +// consoles implements ConsoleInterface +type consoles struct { + client rest.Interface +} + +// newConsoles returns a Consoles +func newConsoles(c *OperatorV1Client) *consoles { + return &consoles{ + client: c.RESTClient(), + } +} + +// Get takes name of the console, and returns the corresponding console object, and an error if there is any. +func (c *consoles) Get(name string, options metav1.GetOptions) (result *v1.Console, err error) { + result = &v1.Console{} + err = c.client.Get(). + Resource("consoles"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of Consoles that match those selectors. +func (c *consoles) List(opts metav1.ListOptions) (result *v1.ConsoleList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.ConsoleList{} + err = c.client.Get(). + Resource("consoles"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested consoles. +func (c *consoles) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("consoles"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a console and creates it. Returns the server's representation of the console, and an error, if there is any. +func (c *consoles) Create(console *v1.Console) (result *v1.Console, err error) { + result = &v1.Console{} + err = c.client.Post(). + Resource("consoles"). + Body(console). + Do(). + Into(result) + return +} + +// Update takes the representation of a console and updates it. Returns the server's representation of the console, and an error, if there is any. +func (c *consoles) Update(console *v1.Console) (result *v1.Console, err error) { + result = &v1.Console{} + err = c.client.Put(). + Resource("consoles"). + Name(console.Name). + Body(console). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *consoles) UpdateStatus(console *v1.Console) (result *v1.Console, err error) { + result = &v1.Console{} + err = c.client.Put(). + Resource("consoles"). + Name(console.Name). + SubResource("status"). + Body(console). + Do(). + Into(result) + return +} + +// Delete takes name of the console and deletes it. Returns an error if one occurs. +func (c *consoles) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("consoles"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *consoles) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("consoles"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched console. +func (c *consoles) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Console, err error) { + result = &v1.Console{} + err = c.client.Patch(pt). + Resource("consoles"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/dns.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/dns.go new file mode 100644 index 000000000..9b0802e39 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/dns.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// DNSesGetter has a method to return a DNSInterface. +// A group's client should implement this interface. +type DNSesGetter interface { + DNSes() DNSInterface +} + +// DNSInterface has methods to work with DNS resources. +type DNSInterface interface { + Create(*v1.DNS) (*v1.DNS, error) + Update(*v1.DNS) (*v1.DNS, error) + UpdateStatus(*v1.DNS) (*v1.DNS, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.DNS, error) + List(opts metav1.ListOptions) (*v1.DNSList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.DNS, err error) + DNSExpansion +} + +// dNSes implements DNSInterface +type dNSes struct { + client rest.Interface +} + +// newDNSes returns a DNSes +func newDNSes(c *OperatorV1Client) *dNSes { + return &dNSes{ + client: c.RESTClient(), + } +} + +// Get takes name of the dNS, and returns the corresponding dNS object, and an error if there is any. +func (c *dNSes) Get(name string, options metav1.GetOptions) (result *v1.DNS, err error) { + result = &v1.DNS{} + err = c.client.Get(). + Resource("dnses"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of DNSes that match those selectors. +func (c *dNSes) List(opts metav1.ListOptions) (result *v1.DNSList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.DNSList{} + err = c.client.Get(). + Resource("dnses"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested dNSes. +func (c *dNSes) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("dnses"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a dNS and creates it. Returns the server's representation of the dNS, and an error, if there is any. +func (c *dNSes) Create(dNS *v1.DNS) (result *v1.DNS, err error) { + result = &v1.DNS{} + err = c.client.Post(). + Resource("dnses"). + Body(dNS). + Do(). + Into(result) + return +} + +// Update takes the representation of a dNS and updates it. Returns the server's representation of the dNS, and an error, if there is any. +func (c *dNSes) Update(dNS *v1.DNS) (result *v1.DNS, err error) { + result = &v1.DNS{} + err = c.client.Put(). + Resource("dnses"). + Name(dNS.Name). + Body(dNS). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *dNSes) UpdateStatus(dNS *v1.DNS) (result *v1.DNS, err error) { + result = &v1.DNS{} + err = c.client.Put(). + Resource("dnses"). + Name(dNS.Name). + SubResource("status"). + Body(dNS). + Do(). + Into(result) + return +} + +// Delete takes name of the dNS and deletes it. Returns an error if one occurs. +func (c *dNSes) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("dnses"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *dNSes) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("dnses"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched dNS. +func (c *dNSes) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.DNS, err error) { + result = &v1.DNS{} + err = c.client.Patch(pt). + Resource("dnses"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/doc.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/doc.go new file mode 100644 index 000000000..225e6b2be --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/doc.go @@ -0,0 +1,4 @@ +// Code generated by client-gen. DO NOT EDIT. + +// This package has the automatically generated typed clients. +package v1 diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/etcd.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/etcd.go new file mode 100644 index 000000000..fc526e36d --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/etcd.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// EtcdsGetter has a method to return a EtcdInterface. +// A group's client should implement this interface. +type EtcdsGetter interface { + Etcds() EtcdInterface +} + +// EtcdInterface has methods to work with Etcd resources. +type EtcdInterface interface { + Create(*v1.Etcd) (*v1.Etcd, error) + Update(*v1.Etcd) (*v1.Etcd, error) + UpdateStatus(*v1.Etcd) (*v1.Etcd, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.Etcd, error) + List(opts metav1.ListOptions) (*v1.EtcdList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Etcd, err error) + EtcdExpansion +} + +// etcds implements EtcdInterface +type etcds struct { + client rest.Interface +} + +// newEtcds returns a Etcds +func newEtcds(c *OperatorV1Client) *etcds { + return &etcds{ + client: c.RESTClient(), + } +} + +// Get takes name of the etcd, and returns the corresponding etcd object, and an error if there is any. +func (c *etcds) Get(name string, options metav1.GetOptions) (result *v1.Etcd, err error) { + result = &v1.Etcd{} + err = c.client.Get(). + Resource("etcds"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of Etcds that match those selectors. +func (c *etcds) List(opts metav1.ListOptions) (result *v1.EtcdList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.EtcdList{} + err = c.client.Get(). + Resource("etcds"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested etcds. +func (c *etcds) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("etcds"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a etcd and creates it. Returns the server's representation of the etcd, and an error, if there is any. +func (c *etcds) Create(etcd *v1.Etcd) (result *v1.Etcd, err error) { + result = &v1.Etcd{} + err = c.client.Post(). + Resource("etcds"). + Body(etcd). + Do(). + Into(result) + return +} + +// Update takes the representation of a etcd and updates it. Returns the server's representation of the etcd, and an error, if there is any. +func (c *etcds) Update(etcd *v1.Etcd) (result *v1.Etcd, err error) { + result = &v1.Etcd{} + err = c.client.Put(). + Resource("etcds"). + Name(etcd.Name). + Body(etcd). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *etcds) UpdateStatus(etcd *v1.Etcd) (result *v1.Etcd, err error) { + result = &v1.Etcd{} + err = c.client.Put(). + Resource("etcds"). + Name(etcd.Name). + SubResource("status"). + Body(etcd). + Do(). + Into(result) + return +} + +// Delete takes name of the etcd and deletes it. Returns an error if one occurs. +func (c *etcds) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("etcds"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *etcds) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("etcds"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched etcd. +func (c *etcds) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Etcd, err error) { + result = &v1.Etcd{} + err = c.client.Patch(pt). + Resource("etcds"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/generated_expansion.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/generated_expansion.go new file mode 100644 index 000000000..18807b6ff --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/generated_expansion.go @@ -0,0 +1,33 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +type AuthenticationExpansion interface{} + +type ConsoleExpansion interface{} + +type DNSExpansion interface{} + +type EtcdExpansion interface{} + +type IngressControllerExpansion interface{} + +type KubeAPIServerExpansion interface{} + +type KubeControllerManagerExpansion interface{} + +type KubeSchedulerExpansion interface{} + +type KubeStorageVersionMigratorExpansion interface{} + +type NetworkExpansion interface{} + +type OpenShiftAPIServerExpansion interface{} + +type OpenShiftControllerManagerExpansion interface{} + +type ServiceCAExpansion interface{} + +type ServiceCatalogAPIServerExpansion interface{} + +type ServiceCatalogControllerManagerExpansion interface{} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/ingresscontroller.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/ingresscontroller.go new file mode 100644 index 000000000..03709d826 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/ingresscontroller.go @@ -0,0 +1,175 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// IngressControllersGetter has a method to return a IngressControllerInterface. +// A group's client should implement this interface. +type IngressControllersGetter interface { + IngressControllers(namespace string) IngressControllerInterface +} + +// IngressControllerInterface has methods to work with IngressController resources. +type IngressControllerInterface interface { + Create(*v1.IngressController) (*v1.IngressController, error) + Update(*v1.IngressController) (*v1.IngressController, error) + UpdateStatus(*v1.IngressController) (*v1.IngressController, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.IngressController, error) + List(opts metav1.ListOptions) (*v1.IngressControllerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.IngressController, err error) + IngressControllerExpansion +} + +// ingressControllers implements IngressControllerInterface +type ingressControllers struct { + client rest.Interface + ns string +} + +// newIngressControllers returns a IngressControllers +func newIngressControllers(c *OperatorV1Client, namespace string) *ingressControllers { + return &ingressControllers{ + client: c.RESTClient(), + ns: namespace, + } +} + +// Get takes name of the ingressController, and returns the corresponding ingressController object, and an error if there is any. +func (c *ingressControllers) Get(name string, options metav1.GetOptions) (result *v1.IngressController, err error) { + result = &v1.IngressController{} + err = c.client.Get(). + Namespace(c.ns). + Resource("ingresscontrollers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of IngressControllers that match those selectors. +func (c *ingressControllers) List(opts metav1.ListOptions) (result *v1.IngressControllerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.IngressControllerList{} + err = c.client.Get(). + Namespace(c.ns). + Resource("ingresscontrollers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested ingressControllers. +func (c *ingressControllers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Namespace(c.ns). + Resource("ingresscontrollers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a ingressController and creates it. Returns the server's representation of the ingressController, and an error, if there is any. +func (c *ingressControllers) Create(ingressController *v1.IngressController) (result *v1.IngressController, err error) { + result = &v1.IngressController{} + err = c.client.Post(). + Namespace(c.ns). + Resource("ingresscontrollers"). + Body(ingressController). + Do(). + Into(result) + return +} + +// Update takes the representation of a ingressController and updates it. Returns the server's representation of the ingressController, and an error, if there is any. +func (c *ingressControllers) Update(ingressController *v1.IngressController) (result *v1.IngressController, err error) { + result = &v1.IngressController{} + err = c.client.Put(). + Namespace(c.ns). + Resource("ingresscontrollers"). + Name(ingressController.Name). + Body(ingressController). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *ingressControllers) UpdateStatus(ingressController *v1.IngressController) (result *v1.IngressController, err error) { + result = &v1.IngressController{} + err = c.client.Put(). + Namespace(c.ns). + Resource("ingresscontrollers"). + Name(ingressController.Name). + SubResource("status"). + Body(ingressController). + Do(). + Into(result) + return +} + +// Delete takes name of the ingressController and deletes it. Returns an error if one occurs. +func (c *ingressControllers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Namespace(c.ns). + Resource("ingresscontrollers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *ingressControllers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Namespace(c.ns). + Resource("ingresscontrollers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched ingressController. +func (c *ingressControllers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.IngressController, err error) { + result = &v1.IngressController{} + err = c.client.Patch(pt). + Namespace(c.ns). + Resource("ingresscontrollers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubeapiserver.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubeapiserver.go new file mode 100644 index 000000000..6b1f5377c --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubeapiserver.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// KubeAPIServersGetter has a method to return a KubeAPIServerInterface. +// A group's client should implement this interface. +type KubeAPIServersGetter interface { + KubeAPIServers() KubeAPIServerInterface +} + +// KubeAPIServerInterface has methods to work with KubeAPIServer resources. +type KubeAPIServerInterface interface { + Create(*v1.KubeAPIServer) (*v1.KubeAPIServer, error) + Update(*v1.KubeAPIServer) (*v1.KubeAPIServer, error) + UpdateStatus(*v1.KubeAPIServer) (*v1.KubeAPIServer, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.KubeAPIServer, error) + List(opts metav1.ListOptions) (*v1.KubeAPIServerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeAPIServer, err error) + KubeAPIServerExpansion +} + +// kubeAPIServers implements KubeAPIServerInterface +type kubeAPIServers struct { + client rest.Interface +} + +// newKubeAPIServers returns a KubeAPIServers +func newKubeAPIServers(c *OperatorV1Client) *kubeAPIServers { + return &kubeAPIServers{ + client: c.RESTClient(), + } +} + +// Get takes name of the kubeAPIServer, and returns the corresponding kubeAPIServer object, and an error if there is any. +func (c *kubeAPIServers) Get(name string, options metav1.GetOptions) (result *v1.KubeAPIServer, err error) { + result = &v1.KubeAPIServer{} + err = c.client.Get(). + Resource("kubeapiservers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of KubeAPIServers that match those selectors. +func (c *kubeAPIServers) List(opts metav1.ListOptions) (result *v1.KubeAPIServerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.KubeAPIServerList{} + err = c.client.Get(). + Resource("kubeapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested kubeAPIServers. +func (c *kubeAPIServers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("kubeapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a kubeAPIServer and creates it. Returns the server's representation of the kubeAPIServer, and an error, if there is any. +func (c *kubeAPIServers) Create(kubeAPIServer *v1.KubeAPIServer) (result *v1.KubeAPIServer, err error) { + result = &v1.KubeAPIServer{} + err = c.client.Post(). + Resource("kubeapiservers"). + Body(kubeAPIServer). + Do(). + Into(result) + return +} + +// Update takes the representation of a kubeAPIServer and updates it. Returns the server's representation of the kubeAPIServer, and an error, if there is any. +func (c *kubeAPIServers) Update(kubeAPIServer *v1.KubeAPIServer) (result *v1.KubeAPIServer, err error) { + result = &v1.KubeAPIServer{} + err = c.client.Put(). + Resource("kubeapiservers"). + Name(kubeAPIServer.Name). + Body(kubeAPIServer). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *kubeAPIServers) UpdateStatus(kubeAPIServer *v1.KubeAPIServer) (result *v1.KubeAPIServer, err error) { + result = &v1.KubeAPIServer{} + err = c.client.Put(). + Resource("kubeapiservers"). + Name(kubeAPIServer.Name). + SubResource("status"). + Body(kubeAPIServer). + Do(). + Into(result) + return +} + +// Delete takes name of the kubeAPIServer and deletes it. Returns an error if one occurs. +func (c *kubeAPIServers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("kubeapiservers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *kubeAPIServers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("kubeapiservers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched kubeAPIServer. +func (c *kubeAPIServers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeAPIServer, err error) { + result = &v1.KubeAPIServer{} + err = c.client.Patch(pt). + Resource("kubeapiservers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubecontrollermanager.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubecontrollermanager.go new file mode 100644 index 000000000..8eb5cf851 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubecontrollermanager.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// KubeControllerManagersGetter has a method to return a KubeControllerManagerInterface. +// A group's client should implement this interface. +type KubeControllerManagersGetter interface { + KubeControllerManagers() KubeControllerManagerInterface +} + +// KubeControllerManagerInterface has methods to work with KubeControllerManager resources. +type KubeControllerManagerInterface interface { + Create(*v1.KubeControllerManager) (*v1.KubeControllerManager, error) + Update(*v1.KubeControllerManager) (*v1.KubeControllerManager, error) + UpdateStatus(*v1.KubeControllerManager) (*v1.KubeControllerManager, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.KubeControllerManager, error) + List(opts metav1.ListOptions) (*v1.KubeControllerManagerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeControllerManager, err error) + KubeControllerManagerExpansion +} + +// kubeControllerManagers implements KubeControllerManagerInterface +type kubeControllerManagers struct { + client rest.Interface +} + +// newKubeControllerManagers returns a KubeControllerManagers +func newKubeControllerManagers(c *OperatorV1Client) *kubeControllerManagers { + return &kubeControllerManagers{ + client: c.RESTClient(), + } +} + +// Get takes name of the kubeControllerManager, and returns the corresponding kubeControllerManager object, and an error if there is any. +func (c *kubeControllerManagers) Get(name string, options metav1.GetOptions) (result *v1.KubeControllerManager, err error) { + result = &v1.KubeControllerManager{} + err = c.client.Get(). + Resource("kubecontrollermanagers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of KubeControllerManagers that match those selectors. +func (c *kubeControllerManagers) List(opts metav1.ListOptions) (result *v1.KubeControllerManagerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.KubeControllerManagerList{} + err = c.client.Get(). + Resource("kubecontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested kubeControllerManagers. +func (c *kubeControllerManagers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("kubecontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a kubeControllerManager and creates it. Returns the server's representation of the kubeControllerManager, and an error, if there is any. +func (c *kubeControllerManagers) Create(kubeControllerManager *v1.KubeControllerManager) (result *v1.KubeControllerManager, err error) { + result = &v1.KubeControllerManager{} + err = c.client.Post(). + Resource("kubecontrollermanagers"). + Body(kubeControllerManager). + Do(). + Into(result) + return +} + +// Update takes the representation of a kubeControllerManager and updates it. Returns the server's representation of the kubeControllerManager, and an error, if there is any. +func (c *kubeControllerManagers) Update(kubeControllerManager *v1.KubeControllerManager) (result *v1.KubeControllerManager, err error) { + result = &v1.KubeControllerManager{} + err = c.client.Put(). + Resource("kubecontrollermanagers"). + Name(kubeControllerManager.Name). + Body(kubeControllerManager). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *kubeControllerManagers) UpdateStatus(kubeControllerManager *v1.KubeControllerManager) (result *v1.KubeControllerManager, err error) { + result = &v1.KubeControllerManager{} + err = c.client.Put(). + Resource("kubecontrollermanagers"). + Name(kubeControllerManager.Name). + SubResource("status"). + Body(kubeControllerManager). + Do(). + Into(result) + return +} + +// Delete takes name of the kubeControllerManager and deletes it. Returns an error if one occurs. +func (c *kubeControllerManagers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("kubecontrollermanagers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *kubeControllerManagers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("kubecontrollermanagers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched kubeControllerManager. +func (c *kubeControllerManagers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeControllerManager, err error) { + result = &v1.KubeControllerManager{} + err = c.client.Patch(pt). + Resource("kubecontrollermanagers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubescheduler.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubescheduler.go new file mode 100644 index 000000000..b4b1d8a2a --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubescheduler.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// KubeSchedulersGetter has a method to return a KubeSchedulerInterface. +// A group's client should implement this interface. +type KubeSchedulersGetter interface { + KubeSchedulers() KubeSchedulerInterface +} + +// KubeSchedulerInterface has methods to work with KubeScheduler resources. +type KubeSchedulerInterface interface { + Create(*v1.KubeScheduler) (*v1.KubeScheduler, error) + Update(*v1.KubeScheduler) (*v1.KubeScheduler, error) + UpdateStatus(*v1.KubeScheduler) (*v1.KubeScheduler, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.KubeScheduler, error) + List(opts metav1.ListOptions) (*v1.KubeSchedulerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeScheduler, err error) + KubeSchedulerExpansion +} + +// kubeSchedulers implements KubeSchedulerInterface +type kubeSchedulers struct { + client rest.Interface +} + +// newKubeSchedulers returns a KubeSchedulers +func newKubeSchedulers(c *OperatorV1Client) *kubeSchedulers { + return &kubeSchedulers{ + client: c.RESTClient(), + } +} + +// Get takes name of the kubeScheduler, and returns the corresponding kubeScheduler object, and an error if there is any. +func (c *kubeSchedulers) Get(name string, options metav1.GetOptions) (result *v1.KubeScheduler, err error) { + result = &v1.KubeScheduler{} + err = c.client.Get(). + Resource("kubeschedulers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of KubeSchedulers that match those selectors. +func (c *kubeSchedulers) List(opts metav1.ListOptions) (result *v1.KubeSchedulerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.KubeSchedulerList{} + err = c.client.Get(). + Resource("kubeschedulers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested kubeSchedulers. +func (c *kubeSchedulers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("kubeschedulers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a kubeScheduler and creates it. Returns the server's representation of the kubeScheduler, and an error, if there is any. +func (c *kubeSchedulers) Create(kubeScheduler *v1.KubeScheduler) (result *v1.KubeScheduler, err error) { + result = &v1.KubeScheduler{} + err = c.client.Post(). + Resource("kubeschedulers"). + Body(kubeScheduler). + Do(). + Into(result) + return +} + +// Update takes the representation of a kubeScheduler and updates it. Returns the server's representation of the kubeScheduler, and an error, if there is any. +func (c *kubeSchedulers) Update(kubeScheduler *v1.KubeScheduler) (result *v1.KubeScheduler, err error) { + result = &v1.KubeScheduler{} + err = c.client.Put(). + Resource("kubeschedulers"). + Name(kubeScheduler.Name). + Body(kubeScheduler). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *kubeSchedulers) UpdateStatus(kubeScheduler *v1.KubeScheduler) (result *v1.KubeScheduler, err error) { + result = &v1.KubeScheduler{} + err = c.client.Put(). + Resource("kubeschedulers"). + Name(kubeScheduler.Name). + SubResource("status"). + Body(kubeScheduler). + Do(). + Into(result) + return +} + +// Delete takes name of the kubeScheduler and deletes it. Returns an error if one occurs. +func (c *kubeSchedulers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("kubeschedulers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *kubeSchedulers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("kubeschedulers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched kubeScheduler. +func (c *kubeSchedulers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeScheduler, err error) { + result = &v1.KubeScheduler{} + err = c.client.Patch(pt). + Resource("kubeschedulers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubestorageversionmigrator.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubestorageversionmigrator.go new file mode 100644 index 000000000..0dff019f0 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/kubestorageversionmigrator.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// KubeStorageVersionMigratorsGetter has a method to return a KubeStorageVersionMigratorInterface. +// A group's client should implement this interface. +type KubeStorageVersionMigratorsGetter interface { + KubeStorageVersionMigrators() KubeStorageVersionMigratorInterface +} + +// KubeStorageVersionMigratorInterface has methods to work with KubeStorageVersionMigrator resources. +type KubeStorageVersionMigratorInterface interface { + Create(*v1.KubeStorageVersionMigrator) (*v1.KubeStorageVersionMigrator, error) + Update(*v1.KubeStorageVersionMigrator) (*v1.KubeStorageVersionMigrator, error) + UpdateStatus(*v1.KubeStorageVersionMigrator) (*v1.KubeStorageVersionMigrator, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.KubeStorageVersionMigrator, error) + List(opts metav1.ListOptions) (*v1.KubeStorageVersionMigratorList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeStorageVersionMigrator, err error) + KubeStorageVersionMigratorExpansion +} + +// kubeStorageVersionMigrators implements KubeStorageVersionMigratorInterface +type kubeStorageVersionMigrators struct { + client rest.Interface +} + +// newKubeStorageVersionMigrators returns a KubeStorageVersionMigrators +func newKubeStorageVersionMigrators(c *OperatorV1Client) *kubeStorageVersionMigrators { + return &kubeStorageVersionMigrators{ + client: c.RESTClient(), + } +} + +// Get takes name of the kubeStorageVersionMigrator, and returns the corresponding kubeStorageVersionMigrator object, and an error if there is any. +func (c *kubeStorageVersionMigrators) Get(name string, options metav1.GetOptions) (result *v1.KubeStorageVersionMigrator, err error) { + result = &v1.KubeStorageVersionMigrator{} + err = c.client.Get(). + Resource("kubestorageversionmigrators"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of KubeStorageVersionMigrators that match those selectors. +func (c *kubeStorageVersionMigrators) List(opts metav1.ListOptions) (result *v1.KubeStorageVersionMigratorList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.KubeStorageVersionMigratorList{} + err = c.client.Get(). + Resource("kubestorageversionmigrators"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested kubeStorageVersionMigrators. +func (c *kubeStorageVersionMigrators) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("kubestorageversionmigrators"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a kubeStorageVersionMigrator and creates it. Returns the server's representation of the kubeStorageVersionMigrator, and an error, if there is any. +func (c *kubeStorageVersionMigrators) Create(kubeStorageVersionMigrator *v1.KubeStorageVersionMigrator) (result *v1.KubeStorageVersionMigrator, err error) { + result = &v1.KubeStorageVersionMigrator{} + err = c.client.Post(). + Resource("kubestorageversionmigrators"). + Body(kubeStorageVersionMigrator). + Do(). + Into(result) + return +} + +// Update takes the representation of a kubeStorageVersionMigrator and updates it. Returns the server's representation of the kubeStorageVersionMigrator, and an error, if there is any. +func (c *kubeStorageVersionMigrators) Update(kubeStorageVersionMigrator *v1.KubeStorageVersionMigrator) (result *v1.KubeStorageVersionMigrator, err error) { + result = &v1.KubeStorageVersionMigrator{} + err = c.client.Put(). + Resource("kubestorageversionmigrators"). + Name(kubeStorageVersionMigrator.Name). + Body(kubeStorageVersionMigrator). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *kubeStorageVersionMigrators) UpdateStatus(kubeStorageVersionMigrator *v1.KubeStorageVersionMigrator) (result *v1.KubeStorageVersionMigrator, err error) { + result = &v1.KubeStorageVersionMigrator{} + err = c.client.Put(). + Resource("kubestorageversionmigrators"). + Name(kubeStorageVersionMigrator.Name). + SubResource("status"). + Body(kubeStorageVersionMigrator). + Do(). + Into(result) + return +} + +// Delete takes name of the kubeStorageVersionMigrator and deletes it. Returns an error if one occurs. +func (c *kubeStorageVersionMigrators) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("kubestorageversionmigrators"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *kubeStorageVersionMigrators) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("kubestorageversionmigrators"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched kubeStorageVersionMigrator. +func (c *kubeStorageVersionMigrators) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.KubeStorageVersionMigrator, err error) { + result = &v1.KubeStorageVersionMigrator{} + err = c.client.Patch(pt). + Resource("kubestorageversionmigrators"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/network.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/network.go new file mode 100644 index 000000000..62e2c4dfe --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/network.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// NetworksGetter has a method to return a NetworkInterface. +// A group's client should implement this interface. +type NetworksGetter interface { + Networks() NetworkInterface +} + +// NetworkInterface has methods to work with Network resources. +type NetworkInterface interface { + Create(*v1.Network) (*v1.Network, error) + Update(*v1.Network) (*v1.Network, error) + UpdateStatus(*v1.Network) (*v1.Network, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.Network, error) + List(opts metav1.ListOptions) (*v1.NetworkList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Network, err error) + NetworkExpansion +} + +// networks implements NetworkInterface +type networks struct { + client rest.Interface +} + +// newNetworks returns a Networks +func newNetworks(c *OperatorV1Client) *networks { + return &networks{ + client: c.RESTClient(), + } +} + +// Get takes name of the network, and returns the corresponding network object, and an error if there is any. +func (c *networks) Get(name string, options metav1.GetOptions) (result *v1.Network, err error) { + result = &v1.Network{} + err = c.client.Get(). + Resource("networks"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of Networks that match those selectors. +func (c *networks) List(opts metav1.ListOptions) (result *v1.NetworkList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.NetworkList{} + err = c.client.Get(). + Resource("networks"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested networks. +func (c *networks) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("networks"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a network and creates it. Returns the server's representation of the network, and an error, if there is any. +func (c *networks) Create(network *v1.Network) (result *v1.Network, err error) { + result = &v1.Network{} + err = c.client.Post(). + Resource("networks"). + Body(network). + Do(). + Into(result) + return +} + +// Update takes the representation of a network and updates it. Returns the server's representation of the network, and an error, if there is any. +func (c *networks) Update(network *v1.Network) (result *v1.Network, err error) { + result = &v1.Network{} + err = c.client.Put(). + Resource("networks"). + Name(network.Name). + Body(network). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *networks) UpdateStatus(network *v1.Network) (result *v1.Network, err error) { + result = &v1.Network{} + err = c.client.Put(). + Resource("networks"). + Name(network.Name). + SubResource("status"). + Body(network). + Do(). + Into(result) + return +} + +// Delete takes name of the network and deletes it. Returns an error if one occurs. +func (c *networks) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("networks"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *networks) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("networks"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched network. +func (c *networks) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Network, err error) { + result = &v1.Network{} + err = c.client.Patch(pt). + Resource("networks"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftapiserver.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftapiserver.go new file mode 100644 index 000000000..aa136112f --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftapiserver.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// OpenShiftAPIServersGetter has a method to return a OpenShiftAPIServerInterface. +// A group's client should implement this interface. +type OpenShiftAPIServersGetter interface { + OpenShiftAPIServers() OpenShiftAPIServerInterface +} + +// OpenShiftAPIServerInterface has methods to work with OpenShiftAPIServer resources. +type OpenShiftAPIServerInterface interface { + Create(*v1.OpenShiftAPIServer) (*v1.OpenShiftAPIServer, error) + Update(*v1.OpenShiftAPIServer) (*v1.OpenShiftAPIServer, error) + UpdateStatus(*v1.OpenShiftAPIServer) (*v1.OpenShiftAPIServer, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.OpenShiftAPIServer, error) + List(opts metav1.ListOptions) (*v1.OpenShiftAPIServerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.OpenShiftAPIServer, err error) + OpenShiftAPIServerExpansion +} + +// openShiftAPIServers implements OpenShiftAPIServerInterface +type openShiftAPIServers struct { + client rest.Interface +} + +// newOpenShiftAPIServers returns a OpenShiftAPIServers +func newOpenShiftAPIServers(c *OperatorV1Client) *openShiftAPIServers { + return &openShiftAPIServers{ + client: c.RESTClient(), + } +} + +// Get takes name of the openShiftAPIServer, and returns the corresponding openShiftAPIServer object, and an error if there is any. +func (c *openShiftAPIServers) Get(name string, options metav1.GetOptions) (result *v1.OpenShiftAPIServer, err error) { + result = &v1.OpenShiftAPIServer{} + err = c.client.Get(). + Resource("openshiftapiservers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of OpenShiftAPIServers that match those selectors. +func (c *openShiftAPIServers) List(opts metav1.ListOptions) (result *v1.OpenShiftAPIServerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.OpenShiftAPIServerList{} + err = c.client.Get(). + Resource("openshiftapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested openShiftAPIServers. +func (c *openShiftAPIServers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("openshiftapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a openShiftAPIServer and creates it. Returns the server's representation of the openShiftAPIServer, and an error, if there is any. +func (c *openShiftAPIServers) Create(openShiftAPIServer *v1.OpenShiftAPIServer) (result *v1.OpenShiftAPIServer, err error) { + result = &v1.OpenShiftAPIServer{} + err = c.client.Post(). + Resource("openshiftapiservers"). + Body(openShiftAPIServer). + Do(). + Into(result) + return +} + +// Update takes the representation of a openShiftAPIServer and updates it. Returns the server's representation of the openShiftAPIServer, and an error, if there is any. +func (c *openShiftAPIServers) Update(openShiftAPIServer *v1.OpenShiftAPIServer) (result *v1.OpenShiftAPIServer, err error) { + result = &v1.OpenShiftAPIServer{} + err = c.client.Put(). + Resource("openshiftapiservers"). + Name(openShiftAPIServer.Name). + Body(openShiftAPIServer). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *openShiftAPIServers) UpdateStatus(openShiftAPIServer *v1.OpenShiftAPIServer) (result *v1.OpenShiftAPIServer, err error) { + result = &v1.OpenShiftAPIServer{} + err = c.client.Put(). + Resource("openshiftapiservers"). + Name(openShiftAPIServer.Name). + SubResource("status"). + Body(openShiftAPIServer). + Do(). + Into(result) + return +} + +// Delete takes name of the openShiftAPIServer and deletes it. Returns an error if one occurs. +func (c *openShiftAPIServers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("openshiftapiservers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *openShiftAPIServers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("openshiftapiservers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched openShiftAPIServer. +func (c *openShiftAPIServers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.OpenShiftAPIServer, err error) { + result = &v1.OpenShiftAPIServer{} + err = c.client.Patch(pt). + Resource("openshiftapiservers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftcontrollermanager.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftcontrollermanager.go new file mode 100644 index 000000000..38e168d3c --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/openshiftcontrollermanager.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// OpenShiftControllerManagersGetter has a method to return a OpenShiftControllerManagerInterface. +// A group's client should implement this interface. +type OpenShiftControllerManagersGetter interface { + OpenShiftControllerManagers() OpenShiftControllerManagerInterface +} + +// OpenShiftControllerManagerInterface has methods to work with OpenShiftControllerManager resources. +type OpenShiftControllerManagerInterface interface { + Create(*v1.OpenShiftControllerManager) (*v1.OpenShiftControllerManager, error) + Update(*v1.OpenShiftControllerManager) (*v1.OpenShiftControllerManager, error) + UpdateStatus(*v1.OpenShiftControllerManager) (*v1.OpenShiftControllerManager, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.OpenShiftControllerManager, error) + List(opts metav1.ListOptions) (*v1.OpenShiftControllerManagerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.OpenShiftControllerManager, err error) + OpenShiftControllerManagerExpansion +} + +// openShiftControllerManagers implements OpenShiftControllerManagerInterface +type openShiftControllerManagers struct { + client rest.Interface +} + +// newOpenShiftControllerManagers returns a OpenShiftControllerManagers +func newOpenShiftControllerManagers(c *OperatorV1Client) *openShiftControllerManagers { + return &openShiftControllerManagers{ + client: c.RESTClient(), + } +} + +// Get takes name of the openShiftControllerManager, and returns the corresponding openShiftControllerManager object, and an error if there is any. +func (c *openShiftControllerManagers) Get(name string, options metav1.GetOptions) (result *v1.OpenShiftControllerManager, err error) { + result = &v1.OpenShiftControllerManager{} + err = c.client.Get(). + Resource("openshiftcontrollermanagers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of OpenShiftControllerManagers that match those selectors. +func (c *openShiftControllerManagers) List(opts metav1.ListOptions) (result *v1.OpenShiftControllerManagerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.OpenShiftControllerManagerList{} + err = c.client.Get(). + Resource("openshiftcontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested openShiftControllerManagers. +func (c *openShiftControllerManagers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("openshiftcontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a openShiftControllerManager and creates it. Returns the server's representation of the openShiftControllerManager, and an error, if there is any. +func (c *openShiftControllerManagers) Create(openShiftControllerManager *v1.OpenShiftControllerManager) (result *v1.OpenShiftControllerManager, err error) { + result = &v1.OpenShiftControllerManager{} + err = c.client.Post(). + Resource("openshiftcontrollermanagers"). + Body(openShiftControllerManager). + Do(). + Into(result) + return +} + +// Update takes the representation of a openShiftControllerManager and updates it. Returns the server's representation of the openShiftControllerManager, and an error, if there is any. +func (c *openShiftControllerManagers) Update(openShiftControllerManager *v1.OpenShiftControllerManager) (result *v1.OpenShiftControllerManager, err error) { + result = &v1.OpenShiftControllerManager{} + err = c.client.Put(). + Resource("openshiftcontrollermanagers"). + Name(openShiftControllerManager.Name). + Body(openShiftControllerManager). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *openShiftControllerManagers) UpdateStatus(openShiftControllerManager *v1.OpenShiftControllerManager) (result *v1.OpenShiftControllerManager, err error) { + result = &v1.OpenShiftControllerManager{} + err = c.client.Put(). + Resource("openshiftcontrollermanagers"). + Name(openShiftControllerManager.Name). + SubResource("status"). + Body(openShiftControllerManager). + Do(). + Into(result) + return +} + +// Delete takes name of the openShiftControllerManager and deletes it. Returns an error if one occurs. +func (c *openShiftControllerManagers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("openshiftcontrollermanagers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *openShiftControllerManagers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("openshiftcontrollermanagers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched openShiftControllerManager. +func (c *openShiftControllerManagers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.OpenShiftControllerManager, err error) { + result = &v1.OpenShiftControllerManager{} + err = c.client.Patch(pt). + Resource("openshiftcontrollermanagers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/operator_client.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/operator_client.go new file mode 100644 index 000000000..b6e2f95b3 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/operator_client.go @@ -0,0 +1,143 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + v1 "github.com/openshift/api/operator/v1" + "github.com/openshift/client-go/operator/clientset/versioned/scheme" + rest "k8s.io/client-go/rest" +) + +type OperatorV1Interface interface { + RESTClient() rest.Interface + AuthenticationsGetter + ConsolesGetter + DNSesGetter + EtcdsGetter + IngressControllersGetter + KubeAPIServersGetter + KubeControllerManagersGetter + KubeSchedulersGetter + KubeStorageVersionMigratorsGetter + NetworksGetter + OpenShiftAPIServersGetter + OpenShiftControllerManagersGetter + ServiceCAsGetter + ServiceCatalogAPIServersGetter + ServiceCatalogControllerManagersGetter +} + +// OperatorV1Client is used to interact with features provided by the operator.openshift.io group. +type OperatorV1Client struct { + restClient rest.Interface +} + +func (c *OperatorV1Client) Authentications() AuthenticationInterface { + return newAuthentications(c) +} + +func (c *OperatorV1Client) Consoles() ConsoleInterface { + return newConsoles(c) +} + +func (c *OperatorV1Client) DNSes() DNSInterface { + return newDNSes(c) +} + +func (c *OperatorV1Client) Etcds() EtcdInterface { + return newEtcds(c) +} + +func (c *OperatorV1Client) IngressControllers(namespace string) IngressControllerInterface { + return newIngressControllers(c, namespace) +} + +func (c *OperatorV1Client) KubeAPIServers() KubeAPIServerInterface { + return newKubeAPIServers(c) +} + +func (c *OperatorV1Client) KubeControllerManagers() KubeControllerManagerInterface { + return newKubeControllerManagers(c) +} + +func (c *OperatorV1Client) KubeSchedulers() KubeSchedulerInterface { + return newKubeSchedulers(c) +} + +func (c *OperatorV1Client) KubeStorageVersionMigrators() KubeStorageVersionMigratorInterface { + return newKubeStorageVersionMigrators(c) +} + +func (c *OperatorV1Client) Networks() NetworkInterface { + return newNetworks(c) +} + +func (c *OperatorV1Client) OpenShiftAPIServers() OpenShiftAPIServerInterface { + return newOpenShiftAPIServers(c) +} + +func (c *OperatorV1Client) OpenShiftControllerManagers() OpenShiftControllerManagerInterface { + return newOpenShiftControllerManagers(c) +} + +func (c *OperatorV1Client) ServiceCAs() ServiceCAInterface { + return newServiceCAs(c) +} + +func (c *OperatorV1Client) ServiceCatalogAPIServers() ServiceCatalogAPIServerInterface { + return newServiceCatalogAPIServers(c) +} + +func (c *OperatorV1Client) ServiceCatalogControllerManagers() ServiceCatalogControllerManagerInterface { + return newServiceCatalogControllerManagers(c) +} + +// NewForConfig creates a new OperatorV1Client for the given config. +func NewForConfig(c *rest.Config) (*OperatorV1Client, error) { + config := *c + if err := setConfigDefaults(&config); err != nil { + return nil, err + } + client, err := rest.RESTClientFor(&config) + if err != nil { + return nil, err + } + return &OperatorV1Client{client}, nil +} + +// NewForConfigOrDie creates a new OperatorV1Client for the given config and +// panics if there is an error in the config. +func NewForConfigOrDie(c *rest.Config) *OperatorV1Client { + client, err := NewForConfig(c) + if err != nil { + panic(err) + } + return client +} + +// New creates a new OperatorV1Client for the given RESTClient. +func New(c rest.Interface) *OperatorV1Client { + return &OperatorV1Client{c} +} + +func setConfigDefaults(config *rest.Config) error { + gv := v1.SchemeGroupVersion + config.GroupVersion = &gv + config.APIPath = "/apis" + config.NegotiatedSerializer = scheme.Codecs.WithoutConversion() + + if config.UserAgent == "" { + config.UserAgent = rest.DefaultKubernetesUserAgent() + } + + return nil +} + +// RESTClient returns a RESTClient that is used to communicate +// with API server by this client implementation. +func (c *OperatorV1Client) RESTClient() rest.Interface { + if c == nil { + return nil + } + return c.restClient +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/serviceca.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/serviceca.go new file mode 100644 index 000000000..a451054ed --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/serviceca.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// ServiceCAsGetter has a method to return a ServiceCAInterface. +// A group's client should implement this interface. +type ServiceCAsGetter interface { + ServiceCAs() ServiceCAInterface +} + +// ServiceCAInterface has methods to work with ServiceCA resources. +type ServiceCAInterface interface { + Create(*v1.ServiceCA) (*v1.ServiceCA, error) + Update(*v1.ServiceCA) (*v1.ServiceCA, error) + UpdateStatus(*v1.ServiceCA) (*v1.ServiceCA, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.ServiceCA, error) + List(opts metav1.ListOptions) (*v1.ServiceCAList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCA, err error) + ServiceCAExpansion +} + +// serviceCAs implements ServiceCAInterface +type serviceCAs struct { + client rest.Interface +} + +// newServiceCAs returns a ServiceCAs +func newServiceCAs(c *OperatorV1Client) *serviceCAs { + return &serviceCAs{ + client: c.RESTClient(), + } +} + +// Get takes name of the serviceCA, and returns the corresponding serviceCA object, and an error if there is any. +func (c *serviceCAs) Get(name string, options metav1.GetOptions) (result *v1.ServiceCA, err error) { + result = &v1.ServiceCA{} + err = c.client.Get(). + Resource("servicecas"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of ServiceCAs that match those selectors. +func (c *serviceCAs) List(opts metav1.ListOptions) (result *v1.ServiceCAList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.ServiceCAList{} + err = c.client.Get(). + Resource("servicecas"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested serviceCAs. +func (c *serviceCAs) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("servicecas"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a serviceCA and creates it. Returns the server's representation of the serviceCA, and an error, if there is any. +func (c *serviceCAs) Create(serviceCA *v1.ServiceCA) (result *v1.ServiceCA, err error) { + result = &v1.ServiceCA{} + err = c.client.Post(). + Resource("servicecas"). + Body(serviceCA). + Do(). + Into(result) + return +} + +// Update takes the representation of a serviceCA and updates it. Returns the server's representation of the serviceCA, and an error, if there is any. +func (c *serviceCAs) Update(serviceCA *v1.ServiceCA) (result *v1.ServiceCA, err error) { + result = &v1.ServiceCA{} + err = c.client.Put(). + Resource("servicecas"). + Name(serviceCA.Name). + Body(serviceCA). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *serviceCAs) UpdateStatus(serviceCA *v1.ServiceCA) (result *v1.ServiceCA, err error) { + result = &v1.ServiceCA{} + err = c.client.Put(). + Resource("servicecas"). + Name(serviceCA.Name). + SubResource("status"). + Body(serviceCA). + Do(). + Into(result) + return +} + +// Delete takes name of the serviceCA and deletes it. Returns an error if one occurs. +func (c *serviceCAs) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("servicecas"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *serviceCAs) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("servicecas"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched serviceCA. +func (c *serviceCAs) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCA, err error) { + result = &v1.ServiceCA{} + err = c.client.Patch(pt). + Resource("servicecas"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogapiserver.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogapiserver.go new file mode 100644 index 000000000..dd0d78c79 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogapiserver.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// ServiceCatalogAPIServersGetter has a method to return a ServiceCatalogAPIServerInterface. +// A group's client should implement this interface. +type ServiceCatalogAPIServersGetter interface { + ServiceCatalogAPIServers() ServiceCatalogAPIServerInterface +} + +// ServiceCatalogAPIServerInterface has methods to work with ServiceCatalogAPIServer resources. +type ServiceCatalogAPIServerInterface interface { + Create(*v1.ServiceCatalogAPIServer) (*v1.ServiceCatalogAPIServer, error) + Update(*v1.ServiceCatalogAPIServer) (*v1.ServiceCatalogAPIServer, error) + UpdateStatus(*v1.ServiceCatalogAPIServer) (*v1.ServiceCatalogAPIServer, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.ServiceCatalogAPIServer, error) + List(opts metav1.ListOptions) (*v1.ServiceCatalogAPIServerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCatalogAPIServer, err error) + ServiceCatalogAPIServerExpansion +} + +// serviceCatalogAPIServers implements ServiceCatalogAPIServerInterface +type serviceCatalogAPIServers struct { + client rest.Interface +} + +// newServiceCatalogAPIServers returns a ServiceCatalogAPIServers +func newServiceCatalogAPIServers(c *OperatorV1Client) *serviceCatalogAPIServers { + return &serviceCatalogAPIServers{ + client: c.RESTClient(), + } +} + +// Get takes name of the serviceCatalogAPIServer, and returns the corresponding serviceCatalogAPIServer object, and an error if there is any. +func (c *serviceCatalogAPIServers) Get(name string, options metav1.GetOptions) (result *v1.ServiceCatalogAPIServer, err error) { + result = &v1.ServiceCatalogAPIServer{} + err = c.client.Get(). + Resource("servicecatalogapiservers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of ServiceCatalogAPIServers that match those selectors. +func (c *serviceCatalogAPIServers) List(opts metav1.ListOptions) (result *v1.ServiceCatalogAPIServerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.ServiceCatalogAPIServerList{} + err = c.client.Get(). + Resource("servicecatalogapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested serviceCatalogAPIServers. +func (c *serviceCatalogAPIServers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("servicecatalogapiservers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a serviceCatalogAPIServer and creates it. Returns the server's representation of the serviceCatalogAPIServer, and an error, if there is any. +func (c *serviceCatalogAPIServers) Create(serviceCatalogAPIServer *v1.ServiceCatalogAPIServer) (result *v1.ServiceCatalogAPIServer, err error) { + result = &v1.ServiceCatalogAPIServer{} + err = c.client.Post(). + Resource("servicecatalogapiservers"). + Body(serviceCatalogAPIServer). + Do(). + Into(result) + return +} + +// Update takes the representation of a serviceCatalogAPIServer and updates it. Returns the server's representation of the serviceCatalogAPIServer, and an error, if there is any. +func (c *serviceCatalogAPIServers) Update(serviceCatalogAPIServer *v1.ServiceCatalogAPIServer) (result *v1.ServiceCatalogAPIServer, err error) { + result = &v1.ServiceCatalogAPIServer{} + err = c.client.Put(). + Resource("servicecatalogapiservers"). + Name(serviceCatalogAPIServer.Name). + Body(serviceCatalogAPIServer). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *serviceCatalogAPIServers) UpdateStatus(serviceCatalogAPIServer *v1.ServiceCatalogAPIServer) (result *v1.ServiceCatalogAPIServer, err error) { + result = &v1.ServiceCatalogAPIServer{} + err = c.client.Put(). + Resource("servicecatalogapiservers"). + Name(serviceCatalogAPIServer.Name). + SubResource("status"). + Body(serviceCatalogAPIServer). + Do(). + Into(result) + return +} + +// Delete takes name of the serviceCatalogAPIServer and deletes it. Returns an error if one occurs. +func (c *serviceCatalogAPIServers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("servicecatalogapiservers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *serviceCatalogAPIServers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("servicecatalogapiservers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched serviceCatalogAPIServer. +func (c *serviceCatalogAPIServers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCatalogAPIServer, err error) { + result = &v1.ServiceCatalogAPIServer{} + err = c.client.Patch(pt). + Resource("servicecatalogapiservers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogcontrollermanager.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogcontrollermanager.go new file mode 100644 index 000000000..ae28c773f --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1/servicecatalogcontrollermanager.go @@ -0,0 +1,164 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1 + +import ( + "time" + + v1 "github.com/openshift/api/operator/v1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// ServiceCatalogControllerManagersGetter has a method to return a ServiceCatalogControllerManagerInterface. +// A group's client should implement this interface. +type ServiceCatalogControllerManagersGetter interface { + ServiceCatalogControllerManagers() ServiceCatalogControllerManagerInterface +} + +// ServiceCatalogControllerManagerInterface has methods to work with ServiceCatalogControllerManager resources. +type ServiceCatalogControllerManagerInterface interface { + Create(*v1.ServiceCatalogControllerManager) (*v1.ServiceCatalogControllerManager, error) + Update(*v1.ServiceCatalogControllerManager) (*v1.ServiceCatalogControllerManager, error) + UpdateStatus(*v1.ServiceCatalogControllerManager) (*v1.ServiceCatalogControllerManager, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error + Get(name string, options metav1.GetOptions) (*v1.ServiceCatalogControllerManager, error) + List(opts metav1.ListOptions) (*v1.ServiceCatalogControllerManagerList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCatalogControllerManager, err error) + ServiceCatalogControllerManagerExpansion +} + +// serviceCatalogControllerManagers implements ServiceCatalogControllerManagerInterface +type serviceCatalogControllerManagers struct { + client rest.Interface +} + +// newServiceCatalogControllerManagers returns a ServiceCatalogControllerManagers +func newServiceCatalogControllerManagers(c *OperatorV1Client) *serviceCatalogControllerManagers { + return &serviceCatalogControllerManagers{ + client: c.RESTClient(), + } +} + +// Get takes name of the serviceCatalogControllerManager, and returns the corresponding serviceCatalogControllerManager object, and an error if there is any. +func (c *serviceCatalogControllerManagers) Get(name string, options metav1.GetOptions) (result *v1.ServiceCatalogControllerManager, err error) { + result = &v1.ServiceCatalogControllerManager{} + err = c.client.Get(). + Resource("servicecatalogcontrollermanagers"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of ServiceCatalogControllerManagers that match those selectors. +func (c *serviceCatalogControllerManagers) List(opts metav1.ListOptions) (result *v1.ServiceCatalogControllerManagerList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1.ServiceCatalogControllerManagerList{} + err = c.client.Get(). + Resource("servicecatalogcontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested serviceCatalogControllerManagers. +func (c *serviceCatalogControllerManagers) Watch(opts metav1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("servicecatalogcontrollermanagers"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a serviceCatalogControllerManager and creates it. Returns the server's representation of the serviceCatalogControllerManager, and an error, if there is any. +func (c *serviceCatalogControllerManagers) Create(serviceCatalogControllerManager *v1.ServiceCatalogControllerManager) (result *v1.ServiceCatalogControllerManager, err error) { + result = &v1.ServiceCatalogControllerManager{} + err = c.client.Post(). + Resource("servicecatalogcontrollermanagers"). + Body(serviceCatalogControllerManager). + Do(). + Into(result) + return +} + +// Update takes the representation of a serviceCatalogControllerManager and updates it. Returns the server's representation of the serviceCatalogControllerManager, and an error, if there is any. +func (c *serviceCatalogControllerManagers) Update(serviceCatalogControllerManager *v1.ServiceCatalogControllerManager) (result *v1.ServiceCatalogControllerManager, err error) { + result = &v1.ServiceCatalogControllerManager{} + err = c.client.Put(). + Resource("servicecatalogcontrollermanagers"). + Name(serviceCatalogControllerManager.Name). + Body(serviceCatalogControllerManager). + Do(). + Into(result) + return +} + +// UpdateStatus was generated because the type contains a Status member. +// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). + +func (c *serviceCatalogControllerManagers) UpdateStatus(serviceCatalogControllerManager *v1.ServiceCatalogControllerManager) (result *v1.ServiceCatalogControllerManager, err error) { + result = &v1.ServiceCatalogControllerManager{} + err = c.client.Put(). + Resource("servicecatalogcontrollermanagers"). + Name(serviceCatalogControllerManager.Name). + SubResource("status"). + Body(serviceCatalogControllerManager). + Do(). + Into(result) + return +} + +// Delete takes name of the serviceCatalogControllerManager and deletes it. Returns an error if one occurs. +func (c *serviceCatalogControllerManagers) Delete(name string, options *metav1.DeleteOptions) error { + return c.client.Delete(). + Resource("servicecatalogcontrollermanagers"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *serviceCatalogControllerManagers) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("servicecatalogcontrollermanagers"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched serviceCatalogControllerManager. +func (c *serviceCatalogControllerManagers) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ServiceCatalogControllerManager, err error) { + result = &v1.ServiceCatalogControllerManager{} + err = c.client.Patch(pt). + Resource("servicecatalogcontrollermanagers"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/doc.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/doc.go new file mode 100644 index 000000000..93a7ca4e0 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/doc.go @@ -0,0 +1,4 @@ +// Code generated by client-gen. DO NOT EDIT. + +// This package has the automatically generated typed clients. +package v1alpha1 diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/generated_expansion.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/generated_expansion.go new file mode 100644 index 000000000..42ec352cf --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/generated_expansion.go @@ -0,0 +1,5 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1alpha1 + +type ImageContentSourcePolicyExpansion interface{} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/imagecontentsourcepolicy.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/imagecontentsourcepolicy.go new file mode 100644 index 000000000..bac2a4e76 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/imagecontentsourcepolicy.go @@ -0,0 +1,148 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1alpha1 + +import ( + "time" + + v1alpha1 "github.com/openshift/api/operator/v1alpha1" + scheme "github.com/openshift/client-go/operator/clientset/versioned/scheme" + v1 "k8s.io/apimachinery/pkg/apis/meta/v1" + types "k8s.io/apimachinery/pkg/types" + watch "k8s.io/apimachinery/pkg/watch" + rest "k8s.io/client-go/rest" +) + +// ImageContentSourcePoliciesGetter has a method to return a ImageContentSourcePolicyInterface. +// A group's client should implement this interface. +type ImageContentSourcePoliciesGetter interface { + ImageContentSourcePolicies() ImageContentSourcePolicyInterface +} + +// ImageContentSourcePolicyInterface has methods to work with ImageContentSourcePolicy resources. +type ImageContentSourcePolicyInterface interface { + Create(*v1alpha1.ImageContentSourcePolicy) (*v1alpha1.ImageContentSourcePolicy, error) + Update(*v1alpha1.ImageContentSourcePolicy) (*v1alpha1.ImageContentSourcePolicy, error) + Delete(name string, options *v1.DeleteOptions) error + DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error + Get(name string, options v1.GetOptions) (*v1alpha1.ImageContentSourcePolicy, error) + List(opts v1.ListOptions) (*v1alpha1.ImageContentSourcePolicyList, error) + Watch(opts v1.ListOptions) (watch.Interface, error) + Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.ImageContentSourcePolicy, err error) + ImageContentSourcePolicyExpansion +} + +// imageContentSourcePolicies implements ImageContentSourcePolicyInterface +type imageContentSourcePolicies struct { + client rest.Interface +} + +// newImageContentSourcePolicies returns a ImageContentSourcePolicies +func newImageContentSourcePolicies(c *OperatorV1alpha1Client) *imageContentSourcePolicies { + return &imageContentSourcePolicies{ + client: c.RESTClient(), + } +} + +// Get takes name of the imageContentSourcePolicy, and returns the corresponding imageContentSourcePolicy object, and an error if there is any. +func (c *imageContentSourcePolicies) Get(name string, options v1.GetOptions) (result *v1alpha1.ImageContentSourcePolicy, err error) { + result = &v1alpha1.ImageContentSourcePolicy{} + err = c.client.Get(). + Resource("imagecontentsourcepolicies"). + Name(name). + VersionedParams(&options, scheme.ParameterCodec). + Do(). + Into(result) + return +} + +// List takes label and field selectors, and returns the list of ImageContentSourcePolicies that match those selectors. +func (c *imageContentSourcePolicies) List(opts v1.ListOptions) (result *v1alpha1.ImageContentSourcePolicyList, err error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + result = &v1alpha1.ImageContentSourcePolicyList{} + err = c.client.Get(). + Resource("imagecontentsourcepolicies"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Do(). + Into(result) + return +} + +// Watch returns a watch.Interface that watches the requested imageContentSourcePolicies. +func (c *imageContentSourcePolicies) Watch(opts v1.ListOptions) (watch.Interface, error) { + var timeout time.Duration + if opts.TimeoutSeconds != nil { + timeout = time.Duration(*opts.TimeoutSeconds) * time.Second + } + opts.Watch = true + return c.client.Get(). + Resource("imagecontentsourcepolicies"). + VersionedParams(&opts, scheme.ParameterCodec). + Timeout(timeout). + Watch() +} + +// Create takes the representation of a imageContentSourcePolicy and creates it. Returns the server's representation of the imageContentSourcePolicy, and an error, if there is any. +func (c *imageContentSourcePolicies) Create(imageContentSourcePolicy *v1alpha1.ImageContentSourcePolicy) (result *v1alpha1.ImageContentSourcePolicy, err error) { + result = &v1alpha1.ImageContentSourcePolicy{} + err = c.client.Post(). + Resource("imagecontentsourcepolicies"). + Body(imageContentSourcePolicy). + Do(). + Into(result) + return +} + +// Update takes the representation of a imageContentSourcePolicy and updates it. Returns the server's representation of the imageContentSourcePolicy, and an error, if there is any. +func (c *imageContentSourcePolicies) Update(imageContentSourcePolicy *v1alpha1.ImageContentSourcePolicy) (result *v1alpha1.ImageContentSourcePolicy, err error) { + result = &v1alpha1.ImageContentSourcePolicy{} + err = c.client.Put(). + Resource("imagecontentsourcepolicies"). + Name(imageContentSourcePolicy.Name). + Body(imageContentSourcePolicy). + Do(). + Into(result) + return +} + +// Delete takes name of the imageContentSourcePolicy and deletes it. Returns an error if one occurs. +func (c *imageContentSourcePolicies) Delete(name string, options *v1.DeleteOptions) error { + return c.client.Delete(). + Resource("imagecontentsourcepolicies"). + Name(name). + Body(options). + Do(). + Error() +} + +// DeleteCollection deletes a collection of objects. +func (c *imageContentSourcePolicies) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error { + var timeout time.Duration + if listOptions.TimeoutSeconds != nil { + timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second + } + return c.client.Delete(). + Resource("imagecontentsourcepolicies"). + VersionedParams(&listOptions, scheme.ParameterCodec). + Timeout(timeout). + Body(options). + Do(). + Error() +} + +// Patch applies the patch and returns the patched imageContentSourcePolicy. +func (c *imageContentSourcePolicies) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.ImageContentSourcePolicy, err error) { + result = &v1alpha1.ImageContentSourcePolicy{} + err = c.client.Patch(pt). + Resource("imagecontentsourcepolicies"). + SubResource(subresources...). + Name(name). + Body(data). + Do(). + Into(result) + return +} diff --git a/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/operator_client.go b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/operator_client.go new file mode 100644 index 000000000..9d8c79197 --- /dev/null +++ b/vendor/github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1/operator_client.go @@ -0,0 +1,73 @@ +// Code generated by client-gen. DO NOT EDIT. + +package v1alpha1 + +import ( + v1alpha1 "github.com/openshift/api/operator/v1alpha1" + "github.com/openshift/client-go/operator/clientset/versioned/scheme" + rest "k8s.io/client-go/rest" +) + +type OperatorV1alpha1Interface interface { + RESTClient() rest.Interface + ImageContentSourcePoliciesGetter +} + +// OperatorV1alpha1Client is used to interact with features provided by the operator.openshift.io group. +type OperatorV1alpha1Client struct { + restClient rest.Interface +} + +func (c *OperatorV1alpha1Client) ImageContentSourcePolicies() ImageContentSourcePolicyInterface { + return newImageContentSourcePolicies(c) +} + +// NewForConfig creates a new OperatorV1alpha1Client for the given config. +func NewForConfig(c *rest.Config) (*OperatorV1alpha1Client, error) { + config := *c + if err := setConfigDefaults(&config); err != nil { + return nil, err + } + client, err := rest.RESTClientFor(&config) + if err != nil { + return nil, err + } + return &OperatorV1alpha1Client{client}, nil +} + +// NewForConfigOrDie creates a new OperatorV1alpha1Client for the given config and +// panics if there is an error in the config. +func NewForConfigOrDie(c *rest.Config) *OperatorV1alpha1Client { + client, err := NewForConfig(c) + if err != nil { + panic(err) + } + return client +} + +// New creates a new OperatorV1alpha1Client for the given RESTClient. +func New(c rest.Interface) *OperatorV1alpha1Client { + return &OperatorV1alpha1Client{c} +} + +func setConfigDefaults(config *rest.Config) error { + gv := v1alpha1.SchemeGroupVersion + config.GroupVersion = &gv + config.APIPath = "/apis" + config.NegotiatedSerializer = scheme.Codecs.WithoutConversion() + + if config.UserAgent == "" { + config.UserAgent = rest.DefaultKubernetesUserAgent() + } + + return nil +} + +// RESTClient returns a RESTClient that is used to communicate +// with API server by this client implementation. +func (c *OperatorV1alpha1Client) RESTClient() rest.Interface { + if c == nil { + return nil + } + return c.restClient +} diff --git a/vendor/github.com/openshift/console-operator/LICENSE b/vendor/github.com/openshift/console-operator/LICENSE new file mode 100644 index 000000000..261eeb9e9 --- /dev/null +++ b/vendor/github.com/openshift/console-operator/LICENSE @@ -0,0 +1,201 @@ + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. diff --git a/vendor/github.com/openshift/console-operator/pkg/api/api.go b/vendor/github.com/openshift/console-operator/pkg/api/api.go new file mode 100644 index 000000000..da500d4b8 --- /dev/null +++ b/vendor/github.com/openshift/console-operator/pkg/api/api.go @@ -0,0 +1,32 @@ +package api + +const ( + TargetNamespace = "openshift-console" + ConfigResourceName = "cluster" +) + +// consts to maintain existing names of various sub-resources +const ( + ClusterOperatorName = "console" + OpenShiftConsoleName = "console" + OpenShiftConsoleNamespace = TargetNamespace + OpenShiftConsoleOperatorNamespace = "openshift-console-operator" + OpenShiftConsoleOperator = "console-operator" + OpenShiftConsoleConfigMapName = "console-config" + OpenShiftConsolePublicConfigMapName = "console-public" + ServiceCAConfigMapName = "service-ca" + OpenShiftConsoleDeploymentName = OpenShiftConsoleName + OpenShiftConsoleServiceName = OpenShiftConsoleName + OpenShiftConsoleRouteName = OpenShiftConsoleName + OpenShiftConsoleDownloadsRouteName = "downloads" + OAuthClientName = OpenShiftConsoleName + OpenShiftConfigManagedNamespace = "openshift-config-managed" + OpenShiftConfigNamespace = "openshift-config" + OpenShiftCustomLogoConfigMapName = "custom-logo" + TrustedCAConfigMapName = "trusted-ca-bundle" + TrustedCABundleKey = "ca-bundle.crt" + TrustedCABundleMountDir = "/etc/pki/ca-trust/extracted/pem" + TrustedCABundleMountFile = "tls-ca-bundle.pem" + OCCLIDownloadsCustomResourceName = "oc-cli-downloads" + ODOCLIDownloadsCustomResourceName = "odo-cli-downloads" +)