mirror of
https://github.com/rancher/types.git
synced 2025-08-27 08:18:24 +00:00
generated changes for GlobalDNS
This commit is contained in:
Prachi Damle
Alena Prokharchyk
parent
9244fec8ed
commit
2679cafa40
@ -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
|
||||
|
||||
@ -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)
|
||||
}
|
||||
@ -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
|
||||
}
|
||||
}
|
||||
@ -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)
|
||||
}
|
||||
@ -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
|
||||
}
|
||||
}
|
||||
@ -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,
|
||||
}
|
||||
}
|
||||
|
||||
@ -112,6 +112,10 @@ func addKnownTypes(scheme *runtime.Scheme) error {
|
||||
&ClusterCatalogList{},
|
||||
&MultiClusterApp{},
|
||||
&MultiClusterAppList{},
|
||||
&GlobalDNS{},
|
||||
&GlobalDNSList{},
|
||||
&GlobalDNSProvider{},
|
||||
&GlobalDNSProviderList{},
|
||||
)
|
||||
return nil
|
||||
}
|
||||
|
||||
@ -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
|
||||
}
|
||||
|
||||
115
client/management/v3/zz_generated_global_dns.go
Normal file
115
client/management/v3/zz_generated_global_dns.go
Normal file
@ -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)
|
||||
}
|
||||
101
client/management/v3/zz_generated_global_dns_provider.go
Normal file
101
client/management/v3/zz_generated_global_dns_provider.go
Normal file
@ -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)
|
||||
}
|
||||
@ -0,0 +1,10 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
GlobalDNSProviderSpecType = "globalDnsProviderSpec"
|
||||
GlobalDNSProviderSpecFieldRoute53ProviderConfig = "route53ProviderConfig"
|
||||
)
|
||||
|
||||
type GlobalDNSProviderSpec struct {
|
||||
Route53ProviderConfig *Route53ProviderConfig `json:"route53ProviderConfig,omitempty" yaml:"route53ProviderConfig,omitempty"`
|
||||
}
|
||||
16
client/management/v3/zz_generated_global_dns_spec.go
Normal file
16
client/management/v3/zz_generated_global_dns_spec.go
Normal file
@ -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"`
|
||||
}
|
||||
10
client/management/v3/zz_generated_global_dns_status.go
Normal file
10
client/management/v3/zz_generated_global_dns_status.go
Normal file
@ -0,0 +1,10 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
GlobalDNSStatusType = "globalDnsStatus"
|
||||
GlobalDNSStatusFieldEndpoints = "endpoints"
|
||||
)
|
||||
|
||||
type GlobalDNSStatus struct {
|
||||
Endpoints []string `json:"endpoints,omitempty" yaml:"endpoints,omitempty"`
|
||||
}
|
||||
14
client/management/v3/zz_generated_route53provider_config.go
Normal file
14
client/management/v3/zz_generated_route53provider_config.go
Normal file
@ -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"`
|
||||
}
|
||||
@ -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"`
|
||||
|
||||
Loading…
Reference in New Issue
Block a user