Update generated code

apis/cluster.cattle.io/v1/zz_generated_deepcopy.go

@@ -5,6 +5,22 @@ import (
 	runtime "k8s.io/apimachinery/pkg/runtime"
 )
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *AmazonEC2Config) DeepCopyInto(out *AmazonEC2Config) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AmazonEC2Config.
+func (in *AmazonEC2Config) DeepCopy() *AmazonEC2Config {
+	if in == nil {
+		return nil
+	}
+	out := new(AmazonEC2Config)
+	in.DeepCopyInto(out)
+	return out
+}
+
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *AuthConfig) DeepCopyInto(out *AuthConfig) {
 	*out = *in
@@ -28,6 +44,22 @@ func (in *AuthConfig) DeepCopy() *AuthConfig {
 	return out
 }
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *AzureConfig) DeepCopyInto(out *AzureConfig) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureConfig.
+func (in *AzureConfig) DeepCopy() *AzureConfig {
+	if in == nil {
+		return nil
+	}
+	out := new(AzureConfig)
+	in.DeepCopyInto(out)
+	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
@@ -313,6 +345,22 @@ func (in *ClusterStatus) DeepCopy() *ClusterStatus {
 	return out
 }
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *DigitalOceanConfig) DeepCopyInto(out *DigitalOceanConfig) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DigitalOceanConfig.
+func (in *DigitalOceanConfig) DeepCopy() *DigitalOceanConfig {
+	if in == nil {
+		return nil
+	}
+	out := new(DigitalOceanConfig)
+	in.DeepCopyInto(out)
+	return out
+}
+
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *ETCDService) DeepCopyInto(out *ETCDService) {
 	*out = *in
@@ -421,6 +469,419 @@ func (in *KubeproxyService) DeepCopy() *KubeproxyService {
 	return out
 }
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *Machine) DeepCopyInto(out *Machine) {
+	*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 Machine.
+func (in *Machine) DeepCopy() *Machine {
+	if in == nil {
+		return nil
+	}
+	out := new(Machine)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *Machine) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineCondition) DeepCopyInto(out *MachineCondition) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineCondition.
+func (in *MachineCondition) DeepCopy() *MachineCondition {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineCondition)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineDriver) DeepCopyInto(out *MachineDriver) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	out.Spec = in.Spec
+	in.Status.DeepCopyInto(&out.Status)
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineDriver.
+func (in *MachineDriver) DeepCopy() *MachineDriver {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineDriver)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *MachineDriver) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineDriverCondition) DeepCopyInto(out *MachineDriverCondition) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineDriverCondition.
+func (in *MachineDriverCondition) DeepCopy() *MachineDriverCondition {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineDriverCondition)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineDriverList) DeepCopyInto(out *MachineDriverList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	out.ListMeta = in.ListMeta
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]MachineDriver, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineDriverList.
+func (in *MachineDriverList) DeepCopy() *MachineDriverList {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineDriverList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *MachineDriverList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineDriverSpec) DeepCopyInto(out *MachineDriverSpec) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineDriverSpec.
+func (in *MachineDriverSpec) DeepCopy() *MachineDriverSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineDriverSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineDriverStatus) DeepCopyInto(out *MachineDriverStatus) {
+	*out = *in
+	if in.Conditions != nil {
+		in, out := &in.Conditions, &out.Conditions
+		*out = make([]MachineDriverCondition, len(*in))
+		copy(*out, *in)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineDriverStatus.
+func (in *MachineDriverStatus) DeepCopy() *MachineDriverStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineDriverStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineGeneralParams) DeepCopyInto(out *MachineGeneralParams) {
+	*out = *in
+	if in.EngineOpt != nil {
+		in, out := &in.EngineOpt, &out.EngineOpt
+		*out = make(map[string]string, len(*in))
+		for key, val := range *in {
+			(*out)[key] = val
+		}
+	}
+	if in.EngineInsecureRegistry != nil {
+		in, out := &in.EngineInsecureRegistry, &out.EngineInsecureRegistry
+		*out = make([]string, len(*in))
+		copy(*out, *in)
+	}
+	if in.EngineRegistryMirror != nil {
+		in, out := &in.EngineRegistryMirror, &out.EngineRegistryMirror
+		*out = make([]string, len(*in))
+		copy(*out, *in)
+	}
+	if in.EngineLabel != nil {
+		in, out := &in.EngineLabel, &out.EngineLabel
+		*out = make(map[string]string, len(*in))
+		for key, val := range *in {
+			(*out)[key] = val
+		}
+	}
+	if in.EngineEnv != nil {
+		in, out := &in.EngineEnv, &out.EngineEnv
+		*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 MachineGeneralParams.
+func (in *MachineGeneralParams) DeepCopy() *MachineGeneralParams {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineGeneralParams)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineList) DeepCopyInto(out *MachineList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	out.ListMeta = in.ListMeta
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]Machine, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineList.
+func (in *MachineList) DeepCopy() *MachineList {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *MachineList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineSpec) DeepCopyInto(out *MachineSpec) {
+	*out = *in
+	in.MachineGeneralParams.DeepCopyInto(&out.MachineGeneralParams)
+	out.AmazonEC2Config = in.AmazonEC2Config
+	out.AzureConfig = in.AzureConfig
+	out.DigitalOceanConfig = in.DigitalOceanConfig
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineSpec.
+func (in *MachineSpec) DeepCopy() *MachineSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineStatus) DeepCopyInto(out *MachineStatus) {
+	*out = *in
+	if in.Conditions != nil {
+		in, out := &in.Conditions, &out.Conditions
+		*out = make([]MachineCondition, len(*in))
+		copy(*out, *in)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineStatus.
+func (in *MachineStatus) DeepCopy() *MachineStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineTemplate) DeepCopyInto(out *MachineTemplate) {
+	*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 MachineTemplate.
+func (in *MachineTemplate) DeepCopy() *MachineTemplate {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineTemplate)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *MachineTemplate) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineTemplateCondition) DeepCopyInto(out *MachineTemplateCondition) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineTemplateCondition.
+func (in *MachineTemplateCondition) DeepCopy() *MachineTemplateCondition {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineTemplateCondition)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineTemplateList) DeepCopyInto(out *MachineTemplateList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	out.ListMeta = in.ListMeta
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]MachineTemplate, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineTemplateList.
+func (in *MachineTemplateList) DeepCopy() *MachineTemplateList {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineTemplateList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *MachineTemplateList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	} else {
+		return nil
+	}
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineTemplateSpec) DeepCopyInto(out *MachineTemplateSpec) {
+	*out = *in
+	if in.SecretValues != nil {
+		in, out := &in.SecretValues, &out.SecretValues
+		*out = make(map[string]string, len(*in))
+		for key, val := range *in {
+			(*out)[key] = val
+		}
+	}
+	if in.PublicValues != nil {
+		in, out := &in.PublicValues, &out.PublicValues
+		*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 MachineTemplateSpec.
+func (in *MachineTemplateSpec) DeepCopy() *MachineTemplateSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineTemplateSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *MachineTemplateStatus) DeepCopyInto(out *MachineTemplateStatus) {
+	*out = *in
+	if in.Conditions != nil {
+		in, out := &in.Conditions, &out.Conditions
+		*out = make([]MachineTemplateCondition, len(*in))
+		copy(*out, *in)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MachineTemplateStatus.
+func (in *MachineTemplateStatus) DeepCopy() *MachineTemplateStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(MachineTemplateStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *NetworkConfig) DeepCopyInto(out *NetworkConfig) {
 	*out = *in

apis/cluster.cattle.io/v1/zz_generated_k8s_client.go

@@ -16,6 +16,9 @@ type Interface interface {
 
 	ClustersGetter
 	ClusterNodesGetter
+	MachinesGetter
+	MachineDriversGetter
+	MachineTemplatesGetter
 }
 
 type Client struct {
@@ -23,8 +26,11 @@ type Client struct {
 	restClient rest.Interface
 	starters   []controller.Starter
 
-	clusterControllers     map[string]ClusterController
-	clusterNodeControllers map[string]ClusterNodeController
+	clusterControllers         map[string]ClusterController
+	clusterNodeControllers     map[string]ClusterNodeController
+	machineControllers         map[string]MachineController
+	machineDriverControllers   map[string]MachineDriverController
+	machineTemplateControllers map[string]MachineTemplateController
 }
 
 func NewForConfig(config rest.Config) (Interface, error) {
@@ -41,8 +47,11 @@ func NewForConfig(config rest.Config) (Interface, error) {
 	return &Client{
 		restClient: restClient,
 
-		clusterControllers:     map[string]ClusterController{},
-		clusterNodeControllers: map[string]ClusterNodeController{},
+		clusterControllers:         map[string]ClusterController{},
+		clusterNodeControllers:     map[string]ClusterNodeController{},
+		machineControllers:         map[string]MachineController{},
+		machineDriverControllers:   map[string]MachineDriverController{},
+		machineTemplateControllers: map[string]MachineTemplateController{},
 	}, nil
 }
 
@@ -83,3 +92,42 @@ func (c *Client) ClusterNodes(namespace string) ClusterNodeInterface {
 		objectClient: objectClient,
 	}
 }
+
+type MachinesGetter interface {
+	Machines(namespace string) MachineInterface
+}
+
+func (c *Client) Machines(namespace string) MachineInterface {
+	objectClient := clientbase.NewObjectClient(namespace, c.restClient, &MachineResource, MachineGroupVersionKind, machineFactory{})
+	return &machineClient{
+		ns:           namespace,
+		client:       c,
+		objectClient: objectClient,
+	}
+}
+
+type MachineDriversGetter interface {
+	MachineDrivers(namespace string) MachineDriverInterface
+}
+
+func (c *Client) MachineDrivers(namespace string) MachineDriverInterface {
+	objectClient := clientbase.NewObjectClient(namespace, c.restClient, &MachineDriverResource, MachineDriverGroupVersionKind, machineDriverFactory{})
+	return &machineDriverClient{
+		ns:           namespace,
+		client:       c,
+		objectClient: objectClient,
+	}
+}
+
+type MachineTemplatesGetter interface {
+	MachineTemplates(namespace string) MachineTemplateInterface
+}
+
+func (c *Client) MachineTemplates(namespace string) MachineTemplateInterface {
+	objectClient := clientbase.NewObjectClient(namespace, c.restClient, &MachineTemplateResource, MachineTemplateGroupVersionKind, machineTemplateFactory{})
+	return &machineTemplateClient{
+		ns:           namespace,
+		client:       c,
+		objectClient: objectClient,
+	}
+}

apis/cluster.cattle.io/v1/zz_generated_machine_controller.go

@@ -0,0 +1,187 @@
+package v1
+
+import (
+	"context"
+
+	"github.com/rancher/norman/clientbase"
+	"github.com/rancher/norman/controller"
+	"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 (
+	MachineGroupVersionKind = schema.GroupVersionKind{
+		Version: "v1",
+		Group:   "cluster.cattle.io",
+		Kind:    "Machine",
+	}
+	MachineResource = metav1.APIResource{
+		Name:         "machines",
+		SingularName: "machine",
+		Namespaced:   false,
+		Kind:         MachineGroupVersionKind.Kind,
+	}
+)
+
+type MachineList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []Machine
+}
+
+type MachineHandlerFunc func(key string, obj *Machine) error
+
+type MachineLister interface {
+	List(namespace string, selector labels.Selector) (ret []*Machine, err error)
+	Get(namespace, name string) (*Machine, error)
+}
+
+type MachineController interface {
+	Informer() cache.SharedIndexInformer
+	Lister() MachineLister
+	AddHandler(handler MachineHandlerFunc)
+	Enqueue(namespace, name string)
+	Sync(ctx context.Context) error
+	Start(ctx context.Context, threadiness int) error
+}
+
+type MachineInterface interface {
+	ObjectClient() *clientbase.ObjectClient
+	Create(*Machine) (*Machine, error)
+	Get(name string, opts metav1.GetOptions) (*Machine, error)
+	Update(*Machine) (*Machine, error)
+	Delete(name string, options *metav1.DeleteOptions) error
+	List(opts metav1.ListOptions) (*MachineList, error)
+	Watch(opts metav1.ListOptions) (watch.Interface, error)
+	DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
+	Controller() MachineController
+}
+
+type machineLister struct {
+	controller *machineController
+}
+
+func (l *machineLister) List(namespace string, selector labels.Selector) (ret []*Machine, err error) {
+	err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
+		ret = append(ret, obj.(*Machine))
+	})
+	return
+}
+
+func (l *machineLister) Get(namespace, name string) (*Machine, error) {
+	obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(namespace + "/" + name)
+	if err != nil {
+		return nil, err
+	}
+	if !exists {
+		return nil, errors.NewNotFound(schema.GroupResource{
+			Group:    MachineGroupVersionKind.Group,
+			Resource: "machine",
+		}, name)
+	}
+	return obj.(*Machine), nil
+}
+
+type machineController struct {
+	controller.GenericController
+}
+
+func (c *machineController) Lister() MachineLister {
+	return &machineLister{
+		controller: c,
+	}
+}
+
+func (c *machineController) AddHandler(handler MachineHandlerFunc) {
+	c.GenericController.AddHandler(func(key string) error {
+		obj, exists, err := c.Informer().GetStore().GetByKey(key)
+		if err != nil {
+			return err
+		}
+		if !exists {
+			return handler(key, nil)
+		}
+		return handler(key, obj.(*Machine))
+	})
+}
+
+type machineFactory struct {
+}
+
+func (c machineFactory) Object() runtime.Object {
+	return &Machine{}
+}
+
+func (c machineFactory) List() runtime.Object {
+	return &MachineList{}
+}
+
+func (s *machineClient) Controller() MachineController {
+	s.client.Lock()
+	defer s.client.Unlock()
+
+	c, ok := s.client.machineControllers[s.ns]
+	if ok {
+		return c
+	}
+
+	genericController := controller.NewGenericController(MachineGroupVersionKind.Kind+"Controller",
+		s.objectClient)
+
+	c = &machineController{
+		GenericController: genericController,
+	}
+
+	s.client.machineControllers[s.ns] = c
+	s.client.starters = append(s.client.starters, c)
+
+	return c
+}
+
+type machineClient struct {
+	client       *Client
+	ns           string
+	objectClient *clientbase.ObjectClient
+	controller   MachineController
+}
+
+func (s *machineClient) ObjectClient() *clientbase.ObjectClient {
+	return s.objectClient
+}
+
+func (s *machineClient) Create(o *Machine) (*Machine, error) {
+	obj, err := s.objectClient.Create(o)
+	return obj.(*Machine), err
+}
+
+func (s *machineClient) Get(name string, opts metav1.GetOptions) (*Machine, error) {
+	obj, err := s.objectClient.Get(name, opts)
+	return obj.(*Machine), err
+}
+
+func (s *machineClient) Update(o *Machine) (*Machine, error) {
+	obj, err := s.objectClient.Update(o.Name, o)
+	return obj.(*Machine), err
+}
+
+func (s *machineClient) Delete(name string, options *metav1.DeleteOptions) error {
+	return s.objectClient.Delete(name, options)
+}
+
+func (s *machineClient) List(opts metav1.ListOptions) (*MachineList, error) {
+	obj, err := s.objectClient.List(opts)
+	return obj.(*MachineList), err
+}
+
+func (s *machineClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
+	return s.objectClient.Watch(opts)
+}
+
+func (s *machineClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
+	return s.objectClient.DeleteCollection(deleteOpts, listOpts)
+}

apis/cluster.cattle.io/v1/zz_generated_machine_driver_controller.go

@@ -0,0 +1,187 @@
+package v1
+
+import (
+	"context"
+
+	"github.com/rancher/norman/clientbase"
+	"github.com/rancher/norman/controller"
+	"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 (
+	MachineDriverGroupVersionKind = schema.GroupVersionKind{
+		Version: "v1",
+		Group:   "cluster.cattle.io",
+		Kind:    "MachineDriver",
+	}
+	MachineDriverResource = metav1.APIResource{
+		Name:         "machinedrivers",
+		SingularName: "machinedriver",
+		Namespaced:   false,
+		Kind:         MachineDriverGroupVersionKind.Kind,
+	}
+)
+
+type MachineDriverList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []MachineDriver
+}
+
+type MachineDriverHandlerFunc func(key string, obj *MachineDriver) error
+
+type MachineDriverLister interface {
+	List(namespace string, selector labels.Selector) (ret []*MachineDriver, err error)
+	Get(namespace, name string) (*MachineDriver, error)
+}
+
+type MachineDriverController interface {
+	Informer() cache.SharedIndexInformer
+	Lister() MachineDriverLister
+	AddHandler(handler MachineDriverHandlerFunc)
+	Enqueue(namespace, name string)
+	Sync(ctx context.Context) error
+	Start(ctx context.Context, threadiness int) error
+}
+
+type MachineDriverInterface interface {
+	ObjectClient() *clientbase.ObjectClient
+	Create(*MachineDriver) (*MachineDriver, error)
+	Get(name string, opts metav1.GetOptions) (*MachineDriver, error)
+	Update(*MachineDriver) (*MachineDriver, error)
+	Delete(name string, options *metav1.DeleteOptions) error
+	List(opts metav1.ListOptions) (*MachineDriverList, error)
+	Watch(opts metav1.ListOptions) (watch.Interface, error)
+	DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
+	Controller() MachineDriverController
+}
+
+type machineDriverLister struct {
+	controller *machineDriverController
+}
+
+func (l *machineDriverLister) List(namespace string, selector labels.Selector) (ret []*MachineDriver, err error) {
+	err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
+		ret = append(ret, obj.(*MachineDriver))
+	})
+	return
+}
+
+func (l *machineDriverLister) Get(namespace, name string) (*MachineDriver, error) {
+	obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(namespace + "/" + name)
+	if err != nil {
+		return nil, err
+	}
+	if !exists {
+		return nil, errors.NewNotFound(schema.GroupResource{
+			Group:    MachineDriverGroupVersionKind.Group,
+			Resource: "machineDriver",
+		}, name)
+	}
+	return obj.(*MachineDriver), nil
+}
+
+type machineDriverController struct {
+	controller.GenericController
+}
+
+func (c *machineDriverController) Lister() MachineDriverLister {
+	return &machineDriverLister{
+		controller: c,
+	}
+}
+
+func (c *machineDriverController) AddHandler(handler MachineDriverHandlerFunc) {
+	c.GenericController.AddHandler(func(key string) error {
+		obj, exists, err := c.Informer().GetStore().GetByKey(key)
+		if err != nil {
+			return err
+		}
+		if !exists {
+			return handler(key, nil)
+		}
+		return handler(key, obj.(*MachineDriver))
+	})
+}
+
+type machineDriverFactory struct {
+}
+
+func (c machineDriverFactory) Object() runtime.Object {
+	return &MachineDriver{}
+}
+
+func (c machineDriverFactory) List() runtime.Object {
+	return &MachineDriverList{}
+}
+
+func (s *machineDriverClient) Controller() MachineDriverController {
+	s.client.Lock()
+	defer s.client.Unlock()
+
+	c, ok := s.client.machineDriverControllers[s.ns]
+	if ok {
+		return c
+	}
+
+	genericController := controller.NewGenericController(MachineDriverGroupVersionKind.Kind+"Controller",
+		s.objectClient)
+
+	c = &machineDriverController{
+		GenericController: genericController,
+	}
+
+	s.client.machineDriverControllers[s.ns] = c
+	s.client.starters = append(s.client.starters, c)
+
+	return c
+}
+
+type machineDriverClient struct {
+	client       *Client
+	ns           string
+	objectClient *clientbase.ObjectClient
+	controller   MachineDriverController
+}
+
+func (s *machineDriverClient) ObjectClient() *clientbase.ObjectClient {
+	return s.objectClient
+}
+
+func (s *machineDriverClient) Create(o *MachineDriver) (*MachineDriver, error) {
+	obj, err := s.objectClient.Create(o)
+	return obj.(*MachineDriver), err
+}
+
+func (s *machineDriverClient) Get(name string, opts metav1.GetOptions) (*MachineDriver, error) {
+	obj, err := s.objectClient.Get(name, opts)
+	return obj.(*MachineDriver), err
+}
+
+func (s *machineDriverClient) Update(o *MachineDriver) (*MachineDriver, error) {
+	obj, err := s.objectClient.Update(o.Name, o)
+	return obj.(*MachineDriver), err
+}
+
+func (s *machineDriverClient) Delete(name string, options *metav1.DeleteOptions) error {
+	return s.objectClient.Delete(name, options)
+}
+
+func (s *machineDriverClient) List(opts metav1.ListOptions) (*MachineDriverList, error) {
+	obj, err := s.objectClient.List(opts)
+	return obj.(*MachineDriverList), err
+}
+
+func (s *machineDriverClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
+	return s.objectClient.Watch(opts)
+}
+
+func (s *machineDriverClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
+	return s.objectClient.DeleteCollection(deleteOpts, listOpts)
+}

