1
0
mirror of https://github.com/rancher/types.git synced 2025-09-25 12:21:24 +00:00

go generate

This commit is contained in:
kinarashah
2019-01-10 11:49:02 -08:00
committed by Alena Prokharchyk
parent 167329b41c
commit fb9250553f
15 changed files with 839 additions and 13 deletions

View File

@@ -1,6 +1,7 @@
package v3
import (
projectcattleiov3 "github.com/rancher/types/apis/project.cattle.io/v3"
v1 "k8s.io/api/core/v1"
rbacv1 "k8s.io/api/rbac/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
@@ -3891,7 +3892,7 @@ func (in *MultiClusterApp) DeepCopyInto(out *MultiClusterApp) {
out.TypeMeta = in.TypeMeta
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
in.Spec.DeepCopyInto(&out.Spec)
out.Status = in.Status
in.Status.DeepCopyInto(&out.Status)
return
}
@@ -3946,6 +3947,89 @@ func (in *MultiClusterAppList) DeepCopyObject() runtime.Object {
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *MultiClusterAppRevision) DeepCopyInto(out *MultiClusterAppRevision) {
*out = *in
out.Namespaced = in.Namespaced
out.TypeMeta = in.TypeMeta
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
if in.Answers != nil {
in, out := &in.Answers, &out.Answers
*out = make([]Answer, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MultiClusterAppRevision.
func (in *MultiClusterAppRevision) DeepCopy() *MultiClusterAppRevision {
if in == nil {
return nil
}
out := new(MultiClusterAppRevision)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *MultiClusterAppRevision) 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 *MultiClusterAppRevisionList) DeepCopyInto(out *MultiClusterAppRevisionList) {
*out = *in
out.TypeMeta = in.TypeMeta
out.ListMeta = in.ListMeta
if in.Items != nil {
in, out := &in.Items, &out.Items
*out = make([]MultiClusterAppRevision, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MultiClusterAppRevisionList.
func (in *MultiClusterAppRevisionList) DeepCopy() *MultiClusterAppRevisionList {
if in == nil {
return nil
}
out := new(MultiClusterAppRevisionList)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *MultiClusterAppRevisionList) 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 *MultiClusterAppRollbackInput) DeepCopyInto(out *MultiClusterAppRollbackInput) {
*out = *in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MultiClusterAppRollbackInput.
func (in *MultiClusterAppRollbackInput) DeepCopy() *MultiClusterAppRollbackInput {
if in == nil {
return nil
}
out := new(MultiClusterAppRollbackInput)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *MultiClusterAppSpec) DeepCopyInto(out *MultiClusterAppSpec) {
*out = *in
@@ -3966,6 +4050,7 @@ func (in *MultiClusterAppSpec) DeepCopyInto(out *MultiClusterAppSpec) {
*out = make([]Member, len(*in))
copy(*out, *in)
}
in.UpgradeStrategy.DeepCopyInto(&out.UpgradeStrategy)
return
}
@@ -3982,6 +4067,11 @@ func (in *MultiClusterAppSpec) DeepCopy() *MultiClusterAppSpec {
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *MultiClusterAppStatus) DeepCopyInto(out *MultiClusterAppStatus) {
*out = *in
if in.Conditions != nil {
in, out := &in.Conditions, &out.Conditions
*out = make([]projectcattleiov3.AppCondition, len(*in))
copy(*out, *in)
}
return
}
@@ -6748,6 +6838,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 *RollingUpdate) DeepCopyInto(out *RollingUpdate) {
*out = *in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RollingUpdate.
func (in *RollingUpdate) DeepCopy() *RollingUpdate {
if in == nil {
return nil
}
out := new(RollingUpdate)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *RotateCertificateInput) DeepCopyInto(out *RotateCertificateInput) {
*out = *in
@@ -7632,6 +7738,27 @@ func (in *TokenList) DeepCopyObject() runtime.Object {
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *UpgradeStrategy) DeepCopyInto(out *UpgradeStrategy) {
*out = *in
if in.RollingUpdate != nil {
in, out := &in.RollingUpdate, &out.RollingUpdate
*out = new(RollingUpdate)
**out = **in
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpgradeStrategy.
func (in *UpgradeStrategy) DeepCopy() *UpgradeStrategy {
if in == nil {
return nil
}
out := new(UpgradeStrategy)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *User) DeepCopyInto(out *User) {
*out = *in

View File

@@ -64,6 +64,7 @@ type Interface interface {
ProjectCatalogsGetter
ClusterCatalogsGetter
MultiClusterAppsGetter
MultiClusterAppRevisionsGetter
GlobalDNSsGetter
GlobalDNSProvidersGetter
KontainerDriversGetter
@@ -120,6 +121,7 @@ type Clients struct {
ProjectCatalog ProjectCatalogClient
ClusterCatalog ClusterCatalogClient
MultiClusterApp MultiClusterAppClient
MultiClusterAppRevision MultiClusterAppRevisionClient
GlobalDNS GlobalDNSClient
GlobalDNSProvider GlobalDNSProviderClient
KontainerDriver KontainerDriverClient
@@ -178,6 +180,7 @@ type Client struct {
projectCatalogControllers map[string]ProjectCatalogController
clusterCatalogControllers map[string]ClusterCatalogController
multiClusterAppControllers map[string]MultiClusterAppController
multiClusterAppRevisionControllers map[string]MultiClusterAppRevisionController
globalDnsControllers map[string]GlobalDNSController
globalDnsProviderControllers map[string]GlobalDNSProviderController
kontainerDriverControllers map[string]KontainerDriverController
@@ -352,6 +355,9 @@ func NewClientsFromInterface(iface Interface) *Clients {
MultiClusterApp: &multiClusterAppClient2{
iface: iface.MultiClusterApps(""),
},
MultiClusterAppRevision: &multiClusterAppRevisionClient2{
iface: iface.MultiClusterAppRevisions(""),
},
GlobalDNS: &globalDnsClient2{
iface: iface.GlobalDNSs(""),
},
@@ -433,6 +439,7 @@ func NewForConfig(config rest.Config) (Interface, error) {
projectCatalogControllers: map[string]ProjectCatalogController{},
clusterCatalogControllers: map[string]ClusterCatalogController{},
multiClusterAppControllers: map[string]MultiClusterAppController{},
multiClusterAppRevisionControllers: map[string]MultiClusterAppRevisionController{},
globalDnsControllers: map[string]GlobalDNSController{},
globalDnsProviderControllers: map[string]GlobalDNSProviderController{},
kontainerDriverControllers: map[string]KontainerDriverController{},
@@ -1027,6 +1034,19 @@ func (c *Client) MultiClusterApps(namespace string) MultiClusterAppInterface {
}
}
type MultiClusterAppRevisionsGetter interface {
MultiClusterAppRevisions(namespace string) MultiClusterAppRevisionInterface
}
func (c *Client) MultiClusterAppRevisions(namespace string) MultiClusterAppRevisionInterface {
objectClient := objectclient.NewObjectClient(namespace, c.restClient, &MultiClusterAppRevisionResource, MultiClusterAppRevisionGroupVersionKind, multiClusterAppRevisionFactory{})
return &multiClusterAppRevisionClient{
ns: namespace,
client: c,
objectClient: objectClient,
}
}
type GlobalDNSsGetter interface {
GlobalDNSs(namespace string) GlobalDNSInterface
}

View File

@@ -0,0 +1,440 @@
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/types"
"k8s.io/apimachinery/pkg/watch"
"k8s.io/client-go/tools/cache"
)
var (
MultiClusterAppRevisionGroupVersionKind = schema.GroupVersionKind{
Version: Version,
Group: GroupName,
Kind: "MultiClusterAppRevision",
}
MultiClusterAppRevisionResource = metav1.APIResource{
Name: "multiclusterapprevisions",
SingularName: "multiclusterapprevision",
Namespaced: true,
Kind: MultiClusterAppRevisionGroupVersionKind.Kind,
}
)
func NewMultiClusterAppRevision(namespace, name string, obj MultiClusterAppRevision) *MultiClusterAppRevision {
obj.APIVersion, obj.Kind = MultiClusterAppRevisionGroupVersionKind.ToAPIVersionAndKind()
obj.Name = name
obj.Namespace = namespace
return &obj
}
type MultiClusterAppRevisionList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []MultiClusterAppRevision
}
type MultiClusterAppRevisionHandlerFunc func(key string, obj *MultiClusterAppRevision) (runtime.Object, error)
type MultiClusterAppRevisionChangeHandlerFunc func(obj *MultiClusterAppRevision) (runtime.Object, error)
type MultiClusterAppRevisionLister interface {
List(namespace string, selector labels.Selector) (ret []*MultiClusterAppRevision, err error)
Get(namespace, name string) (*MultiClusterAppRevision, error)
}
type MultiClusterAppRevisionController interface {
Generic() controller.GenericController
Informer() cache.SharedIndexInformer
Lister() MultiClusterAppRevisionLister
AddHandler(ctx context.Context, name string, handler MultiClusterAppRevisionHandlerFunc)
AddClusterScopedHandler(ctx context.Context, name, clusterName string, handler MultiClusterAppRevisionHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
}
type MultiClusterAppRevisionInterface interface {
ObjectClient() *objectclient.ObjectClient
Create(*MultiClusterAppRevision) (*MultiClusterAppRevision, error)
GetNamespaced(namespace, name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error)
Get(name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error)
Update(*MultiClusterAppRevision) (*MultiClusterAppRevision, error)
Delete(name string, options *metav1.DeleteOptions) error
DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error
List(opts metav1.ListOptions) (*MultiClusterAppRevisionList, error)
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() MultiClusterAppRevisionController
AddHandler(ctx context.Context, name string, sync MultiClusterAppRevisionHandlerFunc)
AddLifecycle(ctx context.Context, name string, lifecycle MultiClusterAppRevisionLifecycle)
AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync MultiClusterAppRevisionHandlerFunc)
AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle MultiClusterAppRevisionLifecycle)
}
type multiClusterAppRevisionLister struct {
controller *multiClusterAppRevisionController
}
func (l *multiClusterAppRevisionLister) List(namespace string, selector labels.Selector) (ret []*MultiClusterAppRevision, err error) {
err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
ret = append(ret, obj.(*MultiClusterAppRevision))
})
return
}
func (l *multiClusterAppRevisionLister) Get(namespace, name string) (*MultiClusterAppRevision, 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: MultiClusterAppRevisionGroupVersionKind.Group,
Resource: "multiClusterAppRevision",
}, key)
}
return obj.(*MultiClusterAppRevision), nil
}
type multiClusterAppRevisionController struct {
controller.GenericController
}
func (c *multiClusterAppRevisionController) Generic() controller.GenericController {
return c.GenericController
}
func (c *multiClusterAppRevisionController) Lister() MultiClusterAppRevisionLister {
return &multiClusterAppRevisionLister{
controller: c,
}
}
func (c *multiClusterAppRevisionController) AddHandler(ctx context.Context, name string, handler MultiClusterAppRevisionHandlerFunc) {
c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) {
if obj == nil {
return handler(key, nil)
} else if v, ok := obj.(*MultiClusterAppRevision); ok {
return handler(key, v)
} else {
return nil, nil
}
})
}
func (c *multiClusterAppRevisionController) AddClusterScopedHandler(ctx context.Context, name, cluster string, handler MultiClusterAppRevisionHandlerFunc) {
c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) {
if obj == nil {
return handler(key, nil)
} else if v, ok := obj.(*MultiClusterAppRevision); ok && controller.ObjectInCluster(cluster, obj) {
return handler(key, v)
} else {
return nil, nil
}
})
}
type multiClusterAppRevisionFactory struct {
}
func (c multiClusterAppRevisionFactory) Object() runtime.Object {
return &MultiClusterAppRevision{}
}
func (c multiClusterAppRevisionFactory) List() runtime.Object {
return &MultiClusterAppRevisionList{}
}
func (s *multiClusterAppRevisionClient) Controller() MultiClusterAppRevisionController {
s.client.Lock()
defer s.client.Unlock()
c, ok := s.client.multiClusterAppRevisionControllers[s.ns]
if ok {
return c
}
genericController := controller.NewGenericController(MultiClusterAppRevisionGroupVersionKind.Kind+"Controller",
s.objectClient)
c = &multiClusterAppRevisionController{
GenericController: genericController,
}
s.client.multiClusterAppRevisionControllers[s.ns] = c
s.client.starters = append(s.client.starters, c)
return c
}
type multiClusterAppRevisionClient struct {
client *Client
ns string
objectClient *objectclient.ObjectClient
controller MultiClusterAppRevisionController
}
func (s *multiClusterAppRevisionClient) ObjectClient() *objectclient.ObjectClient {
return s.objectClient
}
func (s *multiClusterAppRevisionClient) Create(o *MultiClusterAppRevision) (*MultiClusterAppRevision, error) {
obj, err := s.objectClient.Create(o)
return obj.(*MultiClusterAppRevision), err
}
func (s *multiClusterAppRevisionClient) Get(name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error) {
obj, err := s.objectClient.Get(name, opts)
return obj.(*MultiClusterAppRevision), err
}
func (s *multiClusterAppRevisionClient) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error) {
obj, err := s.objectClient.GetNamespaced(namespace, name, opts)
return obj.(*MultiClusterAppRevision), err
}
func (s *multiClusterAppRevisionClient) Update(o *MultiClusterAppRevision) (*MultiClusterAppRevision, error) {
obj, err := s.objectClient.Update(o.Name, o)
return obj.(*MultiClusterAppRevision), err
}
func (s *multiClusterAppRevisionClient) Delete(name string, options *metav1.DeleteOptions) error {
return s.objectClient.Delete(name, options)
}
func (s *multiClusterAppRevisionClient) DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error {
return s.objectClient.DeleteNamespaced(namespace, name, options)
}
func (s *multiClusterAppRevisionClient) List(opts metav1.ListOptions) (*MultiClusterAppRevisionList, error) {
obj, err := s.objectClient.List(opts)
return obj.(*MultiClusterAppRevisionList), err
}
func (s *multiClusterAppRevisionClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
return s.objectClient.Watch(opts)
}
// Patch applies the patch and returns the patched deployment.
func (s *multiClusterAppRevisionClient) Patch(o *MultiClusterAppRevision, patchType types.PatchType, data []byte, subresources ...string) (*MultiClusterAppRevision, error) {
obj, err := s.objectClient.Patch(o.Name, o, patchType, data, subresources...)
return obj.(*MultiClusterAppRevision), err
}
func (s *multiClusterAppRevisionClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *multiClusterAppRevisionClient) AddHandler(ctx context.Context, name string, sync MultiClusterAppRevisionHandlerFunc) {
s.Controller().AddHandler(ctx, name, sync)
}
func (s *multiClusterAppRevisionClient) AddLifecycle(ctx context.Context, name string, lifecycle MultiClusterAppRevisionLifecycle) {
sync := NewMultiClusterAppRevisionLifecycleAdapter(name, false, s, lifecycle)
s.Controller().AddHandler(ctx, name, sync)
}
func (s *multiClusterAppRevisionClient) AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync MultiClusterAppRevisionHandlerFunc) {
s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync)
}
func (s *multiClusterAppRevisionClient) AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle MultiClusterAppRevisionLifecycle) {
sync := NewMultiClusterAppRevisionLifecycleAdapter(name+"_"+clusterName, true, s, lifecycle)
s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync)
}
type MultiClusterAppRevisionIndexer func(obj *MultiClusterAppRevision) ([]string, error)
type MultiClusterAppRevisionClientCache interface {
Get(namespace, name string) (*MultiClusterAppRevision, error)
List(namespace string, selector labels.Selector) ([]*MultiClusterAppRevision, error)
Index(name string, indexer MultiClusterAppRevisionIndexer)
GetIndexed(name, key string) ([]*MultiClusterAppRevision, error)
}
type MultiClusterAppRevisionClient interface {
Create(*MultiClusterAppRevision) (*MultiClusterAppRevision, error)
Get(namespace, name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error)
Update(*MultiClusterAppRevision) (*MultiClusterAppRevision, error)
Delete(namespace, name string, options *metav1.DeleteOptions) error
List(namespace string, opts metav1.ListOptions) (*MultiClusterAppRevisionList, error)
Watch(opts metav1.ListOptions) (watch.Interface, error)
Cache() MultiClusterAppRevisionClientCache
OnCreate(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc)
OnChange(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc)
OnRemove(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc)
Enqueue(namespace, name string)
Generic() controller.GenericController
ObjectClient() *objectclient.ObjectClient
Interface() MultiClusterAppRevisionInterface
}
type multiClusterAppRevisionClientCache struct {
client *multiClusterAppRevisionClient2
}
type multiClusterAppRevisionClient2 struct {
iface MultiClusterAppRevisionInterface
controller MultiClusterAppRevisionController
}
func (n *multiClusterAppRevisionClient2) Interface() MultiClusterAppRevisionInterface {
return n.iface
}
func (n *multiClusterAppRevisionClient2) Generic() controller.GenericController {
return n.iface.Controller().Generic()
}
func (n *multiClusterAppRevisionClient2) ObjectClient() *objectclient.ObjectClient {
return n.Interface().ObjectClient()
}
func (n *multiClusterAppRevisionClient2) Enqueue(namespace, name string) {
n.iface.Controller().Enqueue(namespace, name)
}
func (n *multiClusterAppRevisionClient2) Create(obj *MultiClusterAppRevision) (*MultiClusterAppRevision, error) {
return n.iface.Create(obj)
}
func (n *multiClusterAppRevisionClient2) Get(namespace, name string, opts metav1.GetOptions) (*MultiClusterAppRevision, error) {
return n.iface.GetNamespaced(namespace, name, opts)
}
func (n *multiClusterAppRevisionClient2) Update(obj *MultiClusterAppRevision) (*MultiClusterAppRevision, error) {
return n.iface.Update(obj)
}
func (n *multiClusterAppRevisionClient2) Delete(namespace, name string, options *metav1.DeleteOptions) error {
return n.iface.DeleteNamespaced(namespace, name, options)
}
func (n *multiClusterAppRevisionClient2) List(namespace string, opts metav1.ListOptions) (*MultiClusterAppRevisionList, error) {
return n.iface.List(opts)
}
func (n *multiClusterAppRevisionClient2) Watch(opts metav1.ListOptions) (watch.Interface, error) {
return n.iface.Watch(opts)
}
func (n *multiClusterAppRevisionClientCache) Get(namespace, name string) (*MultiClusterAppRevision, error) {
return n.client.controller.Lister().Get(namespace, name)
}
func (n *multiClusterAppRevisionClientCache) List(namespace string, selector labels.Selector) ([]*MultiClusterAppRevision, error) {
return n.client.controller.Lister().List(namespace, selector)
}
func (n *multiClusterAppRevisionClient2) Cache() MultiClusterAppRevisionClientCache {
n.loadController()
return &multiClusterAppRevisionClientCache{
client: n,
}
}
func (n *multiClusterAppRevisionClient2) OnCreate(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc) {
n.loadController()
n.iface.AddLifecycle(ctx, name+"-create", &multiClusterAppRevisionLifecycleDelegate{create: sync})
}
func (n *multiClusterAppRevisionClient2) OnChange(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc) {
n.loadController()
n.iface.AddLifecycle(ctx, name+"-change", &multiClusterAppRevisionLifecycleDelegate{update: sync})
}
func (n *multiClusterAppRevisionClient2) OnRemove(ctx context.Context, name string, sync MultiClusterAppRevisionChangeHandlerFunc) {
n.loadController()
n.iface.AddLifecycle(ctx, name, &multiClusterAppRevisionLifecycleDelegate{remove: sync})
}
func (n *multiClusterAppRevisionClientCache) Index(name string, indexer MultiClusterAppRevisionIndexer) {
err := n.client.controller.Informer().GetIndexer().AddIndexers(map[string]cache.IndexFunc{
name: func(obj interface{}) ([]string, error) {
if v, ok := obj.(*MultiClusterAppRevision); ok {
return indexer(v)
}
return nil, nil
},
})
if err != nil {
panic(err)
}
}
func (n *multiClusterAppRevisionClientCache) GetIndexed(name, key string) ([]*MultiClusterAppRevision, error) {
var result []*MultiClusterAppRevision
objs, err := n.client.controller.Informer().GetIndexer().ByIndex(name, key)
if err != nil {
return nil, err
}
for _, obj := range objs {
if v, ok := obj.(*MultiClusterAppRevision); ok {
result = append(result, v)
}
}
return result, nil
}
func (n *multiClusterAppRevisionClient2) loadController() {
if n.controller == nil {
n.controller = n.iface.Controller()
}
}
type multiClusterAppRevisionLifecycleDelegate struct {
create MultiClusterAppRevisionChangeHandlerFunc
update MultiClusterAppRevisionChangeHandlerFunc
remove MultiClusterAppRevisionChangeHandlerFunc
}
func (n *multiClusterAppRevisionLifecycleDelegate) HasCreate() bool {
return n.create != nil
}
func (n *multiClusterAppRevisionLifecycleDelegate) Create(obj *MultiClusterAppRevision) (runtime.Object, error) {
if n.create == nil {
return obj, nil
}
return n.create(obj)
}
func (n *multiClusterAppRevisionLifecycleDelegate) HasFinalize() bool {
return n.remove != nil
}
func (n *multiClusterAppRevisionLifecycleDelegate) Remove(obj *MultiClusterAppRevision) (runtime.Object, error) {
if n.remove == nil {
return obj, nil
}
return n.remove(obj)
}
func (n *multiClusterAppRevisionLifecycleDelegate) Updated(obj *MultiClusterAppRevision) (runtime.Object, error) {
if n.update == nil {
return obj, nil
}
return n.update(obj)
}

