Please run make generate. diff --git a/charts/kserve-resources/templates/clusterrole.yaml b/charts/kserve-resources/templates/clusterrole.yaml index 46c76a4..6ec72fa 100644 --- a/charts/kserve-resources/templates/clusterrole.yaml +++ b/charts/kserve-resources/templates/clusterrole.yaml @@ -124,6 +124,14 @@ rules: - patch - update - watch +- apiGroups: + - route.openshift.io + resources: + - routes + verbs: + - get + - list + - watch - apiGroups: - serving.knative.dev resources:

Please run make generate. diff --git a/pkg/apis/serving/v1beta1/zz_generated.defaults.go b/pkg/apis/serving/v1beta1/zz_generated.defaults.go index 54778cd..be1f3ef 100644 --- a/pkg/apis/serving/v1beta1/zz_generated.defaults.go +++ b/pkg/apis/serving/v1beta1/zz_generated.defaults.go @@ -22,6 +22,7 @@ limitations under the License. package v1beta1 import ( + v1 "k8s.io/api/core/v1" runtime "k8s.io/apimachinery/pkg/runtime" ) @@ -388,6 +389,51 @@ func SetObjectDefaults_InferenceService(in *InferenceService) { } } if in.Spec.Predictor.WorkerSpec != nil { + for i := range in.Spec.Predictor.WorkerSpec.PodSpec.Volumes { + a := &in.Spec.Predictor.WorkerSpec.PodSpec.Volumes[i] + if a.VolumeSource.ISCSI != nil { + if a.VolumeSource.ISCSI.ISCSIInterface == "" { + a.VolumeSource.ISCSI.ISCSIInterface = "default" + } + } + if a.VolumeSource.RBD != nil { + if a.VolumeSource.RBD.RBDPool == "" { + a.VolumeSource.RBD.RBDPool = "rbd" + } + if a.VolumeSource.RBD.RadosUser == "" { + a.VolumeSource.RBD.RadosUser = "admin" + } + if a.VolumeSource.RBD.Keyring == "" { + a.VolumeSource.RBD.Keyring = "/etc/ceph/keyring" + } + } + if a.VolumeSource.AzureDisk != nil { + if a.VolumeSource.AzureDisk.CachingMode == nil { + ptrVar1 := v1.AzureDataDiskCachingMode(v1.AzureDataDiskCachingReadWrite) + a.VolumeSource.AzureDisk.CachingMode = &ptrVar1 + } + if a.VolumeSource.AzureDisk.FSType == nil { + var ptrVar1 string = "ext4" + a.VolumeSource.AzureDisk.FSType = &ptrVar1 + } + if a.VolumeSource.AzureDisk.ReadOnly == nil { + var ptrVar1 bool = false + a.VolumeSource.AzureDisk.ReadOnly = &ptrVar1 + } + if a.VolumeSource.AzureDisk.Kind == nil { + ptrVar1 := v1.AzureDataDiskKind(v1.AzureSharedBlobDisk) + a.VolumeSource.AzureDisk.Kind = &ptrVar1 + } + } + if a.VolumeSource.ScaleIO != nil { + if a.VolumeSource.ScaleIO.StorageMode == "" { + a.VolumeSource.ScaleIO.StorageMode = "ThinProvisioned" + } + if a.VolumeSource.ScaleIO.FSType == "" { + a.VolumeSource.ScaleIO.FSType = "xfs" + } + } + } for i := range in.Spec.Predictor.WorkerSpec.PodSpec.InitContainers { a := &in.Spec.Predictor.WorkerSpec.PodSpec.InitContainers[i] for j := range a.Ports { @@ -488,6 +534,51 @@ func SetObjectDefaults_InferenceService(in *InferenceService) { } } } + for i := range in.Spec.Predictor.PodSpec.Volumes { + a := &in.Spec.Predictor.PodSpec.Volumes[i] + if a.VolumeSource.ISCSI != nil { + if a.VolumeSource.ISCSI.ISCSIInterface == "" { + a.VolumeSource.ISCSI.ISCSIInterface = "default" + } + } + if a.VolumeSource.RBD != nil { + if a.VolumeSource.RBD.RBDPool == "" { + a.VolumeSource.RBD.RBDPool = "rbd" + } + if a.VolumeSource.RBD.RadosUser == "" { + a.VolumeSource.RBD.RadosUser = "admin" + } + if a.VolumeSource.RBD.Keyring == "" { + a.VolumeSource.RBD.Keyring = "/etc/ceph/keyring" + } + } + if a.VolumeSource.AzureDisk != nil { + if a.VolumeSource.AzureDisk.CachingMode == nil { + ptrVar1 := v1.AzureDataDiskCachingMode(v1.AzureDataDiskCachingReadWrite) + a.VolumeSource.AzureDisk.CachingMode = &ptrVar1 + } + if a.VolumeSource.AzureDisk.FSType == nil { + var ptrVar1 string = "ext4" + a.VolumeSource.AzureDisk.FSType = &ptrVar1 + } + if a.VolumeSource.AzureDisk.ReadOnly == nil { + var ptrVar1 bool = false + a.VolumeSource.AzureDisk.ReadOnly = &ptrVar1 + } + if a.VolumeSource.AzureDisk.Kind == nil { + ptrVar1 := v1.AzureDataDiskKind(v1.AzureSharedBlobDisk) + a.VolumeSource.AzureDisk.Kind = &ptrVar1 + } + } + if a.VolumeSource.ScaleIO != nil { + if a.VolumeSource.ScaleIO.StorageMode == "" { + a.VolumeSource.ScaleIO.StorageMode = "ThinProvisioned" + } + if a.VolumeSource.ScaleIO.FSType == "" { + a.VolumeSource.ScaleIO.FSType = "xfs" + } + } + } for i := range in.Spec.Predictor.PodSpec.InitContainers { a := &in.Spec.Predictor.PodSpec.InitContainers[i] for j := range a.Ports { @@ -620,6 +711,51 @@ func SetObjectDefaults_InferenceServic

Please run make generate. diff --git a/pkg/client/clientset/versioned/fake/clientset_generated.go b/pkg/client/clientset/versioned/fake/clientset_generated.go index a66dc0c..9b922f4 100644 --- a/pkg/client/clientset/versioned/fake/clientset_generated.go +++ b/pkg/client/clientset/versioned/fake/clientset_generated.go @@ -33,8 +33,12 @@ import ( // NewSimpleClientset returns a clientset that will respond with the provided objects. // It's backed by a very simple object tracker that processes creates, updates and deletions as-is, -// without applying any validations and/or defaults. It shouldn't be considered a replacement +// without applying any field management, validations and/or defaults. It shouldn't be considered a replacement // for a real clientset and is mostly useful in simple unit tests. +// +// DEPRECATED: NewClientset replaces this with support for field management, which significantly improves +// server side apply testing. NewClientset is only available when apply configurations are generated (e.g. +// via --with-applyconfig). func NewSimpleClientset(objects ...runtime.Object) *Clientset { o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) for _, obj := range objects {

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterservingruntime.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterservingruntime.go index c6e8bc2..1d39be5 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterservingruntime.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterservingruntime.go @@ -20,14 +20,13 @@ package v1alpha1 import ( "context" - "time" v1alpha1 "github.com/kserve/kserve/pkg/apis/serving/v1alpha1" scheme "github.com/kserve/kserve/pkg/client/clientset/versioned/scheme" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" types "k8s.io/apimachinery/pkg/types" watch "k8s.io/apimachinery/pkg/watch" - rest "k8s.io/client-go/rest" + gentype "k8s.io/client-go/gentype" ) // ClusterServingRuntimesGetter has a method to return a ClusterServingRuntimeInterface. @@ -40,6 +39,7 @@ type ClusterServingRuntimesGetter interface { type ClusterServingRuntimeInterface interface { Create(ctx context.Context, clusterServingRuntime *v1alpha1.ClusterServingRuntime, opts v1.CreateOptions) (*v1alpha1.ClusterServingRuntime, error) Update(ctx context.Context, clusterServingRuntime *v1alpha1.ClusterServingRuntime, opts v1.UpdateOptions) (*v1alpha1.ClusterServingRuntime, error) + // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). UpdateStatus(ctx context.Context, clusterServingRuntime *v1alpha1.ClusterServingRuntime, opts v1.UpdateOptions) (*v1alpha1.ClusterServingRuntime, error) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error @@ -52,144 +52,18 @@ type ClusterServingRuntimeInterface interface { // clusterServingRuntimes implements ClusterServingRuntimeInterface type clusterServingRuntimes struct { - client rest.Interface - ns string + *gentype.ClientWithList[*v1alpha1.ClusterServingRuntime, *v1alpha1.ClusterServingRuntimeList] } // newClusterServingRuntimes returns a ClusterServingRuntimes func newClusterServingRuntimes(c *ServingV1alpha1Client, namespace string) *clusterServingRuntimes { return &clusterServingRuntimes{ - client: c.RESTClient(), - ns: namespace, + gentype.NewClientWithList[*v1alpha1.ClusterServingRuntime, *v1alpha1.ClusterServingRuntimeList]( + "clusterservingruntimes", + c.RESTClient(), + scheme.ParameterCodec, + namespace, + func() *v1alpha1.ClusterServingRuntime { return &v1alpha1.ClusterServingRuntime{} }, + func() *v1alpha1.ClusterServingRuntimeList { return &v1alpha1.ClusterServingRuntimeList{} }), } } - -// Get takes name of the clusterServingRuntime, and returns the corresponding clusterServingRuntime object, and an error if there is any. -func (c *clusterServingRuntimes) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.ClusterServingRuntime, err error) { - result = &v1alpha1.ClusterServingRuntime{} - err = c.client.Get(). - Namespace(c.ns). - Resource("clusterservingruntimes"). - Name(name). - VersionedParams(&options, scheme.ParameterCodec). - Do(ctx). - Into(result) - return -} - -// List takes label and field selectors, and returns the list of ClusterServingRuntimes that match those selectors. -func (c *clusterServingRuntimes) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.ClusterServingRuntimeList, err error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeout = time.Duration(*opts.TimeoutSeconds) * time.Second - } - result = &v1alpha1.ClusterServingRuntimeList{} - err = c.client.Get(). - Namespace(c.ns). - Resource("clusterservingruntimes"). - VersionedParams(&opts, scheme.ParameterCodec). - Timeout(timeout). - Do(ctx). - Into(result) - return -} - -// Watch returns a watch.Interface that watches the requested clusterServingRuntimes. -func (c *clusterServingRuntimes) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeou

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterstoragecontainer.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterstoragecontainer.go index 3b3cd69..4a0a9cf 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterstoragecontainer.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/clusterstoragecontainer.go @@ -20,14 +20,13 @@ package v1alpha1 import ( "context" - "time" v1alpha1 "github.com/kserve/kserve/pkg/apis/serving/v1alpha1" scheme "github.com/kserve/kserve/pkg/client/clientset/versioned/scheme" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" types "k8s.io/apimachinery/pkg/types" watch "k8s.io/apimachinery/pkg/watch" - rest "k8s.io/client-go/rest" + gentype "k8s.io/client-go/gentype" ) // ClusterStorageContainersGetter has a method to return a ClusterStorageContainerInterface. @@ -51,128 +50,18 @@ type ClusterStorageContainerInterface interface { // clusterStorageContainers implements ClusterStorageContainerInterface type clusterStorageContainers struct { - client rest.Interface - ns string + *gentype.ClientWithList[*v1alpha1.ClusterStorageContainer, *v1alpha1.ClusterStorageContainerList] } // newClusterStorageContainers returns a ClusterStorageContainers func newClusterStorageContainers(c *ServingV1alpha1Client, namespace string) *clusterStorageContainers { return &clusterStorageContainers{ - client: c.RESTClient(), - ns: namespace, + gentype.NewClientWithList[*v1alpha1.ClusterStorageContainer, *v1alpha1.ClusterStorageContainerList]( + "clusterstoragecontainers", + c.RESTClient(), + scheme.ParameterCodec, + namespace, + func() *v1alpha1.ClusterStorageContainer { return &v1alpha1.ClusterStorageContainer{} }, + func() *v1alpha1.ClusterStorageContainerList { return &v1alpha1.ClusterStorageContainerList{} }), } } - -// Get takes name of the clusterStorageContainer, and returns the corresponding clusterStorageContainer object, and an error if there is any. -func (c *clusterStorageContainers) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.ClusterStorageContainer, err error) { - result = &v1alpha1.ClusterStorageContainer{} - err = c.client.Get(). - Namespace(c.ns). - Resource("clusterstoragecontainers"). - Name(name). - VersionedParams(&options, scheme.ParameterCodec). - Do(ctx). - Into(result) - return -} - -// List takes label and field selectors, and returns the list of ClusterStorageContainers that match those selectors. -func (c *clusterStorageContainers) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.ClusterStorageContainerList, err error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeout = time.Duration(*opts.TimeoutSeconds) * time.Second - } - result = &v1alpha1.ClusterStorageContainerList{} - err = c.client.Get(). - Namespace(c.ns). - Resource("clusterstoragecontainers"). - VersionedParams(&opts, scheme.ParameterCodec). - Timeout(timeout). - Do(ctx). - Into(result) - return -} - -// Watch returns a watch.Interface that watches the requested clusterStorageContainers. -func (c *clusterStorageContainers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeout = time.Duration(*opts.TimeoutSeconds) * time.Second - } - opts.Watch = true - return c.client.Get(). - Namespace(c.ns). - Resource("clusterstoragecontainers"). - VersionedParams(&opts, scheme.ParameterCodec). - Timeout(timeout). - Watch(ctx) -} - -// Create takes the representation of a clusterStorageContainer and creates it. Returns the server's representation of the clusterStorageContainer, and an error, if there is any. -func (c *clusterStorageContainers) Create(ctx context.Context, clusterStorageContainer *v1alpha1.ClusterStorageContainer, opts v1.CreateOptions) (result *v1alpha1.ClusterStorageContainer, err error) { - result = &v1alpha1.ClusterStorageContainer{} - err = c.client.Post(). - Namespace(c.ns). - Resource("cluste

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterservingruntime.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterservingruntime.go index b4b75e2..11d9357 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterservingruntime.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterservingruntime.go @@ -41,22 +41,24 @@ var clusterservingruntimesKind = v1alpha1.SchemeGroupVersion.WithKind("ClusterSe // Get takes name of the clusterServingRuntime, and returns the corresponding clusterServingRuntime object, and an error if there is any. func (c *FakeClusterServingRuntimes) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.ClusterServingRuntime, err error) { + emptyResult := &v1alpha1.ClusterServingRuntime{} obj, err := c.Fake. - Invokes(testing.NewGetAction(clusterservingruntimesResource, c.ns, name), &v1alpha1.ClusterServingRuntime{}) + Invokes(testing.NewGetActionWithOptions(clusterservingruntimesResource, c.ns, name, options), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.ClusterServingRuntime), err } // List takes label and field selectors, and returns the list of ClusterServingRuntimes that match those selectors. func (c *FakeClusterServingRuntimes) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.ClusterServingRuntimeList, err error) { + emptyResult := &v1alpha1.ClusterServingRuntimeList{} obj, err := c.Fake. - Invokes(testing.NewListAction(clusterservingruntimesResource, clusterservingruntimesKind, c.ns, opts), &v1alpha1.ClusterServingRuntimeList{}) + Invokes(testing.NewListActionWithOptions(clusterservingruntimesResource, clusterservingruntimesKind, c.ns, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } label, _, _ := testing.ExtractFromListOptions(opts) @@ -75,40 +77,43 @@ func (c *FakeClusterServingRuntimes) List(ctx context.Context, opts v1.ListOptio // Watch returns a watch.Interface that watches the requested clusterServingRuntimes. func (c *FakeClusterServingRuntimes) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { return c.Fake. - InvokesWatch(testing.NewWatchAction(clusterservingruntimesResource, c.ns, opts)) + InvokesWatch(testing.NewWatchActionWithOptions(clusterservingruntimesResource, c.ns, opts)) } // Create takes the representation of a clusterServingRuntime and creates it. Returns the server's representation of the clusterServingRuntime, and an error, if there is any. func (c *FakeClusterServingRuntimes) Create(ctx context.Context, clusterServingRuntime *v1alpha1.ClusterServingRuntime, opts v1.CreateOptions) (result *v1alpha1.ClusterServingRuntime, err error) { + emptyResult := &v1alpha1.ClusterServingRuntime{} obj, err := c.Fake. - Invokes(testing.NewCreateAction(clusterservingruntimesResource, c.ns, clusterServingRuntime), &v1alpha1.ClusterServingRuntime{}) + Invokes(testing.NewCreateActionWithOptions(clusterservingruntimesResource, c.ns, clusterServingRuntime, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.ClusterServingRuntime), err } // Update takes the representation of a clusterServingRuntime and updates it. Returns the server's representation of the clusterServingRuntime, and an error, if there is any. func (c *FakeClusterServingRuntimes) Update(ctx context.Context, clusterServingRuntime *v1alpha1.ClusterServingRuntime, opts v1.UpdateOptions) (result *v1alpha1.ClusterServingRuntime, err error) { + emptyResult := &v1alpha1.ClusterServingRuntime{} obj, err := c.Fake. - Invokes(testing.NewUpdateAction(clusterservingruntimesResource, c.ns, clusterServingRuntime), &v1alpha1.ClusterServingRuntime{}) + Invokes(testing.NewUpdateActionWithOptions(clusterservingruntimesResource, c.ns, clusterServingRuntime, opts), emptyResult) if obj == nil { - return nil, err + return emptyResu

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterstoragecontainer.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterstoragecontainer.go index fbbe6ef..a5a77e7 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterstoragecontainer.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_clusterstoragecontainer.go @@ -41,22 +41,24 @@ var clusterstoragecontainersKind = v1alpha1.SchemeGroupVersion.WithKind("Cluster // Get takes name of the clusterStorageContainer, and returns the corresponding clusterStorageContainer object, and an error if there is any. func (c *FakeClusterStorageContainers) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.ClusterStorageContainer, err error) { + emptyResult := &v1alpha1.ClusterStorageContainer{} obj, err := c.Fake. - Invokes(testing.NewGetAction(clusterstoragecontainersResource, c.ns, name), &v1alpha1.ClusterStorageContainer{}) + Invokes(testing.NewGetActionWithOptions(clusterstoragecontainersResource, c.ns, name, options), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.ClusterStorageContainer), err } // List takes label and field selectors, and returns the list of ClusterStorageContainers that match those selectors. func (c *FakeClusterStorageContainers) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.ClusterStorageContainerList, err error) { + emptyResult := &v1alpha1.ClusterStorageContainerList{} obj, err := c.Fake. - Invokes(testing.NewListAction(clusterstoragecontainersResource, clusterstoragecontainersKind, c.ns, opts), &v1alpha1.ClusterStorageContainerList{}) + Invokes(testing.NewListActionWithOptions(clusterstoragecontainersResource, clusterstoragecontainersKind, c.ns, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } label, _, _ := testing.ExtractFromListOptions(opts) @@ -75,28 +77,30 @@ func (c *FakeClusterStorageContainers) List(ctx context.Context, opts v1.ListOpt // Watch returns a watch.Interface that watches the requested clusterStorageContainers. func (c *FakeClusterStorageContainers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { return c.Fake. - InvokesWatch(testing.NewWatchAction(clusterstoragecontainersResource, c.ns, opts)) + InvokesWatch(testing.NewWatchActionWithOptions(clusterstoragecontainersResource, c.ns, opts)) } // Create takes the representation of a clusterStorageContainer and creates it. Returns the server's representation of the clusterStorageContainer, and an error, if there is any. func (c *FakeClusterStorageContainers) Create(ctx context.Context, clusterStorageContainer *v1alpha1.ClusterStorageContainer, opts v1.CreateOptions) (result *v1alpha1.ClusterStorageContainer, err error) { + emptyResult := &v1alpha1.ClusterStorageContainer{} obj, err := c.Fake. - Invokes(testing.NewCreateAction(clusterstoragecontainersResource, c.ns, clusterStorageContainer), &v1alpha1.ClusterStorageContainer{}) + Invokes(testing.NewCreateActionWithOptions(clusterstoragecontainersResource, c.ns, clusterStorageContainer, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.ClusterStorageContainer), err } // Update takes the representation of a clusterStorageContainer and updates it. Returns the server's representation of the clusterStorageContainer, and an error, if there is any. func (c *FakeClusterStorageContainers) Update(ctx context.Context, clusterStorageContainer *v1alpha1.ClusterStorageContainer, opts v1.UpdateOptions) (result *v1alpha1.ClusterStorageContainer, err error) { + emptyResult := &v1alpha1.ClusterStorageContainer{} obj, err := c.Fake. - Invokes(testing.NewUpdateAction(clusterstoragecontainersResource, c.ns, clusterStorageContainer), &v1alpha1.ClusterStorageContainer{}) + Invokes(testing.NewUpdateActionWithOptions(clusterstoragecontainersResource, c.ns, c

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_inferencegraph.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_inferencegraph.go index aeaf9b8..a727a31 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_inferencegraph.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_inferencegraph.go @@ -41,22 +41,24 @@ var inferencegraphsKind = v1alpha1.SchemeGroupVersion.WithKind("InferenceGraph") // Get takes name of the inferenceGraph, and returns the corresponding inferenceGraph object, and an error if there is any. func (c *FakeInferenceGraphs) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.InferenceGraph, err error) { + emptyResult := &v1alpha1.InferenceGraph{} obj, err := c.Fake. - Invokes(testing.NewGetAction(inferencegraphsResource, c.ns, name), &v1alpha1.InferenceGraph{}) + Invokes(testing.NewGetActionWithOptions(inferencegraphsResource, c.ns, name, options), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.InferenceGraph), err } // List takes label and field selectors, and returns the list of InferenceGraphs that match those selectors. func (c *FakeInferenceGraphs) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.InferenceGraphList, err error) { + emptyResult := &v1alpha1.InferenceGraphList{} obj, err := c.Fake. - Invokes(testing.NewListAction(inferencegraphsResource, inferencegraphsKind, c.ns, opts), &v1alpha1.InferenceGraphList{}) + Invokes(testing.NewListActionWithOptions(inferencegraphsResource, inferencegraphsKind, c.ns, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } label, _, _ := testing.ExtractFromListOptions(opts) @@ -75,40 +77,43 @@ func (c *FakeInferenceGraphs) List(ctx context.Context, opts v1.ListOptions) (re // Watch returns a watch.Interface that watches the requested inferenceGraphs. func (c *FakeInferenceGraphs) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { return c.Fake. - InvokesWatch(testing.NewWatchAction(inferencegraphsResource, c.ns, opts)) + InvokesWatch(testing.NewWatchActionWithOptions(inferencegraphsResource, c.ns, opts)) } // Create takes the representation of a inferenceGraph and creates it. Returns the server's representation of the inferenceGraph, and an error, if there is any. func (c *FakeInferenceGraphs) Create(ctx context.Context, inferenceGraph *v1alpha1.InferenceGraph, opts v1.CreateOptions) (result *v1alpha1.InferenceGraph, err error) { + emptyResult := &v1alpha1.InferenceGraph{} obj, err := c.Fake. - Invokes(testing.NewCreateAction(inferencegraphsResource, c.ns, inferenceGraph), &v1alpha1.InferenceGraph{}) + Invokes(testing.NewCreateActionWithOptions(inferencegraphsResource, c.ns, inferenceGraph, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.InferenceGraph), err } // Update takes the representation of a inferenceGraph and updates it. Returns the server's representation of the inferenceGraph, and an error, if there is any. func (c *FakeInferenceGraphs) Update(ctx context.Context, inferenceGraph *v1alpha1.InferenceGraph, opts v1.UpdateOptions) (result *v1alpha1.InferenceGraph, err error) { + emptyResult := &v1alpha1.InferenceGraph{} obj, err := c.Fake. - Invokes(testing.NewUpdateAction(inferencegraphsResource, c.ns, inferenceGraph), &v1alpha1.InferenceGraph{}) + Invokes(testing.NewUpdateActionWithOptions(inferencegraphsResource, c.ns, inferenceGraph, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.InferenceGraph), err } // UpdateStatus was generated because the type contains a Status member. // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeInferenceGraphs) UpdateStatus(ctx context.Context, inferenceGraph *v1alpha1.InferenceGraph, opts v1.UpdateOptions) (*v

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelcache.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelcache.go index b2bd7c6..5d6779e 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelcache.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelcache.go @@ -41,22 +41,24 @@ var localmodelcachesKind = v1alpha1.SchemeGroupVersion.WithKind("LocalModelCache // Get takes name of the localModelCache, and returns the corresponding localModelCache object, and an error if there is any. func (c *FakeLocalModelCaches) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.LocalModelCache, err error) { + emptyResult := &v1alpha1.LocalModelCache{} obj, err := c.Fake. - Invokes(testing.NewGetAction(localmodelcachesResource, c.ns, name), &v1alpha1.LocalModelCache{}) + Invokes(testing.NewGetActionWithOptions(localmodelcachesResource, c.ns, name, options), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelCache), err } // List takes label and field selectors, and returns the list of LocalModelCaches that match those selectors. func (c *FakeLocalModelCaches) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.LocalModelCacheList, err error) { + emptyResult := &v1alpha1.LocalModelCacheList{} obj, err := c.Fake. - Invokes(testing.NewListAction(localmodelcachesResource, localmodelcachesKind, c.ns, opts), &v1alpha1.LocalModelCacheList{}) + Invokes(testing.NewListActionWithOptions(localmodelcachesResource, localmodelcachesKind, c.ns, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } label, _, _ := testing.ExtractFromListOptions(opts) @@ -75,40 +77,43 @@ func (c *FakeLocalModelCaches) List(ctx context.Context, opts v1.ListOptions) (r // Watch returns a watch.Interface that watches the requested localModelCaches. func (c *FakeLocalModelCaches) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { return c.Fake. - InvokesWatch(testing.NewWatchAction(localmodelcachesResource, c.ns, opts)) + InvokesWatch(testing.NewWatchActionWithOptions(localmodelcachesResource, c.ns, opts)) } // Create takes the representation of a localModelCache and creates it. Returns the server's representation of the localModelCache, and an error, if there is any. func (c *FakeLocalModelCaches) Create(ctx context.Context, localModelCache *v1alpha1.LocalModelCache, opts v1.CreateOptions) (result *v1alpha1.LocalModelCache, err error) { + emptyResult := &v1alpha1.LocalModelCache{} obj, err := c.Fake. - Invokes(testing.NewCreateAction(localmodelcachesResource, c.ns, localModelCache), &v1alpha1.LocalModelCache{}) + Invokes(testing.NewCreateActionWithOptions(localmodelcachesResource, c.ns, localModelCache, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelCache), err } // Update takes the representation of a localModelCache and updates it. Returns the server's representation of the localModelCache, and an error, if there is any. func (c *FakeLocalModelCaches) Update(ctx context.Context, localModelCache *v1alpha1.LocalModelCache, opts v1.UpdateOptions) (result *v1alpha1.LocalModelCache, err error) { + emptyResult := &v1alpha1.LocalModelCache{} obj, err := c.Fake. - Invokes(testing.NewUpdateAction(localmodelcachesResource, c.ns, localModelCache), &v1alpha1.LocalModelCache{}) + Invokes(testing.NewUpdateActionWithOptions(localmodelcachesResource, c.ns, localModelCache, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelCache), err } // UpdateStatus was generated because the type contains a Status member. // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeLocalModelCaches) UpdateStatus(ctx context.Context, localModelCach

Please run make generate. diff --git a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelnode.go b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelnode.go index c0a64c4..7aa6f8a 100644 --- a/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelnode.go +++ b/pkg/client/clientset/versioned/typed/serving/v1alpha1/fake/fake_localmodelnode.go @@ -41,22 +41,24 @@ var localmodelnodesKind = v1alpha1.SchemeGroupVersion.WithKind("LocalModelNode") // Get takes name of the localModelNode, and returns the corresponding localModelNode object, and an error if there is any. func (c *FakeLocalModelNodes) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.LocalModelNode, err error) { + emptyResult := &v1alpha1.LocalModelNode{} obj, err := c.Fake. - Invokes(testing.NewGetAction(localmodelnodesResource, c.ns, name), &v1alpha1.LocalModelNode{}) + Invokes(testing.NewGetActionWithOptions(localmodelnodesResource, c.ns, name, options), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelNode), err } // List takes label and field selectors, and returns the list of LocalModelNodes that match those selectors. func (c *FakeLocalModelNodes) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.LocalModelNodeList, err error) { + emptyResult := &v1alpha1.LocalModelNodeList{} obj, err := c.Fake. - Invokes(testing.NewListAction(localmodelnodesResource, localmodelnodesKind, c.ns, opts), &v1alpha1.LocalModelNodeList{}) + Invokes(testing.NewListActionWithOptions(localmodelnodesResource, localmodelnodesKind, c.ns, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } label, _, _ := testing.ExtractFromListOptions(opts) @@ -75,40 +77,43 @@ func (c *FakeLocalModelNodes) List(ctx context.Context, opts v1.ListOptions) (re // Watch returns a watch.Interface that watches the requested localModelNodes. func (c *FakeLocalModelNodes) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { return c.Fake. - InvokesWatch(testing.NewWatchAction(localmodelnodesResource, c.ns, opts)) + InvokesWatch(testing.NewWatchActionWithOptions(localmodelnodesResource, c.ns, opts)) } // Create takes the representation of a localModelNode and creates it. Returns the server's representation of the localModelNode, and an error, if there is any. func (c *FakeLocalModelNodes) Create(ctx context.Context, localModelNode *v1alpha1.LocalModelNode, opts v1.CreateOptions) (result *v1alpha1.LocalModelNode, err error) { + emptyResult := &v1alpha1.LocalModelNode{} obj, err := c.Fake. - Invokes(testing.NewCreateAction(localmodelnodesResource, c.ns, localModelNode), &v1alpha1.LocalModelNode{}) + Invokes(testing.NewCreateActionWithOptions(localmodelnodesResource, c.ns, localModelNode, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelNode), err } // Update takes the representation of a localModelNode and updates it. Returns the server's representation of the localModelNode, and an error, if there is any. func (c *FakeLocalModelNodes) Update(ctx context.Context, localModelNode *v1alpha1.LocalModelNode, opts v1.UpdateOptions) (result *v1alpha1.LocalModelNode, err error) { + emptyResult := &v1alpha1.LocalModelNode{} obj, err := c.Fake. - Invokes(testing.NewUpdateAction(localmodelnodesResource, c.ns, localModelNode), &v1alpha1.LocalModelNode{}) + Invokes(testing.NewUpdateActionWithOptions(localmodelnodesResource, c.ns, localModelNode, opts), emptyResult) if obj == nil { - return nil, err + return emptyResult, err } return obj.(*v1alpha1.LocalModelNode), err } // UpdateStatus was generated because the type contains a Status member. // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeLocalModelNodes) UpdateStatus(ctx context.Context, localModelNode *v1alpha1.LocalModelNode, opts v1.UpdateOptions) (*v