apis/cluster.cattle.io/v1/zz_generated_machine_template_controller.go

@@ -0,0 +1,187 @@
+package v1
+
+import (
+	"context"
+
+	"github.com/rancher/norman/clientbase"
+	"github.com/rancher/norman/controller"
+	"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 (
+	MachineTemplateGroupVersionKind = schema.GroupVersionKind{
+		Version: "v1",
+		Group:   "cluster.cattle.io",
+		Kind:    "MachineTemplate",
+	}
+	MachineTemplateResource = metav1.APIResource{
+		Name:         "machinetemplates",
+		SingularName: "machinetemplate",
+		Namespaced:   false,
+		Kind:         MachineTemplateGroupVersionKind.Kind,
+	}
+)
+
+type MachineTemplateList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []MachineTemplate
+}
+
+type MachineTemplateHandlerFunc func(key string, obj *MachineTemplate) error
+
+type MachineTemplateLister interface {
+	List(namespace string, selector labels.Selector) (ret []*MachineTemplate, err error)
+	Get(namespace, name string) (*MachineTemplate, error)
+}
+
+type MachineTemplateController interface {
+	Informer() cache.SharedIndexInformer
+	Lister() MachineTemplateLister
+	AddHandler(handler MachineTemplateHandlerFunc)
+	Enqueue(namespace, name string)
+	Sync(ctx context.Context) error
+	Start(ctx context.Context, threadiness int) error
+}
+
+type MachineTemplateInterface interface {
+	ObjectClient() *clientbase.ObjectClient
+	Create(*MachineTemplate) (*MachineTemplate, error)
+	Get(name string, opts metav1.GetOptions) (*MachineTemplate, error)
+	Update(*MachineTemplate) (*MachineTemplate, error)
+	Delete(name string, options *metav1.DeleteOptions) error
+	List(opts metav1.ListOptions) (*MachineTemplateList, error)
+	Watch(opts metav1.ListOptions) (watch.Interface, error)
+	DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
+	Controller() MachineTemplateController
+}
+
+type machineTemplateLister struct {
+	controller *machineTemplateController
+}
+
+func (l *machineTemplateLister) List(namespace string, selector labels.Selector) (ret []*MachineTemplate, err error) {
+	err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
+		ret = append(ret, obj.(*MachineTemplate))
+	})
+	return
+}
+
+func (l *machineTemplateLister) Get(namespace, name string) (*MachineTemplate, error) {
+	obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(namespace + "/" + name)
+	if err != nil {
+		return nil, err
+	}
+	if !exists {
+		return nil, errors.NewNotFound(schema.GroupResource{
+			Group:    MachineTemplateGroupVersionKind.Group,
+			Resource: "machineTemplate",
+		}, name)
+	}
+	return obj.(*MachineTemplate), nil
+}
+
+type machineTemplateController struct {
+	controller.GenericController
+}
+
+func (c *machineTemplateController) Lister() MachineTemplateLister {
+	return &machineTemplateLister{
+		controller: c,
+	}
+}
+
+func (c *machineTemplateController) AddHandler(handler MachineTemplateHandlerFunc) {
+	c.GenericController.AddHandler(func(key string) error {
+		obj, exists, err := c.Informer().GetStore().GetByKey(key)
+		if err != nil {
+			return err
+		}
+		if !exists {
+			return handler(key, nil)
+		}
+		return handler(key, obj.(*MachineTemplate))
+	})
+}
+
+type machineTemplateFactory struct {
+}
+
+func (c machineTemplateFactory) Object() runtime.Object {
+	return &MachineTemplate{}
+}
+
+func (c machineTemplateFactory) List() runtime.Object {
+	return &MachineTemplateList{}
+}
+
+func (s *machineTemplateClient) Controller() MachineTemplateController {
+	s.client.Lock()
+	defer s.client.Unlock()
+
+	c, ok := s.client.machineTemplateControllers[s.ns]
+	if ok {
+		return c
+	}
+
+	genericController := controller.NewGenericController(MachineTemplateGroupVersionKind.Kind+"Controller",
+		s.objectClient)
+
+	c = &machineTemplateController{
+		GenericController: genericController,
+	}
+
+	s.client.machineTemplateControllers[s.ns] = c
+	s.client.starters = append(s.client.starters, c)
+
+	return c
+}
+
+type machineTemplateClient struct {
+	client       *Client
+	ns           string
+	objectClient *clientbase.ObjectClient
+	controller   MachineTemplateController
+}
+
+func (s *machineTemplateClient) ObjectClient() *clientbase.ObjectClient {
+	return s.objectClient
+}
+
+func (s *machineTemplateClient) Create(o *MachineTemplate) (*MachineTemplate, error) {
+	obj, err := s.objectClient.Create(o)
+	return obj.(*MachineTemplate), err
+}
+
+func (s *machineTemplateClient) Get(name string, opts metav1.GetOptions) (*MachineTemplate, error) {
+	obj, err := s.objectClient.Get(name, opts)
+	return obj.(*MachineTemplate), err
+}
+
+func (s *machineTemplateClient) Update(o *MachineTemplate) (*MachineTemplate, error) {
+	obj, err := s.objectClient.Update(o.Name, o)
+	return obj.(*MachineTemplate), err
+}
+
+func (s *machineTemplateClient) Delete(name string, options *metav1.DeleteOptions) error {
+	return s.objectClient.Delete(name, options)
+}
+
+func (s *machineTemplateClient) List(opts metav1.ListOptions) (*MachineTemplateList, error) {
+	obj, err := s.objectClient.List(opts)
+	return obj.(*MachineTemplateList), err
+}
+
+func (s *machineTemplateClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
+	return s.objectClient.Watch(opts)
+}
+
+func (s *machineTemplateClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
+	return s.objectClient.DeleteCollection(deleteOpts, listOpts)
+}