mirror of
https://github.com/rancher/types.git
synced 2025-09-01 05:09:10 +00:00
Go generate
This commit is contained in:
committed by
Craig Jellick
parent
400a07bd51
commit
3775fd11c9
@@ -171,37 +171,6 @@ func (in *AlertSystemImages) DeepCopy() *AlertSystemImages {
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *AmazonElasticContainerServiceConfig) DeepCopyInto(out *AmazonElasticContainerServiceConfig) {
|
||||
*out = *in
|
||||
if in.Subnets != nil {
|
||||
in, out := &in.Subnets, &out.Subnets
|
||||
*out = make([]string, len(*in))
|
||||
copy(*out, *in)
|
||||
}
|
||||
if in.SecurityGroups != nil {
|
||||
in, out := &in.SecurityGroups, &out.SecurityGroups
|
||||
*out = make([]string, len(*in))
|
||||
copy(*out, *in)
|
||||
}
|
||||
if in.AssociateWorkerNodePublicIP != nil {
|
||||
in, out := &in.AssociateWorkerNodePublicIP, &out.AssociateWorkerNodePublicIP
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AmazonElasticContainerServiceConfig.
|
||||
func (in *AmazonElasticContainerServiceConfig) DeepCopy() *AmazonElasticContainerServiceConfig {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(AmazonElasticContainerServiceConfig)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *Answer) DeepCopyInto(out *Answer) {
|
||||
*out = *in
|
||||
@@ -416,29 +385,6 @@ func (in *AzureCloudProvider) DeepCopy() *AzureCloudProvider {
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *AzureKubernetesServiceConfig) DeepCopyInto(out *AzureKubernetesServiceConfig) {
|
||||
*out = *in
|
||||
if in.Tag != nil {
|
||||
in, out := &in.Tag, &out.Tag
|
||||
*out = make(map[string]string, len(*in))
|
||||
for key, val := range *in {
|
||||
(*out)[key] = val
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureKubernetesServiceConfig.
|
||||
func (in *AzureKubernetesServiceConfig) DeepCopy() *AzureKubernetesServiceConfig {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(AzureKubernetesServiceConfig)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *BaseService) DeepCopyInto(out *BaseService) {
|
||||
*out = *in
|
||||
@@ -1253,13 +1199,11 @@ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec) {
|
||||
}
|
||||
if in.GoogleKubernetesEngineConfig != nil {
|
||||
in, out := &in.GoogleKubernetesEngineConfig, &out.GoogleKubernetesEngineConfig
|
||||
*out = new(GoogleKubernetesEngineConfig)
|
||||
(*in).DeepCopyInto(*out)
|
||||
*out = (*in).DeepCopy()
|
||||
}
|
||||
if in.AzureKubernetesServiceConfig != nil {
|
||||
in, out := &in.AzureKubernetesServiceConfig, &out.AzureKubernetesServiceConfig
|
||||
*out = new(AzureKubernetesServiceConfig)
|
||||
(*in).DeepCopyInto(*out)
|
||||
*out = (*in).DeepCopy()
|
||||
}
|
||||
if in.RancherKubernetesEngineConfig != nil {
|
||||
in, out := &in.RancherKubernetesEngineConfig, &out.RancherKubernetesEngineConfig
|
||||
@@ -1268,8 +1212,11 @@ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec) {
|
||||
}
|
||||
if in.AmazonElasticContainerServiceConfig != nil {
|
||||
in, out := &in.AmazonElasticContainerServiceConfig, &out.AmazonElasticContainerServiceConfig
|
||||
*out = new(AmazonElasticContainerServiceConfig)
|
||||
(*in).DeepCopyInto(*out)
|
||||
*out = (*in).DeepCopy()
|
||||
}
|
||||
if in.GenericEngineConfig != nil {
|
||||
in, out := &in.GenericEngineConfig, &out.GenericEngineConfig
|
||||
*out = (*in).DeepCopy()
|
||||
}
|
||||
if in.EnableNetworkPolicy != nil {
|
||||
in, out := &in.EnableNetworkPolicy, &out.EnableNetworkPolicy
|
||||
@@ -2329,59 +2276,6 @@ func (in *GlobalVsphereOpts) DeepCopy() *GlobalVsphereOpts {
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *GoogleKubernetesEngineConfig) DeepCopyInto(out *GoogleKubernetesEngineConfig) {
|
||||
*out = *in
|
||||
if in.Labels != nil {
|
||||
in, out := &in.Labels, &out.Labels
|
||||
*out = make(map[string]string, len(*in))
|
||||
for key, val := range *in {
|
||||
(*out)[key] = val
|
||||
}
|
||||
}
|
||||
if in.EnableHTTPLoadBalancing != nil {
|
||||
in, out := &in.EnableHTTPLoadBalancing, &out.EnableHTTPLoadBalancing
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
if in.EnableHorizontalPodAutoscaling != nil {
|
||||
in, out := &in.EnableHorizontalPodAutoscaling, &out.EnableHorizontalPodAutoscaling
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
if in.EnableNetworkPolicyConfig != nil {
|
||||
in, out := &in.EnableNetworkPolicyConfig, &out.EnableNetworkPolicyConfig
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
if in.Locations != nil {
|
||||
in, out := &in.Locations, &out.Locations
|
||||
*out = make([]string, len(*in))
|
||||
copy(*out, *in)
|
||||
}
|
||||
if in.EnableStackdriverLogging != nil {
|
||||
in, out := &in.EnableStackdriverLogging, &out.EnableStackdriverLogging
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
if in.EnableStackdriverMonitoring != nil {
|
||||
in, out := &in.EnableStackdriverMonitoring, &out.EnableStackdriverMonitoring
|
||||
*out = new(bool)
|
||||
**out = **in
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GoogleKubernetesEngineConfig.
|
||||
func (in *GoogleKubernetesEngineConfig) DeepCopy() *GoogleKubernetesEngineConfig {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(GoogleKubernetesEngineConfig)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *Group) DeepCopyInto(out *Group) {
|
||||
*out = *in
|
||||
@@ -2663,6 +2557,109 @@ func (in *KeyCloakConfig) DeepCopyObject() runtime.Object {
|
||||
return nil
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *KontainerDriver) DeepCopyInto(out *KontainerDriver) {
|
||||
*out = *in
|
||||
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 KontainerDriver.
|
||||
func (in *KontainerDriver) DeepCopy() *KontainerDriver {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(KontainerDriver)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
||||
func (in *KontainerDriver) 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 *KontainerDriverList) DeepCopyInto(out *KontainerDriverList) {
|
||||
*out = *in
|
||||
out.TypeMeta = in.TypeMeta
|
||||
out.ListMeta = in.ListMeta
|
||||
if in.Items != nil {
|
||||
in, out := &in.Items, &out.Items
|
||||
*out = make([]KontainerDriver, len(*in))
|
||||
for i := range *in {
|
||||
(*in)[i].DeepCopyInto(&(*out)[i])
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KontainerDriverList.
|
||||
func (in *KontainerDriverList) DeepCopy() *KontainerDriverList {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(KontainerDriverList)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
||||
func (in *KontainerDriverList) 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 *KontainerDriverSpec) DeepCopyInto(out *KontainerDriverSpec) {
|
||||
*out = *in
|
||||
if in.WhitelistDomains != nil {
|
||||
in, out := &in.WhitelistDomains, &out.WhitelistDomains
|
||||
*out = make([]string, len(*in))
|
||||
copy(*out, *in)
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KontainerDriverSpec.
|
||||
func (in *KontainerDriverSpec) DeepCopy() *KontainerDriverSpec {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(KontainerDriverSpec)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *KontainerDriverStatus) DeepCopyInto(out *KontainerDriverStatus) {
|
||||
*out = *in
|
||||
if in.Conditions != nil {
|
||||
in, out := &in.Conditions, &out.Conditions
|
||||
*out = make([]Condition, len(*in))
|
||||
copy(*out, *in)
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KontainerDriverStatus.
|
||||
func (in *KontainerDriverStatus) DeepCopy() *KontainerDriverStatus {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(KontainerDriverStatus)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *KubeAPIService) DeepCopyInto(out *KubeAPIService) {
|
||||
*out = *in
|
||||
@@ -3125,6 +3122,16 @@ func (in *LoggingSystemImages) DeepCopy() *LoggingSystemImages {
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in MapStringInterface) DeepCopyInto(out *MapStringInterface) {
|
||||
{
|
||||
in := &in
|
||||
clone := in.DeepCopy()
|
||||
*out = *clone
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *MetadataOpenstackOpts) DeepCopyInto(out *MetadataOpenstackOpts) {
|
||||
*out = *in
|
||||
|
@@ -62,6 +62,7 @@ type Interface interface {
|
||||
MultiClusterAppsGetter
|
||||
GlobalDNSsGetter
|
||||
GlobalDNSProvidersGetter
|
||||
KontainerDriversGetter
|
||||
}
|
||||
|
||||
type Clients struct {
|
||||
@@ -107,6 +108,7 @@ type Clients struct {
|
||||
MultiClusterApp MultiClusterAppClient
|
||||
GlobalDNS GlobalDNSClient
|
||||
GlobalDNSProvider GlobalDNSProviderClient
|
||||
KontainerDriver KontainerDriverClient
|
||||
}
|
||||
|
||||
type Client struct {
|
||||
@@ -156,6 +158,7 @@ type Client struct {
|
||||
multiClusterAppControllers map[string]MultiClusterAppController
|
||||
globalDnsControllers map[string]GlobalDNSController
|
||||
globalDnsProviderControllers map[string]GlobalDNSProviderController
|
||||
kontainerDriverControllers map[string]KontainerDriverController
|
||||
}
|
||||
|
||||
func Factory(ctx context.Context, config rest.Config) (context.Context, controller.Starter, error) {
|
||||
@@ -316,6 +319,9 @@ func NewClientsFromInterface(iface Interface) *Clients {
|
||||
GlobalDNSProvider: &globalDnsProviderClient2{
|
||||
iface: iface.GlobalDNSProviders(""),
|
||||
},
|
||||
KontainerDriver: &kontainerDriverClient2{
|
||||
iface: iface.KontainerDrivers(""),
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
@@ -374,6 +380,7 @@ func NewForConfig(config rest.Config) (Interface, error) {
|
||||
multiClusterAppControllers: map[string]MultiClusterAppController{},
|
||||
globalDnsControllers: map[string]GlobalDNSController{},
|
||||
globalDnsProviderControllers: map[string]GlobalDNSProviderController{},
|
||||
kontainerDriverControllers: map[string]KontainerDriverController{},
|
||||
}, nil
|
||||
}
|
||||
|
||||
@@ -934,3 +941,16 @@ func (c *Client) GlobalDNSProviders(namespace string) GlobalDNSProviderInterface
|
||||
objectClient: objectClient,
|
||||
}
|
||||
}
|
||||
|
||||
type KontainerDriversGetter interface {
|
||||
KontainerDrivers(namespace string) KontainerDriverInterface
|
||||
}
|
||||
|
||||
func (c *Client) KontainerDrivers(namespace string) KontainerDriverInterface {
|
||||
objectClient := objectclient.NewObjectClient(namespace, c.restClient, &KontainerDriverResource, KontainerDriverGroupVersionKind, kontainerDriverFactory{})
|
||||
return &kontainerDriverClient{
|
||||
ns: namespace,
|
||||
client: c,
|
||||
objectClient: objectClient,
|
||||
}
|
||||
}
|
||||
|
@@ -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 (
|
||||
KontainerDriverGroupVersionKind = schema.GroupVersionKind{
|
||||
Version: Version,
|
||||
Group: GroupName,
|
||||
Kind: "KontainerDriver",
|
||||
}
|
||||
KontainerDriverResource = metav1.APIResource{
|
||||
Name: "kontainerdrivers",
|
||||
SingularName: "kontainerdriver",
|
||||
Namespaced: false,
|
||||
Kind: KontainerDriverGroupVersionKind.Kind,
|
||||
}
|
||||
)
|
||||
|
||||
type KontainerDriverList struct {
|
||||
metav1.TypeMeta `json:",inline"`
|
||||
metav1.ListMeta `json:"metadata,omitempty"`
|
||||
Items []KontainerDriver
|
||||
}
|
||||
|
||||
type KontainerDriverHandlerFunc func(key string, obj *KontainerDriver) (runtime.Object, error)
|
||||
|
||||
type KontainerDriverChangeHandlerFunc func(obj *KontainerDriver) (runtime.Object, error)
|
||||
|
||||
type KontainerDriverLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*KontainerDriver, err error)
|
||||
Get(namespace, name string) (*KontainerDriver, error)
|
||||
}
|
||||
|
||||
type KontainerDriverController interface {
|
||||
Generic() controller.GenericController
|
||||
Informer() cache.SharedIndexInformer
|
||||
Lister() KontainerDriverLister
|
||||
AddHandler(ctx context.Context, name string, handler KontainerDriverHandlerFunc)
|
||||
AddClusterScopedHandler(ctx context.Context, name, clusterName string, handler KontainerDriverHandlerFunc)
|
||||
Enqueue(namespace, name string)
|
||||
Sync(ctx context.Context) error
|
||||
Start(ctx context.Context, threadiness int) error
|
||||
}
|
||||
|
||||
type KontainerDriverInterface interface {
|
||||
ObjectClient() *objectclient.ObjectClient
|
||||
Create(*KontainerDriver) (*KontainerDriver, error)
|
||||
GetNamespaced(namespace, name string, opts metav1.GetOptions) (*KontainerDriver, error)
|
||||
Get(name string, opts metav1.GetOptions) (*KontainerDriver, error)
|
||||
Update(*KontainerDriver) (*KontainerDriver, error)
|
||||
Delete(name string, options *metav1.DeleteOptions) error
|
||||
DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error
|
||||
List(opts metav1.ListOptions) (*KontainerDriverList, error)
|
||||
Watch(opts metav1.ListOptions) (watch.Interface, error)
|
||||
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
|
||||
Controller() KontainerDriverController
|
||||
AddHandler(ctx context.Context, name string, sync KontainerDriverHandlerFunc)
|
||||
AddLifecycle(ctx context.Context, name string, lifecycle KontainerDriverLifecycle)
|
||||
AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync KontainerDriverHandlerFunc)
|
||||
AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle KontainerDriverLifecycle)
|
||||
}
|
||||
|
||||
type kontainerDriverLister struct {
|
||||
controller *kontainerDriverController
|
||||
}
|
||||
|
||||
func (l *kontainerDriverLister) List(namespace string, selector labels.Selector) (ret []*KontainerDriver, err error) {
|
||||
err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
|
||||
ret = append(ret, obj.(*KontainerDriver))
|
||||
})
|
||||
return
|
||||
}
|
||||
|
||||
func (l *kontainerDriverLister) Get(namespace, name string) (*KontainerDriver, 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: KontainerDriverGroupVersionKind.Group,
|
||||
Resource: "kontainerDriver",
|
||||
}, key)
|
||||
}
|
||||
return obj.(*KontainerDriver), nil
|
||||
}
|
||||
|
||||
type kontainerDriverController struct {
|
||||
controller.GenericController
|
||||
}
|
||||
|
||||
func (c *kontainerDriverController) Generic() controller.GenericController {
|
||||
return c.GenericController
|
||||
}
|
||||
|
||||
func (c *kontainerDriverController) Lister() KontainerDriverLister {
|
||||
return &kontainerDriverLister{
|
||||
controller: c,
|
||||
}
|
||||
}
|
||||
|
||||
func (c *kontainerDriverController) AddHandler(ctx context.Context, name string, handler KontainerDriverHandlerFunc) {
|
||||
c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) {
|
||||
if obj == nil {
|
||||
return handler(key, nil)
|
||||
} else if v, ok := obj.(*KontainerDriver); ok {
|
||||
return handler(key, v)
|
||||
} else {
|
||||
return nil, nil
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func (c *kontainerDriverController) AddClusterScopedHandler(ctx context.Context, name, cluster string, handler KontainerDriverHandlerFunc) {
|
||||
c.GenericController.AddHandler(ctx, name, func(key string, obj interface{}) (interface{}, error) {
|
||||
if obj == nil {
|
||||
return handler(key, nil)
|
||||
} else if v, ok := obj.(*KontainerDriver); ok && controller.ObjectInCluster(cluster, obj) {
|
||||
return handler(key, v)
|
||||
} else {
|
||||
return nil, nil
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
type kontainerDriverFactory struct {
|
||||
}
|
||||
|
||||
func (c kontainerDriverFactory) Object() runtime.Object {
|
||||
return &KontainerDriver{}
|
||||
}
|
||||
|
||||
func (c kontainerDriverFactory) List() runtime.Object {
|
||||
return &KontainerDriverList{}
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Controller() KontainerDriverController {
|
||||
s.client.Lock()
|
||||
defer s.client.Unlock()
|
||||
|
||||
c, ok := s.client.kontainerDriverControllers[s.ns]
|
||||
if ok {
|
||||
return c
|
||||
}
|
||||
|
||||
genericController := controller.NewGenericController(KontainerDriverGroupVersionKind.Kind+"Controller",
|
||||
s.objectClient)
|
||||
|
||||
c = &kontainerDriverController{
|
||||
GenericController: genericController,
|
||||
}
|
||||
|
||||
s.client.kontainerDriverControllers[s.ns] = c
|
||||
s.client.starters = append(s.client.starters, c)
|
||||
|
||||
return c
|
||||
}
|
||||
|
||||
type kontainerDriverClient struct {
|
||||
client *Client
|
||||
ns string
|
||||
objectClient *objectclient.ObjectClient
|
||||
controller KontainerDriverController
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) ObjectClient() *objectclient.ObjectClient {
|
||||
return s.objectClient
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Create(o *KontainerDriver) (*KontainerDriver, error) {
|
||||
obj, err := s.objectClient.Create(o)
|
||||
return obj.(*KontainerDriver), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Get(name string, opts metav1.GetOptions) (*KontainerDriver, error) {
|
||||
obj, err := s.objectClient.Get(name, opts)
|
||||
return obj.(*KontainerDriver), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*KontainerDriver, error) {
|
||||
obj, err := s.objectClient.GetNamespaced(namespace, name, opts)
|
||||
return obj.(*KontainerDriver), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Update(o *KontainerDriver) (*KontainerDriver, error) {
|
||||
obj, err := s.objectClient.Update(o.Name, o)
|
||||
return obj.(*KontainerDriver), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Delete(name string, options *metav1.DeleteOptions) error {
|
||||
return s.objectClient.Delete(name, options)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error {
|
||||
return s.objectClient.DeleteNamespaced(namespace, name, options)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) List(opts metav1.ListOptions) (*KontainerDriverList, error) {
|
||||
obj, err := s.objectClient.List(opts)
|
||||
return obj.(*KontainerDriverList), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
|
||||
return s.objectClient.Watch(opts)
|
||||
}
|
||||
|
||||
// Patch applies the patch and returns the patched deployment.
|
||||
func (s *kontainerDriverClient) Patch(o *KontainerDriver, data []byte, subresources ...string) (*KontainerDriver, error) {
|
||||
obj, err := s.objectClient.Patch(o.Name, o, data, subresources...)
|
||||
return obj.(*KontainerDriver), err
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
|
||||
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) AddHandler(ctx context.Context, name string, sync KontainerDriverHandlerFunc) {
|
||||
s.Controller().AddHandler(ctx, name, sync)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) AddLifecycle(ctx context.Context, name string, lifecycle KontainerDriverLifecycle) {
|
||||
sync := NewKontainerDriverLifecycleAdapter(name, false, s, lifecycle)
|
||||
s.Controller().AddHandler(ctx, name, sync)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) AddClusterScopedHandler(ctx context.Context, name, clusterName string, sync KontainerDriverHandlerFunc) {
|
||||
s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync)
|
||||
}
|
||||
|
||||
func (s *kontainerDriverClient) AddClusterScopedLifecycle(ctx context.Context, name, clusterName string, lifecycle KontainerDriverLifecycle) {
|
||||
sync := NewKontainerDriverLifecycleAdapter(name+"_"+clusterName, true, s, lifecycle)
|
||||
s.Controller().AddClusterScopedHandler(ctx, name, clusterName, sync)
|
||||
}
|
||||
|
||||
type KontainerDriverIndexer func(obj *KontainerDriver) ([]string, error)
|
||||
|
||||
type KontainerDriverClientCache interface {
|
||||
Get(namespace, name string) (*KontainerDriver, error)
|
||||
List(namespace string, selector labels.Selector) ([]*KontainerDriver, error)
|
||||
|
||||
Index(name string, indexer KontainerDriverIndexer)
|
||||
GetIndexed(name, key string) ([]*KontainerDriver, error)
|
||||
}
|
||||
|
||||
type KontainerDriverClient interface {
|
||||
Create(*KontainerDriver) (*KontainerDriver, error)
|
||||
Get(namespace, name string, opts metav1.GetOptions) (*KontainerDriver, error)
|
||||
Update(*KontainerDriver) (*KontainerDriver, error)
|
||||
Delete(namespace, name string, options *metav1.DeleteOptions) error
|
||||
List(namespace string, opts metav1.ListOptions) (*KontainerDriverList, error)
|
||||
Watch(opts metav1.ListOptions) (watch.Interface, error)
|
||||
|
||||
Cache() KontainerDriverClientCache
|
||||
|
||||
OnCreate(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc)
|
||||
OnChange(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc)
|
||||
OnRemove(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc)
|
||||
Enqueue(namespace, name string)
|
||||
|
||||
Generic() controller.GenericController
|
||||
Interface() KontainerDriverInterface
|
||||
}
|
||||
|
||||
type kontainerDriverClientCache struct {
|
||||
client *kontainerDriverClient2
|
||||
}
|
||||
|
||||
type kontainerDriverClient2 struct {
|
||||
iface KontainerDriverInterface
|
||||
controller KontainerDriverController
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Interface() KontainerDriverInterface {
|
||||
return n.iface
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Generic() controller.GenericController {
|
||||
return n.iface.Controller().Generic()
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Enqueue(namespace, name string) {
|
||||
n.iface.Controller().Enqueue(namespace, name)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Create(obj *KontainerDriver) (*KontainerDriver, error) {
|
||||
return n.iface.Create(obj)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Get(namespace, name string, opts metav1.GetOptions) (*KontainerDriver, error) {
|
||||
return n.iface.GetNamespaced(namespace, name, opts)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Update(obj *KontainerDriver) (*KontainerDriver, error) {
|
||||
return n.iface.Update(obj)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Delete(namespace, name string, options *metav1.DeleteOptions) error {
|
||||
return n.iface.DeleteNamespaced(namespace, name, options)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) List(namespace string, opts metav1.ListOptions) (*KontainerDriverList, error) {
|
||||
return n.iface.List(opts)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Watch(opts metav1.ListOptions) (watch.Interface, error) {
|
||||
return n.iface.Watch(opts)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClientCache) Get(namespace, name string) (*KontainerDriver, error) {
|
||||
return n.client.controller.Lister().Get(namespace, name)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClientCache) List(namespace string, selector labels.Selector) ([]*KontainerDriver, error) {
|
||||
return n.client.controller.Lister().List(namespace, selector)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) Cache() KontainerDriverClientCache {
|
||||
n.loadController()
|
||||
return &kontainerDriverClientCache{
|
||||
client: n,
|
||||
}
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) OnCreate(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc) {
|
||||
n.loadController()
|
||||
n.iface.AddLifecycle(ctx, name+"-create", &kontainerDriverLifecycleDelegate{create: sync})
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) OnChange(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc) {
|
||||
n.loadController()
|
||||
n.iface.AddLifecycle(ctx, name+"-change", &kontainerDriverLifecycleDelegate{update: sync})
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) OnRemove(ctx context.Context, name string, sync KontainerDriverChangeHandlerFunc) {
|
||||
n.loadController()
|
||||
n.iface.AddLifecycle(ctx, name, &kontainerDriverLifecycleDelegate{remove: sync})
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClientCache) Index(name string, indexer KontainerDriverIndexer) {
|
||||
err := n.client.controller.Informer().GetIndexer().AddIndexers(map[string]cache.IndexFunc{
|
||||
name: func(obj interface{}) ([]string, error) {
|
||||
if v, ok := obj.(*KontainerDriver); ok {
|
||||
return indexer(v)
|
||||
}
|
||||
return nil, nil
|
||||
},
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClientCache) GetIndexed(name, key string) ([]*KontainerDriver, error) {
|
||||
var result []*KontainerDriver
|
||||
objs, err := n.client.controller.Informer().GetIndexer().ByIndex(name, key)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
for _, obj := range objs {
|
||||
if v, ok := obj.(*KontainerDriver); ok {
|
||||
result = append(result, v)
|
||||
}
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
|
||||
func (n *kontainerDriverClient2) loadController() {
|
||||
if n.controller == nil {
|
||||
n.controller = n.iface.Controller()
|
||||
}
|
||||
}
|
||||
|
||||
type kontainerDriverLifecycleDelegate struct {
|
||||
create KontainerDriverChangeHandlerFunc
|
||||
update KontainerDriverChangeHandlerFunc
|
||||
remove KontainerDriverChangeHandlerFunc
|
||||
}
|
||||
|
||||
func (n *kontainerDriverLifecycleDelegate) HasCreate() bool {
|
||||
return n.create != nil
|
||||
}
|
||||
|
||||
func (n *kontainerDriverLifecycleDelegate) Create(obj *KontainerDriver) (runtime.Object, error) {
|
||||
if n.create == nil {
|
||||
return obj, nil
|
||||
}
|
||||
return n.create(obj)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverLifecycleDelegate) HasFinalize() bool {
|
||||
return n.remove != nil
|
||||
}
|
||||
|
||||
func (n *kontainerDriverLifecycleDelegate) Remove(obj *KontainerDriver) (runtime.Object, error) {
|
||||
if n.remove == nil {
|
||||
return obj, nil
|
||||
}
|
||||
return n.remove(obj)
|
||||
}
|
||||
|
||||
func (n *kontainerDriverLifecycleDelegate) Updated(obj *KontainerDriver) (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 KontainerDriverLifecycle interface {
|
||||
Create(obj *KontainerDriver) (runtime.Object, error)
|
||||
Remove(obj *KontainerDriver) (runtime.Object, error)
|
||||
Updated(obj *KontainerDriver) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type kontainerDriverLifecycleAdapter struct {
|
||||
lifecycle KontainerDriverLifecycle
|
||||
}
|
||||
|
||||
func (w *kontainerDriverLifecycleAdapter) HasCreate() bool {
|
||||
o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition)
|
||||
return !ok || o.HasCreate()
|
||||
}
|
||||
|
||||
func (w *kontainerDriverLifecycleAdapter) HasFinalize() bool {
|
||||
o, ok := w.lifecycle.(lifecycle.ObjectLifecycleCondition)
|
||||
return !ok || o.HasFinalize()
|
||||
}
|
||||
|
||||
func (w *kontainerDriverLifecycleAdapter) Create(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Create(obj.(*KontainerDriver))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func (w *kontainerDriverLifecycleAdapter) Finalize(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Remove(obj.(*KontainerDriver))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func (w *kontainerDriverLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Updated(obj.(*KontainerDriver))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func NewKontainerDriverLifecycleAdapter(name string, clusterScoped bool, client KontainerDriverInterface, l KontainerDriverLifecycle) KontainerDriverHandlerFunc {
|
||||
adapter := &kontainerDriverLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *KontainerDriver) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
}
|
@@ -116,6 +116,8 @@ func addKnownTypes(scheme *runtime.Scheme) error {
|
||||
&GlobalDNSList{},
|
||||
&GlobalDNSProvider{},
|
||||
&GlobalDNSProviderList{},
|
||||
&KontainerDriver{},
|
||||
&KontainerDriverList{},
|
||||
)
|
||||
return nil
|
||||
}
|
||||
|
Reference in New Issue
Block a user