This is an automated email from the ASF dual-hosted git repository. squakez pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 1c118def21f8339906ef14180e2a795730c46107 Author: Keerthan <[email protected]> AuthorDate: Thu Sep 24 20:49:28 2026 +0530 Fix #5935: Restore ArkMQ clientset generation in script/gen_client.sh --- .../arkmq/clientset/internalclientset/clientset.go | 121 +++++++++++++++++++++ .../internalclientset/fake/clientset_generated.go | 102 +++++++++++++++++ .../arkmq/clientset/internalclientset/fake/doc.go | 21 ++++ .../clientset/internalclientset/fake/register.go | 57 ++++++++++ .../clientset/internalclientset/scheme/doc.go | 21 ++++ .../clientset/internalclientset/scheme/register.go | 57 ++++++++++ .../typed/arkmq/v1beta1/activemqartemis.go | 63 +++++++++++ .../typed/arkmq/v1beta1/activemqartemisaddress.go | 63 +++++++++++ .../typed/arkmq/v1beta1/arkmq_client.go | 107 ++++++++++++++++++ .../internalclientset/typed/arkmq/v1beta1/doc.go | 21 ++++ .../typed/arkmq/v1beta1/fake/doc.go | 21 ++++ .../arkmq/v1beta1/fake/fake_activemqartemis.go | 53 +++++++++ .../v1beta1/fake/fake_activemqartemisaddress.go | 53 +++++++++ .../typed/arkmq/v1beta1/fake/fake_arkmq_client.go | 45 ++++++++ .../typed/arkmq/v1beta1/generated_expansion.go | 24 ++++ script/gen_client.sh | 9 ++ 16 files changed, 838 insertions(+) diff --git a/pkg/client/arkmq/clientset/internalclientset/clientset.go b/pkg/client/arkmq/clientset/internalclientset/clientset.go new file mode 100644 index 000000000..6bfbf6fed --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/clientset.go @@ -0,0 +1,121 @@ +/* +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 internalclientset + +import ( + fmt "fmt" + http "net/http" + + brokerv1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1" + discovery "k8s.io/client-go/discovery" + rest "k8s.io/client-go/rest" + flowcontrol "k8s.io/client-go/util/flowcontrol" +) + +type Interface interface { + Discovery() discovery.DiscoveryInterfaces + BrokerV1beta1() brokerv1beta1.BrokerV1beta1Interface +} + +// Clientset contains the clients for groups. +type Clientset struct { + *discovery.DiscoveryClient + brokerV1beta1 *brokerv1beta1.BrokerV1beta1Client +} + +// BrokerV1beta1 retrieves the BrokerV1beta1Client +func (c *Clientset) BrokerV1beta1() brokerv1beta1.BrokerV1beta1Interface { + return c.brokerV1beta1 +} + +// Discovery retrieves the DiscoveryClient +func (c *Clientset) Discovery() discovery.DiscoveryInterfaces { + 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. +// NewForConfig is equivalent to NewForConfigAndClient(c, httpClient), +// where httpClient was generated with rest.HTTPClientFor(c). +func NewForConfig(c *rest.Config) (*Clientset, error) { + configShallowCopy := *c + + if configShallowCopy.UserAgent == "" { + configShallowCopy.UserAgent = rest.DefaultKubernetesUserAgent() + } + + // share the transport between all clients + httpClient, err := rest.HTTPClientFor(&configShallowCopy) + if err != nil { + return nil, err + } + + return NewForConfigAndClient(&configShallowCopy, httpClient) +} + +// NewForConfigAndClient creates a new Clientset for the given config and http client. +// Note the http client provided takes precedence over the configured transport values. +// If config's RateLimiter is not set and QPS and Burst are acceptable, +// NewForConfigAndClient will generate a rate-limiter in configShallowCopy. +func NewForConfigAndClient(c *rest.Config, httpClient *http.Client) (*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.brokerV1beta1, err = brokerv1beta1.NewForConfigAndClient(&configShallowCopy, httpClient) + if err != nil { + return nil, err + } + + cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfigAndClient(&configShallowCopy, httpClient) + 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 { + cs, err := NewForConfig(c) + if err != nil { + panic(err) + } + return cs +} + +// New creates a new Clientset for the given RESTClient. +func New(c rest.Interface) *Clientset { + var cs Clientset + cs.brokerV1beta1 = brokerv1beta1.New(c) + + cs.DiscoveryClient = discovery.NewDiscoveryClient(c) + return &cs +} diff --git a/pkg/client/arkmq/clientset/internalclientset/fake/clientset_generated.go b/pkg/client/arkmq/clientset/internalclientset/fake/clientset_generated.go new file mode 100644 index 000000000..2406b49b0 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/fake/clientset_generated.go @@ -0,0 +1,102 @@ +/* +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 ( + clientset "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset" + brokerv1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1" + fakebrokerv1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "k8s.io/apimachinery/pkg/runtime" + "k8s.io/apimachinery/pkg/watch" + "k8s.io/client-go/discovery" + fakediscovery "k8s.io/client-go/discovery/fake" + "k8s.io/client-go/testing" +) + +// NewSimpleClientset returns a clientset that will respond with the provided objects. +// It's backed by a very simple object tracker that processes creates, updates and deletions as-is, +// without applying any field management, validations and/or defaults. It shouldn't be considered a replacement +// for a real clientset and is mostly useful in simple unit tests. +func NewSimpleClientset(objects ...runtime.Object) *Clientset { + o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) + for _, obj := range objects { + if err := o.Add(obj); err != nil { + panic(err) + } + } + + cs := &Clientset{tracker: o} + cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake} + cs.AddReactor("*", "*", testing.ObjectReaction(o)) + cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { + var opts metav1.ListOptions + if watchAction, ok := action.(testing.WatchActionImpl); ok { + opts = watchAction.ListOptions + } + gvr := action.GetResource() + ns := action.GetNamespace() + watch, err := o.Watch(gvr, ns, opts) + if err != nil { + return false, nil, err + } + return true, watch, nil + }) + + return cs +} + +// Clientset implements clientset.Interface. Meant to be embedded into a +// struct to get a default implementation. This makes faking out just the method +// you want to test easier. +type Clientset struct { + testing.Fake + discovery *fakediscovery.FakeDiscovery + tracker testing.ObjectTracker +} + +func (c *Clientset) Discovery() discovery.DiscoveryInterfaces { + return c.discovery +} + +func (c *Clientset) Tracker() testing.ObjectTracker { + return c.tracker +} + +// IsWatchListSemanticsUnSupported informs the reflector that this client +// doesn't support WatchList semantics. +// +// This is a synthetic method whose sole purpose is to satisfy the optional +// interface check performed by the reflector. +// Returning true signals that WatchList can NOT be used. +// No additional logic is implemented here. +func (c *Clientset) IsWatchListSemanticsUnSupported() bool { + return true +} + +var ( + _ clientset.Interface = &Clientset{} + _ testing.FakeClient = &Clientset{} +) + +// BrokerV1beta1 retrieves the BrokerV1beta1Client +func (c *Clientset) BrokerV1beta1() brokerv1beta1.BrokerV1beta1Interface { + return &fakebrokerv1beta1.FakeBrokerV1beta1{Fake: &c.Fake} +} diff --git a/pkg/client/arkmq/clientset/internalclientset/fake/doc.go b/pkg/client/arkmq/clientset/internalclientset/fake/doc.go new file mode 100644 index 000000000..9c6a5fa07 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/fake/doc.go @@ -0,0 +1,21 @@ +/* +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. + +// This package has the automatically generated fake clientset. +package fake diff --git a/pkg/client/arkmq/clientset/internalclientset/fake/register.go b/pkg/client/arkmq/clientset/internalclientset/fake/register.go new file mode 100644 index 000000000..6626d0c24 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/fake/register.go @@ -0,0 +1,57 @@ +/* +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 ( + brokerv1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + 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 localSchemeBuilder = runtime.SchemeBuilder{ + brokerv1beta1.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/pkg/client/arkmq/clientset/internalclientset/scheme/doc.go b/pkg/client/arkmq/clientset/internalclientset/scheme/doc.go new file mode 100644 index 000000000..dd7d3b588 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/scheme/doc.go @@ -0,0 +1,21 @@ +/* +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. + +// This package contains the scheme of the automatically generated clientset. +package scheme diff --git a/pkg/client/arkmq/clientset/internalclientset/scheme/register.go b/pkg/client/arkmq/clientset/internalclientset/scheme/register.go new file mode 100644 index 000000000..4d0cfde87 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/scheme/register.go @@ -0,0 +1,57 @@ +/* +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 scheme + +import ( + brokerv1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + 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{ + brokerv1beta1.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/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemis.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemis.go new file mode 100644 index 000000000..b4c09a538 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemis.go @@ -0,0 +1,63 @@ +/* +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 v1beta1 + +import ( + context "context" + + arkmqv1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + scheme "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/scheme" + v1 "k8s.io/apimachinery/pkg/apis/meta/v1" + watch "k8s.io/apimachinery/pkg/watch" + gentype "k8s.io/client-go/gentype" +) + +// ActiveMQArtemisesGetter has a method to return a ActiveMQArtemisInterface. +// A group's client should implement this interface. +type ActiveMQArtemisesGetter interface { + ActiveMQArtemises(namespace string) ActiveMQArtemisInterface +} + +// ActiveMQArtemisInterface has methods to work with ActiveMQArtemis resources. +type ActiveMQArtemisInterface interface { + Get(ctx context.Context, name string, opts v1.GetOptions) (*arkmqv1beta1.ActiveMQArtemis, error) + List(ctx context.Context, opts v1.ListOptions) (*arkmqv1beta1.ActiveMQArtemisList, error) + Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) + ActiveMQArtemisExpansion +} + +// activeMQArtemises implements ActiveMQArtemisInterface +type activeMQArtemises struct { + *gentype.ClientWithList[*arkmqv1beta1.ActiveMQArtemis, *arkmqv1beta1.ActiveMQArtemisList] +} + +// newActiveMQArtemises returns a ActiveMQArtemises +func newActiveMQArtemises(c *BrokerV1beta1Client, namespace string) *activeMQArtemises { + return &activeMQArtemises{ + gentype.NewClientWithList[*arkmqv1beta1.ActiveMQArtemis, *arkmqv1beta1.ActiveMQArtemisList]( + "activemqartemises", + c.RESTClient(), + scheme.ParameterCodec, + namespace, + func() *arkmqv1beta1.ActiveMQArtemis { return &arkmqv1beta1.ActiveMQArtemis{} }, + func() *arkmqv1beta1.ActiveMQArtemisList { return &arkmqv1beta1.ActiveMQArtemisList{} }, + ), + } +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemisaddress.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemisaddress.go new file mode 100644 index 000000000..f8d753cac --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemisaddress.go @@ -0,0 +1,63 @@ +/* +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 v1beta1 + +import ( + context "context" + + arkmqv1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + scheme "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/scheme" + v1 "k8s.io/apimachinery/pkg/apis/meta/v1" + watch "k8s.io/apimachinery/pkg/watch" + gentype "k8s.io/client-go/gentype" +) + +// ActiveMQArtemisAddressesGetter has a method to return a ActiveMQArtemisAddressInterface. +// A group's client should implement this interface. +type ActiveMQArtemisAddressesGetter interface { + ActiveMQArtemisAddresses(namespace string) ActiveMQArtemisAddressInterface +} + +// ActiveMQArtemisAddressInterface has methods to work with ActiveMQArtemisAddress resources. +type ActiveMQArtemisAddressInterface interface { + Get(ctx context.Context, name string, opts v1.GetOptions) (*arkmqv1beta1.ActiveMQArtemisAddress, error) + List(ctx context.Context, opts v1.ListOptions) (*arkmqv1beta1.ActiveMQArtemisAddressList, error) + Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) + ActiveMQArtemisAddressExpansion +} + +// activeMQArtemisAddresses implements ActiveMQArtemisAddressInterface +type activeMQArtemisAddresses struct { + *gentype.ClientWithList[*arkmqv1beta1.ActiveMQArtemisAddress, *arkmqv1beta1.ActiveMQArtemisAddressList] +} + +// newActiveMQArtemisAddresses returns a ActiveMQArtemisAddresses +func newActiveMQArtemisAddresses(c *BrokerV1beta1Client, namespace string) *activeMQArtemisAddresses { + return &activeMQArtemisAddresses{ + gentype.NewClientWithList[*arkmqv1beta1.ActiveMQArtemisAddress, *arkmqv1beta1.ActiveMQArtemisAddressList]( + "activemqartemisaddresses", + c.RESTClient(), + scheme.ParameterCodec, + namespace, + func() *arkmqv1beta1.ActiveMQArtemisAddress { return &arkmqv1beta1.ActiveMQArtemisAddress{} }, + func() *arkmqv1beta1.ActiveMQArtemisAddressList { return &arkmqv1beta1.ActiveMQArtemisAddressList{} }, + ), + } +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/arkmq_client.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/arkmq_client.go new file mode 100644 index 000000000..881d6e2cf --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/arkmq_client.go @@ -0,0 +1,107 @@ +/* +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 v1beta1 + +import ( + http "net/http" + + arkmqv1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + scheme "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/scheme" + rest "k8s.io/client-go/rest" +) + +type BrokerV1beta1Interface interface { + RESTClient() rest.Interface + ActiveMQArtemisesGetter + ActiveMQArtemisAddressesGetter +} + +// BrokerV1beta1Client is used to interact with features provided by the broker.amq.io group. +type BrokerV1beta1Client struct { + restClient rest.Interface +} + +func (c *BrokerV1beta1Client) ActiveMQArtemises(namespace string) ActiveMQArtemisInterface { + return newActiveMQArtemises(c, namespace) +} + +func (c *BrokerV1beta1Client) ActiveMQArtemisAddresses(namespace string) ActiveMQArtemisAddressInterface { + return newActiveMQArtemisAddresses(c, namespace) +} + +// NewForConfig creates a new BrokerV1beta1Client for the given config. +// NewForConfig is equivalent to NewForConfigAndClient(c, httpClient), +// where httpClient was generated with rest.HTTPClientFor(c). +func NewForConfig(c *rest.Config) (*BrokerV1beta1Client, error) { + config := *c + setConfigDefaults(&config) + httpClient, err := rest.HTTPClientFor(&config) + if err != nil { + return nil, err + } + return NewForConfigAndClient(&config, httpClient) +} + +// NewForConfigAndClient creates a new BrokerV1beta1Client for the given config and http client. +// Note the http client provided takes precedence over the configured transport values. +func NewForConfigAndClient(c *rest.Config, h *http.Client) (*BrokerV1beta1Client, error) { + config := *c + setConfigDefaults(&config) + client, err := rest.RESTClientForConfigAndClient(&config, h) + if err != nil { + return nil, err + } + return &BrokerV1beta1Client{client}, nil +} + +// NewForConfigOrDie creates a new BrokerV1beta1Client for the given config and +// panics if there is an error in the config. +func NewForConfigOrDie(c *rest.Config) *BrokerV1beta1Client { + client, err := NewForConfig(c) + if err != nil { + panic(err) + } + return client +} + +// New creates a new BrokerV1beta1Client for the given RESTClient. +func New(c rest.Interface) *BrokerV1beta1Client { + return &BrokerV1beta1Client{c} +} + +func setConfigDefaults(config *rest.Config) { + gv := arkmqv1beta1.SchemeGroupVersion + config.GroupVersion = &gv + config.APIPath = "/apis" + config.NegotiatedSerializer = rest.CodecFactoryForGeneratedClient(scheme.Scheme, scheme.Codecs).WithoutConversion() + + if config.UserAgent == "" { + config.UserAgent = rest.DefaultKubernetesUserAgent() + } +} + +// RESTClient returns a RESTClient that is used to communicate +// with API server by this client implementation. +func (c *BrokerV1beta1Client) RESTClient() rest.Interface { + if c == nil { + return nil + } + return c.restClient +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/doc.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/doc.go new file mode 100644 index 000000000..69b5e249c --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/doc.go @@ -0,0 +1,21 @@ +/* +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. + +// This package has the automatically generated typed clients. +package v1beta1 diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/doc.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/doc.go new file mode 100644 index 000000000..5d1c76cc9 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/doc.go @@ -0,0 +1,21 @@ +/* +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 has the automatically generated clients. +package fake diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemis.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemis.go new file mode 100644 index 000000000..5c4620f05 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemis.go @@ -0,0 +1,53 @@ +/* +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 ( + v1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + arkmqv1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1" + gentype "k8s.io/client-go/gentype" +) + +// fakeActiveMQArtemises implements ActiveMQArtemisInterface +type fakeActiveMQArtemises struct { + *gentype.FakeClientWithList[*v1beta1.ActiveMQArtemis, *v1beta1.ActiveMQArtemisList] + Fake *FakeBrokerV1beta1 +} + +func newFakeActiveMQArtemises(fake *FakeBrokerV1beta1, namespace string) arkmqv1beta1.ActiveMQArtemisInterface { + return &fakeActiveMQArtemises{ + gentype.NewFakeClientWithList[*v1beta1.ActiveMQArtemis, *v1beta1.ActiveMQArtemisList]( + fake.Fake, + namespace, + v1beta1.SchemeGroupVersion.WithResource("activemqartemises"), + v1beta1.SchemeGroupVersion.WithKind("ActiveMQArtemis"), + func() *v1beta1.ActiveMQArtemis { return &v1beta1.ActiveMQArtemis{} }, + func() *v1beta1.ActiveMQArtemisList { return &v1beta1.ActiveMQArtemisList{} }, + func(dst, src *v1beta1.ActiveMQArtemisList) { dst.ListMeta = src.ListMeta }, + func(list *v1beta1.ActiveMQArtemisList) []*v1beta1.ActiveMQArtemis { + return gentype.ToPointerSlice(list.Items) + }, + func(list *v1beta1.ActiveMQArtemisList, items []*v1beta1.ActiveMQArtemis) { + list.Items = gentype.FromPointerSlice(items) + }, + ), + fake, + } +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemisaddress.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemisaddress.go new file mode 100644 index 000000000..2f6681b77 --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemisaddress.go @@ -0,0 +1,53 @@ +/* +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 ( + v1beta1 "github.com/apache/camel-k/v2/pkg/apis/duck/arkmq/v1beta1" + arkmqv1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1" + gentype "k8s.io/client-go/gentype" +) + +// fakeActiveMQArtemisAddresses implements ActiveMQArtemisAddressInterface +type fakeActiveMQArtemisAddresses struct { + *gentype.FakeClientWithList[*v1beta1.ActiveMQArtemisAddress, *v1beta1.ActiveMQArtemisAddressList] + Fake *FakeBrokerV1beta1 +} + +func newFakeActiveMQArtemisAddresses(fake *FakeBrokerV1beta1, namespace string) arkmqv1beta1.ActiveMQArtemisAddressInterface { + return &fakeActiveMQArtemisAddresses{ + gentype.NewFakeClientWithList[*v1beta1.ActiveMQArtemisAddress, *v1beta1.ActiveMQArtemisAddressList]( + fake.Fake, + namespace, + v1beta1.SchemeGroupVersion.WithResource("activemqartemisaddresses"), + v1beta1.SchemeGroupVersion.WithKind("ActiveMQArtemisAddress"), + func() *v1beta1.ActiveMQArtemisAddress { return &v1beta1.ActiveMQArtemisAddress{} }, + func() *v1beta1.ActiveMQArtemisAddressList { return &v1beta1.ActiveMQArtemisAddressList{} }, + func(dst, src *v1beta1.ActiveMQArtemisAddressList) { dst.ListMeta = src.ListMeta }, + func(list *v1beta1.ActiveMQArtemisAddressList) []*v1beta1.ActiveMQArtemisAddress { + return gentype.ToPointerSlice(list.Items) + }, + func(list *v1beta1.ActiveMQArtemisAddressList, items []*v1beta1.ActiveMQArtemisAddress) { + list.Items = gentype.FromPointerSlice(items) + }, + ), + fake, + } +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_arkmq_client.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_arkmq_client.go new file mode 100644 index 000000000..be83e82fc --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_arkmq_client.go @@ -0,0 +1,45 @@ +/* +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 ( + v1beta1 "github.com/apache/camel-k/v2/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1" + rest "k8s.io/client-go/rest" + testing "k8s.io/client-go/testing" +) + +type FakeBrokerV1beta1 struct { + *testing.Fake +} + +func (c *FakeBrokerV1beta1) ActiveMQArtemises(namespace string) v1beta1.ActiveMQArtemisInterface { + return newFakeActiveMQArtemises(c, namespace) +} + +func (c *FakeBrokerV1beta1) ActiveMQArtemisAddresses(namespace string) v1beta1.ActiveMQArtemisAddressInterface { + return newFakeActiveMQArtemisAddresses(c, namespace) +} + +// RESTClient returns a RESTClient that is used to communicate +// with API server by this client implementation. +func (c *FakeBrokerV1beta1) RESTClient() rest.Interface { + var ret *rest.RESTClient + return ret +} diff --git a/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/generated_expansion.go b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/generated_expansion.go new file mode 100644 index 000000000..50d18cb0c --- /dev/null +++ b/pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/generated_expansion.go @@ -0,0 +1,24 @@ +/* +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 v1beta1 + +type ActiveMQArtemisExpansion interface{} + +type ActiveMQArtemisAddressExpansion interface{} diff --git a/script/gen_client.sh b/script/gen_client.sh index eee5768fe..cb9a3ffb0 100755 --- a/script/gen_client.sh +++ b/script/gen_client.sh @@ -25,6 +25,7 @@ cd $location/../pkg/client rm -rf camel rm -rf strimzi rm -rf keda +rm -rf arkmq echo "Generating Go client code..." @@ -58,6 +59,14 @@ $(go env GOPATH)/bin/client-gen \ --output-dir=./keda/clientset/ \ --output-pkg=github.com/apache/camel-k/v2/pkg/client/keda/clientset +$(go env GOPATH)/bin/client-gen \ + --input arkmq/v1beta1 \ + --go-header-file=../../script/headers/default.txt \ + --input-base=github.com/apache/camel-k/v2/pkg/apis/duck \ + --output-dir=./arkmq/clientset/ \ + --output-pkg=github.com/apache/camel-k/v2/pkg/client/arkmq/clientset + + $(go env GOPATH)/bin/lister-gen \ "github.com/apache/camel-k/v2/pkg/apis/camel/v1" \
