This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/master by this push:
new f13873c chore(client): generate client interface for catalog
f13873c is described below
commit f13873c3b5914ac6d491228dd5694146f269ca25
Author: Nicola Ferraro <ni.ferr...@gmail.com>
AuthorDate: Fri May 29 17:31:41 2020 +0200
chore(client): generate client interface for catalog
---
pkg/apis/camel/v1/camelcatalog_types.go | 1 +
.../versioned/typed/camel/v1/camel_client.go | 5 +
.../versioned/typed/camel/v1/camelcatalog.go | 192 +++++++++++++++++++++
.../typed/camel/v1/fake/fake_camel_client.go | 4 +
.../typed/camel/v1/fake/fake_camelcatalog.go | 141 +++++++++++++++
.../typed/camel/v1/generated_expansion.go | 2 +
.../externalversions/camel/v1/camelcatalog.go | 90 ++++++++++
.../externalversions/camel/v1/interface.go | 7 +
.../camel/informers/externalversions/generic.go | 2 +
pkg/client/camel/listers/camel/v1/camelcatalog.go | 95 ++++++++++
.../camel/listers/camel/v1/expansion_generated.go | 8 +
11 files changed, 547 insertions(+)
diff --git a/pkg/apis/camel/v1/camelcatalog_types.go
b/pkg/apis/camel/v1/camelcatalog_types.go
index fb8db99..6bad16a 100644
--- a/pkg/apis/camel/v1/camelcatalog_types.go
+++ b/pkg/apis/camel/v1/camelcatalog_types.go
@@ -72,6 +72,7 @@ type CamelCatalogStatus struct {
// CamelCatalog is the Schema for the camelcatalogs API
// +k8s:openapi-gen=true
+// +genclient
type CamelCatalog struct {
metav1.TypeMeta `json:",inline" yaml:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" yaml:"metadata,omitempty"`
diff --git
a/pkg/client/camel/clientset/versioned/typed/camel/v1/camel_client.go
b/pkg/client/camel/clientset/versioned/typed/camel/v1/camel_client.go
index 095a5d4..8fd6f87 100644
--- a/pkg/client/camel/clientset/versioned/typed/camel/v1/camel_client.go
+++ b/pkg/client/camel/clientset/versioned/typed/camel/v1/camel_client.go
@@ -28,6 +28,7 @@ import (
type CamelV1Interface interface {
RESTClient() rest.Interface
BuildsGetter
+ CamelCatalogsGetter
IntegrationsGetter
IntegrationKitsGetter
IntegrationPlatformsGetter
@@ -42,6 +43,10 @@ func (c *CamelV1Client) Builds(namespace string)
BuildInterface {
return newBuilds(c, namespace)
}
+func (c *CamelV1Client) CamelCatalogs(namespace string) CamelCatalogInterface {
+ return newCamelCatalogs(c, namespace)
+}
+
func (c *CamelV1Client) Integrations(namespace string) IntegrationInterface {
return newIntegrations(c, namespace)
}
diff --git
a/pkg/client/camel/clientset/versioned/typed/camel/v1/camelcatalog.go
b/pkg/client/camel/clientset/versioned/typed/camel/v1/camelcatalog.go
new file mode 100644
index 0000000..566155a
--- /dev/null
+++ b/pkg/client/camel/clientset/versioned/typed/camel/v1/camelcatalog.go
@@ -0,0 +1,192 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You 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.
+*/
+
+// Code generated by client-gen. DO NOT EDIT.
+
+package v1
+
+import (
+ "time"
+
+ v1 "github.com/apache/camel-k/pkg/apis/camel/v1"
+ scheme
"github.com/apache/camel-k/pkg/client/camel/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"
+)
+
+// CamelCatalogsGetter has a method to return a CamelCatalogInterface.
+// A group's client should implement this interface.
+type CamelCatalogsGetter interface {
+ CamelCatalogs(namespace string) CamelCatalogInterface
+}
+
+// CamelCatalogInterface has methods to work with CamelCatalog resources.
+type CamelCatalogInterface interface {
+ Create(*v1.CamelCatalog) (*v1.CamelCatalog, error)
+ Update(*v1.CamelCatalog) (*v1.CamelCatalog, error)
+ UpdateStatus(*v1.CamelCatalog) (*v1.CamelCatalog, error)
+ Delete(name string, options *metav1.DeleteOptions) error
+ DeleteCollection(options *metav1.DeleteOptions, listOptions
metav1.ListOptions) error
+ Get(name string, options metav1.GetOptions) (*v1.CamelCatalog, error)
+ List(opts metav1.ListOptions) (*v1.CamelCatalogList, error)
+ Watch(opts metav1.ListOptions) (watch.Interface, error)
+ Patch(name string, pt types.PatchType, data []byte, subresources
...string) (result *v1.CamelCatalog, err error)
+ CamelCatalogExpansion
+}
+
+// camelCatalogs implements CamelCatalogInterface
+type camelCatalogs struct {
+ client rest.Interface
+ ns string
+}
+
+// newCamelCatalogs returns a CamelCatalogs
+func newCamelCatalogs(c *CamelV1Client, namespace string) *camelCatalogs {
+ return &camelCatalogs{
+ client: c.RESTClient(),
+ ns: namespace,
+ }
+}
+
+// Get takes name of the camelCatalog, and returns the corresponding
camelCatalog object, and an error if there is any.
+func (c *camelCatalogs) Get(name string, options metav1.GetOptions) (result
*v1.CamelCatalog, err error) {
+ result = &v1.CamelCatalog{}
+ err = c.client.Get().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ Name(name).
+ VersionedParams(&options, scheme.ParameterCodec).
+ Do().
+ Into(result)
+ return
+}
+
+// List takes label and field selectors, and returns the list of CamelCatalogs
that match those selectors.
+func (c *camelCatalogs) List(opts metav1.ListOptions) (result
*v1.CamelCatalogList, err error) {
+ var timeout time.Duration
+ if opts.TimeoutSeconds != nil {
+ timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
+ }
+ result = &v1.CamelCatalogList{}
+ err = c.client.Get().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ VersionedParams(&opts, scheme.ParameterCodec).
+ Timeout(timeout).
+ Do().
+ Into(result)
+ return
+}
+
+// Watch returns a watch.Interface that watches the requested camelCatalogs.
+func (c *camelCatalogs) 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("camelcatalogs").
+ VersionedParams(&opts, scheme.ParameterCodec).
+ Timeout(timeout).
+ Watch()
+}
+
+// Create takes the representation of a camelCatalog and creates it. Returns
the server's representation of the camelCatalog, and an error, if there is any.
+func (c *camelCatalogs) Create(camelCatalog *v1.CamelCatalog) (result
*v1.CamelCatalog, err error) {
+ result = &v1.CamelCatalog{}
+ err = c.client.Post().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ Body(camelCatalog).
+ Do().
+ Into(result)
+ return
+}
+
+// Update takes the representation of a camelCatalog and updates it. Returns
the server's representation of the camelCatalog, and an error, if there is any.
+func (c *camelCatalogs) Update(camelCatalog *v1.CamelCatalog) (result
*v1.CamelCatalog, err error) {
+ result = &v1.CamelCatalog{}
+ err = c.client.Put().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ Name(camelCatalog.Name).
+ Body(camelCatalog).
+ 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 *camelCatalogs) UpdateStatus(camelCatalog *v1.CamelCatalog) (result
*v1.CamelCatalog, err error) {
+ result = &v1.CamelCatalog{}
+ err = c.client.Put().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ Name(camelCatalog.Name).
+ SubResource("status").
+ Body(camelCatalog).
+ Do().
+ Into(result)
+ return
+}
+
+// Delete takes name of the camelCatalog and deletes it. Returns an error if
one occurs.
+func (c *camelCatalogs) Delete(name string, options *metav1.DeleteOptions)
error {
+ return c.client.Delete().
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ Name(name).
+ Body(options).
+ Do().
+ Error()
+}
+
+// DeleteCollection deletes a collection of objects.
+func (c *camelCatalogs) 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("camelcatalogs").
+ VersionedParams(&listOptions, scheme.ParameterCodec).
+ Timeout(timeout).
+ Body(options).
+ Do().
+ Error()
+}
+
+// Patch applies the patch and returns the patched camelCatalog.
+func (c *camelCatalogs) Patch(name string, pt types.PatchType, data []byte,
subresources ...string) (result *v1.CamelCatalog, err error) {
+ result = &v1.CamelCatalog{}
+ err = c.client.Patch(pt).
+ Namespace(c.ns).
+ Resource("camelcatalogs").
+ SubResource(subresources...).
+ Name(name).
+ Body(data).
+ Do().
+ Into(result)
+ return
+}
diff --git
a/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camel_client.go
b/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camel_client.go
index fc6e45f..1117ef2 100644
---
a/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camel_client.go
+++
b/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camel_client.go
@@ -33,6 +33,10 @@ func (c *FakeCamelV1) Builds(namespace string)
v1.BuildInterface {
return &FakeBuilds{c, namespace}
}
+func (c *FakeCamelV1) CamelCatalogs(namespace string) v1.CamelCatalogInterface
{
+ return &FakeCamelCatalogs{c, namespace}
+}
+
func (c *FakeCamelV1) Integrations(namespace string) v1.IntegrationInterface {
return &FakeIntegrations{c, namespace}
}
diff --git
a/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camelcatalog.go
b/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camelcatalog.go
new file mode 100644
index 0000000..1a30e41
--- /dev/null
+++
b/pkg/client/camel/clientset/versioned/typed/camel/v1/fake/fake_camelcatalog.go
@@ -0,0 +1,141 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You 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.
+*/
+
+// Code generated by client-gen. DO NOT EDIT.
+
+package fake
+
+import (
+ camelv1 "github.com/apache/camel-k/pkg/apis/camel/v1"
+ v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+ labels "k8s.io/apimachinery/pkg/labels"
+ schema "k8s.io/apimachinery/pkg/runtime/schema"
+ types "k8s.io/apimachinery/pkg/types"
+ watch "k8s.io/apimachinery/pkg/watch"
+ testing "k8s.io/client-go/testing"
+)
+
+// FakeCamelCatalogs implements CamelCatalogInterface
+type FakeCamelCatalogs struct {
+ Fake *FakeCamelV1
+ ns string
+}
+
+var camelcatalogsResource = schema.GroupVersionResource{Group:
"camel.apache.org", Version: "v1", Resource: "camelcatalogs"}
+
+var camelcatalogsKind = schema.GroupVersionKind{Group: "camel.apache.org",
Version: "v1", Kind: "CamelCatalog"}
+
+// Get takes name of the camelCatalog, and returns the corresponding
camelCatalog object, and an error if there is any.
+func (c *FakeCamelCatalogs) Get(name string, options v1.GetOptions) (result
*camelv1.CamelCatalog, err error) {
+ obj, err := c.Fake.
+ Invokes(testing.NewGetAction(camelcatalogsResource, c.ns,
name), &camelv1.CamelCatalog{})
+
+ if obj == nil {
+ return nil, err
+ }
+ return obj.(*camelv1.CamelCatalog), err
+}
+
+// List takes label and field selectors, and returns the list of CamelCatalogs
that match those selectors.
+func (c *FakeCamelCatalogs) List(opts v1.ListOptions) (result
*camelv1.CamelCatalogList, err error) {
+ obj, err := c.Fake.
+ Invokes(testing.NewListAction(camelcatalogsResource,
camelcatalogsKind, c.ns, opts), &camelv1.CamelCatalogList{})
+
+ if obj == nil {
+ return nil, err
+ }
+
+ label, _, _ := testing.ExtractFromListOptions(opts)
+ if label == nil {
+ label = labels.Everything()
+ }
+ list := &camelv1.CamelCatalogList{ListMeta:
obj.(*camelv1.CamelCatalogList).ListMeta}
+ for _, item := range obj.(*camelv1.CamelCatalogList).Items {
+ if label.Matches(labels.Set(item.Labels)) {
+ list.Items = append(list.Items, item)
+ }
+ }
+ return list, err
+}
+
+// Watch returns a watch.Interface that watches the requested camelCatalogs.
+func (c *FakeCamelCatalogs) Watch(opts v1.ListOptions) (watch.Interface,
error) {
+ return c.Fake.
+ InvokesWatch(testing.NewWatchAction(camelcatalogsResource,
c.ns, opts))
+
+}
+
+// Create takes the representation of a camelCatalog and creates it. Returns
the server's representation of the camelCatalog, and an error, if there is any.
+func (c *FakeCamelCatalogs) Create(camelCatalog *camelv1.CamelCatalog) (result
*camelv1.CamelCatalog, err error) {
+ obj, err := c.Fake.
+ Invokes(testing.NewCreateAction(camelcatalogsResource, c.ns,
camelCatalog), &camelv1.CamelCatalog{})
+
+ if obj == nil {
+ return nil, err
+ }
+ return obj.(*camelv1.CamelCatalog), err
+}
+
+// Update takes the representation of a camelCatalog and updates it. Returns
the server's representation of the camelCatalog, and an error, if there is any.
+func (c *FakeCamelCatalogs) Update(camelCatalog *camelv1.CamelCatalog) (result
*camelv1.CamelCatalog, err error) {
+ obj, err := c.Fake.
+ Invokes(testing.NewUpdateAction(camelcatalogsResource, c.ns,
camelCatalog), &camelv1.CamelCatalog{})
+
+ if obj == nil {
+ return nil, err
+ }
+ return obj.(*camelv1.CamelCatalog), err
+}
+
+// UpdateStatus was generated because the type contains a Status member.
+// Add a +genclient:noStatus comment above the type to avoid generating
UpdateStatus().
+func (c *FakeCamelCatalogs) UpdateStatus(camelCatalog *camelv1.CamelCatalog)
(*camelv1.CamelCatalog, error) {
+ obj, err := c.Fake.
+
Invokes(testing.NewUpdateSubresourceAction(camelcatalogsResource, "status",
c.ns, camelCatalog), &camelv1.CamelCatalog{})
+
+ if obj == nil {
+ return nil, err
+ }
+ return obj.(*camelv1.CamelCatalog), err
+}
+
+// Delete takes name of the camelCatalog and deletes it. Returns an error if
one occurs.
+func (c *FakeCamelCatalogs) Delete(name string, options *v1.DeleteOptions)
error {
+ _, err := c.Fake.
+ Invokes(testing.NewDeleteAction(camelcatalogsResource, c.ns,
name), &camelv1.CamelCatalog{})
+
+ return err
+}
+
+// DeleteCollection deletes a collection of objects.
+func (c *FakeCamelCatalogs) DeleteCollection(options *v1.DeleteOptions,
listOptions v1.ListOptions) error {
+ action := testing.NewDeleteCollectionAction(camelcatalogsResource,
c.ns, listOptions)
+
+ _, err := c.Fake.Invokes(action, &camelv1.CamelCatalogList{})
+ return err
+}
+
+// Patch applies the patch and returns the patched camelCatalog.
+func (c *FakeCamelCatalogs) Patch(name string, pt types.PatchType, data
[]byte, subresources ...string) (result *camelv1.CamelCatalog, err error) {
+ obj, err := c.Fake.
+
Invokes(testing.NewPatchSubresourceAction(camelcatalogsResource, c.ns, name,
pt, data, subresources...), &camelv1.CamelCatalog{})
+
+ if obj == nil {
+ return nil, err
+ }
+ return obj.(*camelv1.CamelCatalog), err
+}
diff --git
a/pkg/client/camel/clientset/versioned/typed/camel/v1/generated_expansion.go
b/pkg/client/camel/clientset/versioned/typed/camel/v1/generated_expansion.go
index d4a0d7a..41a8b54 100644
--- a/pkg/client/camel/clientset/versioned/typed/camel/v1/generated_expansion.go
+++ b/pkg/client/camel/clientset/versioned/typed/camel/v1/generated_expansion.go
@@ -21,6 +21,8 @@ package v1
type BuildExpansion interface{}
+type CamelCatalogExpansion interface{}
+
type IntegrationExpansion interface{}
type IntegrationKitExpansion interface{}
diff --git
a/pkg/client/camel/informers/externalversions/camel/v1/camelcatalog.go
b/pkg/client/camel/informers/externalversions/camel/v1/camelcatalog.go
new file mode 100644
index 0000000..6c9faaf
--- /dev/null
+++ b/pkg/client/camel/informers/externalversions/camel/v1/camelcatalog.go
@@ -0,0 +1,90 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You 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.
+*/
+
+// Code generated by informer-gen. DO NOT EDIT.
+
+package v1
+
+import (
+ time "time"
+
+ camelv1 "github.com/apache/camel-k/pkg/apis/camel/v1"
+ versioned
"github.com/apache/camel-k/pkg/client/camel/clientset/versioned"
+ internalinterfaces
"github.com/apache/camel-k/pkg/client/camel/informers/externalversions/internalinterfaces"
+ v1 "github.com/apache/camel-k/pkg/client/camel/listers/camel/v1"
+ metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+ runtime "k8s.io/apimachinery/pkg/runtime"
+ watch "k8s.io/apimachinery/pkg/watch"
+ cache "k8s.io/client-go/tools/cache"
+)
+
+// CamelCatalogInformer provides access to a shared informer and lister for
+// CamelCatalogs.
+type CamelCatalogInformer interface {
+ Informer() cache.SharedIndexInformer
+ Lister() v1.CamelCatalogLister
+}
+
+type camelCatalogInformer struct {
+ factory internalinterfaces.SharedInformerFactory
+ tweakListOptions internalinterfaces.TweakListOptionsFunc
+ namespace string
+}
+
+// NewCamelCatalogInformer constructs a new informer for CamelCatalog type.
+// Always prefer using an informer factory to get a shared informer instead of
getting an independent
+// one. This reduces memory footprint and number of connections to the server.
+func NewCamelCatalogInformer(client versioned.Interface, namespace string,
resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
+ return NewFilteredCamelCatalogInformer(client, namespace, resyncPeriod,
indexers, nil)
+}
+
+// NewFilteredCamelCatalogInformer constructs a new informer for CamelCatalog
type.
+// Always prefer using an informer factory to get a shared informer instead of
getting an independent
+// one. This reduces memory footprint and number of connections to the server.
+func NewFilteredCamelCatalogInformer(client versioned.Interface, namespace
string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions
internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
+ return cache.NewSharedIndexInformer(
+ &cache.ListWatch{
+ ListFunc: func(options metav1.ListOptions)
(runtime.Object, error) {
+ if tweakListOptions != nil {
+ tweakListOptions(&options)
+ }
+ return
client.CamelV1().CamelCatalogs(namespace).List(options)
+ },
+ WatchFunc: func(options metav1.ListOptions)
(watch.Interface, error) {
+ if tweakListOptions != nil {
+ tweakListOptions(&options)
+ }
+ return
client.CamelV1().CamelCatalogs(namespace).Watch(options)
+ },
+ },
+ &camelv1.CamelCatalog{},
+ resyncPeriod,
+ indexers,
+ )
+}
+
+func (f *camelCatalogInformer) defaultInformer(client versioned.Interface,
resyncPeriod time.Duration) cache.SharedIndexInformer {
+ return NewFilteredCamelCatalogInformer(client, f.namespace,
resyncPeriod, cache.Indexers{cache.NamespaceIndex:
cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
+}
+
+func (f *camelCatalogInformer) Informer() cache.SharedIndexInformer {
+ return f.factory.InformerFor(&camelv1.CamelCatalog{}, f.defaultInformer)
+}
+
+func (f *camelCatalogInformer) Lister() v1.CamelCatalogLister {
+ return v1.NewCamelCatalogLister(f.Informer().GetIndexer())
+}
diff --git a/pkg/client/camel/informers/externalversions/camel/v1/interface.go
b/pkg/client/camel/informers/externalversions/camel/v1/interface.go
index 8f59ff7..144db8e 100644
--- a/pkg/client/camel/informers/externalversions/camel/v1/interface.go
+++ b/pkg/client/camel/informers/externalversions/camel/v1/interface.go
@@ -27,6 +27,8 @@ import (
type Interface interface {
// Builds returns a BuildInformer.
Builds() BuildInformer
+ // CamelCatalogs returns a CamelCatalogInformer.
+ CamelCatalogs() CamelCatalogInformer
// Integrations returns a IntegrationInformer.
Integrations() IntegrationInformer
// IntegrationKits returns a IntegrationKitInformer.
@@ -51,6 +53,11 @@ func (v *version) Builds() BuildInformer {
return &buildInformer{factory: v.factory, namespace: v.namespace,
tweakListOptions: v.tweakListOptions}
}
+// CamelCatalogs returns a CamelCatalogInformer.
+func (v *version) CamelCatalogs() CamelCatalogInformer {
+ return &camelCatalogInformer{factory: v.factory, namespace:
v.namespace, tweakListOptions: v.tweakListOptions}
+}
+
// Integrations returns a IntegrationInformer.
func (v *version) Integrations() IntegrationInformer {
return &integrationInformer{factory: v.factory, namespace: v.namespace,
tweakListOptions: v.tweakListOptions}
diff --git a/pkg/client/camel/informers/externalversions/generic.go
b/pkg/client/camel/informers/externalversions/generic.go
index 2def9d1..2e00c8d 100644
--- a/pkg/client/camel/informers/externalversions/generic.go
+++ b/pkg/client/camel/informers/externalversions/generic.go
@@ -56,6 +56,8 @@ func (f *sharedInformerFactory) ForResource(resource
schema.GroupVersionResource
// Group=camel.apache.org, Version=v1
case v1.SchemeGroupVersion.WithResource("builds"):
return &genericInformer{resource: resource.GroupResource(),
informer: f.Camel().V1().Builds().Informer()}, nil
+ case v1.SchemeGroupVersion.WithResource("camelcatalogs"):
+ return &genericInformer{resource: resource.GroupResource(),
informer: f.Camel().V1().CamelCatalogs().Informer()}, nil
case v1.SchemeGroupVersion.WithResource("integrations"):
return &genericInformer{resource: resource.GroupResource(),
informer: f.Camel().V1().Integrations().Informer()}, nil
case v1.SchemeGroupVersion.WithResource("integrationkits"):
diff --git a/pkg/client/camel/listers/camel/v1/camelcatalog.go
b/pkg/client/camel/listers/camel/v1/camelcatalog.go
new file mode 100644
index 0000000..a3d2ae8
--- /dev/null
+++ b/pkg/client/camel/listers/camel/v1/camelcatalog.go
@@ -0,0 +1,95 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You 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.
+*/
+
+// Code generated by lister-gen. DO NOT EDIT.
+
+package v1
+
+import (
+ v1 "github.com/apache/camel-k/pkg/apis/camel/v1"
+ "k8s.io/apimachinery/pkg/api/errors"
+ "k8s.io/apimachinery/pkg/labels"
+ "k8s.io/client-go/tools/cache"
+)
+
+// CamelCatalogLister helps list CamelCatalogs.
+type CamelCatalogLister interface {
+ // List lists all CamelCatalogs in the indexer.
+ List(selector labels.Selector) (ret []*v1.CamelCatalog, err error)
+ // CamelCatalogs returns an object that can list and get CamelCatalogs.
+ CamelCatalogs(namespace string) CamelCatalogNamespaceLister
+ CamelCatalogListerExpansion
+}
+
+// camelCatalogLister implements the CamelCatalogLister interface.
+type camelCatalogLister struct {
+ indexer cache.Indexer
+}
+
+// NewCamelCatalogLister returns a new CamelCatalogLister.
+func NewCamelCatalogLister(indexer cache.Indexer) CamelCatalogLister {
+ return &camelCatalogLister{indexer: indexer}
+}
+
+// List lists all CamelCatalogs in the indexer.
+func (s *camelCatalogLister) List(selector labels.Selector) (ret
[]*v1.CamelCatalog, err error) {
+ err = cache.ListAll(s.indexer, selector, func(m interface{}) {
+ ret = append(ret, m.(*v1.CamelCatalog))
+ })
+ return ret, err
+}
+
+// CamelCatalogs returns an object that can list and get CamelCatalogs.
+func (s *camelCatalogLister) CamelCatalogs(namespace string)
CamelCatalogNamespaceLister {
+ return camelCatalogNamespaceLister{indexer: s.indexer, namespace:
namespace}
+}
+
+// CamelCatalogNamespaceLister helps list and get CamelCatalogs.
+type CamelCatalogNamespaceLister interface {
+ // List lists all CamelCatalogs in the indexer for a given namespace.
+ List(selector labels.Selector) (ret []*v1.CamelCatalog, err error)
+ // Get retrieves the CamelCatalog from the indexer for a given
namespace and name.
+ Get(name string) (*v1.CamelCatalog, error)
+ CamelCatalogNamespaceListerExpansion
+}
+
+// camelCatalogNamespaceLister implements the CamelCatalogNamespaceLister
+// interface.
+type camelCatalogNamespaceLister struct {
+ indexer cache.Indexer
+ namespace string
+}
+
+// List lists all CamelCatalogs in the indexer for a given namespace.
+func (s camelCatalogNamespaceLister) List(selector labels.Selector) (ret
[]*v1.CamelCatalog, err error) {
+ err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m
interface{}) {
+ ret = append(ret, m.(*v1.CamelCatalog))
+ })
+ return ret, err
+}
+
+// Get retrieves the CamelCatalog from the indexer for a given namespace and
name.
+func (s camelCatalogNamespaceLister) Get(name string) (*v1.CamelCatalog,
error) {
+ obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
+ if err != nil {
+ return nil, err
+ }
+ if !exists {
+ return nil, errors.NewNotFound(v1.Resource("camelcatalog"),
name)
+ }
+ return obj.(*v1.CamelCatalog), nil
+}
diff --git a/pkg/client/camel/listers/camel/v1/expansion_generated.go
b/pkg/client/camel/listers/camel/v1/expansion_generated.go
index 10cc476..3595705 100644
--- a/pkg/client/camel/listers/camel/v1/expansion_generated.go
+++ b/pkg/client/camel/listers/camel/v1/expansion_generated.go
@@ -27,6 +27,14 @@ type BuildListerExpansion interface{}
// BuildNamespaceLister.
type BuildNamespaceListerExpansion interface{}
+// CamelCatalogListerExpansion allows custom methods to be added to
+// CamelCatalogLister.
+type CamelCatalogListerExpansion interface{}
+
+// CamelCatalogNamespaceListerExpansion allows custom methods to be added to
+// CamelCatalogNamespaceLister.
+type CamelCatalogNamespaceListerExpansion interface{}
+
// IntegrationListerExpansion allows custom methods to be added to
// IntegrationLister.
type IntegrationListerExpansion interface{}