View File

@@ -0,0 +1,62 @@
package v3
import (
"github.com/rancher/norman/lifecycle"
"k8s.io/apimachinery/pkg/runtime"
)
type MultiClusterAppRevisionLifecycle interface {
Create(obj *MultiClusterAppRevision) (runtime.Object, error)
Remove(obj *MultiClusterAppRevision) (runtime.Object, error)
Updated(obj *MultiClusterAppRevision) (runtime.Object, error)
}
type multiClusterAppRevisionLifecycleAdapter struct {
lifecycle MultiClusterAppRevisionLifecycle
}
func (w *multiClusterAppRevisionLifecycleAdapter) HasCreate() bool {
o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition)
return !ok || o.HasCreate()
}
func (w *multiClusterAppRevisionLifecycleAdapter) HasFinalize() bool {
o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition)
return !ok || o.HasFinalize()
}
func (w *multiClusterAppRevisionLifecycleAdapter) Create(obj runtime.Object) (runtime.Object, error) {
o, err := w.lifecycle.Create(obj.(*MultiClusterAppRevision))
if o == nil {
return nil, err
}
return o, err
}
func (w *multiClusterAppRevisionLifecycleAdapter) Finalize(obj runtime.Object) (runtime.Object, error) {
o, err := w.lifecycle.Remove(obj.(*MultiClusterAppRevision))
if o == nil {
return nil, err
}
return o, err
}
func (w *multiClusterAppRevisionLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error) {
o, err := w.lifecycle.Updated(obj.(*MultiClusterAppRevision))
if o == nil {
return nil, err
}
return o, err
}
func NewMultiClusterAppRevisionLifecycleAdapter(name string, clusterScoped bool, client MultiClusterAppRevisionInterface, l MultiClusterAppRevisionLifecycle) MultiClusterAppRevisionHandlerFunc {
adapter := &multiClusterAppRevisionLifecycleAdapter{lifecycle: l}
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
return func(key string, obj *MultiClusterAppRevision) (runtime.Object, error) {
newObj, err := syncFn(key, obj)
if o, ok := newObj.(runtime.Object); ok {
return o, err
}
return nil, err
}
}

View File

@@ -120,6 +120,8 @@ func addKnownTypes(scheme *runtime.Scheme) error {
&ClusterCatalogList{},
&MultiClusterApp{},
&MultiClusterAppList{},
&MultiClusterAppRevision{},
&MultiClusterAppRevisionList{},
&GlobalDNS{},
&GlobalDNSList{},
&GlobalDNSProvider{},