From 2679cafa40a31631a5775a07e06ba603029ce8f3 Mon Sep 17 00:00:00 2001 From: Prachi Damle Date: Wed, 28 Nov 2018 16:11:08 -0800 Subject: [PATCH] generated changes for GlobalDNS --- .../v3/zz_generated_deepcopy.go | 201 +++++++++ .../v3/zz_generated_global_dns_controller.go | 427 ++++++++++++++++++ ..._generated_global_dns_lifecycle_adapter.go | 62 +++ ...enerated_global_dns_provider_controller.go | 426 +++++++++++++++++ ...d_global_dns_provider_lifecycle_adapter.go | 62 +++ .../v3/zz_generated_k8s_client.go | 40 ++ .../v3/zz_generated_scheme.go | 4 + client/management/v3/zz_generated_client.go | 4 + .../management/v3/zz_generated_global_dns.go | 115 +++++ .../v3/zz_generated_global_dns_provider.go | 101 +++++ .../zz_generated_global_dns_provider_spec.go | 10 + .../v3/zz_generated_global_dns_spec.go | 16 + .../v3/zz_generated_global_dns_status.go | 10 + .../v3/zz_generated_route53provider_config.go | 14 + compose/zz_generated_compose.go | 2 + 15 files changed, 1494 insertions(+) create mode 100644 apis/management.cattle.io/v3/zz_generated_global_dns_controller.go create mode 100644 apis/management.cattle.io/v3/zz_generated_global_dns_lifecycle_adapter.go create mode 100644 apis/management.cattle.io/v3/zz_generated_global_dns_provider_controller.go create mode 100644 apis/management.cattle.io/v3/zz_generated_global_dns_provider_lifecycle_adapter.go create mode 100644 client/management/v3/zz_generated_global_dns.go create mode 100644 client/management/v3/zz_generated_global_dns_provider.go create mode 100644 client/management/v3/zz_generated_global_dns_provider_spec.go create mode 100644 client/management/v3/zz_generated_global_dns_spec.go create mode 100644 client/management/v3/zz_generated_global_dns_status.go create mode 100644 client/management/v3/zz_generated_route53provider_config.go diff --git a/apis/management.cattle.io/v3/zz_generated_deepcopy.go b/apis/management.cattle.io/v3/zz_generated_deepcopy.go index 566346fe..2eec7cbe 100644 --- a/apis/management.cattle.io/v3/zz_generated_deepcopy.go +++ b/apis/management.cattle.io/v3/zz_generated_deepcopy.go @@ -1987,6 +1987,191 @@ func (in *GithubConfigTestOutput) DeepCopy() *GithubConfigTestOutput { return out } +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNS) DeepCopyInto(out *GlobalDNS) { + *out = *in + out.Namespaced = in.Namespaced + out.TypeMeta = in.TypeMeta + in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) + in.Spec.DeepCopyInto(&out.Spec) + in.Status.DeepCopyInto(&out.Status) + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNS. +func (in *GlobalDNS) DeepCopy() *GlobalDNS { + if in == nil { + return nil + } + out := new(GlobalDNS) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *GlobalDNS) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSList) DeepCopyInto(out *GlobalDNSList) { + *out = *in + out.TypeMeta = in.TypeMeta + out.ListMeta = in.ListMeta + if in.Items != nil { + in, out := &in.Items, &out.Items + *out = make([]GlobalDNS, len(*in)) + for i := range *in { + (*in)[i].DeepCopyInto(&(*out)[i]) + } + } + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSList. +func (in *GlobalDNSList) DeepCopy() *GlobalDNSList { + if in == nil { + return nil + } + out := new(GlobalDNSList) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *GlobalDNSList) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSProvider) DeepCopyInto(out *GlobalDNSProvider) { + *out = *in + out.TypeMeta = in.TypeMeta + in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) + in.Spec.DeepCopyInto(&out.Spec) + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSProvider. +func (in *GlobalDNSProvider) DeepCopy() *GlobalDNSProvider { + if in == nil { + return nil + } + out := new(GlobalDNSProvider) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *GlobalDNSProvider) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSProviderList) DeepCopyInto(out *GlobalDNSProviderList) { + *out = *in + out.TypeMeta = in.TypeMeta + out.ListMeta = in.ListMeta + if in.Items != nil { + in, out := &in.Items, &out.Items + *out = make([]GlobalDNSProvider, len(*in)) + for i := range *in { + (*in)[i].DeepCopyInto(&(*out)[i]) + } + } + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSProviderList. +func (in *GlobalDNSProviderList) DeepCopy() *GlobalDNSProviderList { + if in == nil { + return nil + } + out := new(GlobalDNSProviderList) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *GlobalDNSProviderList) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSProviderSpec) DeepCopyInto(out *GlobalDNSProviderSpec) { + *out = *in + if in.Route53ProviderConfig != nil { + in, out := &in.Route53ProviderConfig, &out.Route53ProviderConfig + *out = new(Route53ProviderConfig) + **out = **in + } + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSProviderSpec. +func (in *GlobalDNSProviderSpec) DeepCopy() *GlobalDNSProviderSpec { + if in == nil { + return nil + } + out := new(GlobalDNSProviderSpec) + in.DeepCopyInto(out) + return out +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSSpec) DeepCopyInto(out *GlobalDNSSpec) { + *out = *in + if in.ProjectNames != nil { + in, out := &in.ProjectNames, &out.ProjectNames + *out = make([]string, len(*in)) + copy(*out, *in) + } + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSSpec. +func (in *GlobalDNSSpec) DeepCopy() *GlobalDNSSpec { + if in == nil { + return nil + } + out := new(GlobalDNSSpec) + in.DeepCopyInto(out) + return out +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *GlobalDNSStatus) DeepCopyInto(out *GlobalDNSStatus) { + *out = *in + if in.Endpoints != nil { + in, out := &in.Endpoints, &out.Endpoints + *out = make([]string, len(*in)) + copy(*out, *in) + } + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalDNSStatus. +func (in *GlobalDNSStatus) DeepCopy() *GlobalDNSStatus { + if in == nil { + return nil + } + out := new(GlobalDNSStatus) + in.DeepCopyInto(out) + return out +} + // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *GlobalOpenstackOpts) DeepCopyInto(out *GlobalOpenstackOpts) { *out = *in @@ -5258,6 +5443,22 @@ func (in *RoleTemplateList) DeepCopyObject() runtime.Object { return nil } +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *Route53ProviderConfig) DeepCopyInto(out *Route53ProviderConfig) { + *out = *in + return +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Route53ProviderConfig. +func (in *Route53ProviderConfig) DeepCopy() *Route53ProviderConfig { + if in == nil { + return nil + } + out := new(Route53ProviderConfig) + in.DeepCopyInto(out) + return out +} + // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *RouteOpenstackOpts) DeepCopyInto(out *RouteOpenstackOpts) { *out = *in diff --git a/apis/management.cattle.io/v3/zz_generated_global_dns_controller.go b/apis/management.cattle.io/v3/zz_generated_global_dns_controller.go new file mode 100644 index 00000000..f6041379 --- /dev/null +++ b/apis/management.cattle.io/v3/zz_generated_global_dns_controller.go @@ -0,0 +1,427 @@ +package v3 + +import ( + "context" + + "github.com/rancher/norman/controller" + "github.com/rancher/norman/objectclient" + "k8s.io/apimachinery/pkg/api/errors" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "k8s.io/apimachinery/pkg/labels" + "k8s.io/apimachinery/pkg/runtime" + "k8s.io/apimachinery/pkg/runtime/schema" + "k8s.io/apimachinery/pkg/watch" + "k8s.io/client-go/tools/cache" +) + +var ( + GlobalDNSGroupVersionKind = schema.GroupVersionKind{ + Version: Version, + Group: GroupName, + Kind: "GlobalDNS", + } + GlobalDNSResource = metav1.APIResource{ + Name: "globaldnses", + SingularName: "globaldns", + Namespaced: true, + + Kind: GlobalDNSGroupVersionKind.Kind, + } +) + +type GlobalDNSList struct { + metav1.TypeMeta `json:",inline"` + metav1.ListMeta `json:"metadata,omitempty"` + Items []GlobalDNS +} + +type GlobalDNSHandlerFunc func(key string, obj *GlobalDNS) (runtime.Object, error) + +type GlobalDNSChangeHandlerFunc func(obj *GlobalDNS) (runtime.Object, error) + +type GlobalDNSLister interface { + List(namespace string, selector labels.Selector) (ret []*GlobalDNS, err error) + Get(namespace, name string) (*GlobalDNS, error) +} + +type GlobalDNSController interface { + Generic() controller.GenericController + Informer() cache.SharedIndexInformer + Lister() GlobalDNSLister + AddHandler(ctx context.Context, name string, handler GlobalDNSHandlerFunc) + AddClusterScopedHandler(ctx context.Context, name, clusterName string, handler GlobalDNSHandlerFunc) + Enqueue(namespace, name string) + Sync(ctx context.Context) error + Start(ctx context.Context, threadiness int) error +} + +type GlobalDNSInterface interface { + ObjectClient() *objectclient.ObjectClient + Create(*GlobalDNS) (*GlobalDNS, error) + GetNamespaced(namespace, name string, opts metav1.GetOptions) (*GlobalDNS, error) + Get(name string, opts metav1.GetOptions) (*GlobalDNS, error) + Update(*GlobalDNS) (*GlobalDNS, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error + List(opts metav1.ListOptions) (*GlobalDNSList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error + Controller() GlobalDNSController + AddHandler(ctx context.Context, name string, sync GlobalDNSHandlerFunc) + AddLifecycle(ctx context.Context, name string, lifecycle GlobalDNSLifecycle) + AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync GlobalDNSHandlerFunc) + AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle GlobalDNSLifecycle) +} + +type globalDnsLister struct { + controller *globalDnsController +} + +func (l *globalDnsLister) List(namespace string, selector labels.Selector) (ret []*GlobalDNS, err error) { + err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) { + ret = append(ret, obj.(*GlobalDNS)) + }) + return +} + +func (l *globalDnsLister) Get(namespace, name string) (*GlobalDNS, error) { + var key string + if namespace != "" { + key = namespace + "/" + name + } else { + key = name + } + obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(key) + if err != nil { + return nil, err + } + if !exists { + return nil, errors.NewNotFound(schema.GroupResource{ + Group: GlobalDNSGroupVersionKind.Group, + Resource: "globalDns", + }, key) + } + return obj.(*GlobalDNS), nil +} + +type globalDnsController struct { + controller.GenericController +} + +func (c *globalDnsController) Generic() controller.GenericController { + return c.GenericController +} + +func (c *globalDnsController) Lister() GlobalDNSLister { + return &globalDnsLister{ + controller: c, + } +} + +func (c *globalDnsController) AddHandler(ctx context.Context, name string, handler GlobalDNSHandlerFunc) { + c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) { + if obj == nil { + return handler(key, nil) + } else if v, ok := obj.(*GlobalDNS); ok { + return handler(key, v) + } else { + return nil, nil + } + }) +} + +func (c *globalDnsController) AddClusterScopedHandler(ctx context.Context, name, cluster string, handler GlobalDNSHandlerFunc) { + c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) { + if obj == nil { + return handler(key, nil) + } else if v, ok := obj.(*GlobalDNS); ok && controller.ObjectInCluster(cluster, obj) { + return handler(key, v) + } else { + return nil, nil + } + }) +} + +type globalDnsFactory struct { +} + +func (c globalDnsFactory) Object() runtime.Object { + return &GlobalDNS{} +} + +func (c globalDnsFactory) List() runtime.Object { + return &GlobalDNSList{} +} + +func (s *globalDnsClient) Controller() GlobalDNSController { + s.client.Lock() + defer s.client.Unlock() + + c, ok := s.client.globalDnsControllers[s.ns] + if ok { + return c + } + + genericController := controller.NewGenericController(GlobalDNSGroupVersionKind.Kind+"Controller", + s.objectClient) + + c = &globalDnsController{ + GenericController: genericController, + } + + s.client.globalDnsControllers[s.ns] = c + s.client.starters = append(s.client.starters, c) + + return c +} + +type globalDnsClient struct { + client *Client + ns string + objectClient *objectclient.ObjectClient + controller GlobalDNSController +} + +func (s *globalDnsClient) ObjectClient() *objectclient.ObjectClient { + return s.objectClient +} + +func (s *globalDnsClient) Create(o *GlobalDNS) (*GlobalDNS, error) { + obj, err := s.objectClient.Create(o) + return obj.(*GlobalDNS), err +} + +func (s *globalDnsClient) Get(name string, opts metav1.GetOptions) (*GlobalDNS, error) { + obj, err := s.objectClient.Get(name, opts) + return obj.(*GlobalDNS), err +} + +func (s *globalDnsClient) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*GlobalDNS, error) { + obj, err := s.objectClient.GetNamespaced(namespace, name, opts) + return obj.(*GlobalDNS), err +} + +func (s *globalDnsClient) Update(o *GlobalDNS) (*GlobalDNS, error) { + obj, err := s.objectClient.Update(o.Name, o) + return obj.(*GlobalDNS), err +} + +func (s *globalDnsClient) Delete(name string, options *metav1.DeleteOptions) error { + return s.objectClient.Delete(name, options) +} + +func (s *globalDnsClient) DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error { + return s.objectClient.DeleteNamespaced(namespace, name, options) +} + +func (s *globalDnsClient) List(opts metav1.ListOptions) (*GlobalDNSList, error) { + obj, err := s.objectClient.List(opts) + return obj.(*GlobalDNSList), err +} + +func (s *globalDnsClient) Watch(opts metav1.ListOptions) (watch.Interface, error) { + return s.objectClient.Watch(opts) +} + +// Patch applies the patch and returns the patched deployment. +func (s *globalDnsClient) Patch(o *GlobalDNS, data []byte, subresources ...string) (*GlobalDNS, error) { + obj, err := s.objectClient.Patch(o.Name, o, data, subresources...) + return obj.(*GlobalDNS), err +} + +func (s *globalDnsClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error { + return s.objectClient.DeleteCollection(deleteOpts, listOpts) +} + +func (s *globalDnsClient) AddHandler(ctx context.Context, name string, sync GlobalDNSHandlerFunc) { + s.Controller().AddHandler(ctx, name, sync) +} + +func (s *globalDnsClient) AddLifecycle(ctx context.Context, name string, lifecycle GlobalDNSLifecycle) { + sync := NewGlobalDNSLifecycleAdapter(name, false, s, lifecycle) + s.Controller().AddHandler(ctx, name, sync) +} + +func (s *globalDnsClient) AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync GlobalDNSHandlerFunc) { + s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync) +} + +func (s *globalDnsClient) AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle GlobalDNSLifecycle) { + sync := NewGlobalDNSLifecycleAdapter(name+"_"+clusterName, true, s, lifecycle) + s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync) +} + +type GlobalDNSIndexer func(obj *GlobalDNS) ([]string, error) + +type GlobalDNSClientCache interface { + Get(namespace, name string) (*GlobalDNS, error) + List(namespace string, selector labels.Selector) ([]*GlobalDNS, error) + + Index(name string, indexer GlobalDNSIndexer) + GetIndexed(name, key string) ([]*GlobalDNS, error) +} + +type GlobalDNSClient interface { + Create(*GlobalDNS) (*GlobalDNS, error) + Get(namespace, name string, opts metav1.GetOptions) (*GlobalDNS, error) + Update(*GlobalDNS) (*GlobalDNS, error) + Delete(namespace, name string, options *metav1.DeleteOptions) error + List(namespace string, opts metav1.ListOptions) (*GlobalDNSList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + + Cache() GlobalDNSClientCache + + OnCreate(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) + OnChange(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) + OnRemove(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) + Enqueue(namespace, name string) + + Generic() controller.GenericController + Interface() GlobalDNSInterface +} + +type globalDnsClientCache struct { + client *globalDnsClient2 +} + +type globalDnsClient2 struct { + iface GlobalDNSInterface + controller GlobalDNSController +} + +func (n *globalDnsClient2) Interface() GlobalDNSInterface { + return n.iface +} + +func (n *globalDnsClient2) Generic() controller.GenericController { + return n.iface.Controller().Generic() +} + +func (n *globalDnsClient2) Enqueue(namespace, name string) { + n.iface.Controller().Enqueue(namespace, name) +} + +func (n *globalDnsClient2) Create(obj *GlobalDNS) (*GlobalDNS, error) { + return n.iface.Create(obj) +} + +func (n *globalDnsClient2) Get(namespace, name string, opts metav1.GetOptions) (*GlobalDNS, error) { + return n.iface.GetNamespaced(namespace, name, opts) +} + +func (n *globalDnsClient2) Update(obj *GlobalDNS) (*GlobalDNS, error) { + return n.iface.Update(obj) +} + +func (n *globalDnsClient2) Delete(namespace, name string, options *metav1.DeleteOptions) error { + return n.iface.DeleteNamespaced(namespace, name, options) +} + +func (n *globalDnsClient2) List(namespace string, opts metav1.ListOptions) (*GlobalDNSList, error) { + return n.iface.List(opts) +} + +func (n *globalDnsClient2) Watch(opts metav1.ListOptions) (watch.Interface, error) { + return n.iface.Watch(opts) +} + +func (n *globalDnsClientCache) Get(namespace, name string) (*GlobalDNS, error) { + return n.client.controller.Lister().Get(namespace, name) +} + +func (n *globalDnsClientCache) List(namespace string, selector labels.Selector) ([]*GlobalDNS, error) { + return n.client.controller.Lister().List(namespace, selector) +} + +func (n *globalDnsClient2) Cache() GlobalDNSClientCache { + n.loadController() + return &globalDnsClientCache{ + client: n, + } +} + +func (n *globalDnsClient2) OnCreate(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name+"-create", &globalDnsLifecycleDelegate{create: sync}) +} + +func (n *globalDnsClient2) OnChange(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name+"-change", &globalDnsLifecycleDelegate{update: sync}) +} + +func (n *globalDnsClient2) OnRemove(ctx context.Context, name string, sync GlobalDNSChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name, &globalDnsLifecycleDelegate{remove: sync}) +} + +func (n *globalDnsClientCache) Index(name string, indexer GlobalDNSIndexer) { + err := n.client.controller.Informer().GetIndexer().AddIndexers(map[string]cache.IndexFunc{ + name: func(obj interface{}) ([]string, error) { + if v, ok := obj.(*GlobalDNS); ok { + return indexer(v) + } + return nil, nil + }, + }) + + if err != nil { + panic(err) + } +} + +func (n *globalDnsClientCache) GetIndexed(name, key string) ([]*GlobalDNS, error) { + var result []*GlobalDNS + objs, err := n.client.controller.Informer().GetIndexer().ByIndex(name, key) + if err != nil { + return nil, err + } + for _, obj := range objs { + if v, ok := obj.(*GlobalDNS); ok { + result = append(result, v) + } + } + + return result, nil +} + +func (n *globalDnsClient2) loadController() { + if n.controller == nil { + n.controller = n.iface.Controller() + } +} + +type globalDnsLifecycleDelegate struct { + create GlobalDNSChangeHandlerFunc + update GlobalDNSChangeHandlerFunc + remove GlobalDNSChangeHandlerFunc +} + +func (n *globalDnsLifecycleDelegate) HasCreate() bool { + return n.create != nil +} + +func (n *globalDnsLifecycleDelegate) Create(obj *GlobalDNS) (runtime.Object, error) { + if n.create == nil { + return obj, nil + } + return n.create(obj) +} + +func (n *globalDnsLifecycleDelegate) HasFinalize() bool { + return n.remove != nil +} + +func (n *globalDnsLifecycleDelegate) Remove(obj *GlobalDNS) (runtime.Object, error) { + if n.remove == nil { + return obj, nil + } + return n.remove(obj) +} + +func (n *globalDnsLifecycleDelegate) Updated(obj *GlobalDNS) (runtime.Object, error) { + if n.update == nil { + return obj, nil + } + return n.update(obj) +} diff --git a/apis/management.cattle.io/v3/zz_generated_global_dns_lifecycle_adapter.go b/apis/management.cattle.io/v3/zz_generated_global_dns_lifecycle_adapter.go new file mode 100644 index 00000000..6b126732 --- /dev/null +++ b/apis/management.cattle.io/v3/zz_generated_global_dns_lifecycle_adapter.go @@ -0,0 +1,62 @@ +package v3 + +import ( + "github.com/rancher/norman/lifecycle" + "k8s.io/apimachinery/pkg/runtime" +) + +type GlobalDNSLifecycle interface { + Create(obj *GlobalDNS) (runtime.Object, error) + Remove(obj *GlobalDNS) (runtime.Object, error) + Updated(obj *GlobalDNS) (runtime.Object, error) +} + +type globalDnsLifecycleAdapter struct { + lifecycle GlobalDNSLifecycle +} + +func (w *globalDnsLifecycleAdapter) HasCreate() bool { + o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition) + return !ok || o.HasCreate() +} + +func (w *globalDnsLifecycleAdapter) HasFinalize() bool { + o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition) + return !ok || o.HasFinalize() +} + +func (w *globalDnsLifecycleAdapter) Create(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Create(obj.(*GlobalDNS)) + if o == nil { + return nil, err + } + return o, err +} + +func (w *globalDnsLifecycleAdapter) Finalize(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Remove(obj.(*GlobalDNS)) + if o == nil { + return nil, err + } + return o, err +} + +func (w *globalDnsLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Updated(obj.(*GlobalDNS)) + if o == nil { + return nil, err + } + return o, err +} + +func NewGlobalDNSLifecycleAdapter(name string, clusterScoped bool, client GlobalDNSInterface, l GlobalDNSLifecycle) GlobalDNSHandlerFunc { + adapter := &globalDnsLifecycleAdapter{lifecycle: l} + syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient()) + return func(key string, obj *GlobalDNS) (runtime.Object, error) { + newObj, err := syncFn(key, obj) + if o, ok := newObj.(runtime.Object); ok { + return o, err + } + return nil, err + } +} diff --git a/apis/management.cattle.io/v3/zz_generated_global_dns_provider_controller.go b/apis/management.cattle.io/v3/zz_generated_global_dns_provider_controller.go new file mode 100644 index 00000000..5bb7dd29 --- /dev/null +++ b/apis/management.cattle.io/v3/zz_generated_global_dns_provider_controller.go @@ -0,0 +1,426 @@ +package v3 + +import ( + "context" + + "github.com/rancher/norman/controller" + "github.com/rancher/norman/objectclient" + "k8s.io/apimachinery/pkg/api/errors" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "k8s.io/apimachinery/pkg/labels" + "k8s.io/apimachinery/pkg/runtime" + "k8s.io/apimachinery/pkg/runtime/schema" + "k8s.io/apimachinery/pkg/watch" + "k8s.io/client-go/tools/cache" +) + +var ( + GlobalDNSProviderGroupVersionKind = schema.GroupVersionKind{ + Version: Version, + Group: GroupName, + Kind: "GlobalDNSProvider", + } + GlobalDNSProviderResource = metav1.APIResource{ + Name: "globaldnsproviders", + SingularName: "globaldnsprovider", + Namespaced: false, + Kind: GlobalDNSProviderGroupVersionKind.Kind, + } +) + +type GlobalDNSProviderList struct { + metav1.TypeMeta `json:",inline"` + metav1.ListMeta `json:"metadata,omitempty"` + Items []GlobalDNSProvider +} + +type GlobalDNSProviderHandlerFunc func(key string, obj *GlobalDNSProvider) (runtime.Object, error) + +type GlobalDNSProviderChangeHandlerFunc func(obj *GlobalDNSProvider) (runtime.Object, error) + +type GlobalDNSProviderLister interface { + List(namespace string, selector labels.Selector) (ret []*GlobalDNSProvider, err error) + Get(namespace, name string) (*GlobalDNSProvider, error) +} + +type GlobalDNSProviderController interface { + Generic() controller.GenericController + Informer() cache.SharedIndexInformer + Lister() GlobalDNSProviderLister + AddHandler(ctx context.Context, name string, handler GlobalDNSProviderHandlerFunc) + AddClusterScopedHandler(ctx context.Context, name, clusterName string, handler GlobalDNSProviderHandlerFunc) + Enqueue(namespace, name string) + Sync(ctx context.Context) error + Start(ctx context.Context, threadiness int) error +} + +type GlobalDNSProviderInterface interface { + ObjectClient() *objectclient.ObjectClient + Create(*GlobalDNSProvider) (*GlobalDNSProvider, error) + GetNamespaced(namespace, name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) + Get(name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) + Update(*GlobalDNSProvider) (*GlobalDNSProvider, error) + Delete(name string, options *metav1.DeleteOptions) error + DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error + List(opts metav1.ListOptions) (*GlobalDNSProviderList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error + Controller() GlobalDNSProviderController + AddHandler(ctx context.Context, name string, sync GlobalDNSProviderHandlerFunc) + AddLifecycle(ctx context.Context, name string, lifecycle GlobalDNSProviderLifecycle) + AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync GlobalDNSProviderHandlerFunc) + AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle GlobalDNSProviderLifecycle) +} + +type globalDnsProviderLister struct { + controller *globalDnsProviderController +} + +func (l *globalDnsProviderLister) List(namespace string, selector labels.Selector) (ret []*GlobalDNSProvider, err error) { + err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) { + ret = append(ret, obj.(*GlobalDNSProvider)) + }) + return +} + +func (l *globalDnsProviderLister) Get(namespace, name string) (*GlobalDNSProvider, error) { + var key string + if namespace != "" { + key = namespace + "/" + name + } else { + key = name + } + obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(key) + if err != nil { + return nil, err + } + if !exists { + return nil, errors.NewNotFound(schema.GroupResource{ + Group: GlobalDNSProviderGroupVersionKind.Group, + Resource: "globalDnsProvider", + }, key) + } + return obj.(*GlobalDNSProvider), nil +} + +type globalDnsProviderController struct { + controller.GenericController +} + +func (c *globalDnsProviderController) Generic() controller.GenericController { + return c.GenericController +} + +func (c *globalDnsProviderController) Lister() GlobalDNSProviderLister { + return &globalDnsProviderLister{ + controller: c, + } +} + +func (c *globalDnsProviderController) AddHandler(ctx context.Context, name string, handler GlobalDNSProviderHandlerFunc) { + c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) { + if obj == nil { + return handler(key, nil) + } else if v, ok := obj.(*GlobalDNSProvider); ok { + return handler(key, v) + } else { + return nil, nil + } + }) +} + +func (c *globalDnsProviderController) AddClusterScopedHandler(ctx context.Context, name, cluster string, handler GlobalDNSProviderHandlerFunc) { + c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) { + if obj == nil { + return handler(key, nil) + } else if v, ok := obj.(*GlobalDNSProvider); ok && controller.ObjectInCluster(cluster, obj) { + return handler(key, v) + } else { + return nil, nil + } + }) +} + +type globalDnsProviderFactory struct { +} + +func (c globalDnsProviderFactory) Object() runtime.Object { + return &GlobalDNSProvider{} +} + +func (c globalDnsProviderFactory) List() runtime.Object { + return &GlobalDNSProviderList{} +} + +func (s *globalDnsProviderClient) Controller() GlobalDNSProviderController { + s.client.Lock() + defer s.client.Unlock() + + c, ok := s.client.globalDnsProviderControllers[s.ns] + if ok { + return c + } + + genericController := controller.NewGenericController(GlobalDNSProviderGroupVersionKind.Kind+"Controller", + s.objectClient) + + c = &globalDnsProviderController{ + GenericController: genericController, + } + + s.client.globalDnsProviderControllers[s.ns] = c + s.client.starters = append(s.client.starters, c) + + return c +} + +type globalDnsProviderClient struct { + client *Client + ns string + objectClient *objectclient.ObjectClient + controller GlobalDNSProviderController +} + +func (s *globalDnsProviderClient) ObjectClient() *objectclient.ObjectClient { + return s.objectClient +} + +func (s *globalDnsProviderClient) Create(o *GlobalDNSProvider) (*GlobalDNSProvider, error) { + obj, err := s.objectClient.Create(o) + return obj.(*GlobalDNSProvider), err +} + +func (s *globalDnsProviderClient) Get(name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) { + obj, err := s.objectClient.Get(name, opts) + return obj.(*GlobalDNSProvider), err +} + +func (s *globalDnsProviderClient) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) { + obj, err := s.objectClient.GetNamespaced(namespace, name, opts) + return obj.(*GlobalDNSProvider), err +} + +func (s *globalDnsProviderClient) Update(o *GlobalDNSProvider) (*GlobalDNSProvider, error) { + obj, err := s.objectClient.Update(o.Name, o) + return obj.(*GlobalDNSProvider), err +} + +func (s *globalDnsProviderClient) Delete(name string, options *metav1.DeleteOptions) error { + return s.objectClient.Delete(name, options) +} + +func (s *globalDnsProviderClient) DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error { + return s.objectClient.DeleteNamespaced(namespace, name, options) +} + +func (s *globalDnsProviderClient) List(opts metav1.ListOptions) (*GlobalDNSProviderList, error) { + obj, err := s.objectClient.List(opts) + return obj.(*GlobalDNSProviderList), err +} + +func (s *globalDnsProviderClient) Watch(opts metav1.ListOptions) (watch.Interface, error) { + return s.objectClient.Watch(opts) +} + +// Patch applies the patch and returns the patched deployment. +func (s *globalDnsProviderClient) Patch(o *GlobalDNSProvider, data []byte, subresources ...string) (*GlobalDNSProvider, error) { + obj, err := s.objectClient.Patch(o.Name, o, data, subresources...) + return obj.(*GlobalDNSProvider), err +} + +func (s *globalDnsProviderClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error { + return s.objectClient.DeleteCollection(deleteOpts, listOpts) +} + +func (s *globalDnsProviderClient) AddHandler(ctx context.Context, name string, sync GlobalDNSProviderHandlerFunc) { + s.Controller().AddHandler(ctx, name, sync) +} + +func (s *globalDnsProviderClient) AddLifecycle(ctx context.Context, name string, lifecycle GlobalDNSProviderLifecycle) { + sync := NewGlobalDNSProviderLifecycleAdapter(name, false, s, lifecycle) + s.Controller().AddHandler(ctx, name, sync) +} + +func (s *globalDnsProviderClient) AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync GlobalDNSProviderHandlerFunc) { + s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync) +} + +func (s *globalDnsProviderClient) AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle GlobalDNSProviderLifecycle) { + sync := NewGlobalDNSProviderLifecycleAdapter(name+"_"+clusterName, true, s, lifecycle) + s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync) +} + +type GlobalDNSProviderIndexer func(obj *GlobalDNSProvider) ([]string, error) + +type GlobalDNSProviderClientCache interface { + Get(namespace, name string) (*GlobalDNSProvider, error) + List(namespace string, selector labels.Selector) ([]*GlobalDNSProvider, error) + + Index(name string, indexer GlobalDNSProviderIndexer) + GetIndexed(name, key string) ([]*GlobalDNSProvider, error) +} + +type GlobalDNSProviderClient interface { + Create(*GlobalDNSProvider) (*GlobalDNSProvider, error) + Get(namespace, name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) + Update(*GlobalDNSProvider) (*GlobalDNSProvider, error) + Delete(namespace, name string, options *metav1.DeleteOptions) error + List(namespace string, opts metav1.ListOptions) (*GlobalDNSProviderList, error) + Watch(opts metav1.ListOptions) (watch.Interface, error) + + Cache() GlobalDNSProviderClientCache + + OnCreate(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) + OnChange(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) + OnRemove(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) + Enqueue(namespace, name string) + + Generic() controller.GenericController + Interface() GlobalDNSProviderInterface +} + +type globalDnsProviderClientCache struct { + client *globalDnsProviderClient2 +} + +type globalDnsProviderClient2 struct { + iface GlobalDNSProviderInterface + controller GlobalDNSProviderController +} + +func (n *globalDnsProviderClient2) Interface() GlobalDNSProviderInterface { + return n.iface +} + +func (n *globalDnsProviderClient2) Generic() controller.GenericController { + return n.iface.Controller().Generic() +} + +func (n *globalDnsProviderClient2) Enqueue(namespace, name string) { + n.iface.Controller().Enqueue(namespace, name) +} + +func (n *globalDnsProviderClient2) Create(obj *GlobalDNSProvider) (*GlobalDNSProvider, error) { + return n.iface.Create(obj) +} + +func (n *globalDnsProviderClient2) Get(namespace, name string, opts metav1.GetOptions) (*GlobalDNSProvider, error) { + return n.iface.GetNamespaced(namespace, name, opts) +} + +func (n *globalDnsProviderClient2) Update(obj *GlobalDNSProvider) (*GlobalDNSProvider, error) { + return n.iface.Update(obj) +} + +func (n *globalDnsProviderClient2) Delete(namespace, name string, options *metav1.DeleteOptions) error { + return n.iface.DeleteNamespaced(namespace, name, options) +} + +func (n *globalDnsProviderClient2) List(namespace string, opts metav1.ListOptions) (*GlobalDNSProviderList, error) { + return n.iface.List(opts) +} + +func (n *globalDnsProviderClient2) Watch(opts metav1.ListOptions) (watch.Interface, error) { + return n.iface.Watch(opts) +} + +func (n *globalDnsProviderClientCache) Get(namespace, name string) (*GlobalDNSProvider, error) { + return n.client.controller.Lister().Get(namespace, name) +} + +func (n *globalDnsProviderClientCache) List(namespace string, selector labels.Selector) ([]*GlobalDNSProvider, error) { + return n.client.controller.Lister().List(namespace, selector) +} + +func (n *globalDnsProviderClient2) Cache() GlobalDNSProviderClientCache { + n.loadController() + return &globalDnsProviderClientCache{ + client: n, + } +} + +func (n *globalDnsProviderClient2) OnCreate(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name+"-create", &globalDnsProviderLifecycleDelegate{create: sync}) +} + +func (n *globalDnsProviderClient2) OnChange(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name+"-change", &globalDnsProviderLifecycleDelegate{update: sync}) +} + +func (n *globalDnsProviderClient2) OnRemove(ctx context.Context, name string, sync GlobalDNSProviderChangeHandlerFunc) { + n.loadController() + n.iface.AddLifecycle(ctx, name, &globalDnsProviderLifecycleDelegate{remove: sync}) +} + +func (n *globalDnsProviderClientCache) Index(name string, indexer GlobalDNSProviderIndexer) { + err := n.client.controller.Informer().GetIndexer().AddIndexers(map[string]cache.IndexFunc{ + name: func(obj interface{}) ([]string, error) { + if v, ok := obj.(*GlobalDNSProvider); ok { + return indexer(v) + } + return nil, nil + }, + }) + + if err != nil { + panic(err) + } +} + +func (n *globalDnsProviderClientCache) GetIndexed(name, key string) ([]*GlobalDNSProvider, error) { + var result []*GlobalDNSProvider + objs, err := n.client.controller.Informer().GetIndexer().ByIndex(name, key) + if err != nil { + return nil, err + } + for _, obj := range objs { + if v, ok := obj.(*GlobalDNSProvider); ok { + result = append(result, v) + } + } + + return result, nil +} + +func (n *globalDnsProviderClient2) loadController() { + if n.controller == nil { + n.controller = n.iface.Controller() + } +} + +type globalDnsProviderLifecycleDelegate struct { + create GlobalDNSProviderChangeHandlerFunc + update GlobalDNSProviderChangeHandlerFunc + remove GlobalDNSProviderChangeHandlerFunc +} + +func (n *globalDnsProviderLifecycleDelegate) HasCreate() bool { + return n.create != nil +} + +func (n *globalDnsProviderLifecycleDelegate) Create(obj *GlobalDNSProvider) (runtime.Object, error) { + if n.create == nil { + return obj, nil + } + return n.create(obj) +} + +func (n *globalDnsProviderLifecycleDelegate) HasFinalize() bool { + return n.remove != nil +} + +func (n *globalDnsProviderLifecycleDelegate) Remove(obj *GlobalDNSProvider) (runtime.Object, error) { + if n.remove == nil { + return obj, nil + } + return n.remove(obj) +} + +func (n *globalDnsProviderLifecycleDelegate) Updated(obj *GlobalDNSProvider) (runtime.Object, error) { + if n.update == nil { + return obj, nil + } + return n.update(obj) +} diff --git a/apis/management.cattle.io/v3/zz_generated_global_dns_provider_lifecycle_adapter.go b/apis/management.cattle.io/v3/zz_generated_global_dns_provider_lifecycle_adapter.go new file mode 100644 index 00000000..3755bca7 --- /dev/null +++ b/apis/management.cattle.io/v3/zz_generated_global_dns_provider_lifecycle_adapter.go @@ -0,0 +1,62 @@ +package v3 + +import ( + "github.com/rancher/norman/lifecycle" + "k8s.io/apimachinery/pkg/runtime" +) + +type GlobalDNSProviderLifecycle interface { + Create(obj *GlobalDNSProvider) (runtime.Object, error) + Remove(obj *GlobalDNSProvider) (runtime.Object, error) + Updated(obj *GlobalDNSProvider) (runtime.Object, error) +} + +type globalDnsProviderLifecycleAdapter struct { + lifecycle GlobalDNSProviderLifecycle +} + +func (w *globalDnsProviderLifecycleAdapter) HasCreate() bool { + o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition) + return !ok || o.HasCreate() +} + +func (w *globalDnsProviderLifecycleAdapter) HasFinalize() bool { + o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition) + return !ok || o.HasFinalize() +} + +func (w *globalDnsProviderLifecycleAdapter) Create(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Create(obj.(*GlobalDNSProvider)) + if o == nil { + return nil, err + } + return o, err +} + +func (w *globalDnsProviderLifecycleAdapter) Finalize(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Remove(obj.(*GlobalDNSProvider)) + if o == nil { + return nil, err + } + return o, err +} + +func (w *globalDnsProviderLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error) { + o, err := w.lifecycle.Updated(obj.(*GlobalDNSProvider)) + if o == nil { + return nil, err + } + return o, err +} + +func NewGlobalDNSProviderLifecycleAdapter(name string, clusterScoped bool, client GlobalDNSProviderInterface, l GlobalDNSProviderLifecycle) GlobalDNSProviderHandlerFunc { + adapter := &globalDnsProviderLifecycleAdapter{lifecycle: l} + syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient()) + return func(key string, obj *GlobalDNSProvider) (runtime.Object, error) { + newObj, err := syncFn(key, obj) + if o, ok := newObj.(runtime.Object); ok { + return o, err + } + return nil, err + } +} diff --git a/apis/management.cattle.io/v3/zz_generated_k8s_client.go b/apis/management.cattle.io/v3/zz_generated_k8s_client.go index 042ef741..10dda954 100644 --- a/apis/management.cattle.io/v3/zz_generated_k8s_client.go +++ b/apis/management.cattle.io/v3/zz_generated_k8s_client.go @@ -60,6 +60,8 @@ type Interface interface { ProjectCatalogsGetter ClusterCatalogsGetter MultiClusterAppsGetter + GlobalDNSsGetter + GlobalDNSProvidersGetter } type Clients struct { @@ -103,6 +105,8 @@ type Clients struct { ProjectCatalog ProjectCatalogClient ClusterCatalog ClusterCatalogClient MultiClusterApp MultiClusterAppClient + GlobalDNS GlobalDNSClient + GlobalDNSProvider GlobalDNSProviderClient } type Client struct { @@ -150,6 +154,8 @@ type Client struct { projectCatalogControllers map[string]ProjectCatalogController clusterCatalogControllers map[string]ClusterCatalogController multiClusterAppControllers map[string]MultiClusterAppController + globalDnsControllers map[string]GlobalDNSController + globalDnsProviderControllers map[string]GlobalDNSProviderController } func Factory(ctx context.Context, config rest.Config) (context.Context, controller.Starter, error) { @@ -304,6 +310,12 @@ func NewClientsFromInterface(iface Interface) *Clients { MultiClusterApp: &multiClusterAppClient2{ iface: iface.MultiClusterApps(""), }, + GlobalDNS: &globalDnsClient2{ + iface: iface.GlobalDNSs(""), + }, + GlobalDNSProvider: &globalDnsProviderClient2{ + iface: iface.GlobalDNSProviders(""), + }, } } @@ -360,6 +372,8 @@ func NewForConfig(config rest.Config) (Interface, error) { projectCatalogControllers: map[string]ProjectCatalogController{}, clusterCatalogControllers: map[string]ClusterCatalogController{}, multiClusterAppControllers: map[string]MultiClusterAppController{}, + globalDnsControllers: map[string]GlobalDNSController{}, + globalDnsProviderControllers: map[string]GlobalDNSProviderController{}, }, nil } @@ -894,3 +908,29 @@ func (c *Client) MultiClusterApps(namespace string) MultiClusterAppInterface { objectClient: objectClient, } } + +type GlobalDNSsGetter interface { + GlobalDNSs(namespace string) GlobalDNSInterface +} + +func (c *Client) GlobalDNSs(namespace string) GlobalDNSInterface { + objectClient := objectclient.NewObjectClient(namespace, c.restClient, &GlobalDNSResource, GlobalDNSGroupVersionKind, globalDnsFactory{}) + return &globalDnsClient{ + ns: namespace, + client: c, + objectClient: objectClient, + } +} + +type GlobalDNSProvidersGetter interface { + GlobalDNSProviders(namespace string) GlobalDNSProviderInterface +} + +func (c *Client) GlobalDNSProviders(namespace string) GlobalDNSProviderInterface { + objectClient := objectclient.NewObjectClient(namespace, c.restClient, &GlobalDNSProviderResource, GlobalDNSProviderGroupVersionKind, globalDnsProviderFactory{}) + return &globalDnsProviderClient{ + ns: namespace, + client: c, + objectClient: objectClient, + } +} diff --git a/apis/management.cattle.io/v3/zz_generated_scheme.go b/apis/management.cattle.io/v3/zz_generated_scheme.go index 08b62c74..86b0e824 100644 --- a/apis/management.cattle.io/v3/zz_generated_scheme.go +++ b/apis/management.cattle.io/v3/zz_generated_scheme.go @@ -112,6 +112,10 @@ func addKnownTypes(scheme *runtime.Scheme) error { &ClusterCatalogList{}, &MultiClusterApp{}, &MultiClusterAppList{}, + &GlobalDNS{}, + &GlobalDNSList{}, + &GlobalDNSProvider{}, + &GlobalDNSProviderList{}, ) return nil } diff --git a/client/management/v3/zz_generated_client.go b/client/management/v3/zz_generated_client.go index 90491f74..6ab84903 100644 --- a/client/management/v3/zz_generated_client.go +++ b/client/management/v3/zz_generated_client.go @@ -46,6 +46,8 @@ type Client struct { ProjectCatalog ProjectCatalogOperations ClusterCatalog ClusterCatalogOperations MultiClusterApp MultiClusterAppOperations + GlobalDNS GlobalDNSOperations + GlobalDNSProvider GlobalDNSProviderOperations } func NewClient(opts *clientbase.ClientOpts) (*Client, error) { @@ -97,6 +99,8 @@ func NewClient(opts *clientbase.ClientOpts) (*Client, error) { client.ProjectCatalog = newProjectCatalogClient(client) client.ClusterCatalog = newClusterCatalogClient(client) client.MultiClusterApp = newMultiClusterAppClient(client) + client.GlobalDNS = newGlobalDNSClient(client) + client.GlobalDNSProvider = newGlobalDNSProviderClient(client) return client, nil } diff --git a/client/management/v3/zz_generated_global_dns.go b/client/management/v3/zz_generated_global_dns.go new file mode 100644 index 00000000..828cf4d2 --- /dev/null +++ b/client/management/v3/zz_generated_global_dns.go @@ -0,0 +1,115 @@ +package client + +import ( + "github.com/rancher/norman/types" +) + +const ( + GlobalDNSType = "globalDns" + GlobalDNSFieldAnnotations = "annotations" + GlobalDNSFieldCreated = "created" + GlobalDNSFieldCreatorID = "creatorId" + GlobalDNSFieldFQDN = "fqdn" + GlobalDNSFieldLabels = "labels" + GlobalDNSFieldMultiClusterAppID = "multiClusterAppId" + GlobalDNSFieldName = "name" + GlobalDNSFieldOwnerReferences = "ownerReferences" + GlobalDNSFieldProjectIDs = "projectIds" + GlobalDNSFieldProviderID = "providerId" + GlobalDNSFieldRemoved = "removed" + GlobalDNSFieldState = "state" + GlobalDNSFieldStatus = "status" + GlobalDNSFieldTransitioning = "transitioning" + GlobalDNSFieldTransitioningMessage = "transitioningMessage" + GlobalDNSFieldUUID = "uuid" +) + +type GlobalDNS struct { + types.Resource + Annotations map[string]string `json:"annotations,omitempty" yaml:"annotations,omitempty"` + Created string `json:"created,omitempty" yaml:"created,omitempty"` + CreatorID string `json:"creatorId,omitempty" yaml:"creatorId,omitempty"` + FQDN string `json:"fqdn,omitempty" yaml:"fqdn,omitempty"` + Labels map[string]string `json:"labels,omitempty" yaml:"labels,omitempty"` + MultiClusterAppID string `json:"multiClusterAppId,omitempty" yaml:"multiClusterAppId,omitempty"` + Name string `json:"name,omitempty" yaml:"name,omitempty"` + OwnerReferences []OwnerReference `json:"ownerReferences,omitempty" yaml:"ownerReferences,omitempty"` + ProjectIDs []string `json:"projectIds,omitempty" yaml:"projectIds,omitempty"` + ProviderID string `json:"providerId,omitempty" yaml:"providerId,omitempty"` + Removed string `json:"removed,omitempty" yaml:"removed,omitempty"` + State string `json:"state,omitempty" yaml:"state,omitempty"` + Status *GlobalDNSStatus `json:"status,omitempty" yaml:"status,omitempty"` + Transitioning string `json:"transitioning,omitempty" yaml:"transitioning,omitempty"` + TransitioningMessage string `json:"transitioningMessage,omitempty" yaml:"transitioningMessage,omitempty"` + UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"` +} + +type GlobalDNSCollection struct { + types.Collection + Data []GlobalDNS `json:"data,omitempty"` + client *GlobalDNSClient +} + +type GlobalDNSClient struct { + apiClient *Client +} + +type GlobalDNSOperations interface { + List(opts *types.ListOpts) (*GlobalDNSCollection, error) + Create(opts *GlobalDNS) (*GlobalDNS, error) + Update(existing *GlobalDNS, updates interface{}) (*GlobalDNS, error) + Replace(existing *GlobalDNS) (*GlobalDNS, error) + ByID(id string) (*GlobalDNS, error) + Delete(container *GlobalDNS) error +} + +func newGlobalDNSClient(apiClient *Client) *GlobalDNSClient { + return &GlobalDNSClient{ + apiClient: apiClient, + } +} + +func (c *GlobalDNSClient) Create(container *GlobalDNS) (*GlobalDNS, error) { + resp := &GlobalDNS{} + err := c.apiClient.Ops.DoCreate(GlobalDNSType, container, resp) + return resp, err +} + +func (c *GlobalDNSClient) Update(existing *GlobalDNS, updates interface{}) (*GlobalDNS, error) { + resp := &GlobalDNS{} + err := c.apiClient.Ops.DoUpdate(GlobalDNSType, &existing.Resource, updates, resp) + return resp, err +} + +func (c *GlobalDNSClient) Replace(obj *GlobalDNS) (*GlobalDNS, error) { + resp := &GlobalDNS{} + err := c.apiClient.Ops.DoReplace(GlobalDNSType, &obj.Resource, obj, resp) + return resp, err +} + +func (c *GlobalDNSClient) List(opts *types.ListOpts) (*GlobalDNSCollection, error) { + resp := &GlobalDNSCollection{} + err := c.apiClient.Ops.DoList(GlobalDNSType, opts, resp) + resp.client = c + return resp, err +} + +func (cc *GlobalDNSCollection) Next() (*GlobalDNSCollection, error) { + if cc != nil && cc.Pagination != nil && cc.Pagination.Next != "" { + resp := &GlobalDNSCollection{} + err := cc.client.apiClient.Ops.DoNext(cc.Pagination.Next, resp) + resp.client = cc.client + return resp, err + } + return nil, nil +} + +func (c *GlobalDNSClient) ByID(id string) (*GlobalDNS, error) { + resp := &GlobalDNS{} + err := c.apiClient.Ops.DoByID(GlobalDNSType, id, resp) + return resp, err +} + +func (c *GlobalDNSClient) Delete(container *GlobalDNS) error { + return c.apiClient.Ops.DoResourceDelete(GlobalDNSType, &container.Resource) +} diff --git a/client/management/v3/zz_generated_global_dns_provider.go b/client/management/v3/zz_generated_global_dns_provider.go new file mode 100644 index 00000000..0a9a5eaa --- /dev/null +++ b/client/management/v3/zz_generated_global_dns_provider.go @@ -0,0 +1,101 @@ +package client + +import ( + "github.com/rancher/norman/types" +) + +const ( + GlobalDNSProviderType = "globalDnsProvider" + GlobalDNSProviderFieldAnnotations = "annotations" + GlobalDNSProviderFieldCreated = "created" + GlobalDNSProviderFieldCreatorID = "creatorId" + GlobalDNSProviderFieldLabels = "labels" + GlobalDNSProviderFieldName = "name" + GlobalDNSProviderFieldOwnerReferences = "ownerReferences" + GlobalDNSProviderFieldRemoved = "removed" + GlobalDNSProviderFieldRoute53ProviderConfig = "route53ProviderConfig" + GlobalDNSProviderFieldUUID = "uuid" +) + +type GlobalDNSProvider struct { + types.Resource + Annotations map[string]string `json:"annotations,omitempty" yaml:"annotations,omitempty"` + Created string `json:"created,omitempty" yaml:"created,omitempty"` + CreatorID string `json:"creatorId,omitempty" yaml:"creatorId,omitempty"` + Labels map[string]string `json:"labels,omitempty" yaml:"labels,omitempty"` + Name string `json:"name,omitempty" yaml:"name,omitempty"` + OwnerReferences []OwnerReference `json:"ownerReferences,omitempty" yaml:"ownerReferences,omitempty"` + Removed string `json:"removed,omitempty" yaml:"removed,omitempty"` + Route53ProviderConfig *Route53ProviderConfig `json:"route53ProviderConfig,omitempty" yaml:"route53ProviderConfig,omitempty"` + UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"` +} + +type GlobalDNSProviderCollection struct { + types.Collection + Data []GlobalDNSProvider `json:"data,omitempty"` + client *GlobalDNSProviderClient +} + +type GlobalDNSProviderClient struct { + apiClient *Client +} + +type GlobalDNSProviderOperations interface { + List(opts *types.ListOpts) (*GlobalDNSProviderCollection, error) + Create(opts *GlobalDNSProvider) (*GlobalDNSProvider, error) + Update(existing *GlobalDNSProvider, updates interface{}) (*GlobalDNSProvider, error) + Replace(existing *GlobalDNSProvider) (*GlobalDNSProvider, error) + ByID(id string) (*GlobalDNSProvider, error) + Delete(container *GlobalDNSProvider) error +} + +func newGlobalDNSProviderClient(apiClient *Client) *GlobalDNSProviderClient { + return &GlobalDNSProviderClient{ + apiClient: apiClient, + } +} + +func (c *GlobalDNSProviderClient) Create(container *GlobalDNSProvider) (*GlobalDNSProvider, error) { + resp := &GlobalDNSProvider{} + err := c.apiClient.Ops.DoCreate(GlobalDNSProviderType, container, resp) + return resp, err +} + +func (c *GlobalDNSProviderClient) Update(existing *GlobalDNSProvider, updates interface{}) (*GlobalDNSProvider, error) { + resp := &GlobalDNSProvider{} + err := c.apiClient.Ops.DoUpdate(GlobalDNSProviderType, &existing.Resource, updates, resp) + return resp, err +} + +func (c *GlobalDNSProviderClient) Replace(obj *GlobalDNSProvider) (*GlobalDNSProvider, error) { + resp := &GlobalDNSProvider{} + err := c.apiClient.Ops.DoReplace(GlobalDNSProviderType, &obj.Resource, obj, resp) + return resp, err +} + +func (c *GlobalDNSProviderClient) List(opts *types.ListOpts) (*GlobalDNSProviderCollection, error) { + resp := &GlobalDNSProviderCollection{} + err := c.apiClient.Ops.DoList(GlobalDNSProviderType, opts, resp) + resp.client = c + return resp, err +} + +func (cc *GlobalDNSProviderCollection) Next() (*GlobalDNSProviderCollection, error) { + if cc != nil && cc.Pagination != nil && cc.Pagination.Next != "" { + resp := &GlobalDNSProviderCollection{} + err := cc.client.apiClient.Ops.DoNext(cc.Pagination.Next, resp) + resp.client = cc.client + return resp, err + } + return nil, nil +} + +func (c *GlobalDNSProviderClient) ByID(id string) (*GlobalDNSProvider, error) { + resp := &GlobalDNSProvider{} + err := c.apiClient.Ops.DoByID(GlobalDNSProviderType, id, resp) + return resp, err +} + +func (c *GlobalDNSProviderClient) Delete(container *GlobalDNSProvider) error { + return c.apiClient.Ops.DoResourceDelete(GlobalDNSProviderType, &container.Resource) +} diff --git a/client/management/v3/zz_generated_global_dns_provider_spec.go b/client/management/v3/zz_generated_global_dns_provider_spec.go new file mode 100644 index 00000000..f1733990 --- /dev/null +++ b/client/management/v3/zz_generated_global_dns_provider_spec.go @@ -0,0 +1,10 @@ +package client + +const ( + GlobalDNSProviderSpecType = "globalDnsProviderSpec" + GlobalDNSProviderSpecFieldRoute53ProviderConfig = "route53ProviderConfig" +) + +type GlobalDNSProviderSpec struct { + Route53ProviderConfig *Route53ProviderConfig `json:"route53ProviderConfig,omitempty" yaml:"route53ProviderConfig,omitempty"` +} diff --git a/client/management/v3/zz_generated_global_dns_spec.go b/client/management/v3/zz_generated_global_dns_spec.go new file mode 100644 index 00000000..1d9886ea --- /dev/null +++ b/client/management/v3/zz_generated_global_dns_spec.go @@ -0,0 +1,16 @@ +package client + +const ( + GlobalDNSSpecType = "globalDnsSpec" + GlobalDNSSpecFieldFQDN = "fqdn" + GlobalDNSSpecFieldMultiClusterAppID = "multiClusterAppId" + GlobalDNSSpecFieldProjectIDs = "projectIds" + GlobalDNSSpecFieldProviderID = "providerId" +) + +type GlobalDNSSpec struct { + FQDN string `json:"fqdn,omitempty" yaml:"fqdn,omitempty"` + MultiClusterAppID string `json:"multiClusterAppId,omitempty" yaml:"multiClusterAppId,omitempty"` + ProjectIDs []string `json:"projectIds,omitempty" yaml:"projectIds,omitempty"` + ProviderID string `json:"providerId,omitempty" yaml:"providerId,omitempty"` +} diff --git a/client/management/v3/zz_generated_global_dns_status.go b/client/management/v3/zz_generated_global_dns_status.go new file mode 100644 index 00000000..7e178cd0 --- /dev/null +++ b/client/management/v3/zz_generated_global_dns_status.go @@ -0,0 +1,10 @@ +package client + +const ( + GlobalDNSStatusType = "globalDnsStatus" + GlobalDNSStatusFieldEndpoints = "endpoints" +) + +type GlobalDNSStatus struct { + Endpoints []string `json:"endpoints,omitempty" yaml:"endpoints,omitempty"` +} diff --git a/client/management/v3/zz_generated_route53provider_config.go b/client/management/v3/zz_generated_route53provider_config.go new file mode 100644 index 00000000..d37000cc --- /dev/null +++ b/client/management/v3/zz_generated_route53provider_config.go @@ -0,0 +1,14 @@ +package client + +const ( + Route53ProviderConfigType = "route53ProviderConfig" + Route53ProviderConfigFieldAccessKey = "accessKey" + Route53ProviderConfigFieldRootDomain = "rootDomain" + Route53ProviderConfigFieldSecretKey = "secretKey" +) + +type Route53ProviderConfig struct { + AccessKey string `json:"accessKey,omitempty" yaml:"accessKey,omitempty"` + RootDomain string `json:"rootDomain,omitempty" yaml:"rootDomain,omitempty"` + SecretKey string `json:"secretKey,omitempty" yaml:"secretKey,omitempty"` +} diff --git a/compose/zz_generated_compose.go b/compose/zz_generated_compose.go index b886386b..159b3cb5 100644 --- a/compose/zz_generated_compose.go +++ b/compose/zz_generated_compose.go @@ -45,6 +45,8 @@ type Config struct { ProjectCatalogs map[string]managementClient.ProjectCatalog `json:"projectCatalogs,omitempty" yaml:"projectCatalogs,omitempty"` ClusterCatalogs map[string]managementClient.ClusterCatalog `json:"clusterCatalogs,omitempty" yaml:"clusterCatalogs,omitempty"` MultiClusterApps map[string]managementClient.MultiClusterApp `json:"multiClusterApps,omitempty" yaml:"multiClusterApps,omitempty"` + GlobalDNSs map[string]managementClient.GlobalDNS `json:"globalDnses,omitempty" yaml:"globalDnses,omitempty"` + GlobalDNSProviders map[string]managementClient.GlobalDNSProvider `json:"globalDnsProviders,omitempty" yaml:"globalDnsProviders,omitempty"` // Cluster Client Namespaces map[string]clusterClient.Namespace `json:"namespaces,omitempty" yaml:"namespaces,omitempty"`