Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use code-generator v1.29.1 for code-generation (#2908)

Browse Source 
Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
This commit is contained in:
Sanket Sudake
2024-02-06 14:00:16 +05:30
committed by GitHub
parent dcecb10e6c
commit 579d46cc1b
57 changed files with 4991 additions and 253 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/generated/clientset/versioned/doc.go
-20
View File
@@ -1,20 +0,0 @@
/*
Copyright The Fission Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// Code generated by client-gen. DO NOT EDIT.
// This package has the automatically generated clientset.
package versioned
pkg/generated/clientset/versioned/typed/core/v1/canaryconfig.go
+61
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -47,6 +50,8 @@ type CanaryConfigInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.CanaryConfigList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.CanaryConfig, err error)
Apply(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error)
ApplyStatus(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error)
CanaryConfigExpansion
}
@@ -193,3 +198,59 @@ func (c *canaryConfigs) Patch(ctx context.Context, name string, pt types.PatchTy
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied canaryConfig.
func (c *canaryConfigs) Apply(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error) {
if _canaryConfig == nil {
return nil, fmt.Errorf("_canaryConfig provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_canaryConfig)
if err != nil {
return nil, err
}
name := _canaryConfig.Name
if name == nil {
return nil, fmt.Errorf("_canaryConfig.Name must be provided to Apply")
}
result = &v1.CanaryConfig{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("canaryconfigs").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
// ApplyStatus was generated because the type contains a Status member.
// Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
func (c *canaryConfigs) ApplyStatus(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error) {
if _canaryConfig == nil {
return nil, fmt.Errorf("_canaryConfig provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_canaryConfig)
if err != nil {
return nil, err
}
name := _canaryConfig.Name
if name == nil {
return nil, fmt.Errorf("_canaryConfig.Name must be provided to Apply")
}
result = &v1.CanaryConfig{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("canaryconfigs").
Name(*name).
SubResource("status").
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/environment.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type EnvironmentInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.EnvironmentList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Environment, err error)
Apply(ctx context.Context, _environment *corev1.EnvironmentApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Environment, err error)
EnvironmentExpansion
}
@@ -176,3 +180,29 @@ func (c *environments) Patch(ctx context.Context, name string, pt types.PatchTyp
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied environment.
func (c *environments) Apply(ctx context.Context, _environment *corev1.EnvironmentApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Environment, err error) {
if _environment == nil {
return nil, fmt.Errorf("_environment provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_environment)
if err != nil {
return nil, err
}
name := _environment.Name
if name == nil {
return nil, fmt.Errorf("_environment.Name must be provided to Apply")
}
result = &v1.Environment{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("environments").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_canaryconfig.go
+76 -29
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeCanaryConfigs struct {
ns string
}
var canaryconfigsResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "canaryconfigs"}
var canaryconfigsResource = v1.SchemeGroupVersion.WithResource("canaryconfigs")
var canaryconfigsKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "CanaryConfig"}
var canaryconfigsKind = v1.SchemeGroupVersion.WithKind("CanaryConfig")
// Get takes name of the _canaryConfig, and returns the corresponding canaryConfig object, and an error if there is any.
func (c *FakeCanaryConfigs) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.CanaryConfig, err error) {
func (c *FakeCanaryConfigs) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.CanaryConfig, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(canaryconfigsResource, c.ns, name), &corev1.CanaryConfig{})
Invokes(testing.NewGetAction(canaryconfigsResource, c.ns, name), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*corev1.CanaryConfig), err
return obj.(*v1.CanaryConfig), err
}
// List takes label and field selectors, and returns the list of CanaryConfigs that match those selectors.
func (c *FakeCanaryConfigs) List(ctx context.Context, opts v1.ListOptions) (result *corev1.CanaryConfigList, err error) {
func (c *FakeCanaryConfigs) List(ctx context.Context, opts metav1.ListOptions) (result *v1.CanaryConfigList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(canaryconfigsResource, canaryconfigsKind, c.ns, opts), &corev1.CanaryConfigList{})
Invokes(testing.NewListAction(canaryconfigsResource, canaryconfigsKind, c.ns, opts), &v1.CanaryConfigList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeCanaryConfigs) List(ctx context.Context, opts v1.ListOptions) (resu
if label == nil {
label = labels.Everything()
}
list := &corev1.CanaryConfigList{ListMeta: obj.(*corev1.CanaryConfigList).ListMeta}
for _, item := range obj.(*corev1.CanaryConfigList).Items {
list := &v1.CanaryConfigList{ListMeta: obj.(*v1.CanaryConfigList).ListMeta}
for _, item := range obj.(*v1.CanaryConfigList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,69 +76,114 @@ func (c *FakeCanaryConfigs) List(ctx context.Context, opts v1.ListOptions) (resu
}
// Watch returns a watch.Interface that watches the requested canaryConfigs.
func (c *FakeCanaryConfigs) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeCanaryConfigs) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(canaryconfigsResource, c.ns, opts))
}
// Create takes the representation of a _canaryConfig and creates it. Returns the server's representation of the canaryConfig, and an error, if there is any.
func (c *FakeCanaryConfigs) Create(ctx context.Context, _canaryConfig *corev1.CanaryConfig, opts v1.CreateOptions) (result *corev1.CanaryConfig, err error) {
func (c *FakeCanaryConfigs) Create(ctx context.Context, _canaryConfig *v1.CanaryConfig, opts metav1.CreateOptions) (result *v1.CanaryConfig, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(canaryconfigsResource, c.ns, _canaryConfig), &corev1.CanaryConfig{})
Invokes(testing.NewCreateAction(canaryconfigsResource, c.ns, _canaryConfig), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*corev1.CanaryConfig), err
return obj.(*v1.CanaryConfig), err
}
// Update takes the representation of a _canaryConfig and updates it. Returns the server's representation of the canaryConfig, and an error, if there is any.
func (c *FakeCanaryConfigs) Update(ctx context.Context, _canaryConfig *corev1.CanaryConfig, opts v1.UpdateOptions) (result *corev1.CanaryConfig, err error) {
func (c *FakeCanaryConfigs) Update(ctx context.Context, _canaryConfig *v1.CanaryConfig, opts metav1.UpdateOptions) (result *v1.CanaryConfig, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(canaryconfigsResource, c.ns, _canaryConfig), &corev1.CanaryConfig{})
Invokes(testing.NewUpdateAction(canaryconfigsResource, c.ns, _canaryConfig), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*corev1.CanaryConfig), err
return obj.(*v1.CanaryConfig), 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 *FakeCanaryConfigs) UpdateStatus(ctx context.Context, _canaryConfig *corev1.CanaryConfig, opts v1.UpdateOptions) (*corev1.CanaryConfig, error) {
func (c *FakeCanaryConfigs) UpdateStatus(ctx context.Context, _canaryConfig *v1.CanaryConfig, opts metav1.UpdateOptions) (*v1.CanaryConfig, error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateSubresourceAction(canaryconfigsResource, "status", c.ns, _canaryConfig), &corev1.CanaryConfig{})
Invokes(testing.NewUpdateSubresourceAction(canaryconfigsResource, "status", c.ns, _canaryConfig), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*corev1.CanaryConfig), err
return obj.(*v1.CanaryConfig), err
}
// Delete takes name of the _canaryConfig and deletes it. Returns an error if one occurs.
func (c *FakeCanaryConfigs) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeCanaryConfigs) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(canaryconfigsResource, c.ns, name, opts), &corev1.CanaryConfig{})
Invokes(testing.NewDeleteActionWithOptions(canaryconfigsResource, c.ns, name, opts), &v1.CanaryConfig{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeCanaryConfigs) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeCanaryConfigs) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(canaryconfigsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.CanaryConfigList{})
_, err := c.Fake.Invokes(action, &v1.CanaryConfigList{})
return err
}
// Patch applies the patch and returns the patched canaryConfig.
func (c *FakeCanaryConfigs) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.CanaryConfig, err error) {
func (c *FakeCanaryConfigs) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.CanaryConfig, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(canaryconfigsResource, c.ns, name, pt, data, subresources...), &corev1.CanaryConfig{})
Invokes(testing.NewPatchSubresourceAction(canaryconfigsResource, c.ns, name, pt, data, subresources...), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*corev1.CanaryConfig), err
return obj.(*v1.CanaryConfig), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied canaryConfig.
func (c *FakeCanaryConfigs) Apply(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error) {
if _canaryConfig == nil {
return nil, fmt.Errorf("_canaryConfig provided to Apply must not be nil")
}
data, err := json.Marshal(_canaryConfig)
if err != nil {
return nil, err
}
name := _canaryConfig.Name
if name == nil {
return nil, fmt.Errorf("_canaryConfig.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(canaryconfigsResource, c.ns, *name, types.ApplyPatchType, data), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*v1.CanaryConfig), err
}
// ApplyStatus was generated because the type contains a Status member.
// Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
func (c *FakeCanaryConfigs) ApplyStatus(ctx context.Context, _canaryConfig *corev1.CanaryConfigApplyConfiguration, opts metav1.ApplyOptions) (result *v1.CanaryConfig, err error) {
if _canaryConfig == nil {
return nil, fmt.Errorf("_canaryConfig provided to Apply must not be nil")
}
data, err := json.Marshal(_canaryConfig)
if err != nil {
return nil, err
}
name := _canaryConfig.Name
if name == nil {
return nil, fmt.Errorf("_canaryConfig.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(canaryconfigsResource, c.ns, *name, types.ApplyPatchType, data, "status"), &v1.CanaryConfig{})
if obj == nil {
return nil, err
}
return obj.(*v1.CanaryConfig), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_environment.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeEnvironments struct {
ns string
}
var environmentsResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "environments"}
var environmentsResource = v1.SchemeGroupVersion.WithResource("environments")
var environmentsKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "Environment"}
var environmentsKind = v1.SchemeGroupVersion.WithKind("Environment")
// Get takes name of the _environment, and returns the corresponding environment object, and an error if there is any.
func (c *FakeEnvironments) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.Environment, err error) {
func (c *FakeEnvironments) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.Environment, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(environmentsResource, c.ns, name), &corev1.Environment{})
Invokes(testing.NewGetAction(environmentsResource, c.ns, name), &v1.Environment{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Environment), err
return obj.(*v1.Environment), err
}
// List takes label and field selectors, and returns the list of Environments that match those selectors.
func (c *FakeEnvironments) List(ctx context.Context, opts v1.ListOptions) (result *corev1.EnvironmentList, err error) {
func (c *FakeEnvironments) List(ctx context.Context, opts metav1.ListOptions) (result *v1.EnvironmentList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(environmentsResource, environmentsKind, c.ns, opts), &corev1.EnvironmentList{})
Invokes(testing.NewListAction(environmentsResource, environmentsKind, c.ns, opts), &v1.EnvironmentList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeEnvironments) List(ctx context.Context, opts v1.ListOptions) (resul
if label == nil {
label = labels.Everything()
}
list := &corev1.EnvironmentList{ListMeta: obj.(*corev1.EnvironmentList).ListMeta}
for _, item := range obj.(*corev1.EnvironmentList).Items {
list := &v1.EnvironmentList{ListMeta: obj.(*v1.EnvironmentList).ListMeta}
for _, item := range obj.(*v1.EnvironmentList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeEnvironments) List(ctx context.Context, opts v1.ListOptions) (resul
}
// Watch returns a watch.Interface that watches the requested environments.
func (c *FakeEnvironments) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeEnvironments) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(environmentsResource, c.ns, opts))
}
// Create takes the representation of a _environment and creates it. Returns the server's representation of the environment, and an error, if there is any.
func (c *FakeEnvironments) Create(ctx context.Context, _environment *corev1.Environment, opts v1.CreateOptions) (result *corev1.Environment, err error) {
func (c *FakeEnvironments) Create(ctx context.Context, _environment *v1.Environment, opts metav1.CreateOptions) (result *v1.Environment, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(environmentsResource, c.ns, _environment), &corev1.Environment{})
Invokes(testing.NewCreateAction(environmentsResource, c.ns, _environment), &v1.Environment{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Environment), err
return obj.(*v1.Environment), err
}
// Update takes the representation of a _environment and updates it. Returns the server's representation of the environment, and an error, if there is any.
func (c *FakeEnvironments) Update(ctx context.Context, _environment *corev1.Environment, opts v1.UpdateOptions) (result *corev1.Environment, err error) {
func (c *FakeEnvironments) Update(ctx context.Context, _environment *v1.Environment, opts metav1.UpdateOptions) (result *v1.Environment, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(environmentsResource, c.ns, _environment), &corev1.Environment{})
Invokes(testing.NewUpdateAction(environmentsResource, c.ns, _environment), &v1.Environment{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Environment), err
return obj.(*v1.Environment), err
}
// Delete takes name of the _environment and deletes it. Returns an error if one occurs.
func (c *FakeEnvironments) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeEnvironments) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(environmentsResource, c.ns, name, opts), &corev1.Environment{})
Invokes(testing.NewDeleteActionWithOptions(environmentsResource, c.ns, name, opts), &v1.Environment{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeEnvironments) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeEnvironments) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(environmentsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.EnvironmentList{})
_, err := c.Fake.Invokes(action, &v1.EnvironmentList{})
return err
}
// Patch applies the patch and returns the patched environment.
func (c *FakeEnvironments) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.Environment, err error) {
func (c *FakeEnvironments) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Environment, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(environmentsResource, c.ns, name, pt, data, subresources...), &corev1.Environment{})
Invokes(testing.NewPatchSubresourceAction(environmentsResource, c.ns, name, pt, data, subresources...), &v1.Environment{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Environment), err
return obj.(*v1.Environment), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied environment.
func (c *FakeEnvironments) Apply(ctx context.Context, _environment *corev1.EnvironmentApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Environment, err error) {
if _environment == nil {
return nil, fmt.Errorf("_environment provided to Apply must not be nil")
}
data, err := json.Marshal(_environment)
if err != nil {
return nil, err
}
name := _environment.Name
if name == nil {
return nil, fmt.Errorf("_environment.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(environmentsResource, c.ns, *name, types.ApplyPatchType, data), &v1.Environment{})
if obj == nil {
return nil, err
}
return obj.(*v1.Environment), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_function.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeFunctions struct {
ns string
}
var functionsResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "functions"}
var functionsResource = v1.SchemeGroupVersion.WithResource("functions")
var functionsKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "Function"}
var functionsKind = v1.SchemeGroupVersion.WithKind("Function")
// Get takes name of the _function, and returns the corresponding function object, and an error if there is any.
func (c *FakeFunctions) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.Function, err error) {
func (c *FakeFunctions) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.Function, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(functionsResource, c.ns, name), &corev1.Function{})
Invokes(testing.NewGetAction(functionsResource, c.ns, name), &v1.Function{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Function), err
return obj.(*v1.Function), err
}
// List takes label and field selectors, and returns the list of Functions that match those selectors.
func (c *FakeFunctions) List(ctx context.Context, opts v1.ListOptions) (result *corev1.FunctionList, err error) {
func (c *FakeFunctions) List(ctx context.Context, opts metav1.ListOptions) (result *v1.FunctionList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(functionsResource, functionsKind, c.ns, opts), &corev1.FunctionList{})
Invokes(testing.NewListAction(functionsResource, functionsKind, c.ns, opts), &v1.FunctionList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeFunctions) List(ctx context.Context, opts v1.ListOptions) (result *
if label == nil {
label = labels.Everything()
}
list := &corev1.FunctionList{ListMeta: obj.(*corev1.FunctionList).ListMeta}
for _, item := range obj.(*corev1.FunctionList).Items {
list := &v1.FunctionList{ListMeta: obj.(*v1.FunctionList).ListMeta}
for _, item := range obj.(*v1.FunctionList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeFunctions) List(ctx context.Context, opts v1.ListOptions) (result *
}
// Watch returns a watch.Interface that watches the requested functions.
func (c *FakeFunctions) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeFunctions) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(functionsResource, c.ns, opts))
}
// Create takes the representation of a _function and creates it. Returns the server's representation of the function, and an error, if there is any.
func (c *FakeFunctions) Create(ctx context.Context, _function *corev1.Function, opts v1.CreateOptions) (result *corev1.Function, err error) {
func (c *FakeFunctions) Create(ctx context.Context, _function *v1.Function, opts metav1.CreateOptions) (result *v1.Function, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(functionsResource, c.ns, _function), &corev1.Function{})
Invokes(testing.NewCreateAction(functionsResource, c.ns, _function), &v1.Function{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Function), err
return obj.(*v1.Function), err
}
// Update takes the representation of a _function and updates it. Returns the server's representation of the function, and an error, if there is any.
func (c *FakeFunctions) Update(ctx context.Context, _function *corev1.Function, opts v1.UpdateOptions) (result *corev1.Function, err error) {
func (c *FakeFunctions) Update(ctx context.Context, _function *v1.Function, opts metav1.UpdateOptions) (result *v1.Function, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(functionsResource, c.ns, _function), &corev1.Function{})
Invokes(testing.NewUpdateAction(functionsResource, c.ns, _function), &v1.Function{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Function), err
return obj.(*v1.Function), err
}
// Delete takes name of the _function and deletes it. Returns an error if one occurs.
func (c *FakeFunctions) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeFunctions) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(functionsResource, c.ns, name, opts), &corev1.Function{})
Invokes(testing.NewDeleteActionWithOptions(functionsResource, c.ns, name, opts), &v1.Function{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeFunctions) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeFunctions) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(functionsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.FunctionList{})
_, err := c.Fake.Invokes(action, &v1.FunctionList{})
return err
}
// Patch applies the patch and returns the patched function.
func (c *FakeFunctions) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.Function, err error) {
func (c *FakeFunctions) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Function, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(functionsResource, c.ns, name, pt, data, subresources...), &corev1.Function{})
Invokes(testing.NewPatchSubresourceAction(functionsResource, c.ns, name, pt, data, subresources...), &v1.Function{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Function), err
return obj.(*v1.Function), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied function.
func (c *FakeFunctions) Apply(ctx context.Context, _function *corev1.FunctionApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Function, err error) {
if _function == nil {
return nil, fmt.Errorf("_function provided to Apply must not be nil")
}
data, err := json.Marshal(_function)
if err != nil {
return nil, err
}
name := _function.Name
if name == nil {
return nil, fmt.Errorf("_function.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(functionsResource, c.ns, *name, types.ApplyPatchType, data), &v1.Function{})
if obj == nil {
return nil, err
}
return obj.(*v1.Function), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_httptrigger.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeHTTPTriggers struct {
ns string
}
var httptriggersResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "httptriggers"}
var httptriggersResource = v1.SchemeGroupVersion.WithResource("httptriggers")
var httptriggersKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "HTTPTrigger"}
var httptriggersKind = v1.SchemeGroupVersion.WithKind("HTTPTrigger")
// Get takes name of the _hTTPTrigger, and returns the corresponding hTTPTrigger object, and an error if there is any.
func (c *FakeHTTPTriggers) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.HTTPTrigger, err error) {
func (c *FakeHTTPTriggers) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.HTTPTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(httptriggersResource, c.ns, name), &corev1.HTTPTrigger{})
Invokes(testing.NewGetAction(httptriggersResource, c.ns, name), &v1.HTTPTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.HTTPTrigger), err
return obj.(*v1.HTTPTrigger), err
}
// List takes label and field selectors, and returns the list of HTTPTriggers that match those selectors.
func (c *FakeHTTPTriggers) List(ctx context.Context, opts v1.ListOptions) (result *corev1.HTTPTriggerList, err error) {
func (c *FakeHTTPTriggers) List(ctx context.Context, opts metav1.ListOptions) (result *v1.HTTPTriggerList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(httptriggersResource, httptriggersKind, c.ns, opts), &corev1.HTTPTriggerList{})
Invokes(testing.NewListAction(httptriggersResource, httptriggersKind, c.ns, opts), &v1.HTTPTriggerList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeHTTPTriggers) List(ctx context.Context, opts v1.ListOptions) (resul
if label == nil {
label = labels.Everything()
}
list := &corev1.HTTPTriggerList{ListMeta: obj.(*corev1.HTTPTriggerList).ListMeta}
for _, item := range obj.(*corev1.HTTPTriggerList).Items {
list := &v1.HTTPTriggerList{ListMeta: obj.(*v1.HTTPTriggerList).ListMeta}
for _, item := range obj.(*v1.HTTPTriggerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeHTTPTriggers) List(ctx context.Context, opts v1.ListOptions) (resul
}
// Watch returns a watch.Interface that watches the requested hTTPTriggers.
func (c *FakeHTTPTriggers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeHTTPTriggers) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(httptriggersResource, c.ns, opts))
}
// Create takes the representation of a _hTTPTrigger and creates it. Returns the server's representation of the hTTPTrigger, and an error, if there is any.
func (c *FakeHTTPTriggers) Create(ctx context.Context, _hTTPTrigger *corev1.HTTPTrigger, opts v1.CreateOptions) (result *corev1.HTTPTrigger, err error) {
func (c *FakeHTTPTriggers) Create(ctx context.Context, _hTTPTrigger *v1.HTTPTrigger, opts metav1.CreateOptions) (result *v1.HTTPTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(httptriggersResource, c.ns, _hTTPTrigger), &corev1.HTTPTrigger{})
Invokes(testing.NewCreateAction(httptriggersResource, c.ns, _hTTPTrigger), &v1.HTTPTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.HTTPTrigger), err
return obj.(*v1.HTTPTrigger), err
}
// Update takes the representation of a _hTTPTrigger and updates it. Returns the server's representation of the hTTPTrigger, and an error, if there is any.
func (c *FakeHTTPTriggers) Update(ctx context.Context, _hTTPTrigger *corev1.HTTPTrigger, opts v1.UpdateOptions) (result *corev1.HTTPTrigger, err error) {
func (c *FakeHTTPTriggers) Update(ctx context.Context, _hTTPTrigger *v1.HTTPTrigger, opts metav1.UpdateOptions) (result *v1.HTTPTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(httptriggersResource, c.ns, _hTTPTrigger), &corev1.HTTPTrigger{})
Invokes(testing.NewUpdateAction(httptriggersResource, c.ns, _hTTPTrigger), &v1.HTTPTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.HTTPTrigger), err
return obj.(*v1.HTTPTrigger), err
}
// Delete takes name of the _hTTPTrigger and deletes it. Returns an error if one occurs.
func (c *FakeHTTPTriggers) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeHTTPTriggers) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(httptriggersResource, c.ns, name, opts), &corev1.HTTPTrigger{})
Invokes(testing.NewDeleteActionWithOptions(httptriggersResource, c.ns, name, opts), &v1.HTTPTrigger{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeHTTPTriggers) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeHTTPTriggers) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(httptriggersResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.HTTPTriggerList{})
_, err := c.Fake.Invokes(action, &v1.HTTPTriggerList{})
return err
}
// Patch applies the patch and returns the patched hTTPTrigger.
func (c *FakeHTTPTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.HTTPTrigger, err error) {
func (c *FakeHTTPTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.HTTPTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(httptriggersResource, c.ns, name, pt, data, subresources...), &corev1.HTTPTrigger{})
Invokes(testing.NewPatchSubresourceAction(httptriggersResource, c.ns, name, pt, data, subresources...), &v1.HTTPTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.HTTPTrigger), err
return obj.(*v1.HTTPTrigger), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied hTTPTrigger.
func (c *FakeHTTPTriggers) Apply(ctx context.Context, _hTTPTrigger *corev1.HTTPTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.HTTPTrigger, err error) {
if _hTTPTrigger == nil {
return nil, fmt.Errorf("_hTTPTrigger provided to Apply must not be nil")
}
data, err := json.Marshal(_hTTPTrigger)
if err != nil {
return nil, err
}
name := _hTTPTrigger.Name
if name == nil {
return nil, fmt.Errorf("_hTTPTrigger.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(httptriggersResource, c.ns, *name, types.ApplyPatchType, data), &v1.HTTPTrigger{})
if obj == nil {
return nil, err
}
return obj.(*v1.HTTPTrigger), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_kuberneteswatchtrigger.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeKubernetesWatchTriggers struct {
ns string
}
var kuberneteswatchtriggersResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "kuberneteswatchtriggers"}
var kuberneteswatchtriggersResource = v1.SchemeGroupVersion.WithResource("kuberneteswatchtriggers")
var kuberneteswatchtriggersKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "KubernetesWatchTrigger"}
var kuberneteswatchtriggersKind = v1.SchemeGroupVersion.WithKind("KubernetesWatchTrigger")
// Get takes name of the _kubernetesWatchTrigger, and returns the corresponding kubernetesWatchTrigger object, and an error if there is any.
func (c *FakeKubernetesWatchTriggers) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.KubernetesWatchTrigger, err error) {
func (c *FakeKubernetesWatchTriggers) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.KubernetesWatchTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(kuberneteswatchtriggersResource, c.ns, name), &corev1.KubernetesWatchTrigger{})
Invokes(testing.NewGetAction(kuberneteswatchtriggersResource, c.ns, name), &v1.KubernetesWatchTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.KubernetesWatchTrigger), err
return obj.(*v1.KubernetesWatchTrigger), err
}
// List takes label and field selectors, and returns the list of KubernetesWatchTriggers that match those selectors.
func (c *FakeKubernetesWatchTriggers) List(ctx context.Context, opts v1.ListOptions) (result *corev1.KubernetesWatchTriggerList, err error) {
func (c *FakeKubernetesWatchTriggers) List(ctx context.Context, opts metav1.ListOptions) (result *v1.KubernetesWatchTriggerList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(kuberneteswatchtriggersResource, kuberneteswatchtriggersKind, c.ns, opts), &corev1.KubernetesWatchTriggerList{})
Invokes(testing.NewListAction(kuberneteswatchtriggersResource, kuberneteswatchtriggersKind, c.ns, opts), &v1.KubernetesWatchTriggerList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeKubernetesWatchTriggers) List(ctx context.Context, opts v1.ListOpti
if label == nil {
label = labels.Everything()
}
list := &corev1.KubernetesWatchTriggerList{ListMeta: obj.(*corev1.KubernetesWatchTriggerList).ListMeta}
for _, item := range obj.(*corev1.KubernetesWatchTriggerList).Items {
list := &v1.KubernetesWatchTriggerList{ListMeta: obj.(*v1.KubernetesWatchTriggerList).ListMeta}
for _, item := range obj.(*v1.KubernetesWatchTriggerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeKubernetesWatchTriggers) List(ctx context.Context, opts v1.ListOpti
}
// Watch returns a watch.Interface that watches the requested kubernetesWatchTriggers.
func (c *FakeKubernetesWatchTriggers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeKubernetesWatchTriggers) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(kuberneteswatchtriggersResource, c.ns, opts))
}
// Create takes the representation of a _kubernetesWatchTrigger and creates it. Returns the server's representation of the kubernetesWatchTrigger, and an error, if there is any.
func (c *FakeKubernetesWatchTriggers) Create(ctx context.Context, _kubernetesWatchTrigger *corev1.KubernetesWatchTrigger, opts v1.CreateOptions) (result *corev1.KubernetesWatchTrigger, err error) {
func (c *FakeKubernetesWatchTriggers) Create(ctx context.Context, _kubernetesWatchTrigger *v1.KubernetesWatchTrigger, opts metav1.CreateOptions) (result *v1.KubernetesWatchTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(kuberneteswatchtriggersResource, c.ns, _kubernetesWatchTrigger), &corev1.KubernetesWatchTrigger{})
Invokes(testing.NewCreateAction(kuberneteswatchtriggersResource, c.ns, _kubernetesWatchTrigger), &v1.KubernetesWatchTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.KubernetesWatchTrigger), err
return obj.(*v1.KubernetesWatchTrigger), err
}
// Update takes the representation of a _kubernetesWatchTrigger and updates it. Returns the server's representation of the kubernetesWatchTrigger, and an error, if there is any.
func (c *FakeKubernetesWatchTriggers) Update(ctx context.Context, _kubernetesWatchTrigger *corev1.KubernetesWatchTrigger, opts v1.UpdateOptions) (result *corev1.KubernetesWatchTrigger, err error) {
func (c *FakeKubernetesWatchTriggers) Update(ctx context.Context, _kubernetesWatchTrigger *v1.KubernetesWatchTrigger, opts metav1.UpdateOptions) (result *v1.KubernetesWatchTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(kuberneteswatchtriggersResource, c.ns, _kubernetesWatchTrigger), &corev1.KubernetesWatchTrigger{})
Invokes(testing.NewUpdateAction(kuberneteswatchtriggersResource, c.ns, _kubernetesWatchTrigger), &v1.KubernetesWatchTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.KubernetesWatchTrigger), err
return obj.(*v1.KubernetesWatchTrigger), err
}
// Delete takes name of the _kubernetesWatchTrigger and deletes it. Returns an error if one occurs.
func (c *FakeKubernetesWatchTriggers) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeKubernetesWatchTriggers) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(kuberneteswatchtriggersResource, c.ns, name, opts), &corev1.KubernetesWatchTrigger{})
Invokes(testing.NewDeleteActionWithOptions(kuberneteswatchtriggersResource, c.ns, name, opts), &v1.KubernetesWatchTrigger{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeKubernetesWatchTriggers) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeKubernetesWatchTriggers) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(kuberneteswatchtriggersResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.KubernetesWatchTriggerList{})
_, err := c.Fake.Invokes(action, &v1.KubernetesWatchTriggerList{})
return err
}
// Patch applies the patch and returns the patched kubernetesWatchTrigger.
func (c *FakeKubernetesWatchTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.KubernetesWatchTrigger, err error) {
func (c *FakeKubernetesWatchTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.KubernetesWatchTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(kuberneteswatchtriggersResource, c.ns, name, pt, data, subresources...), &corev1.KubernetesWatchTrigger{})
Invokes(testing.NewPatchSubresourceAction(kuberneteswatchtriggersResource, c.ns, name, pt, data, subresources...), &v1.KubernetesWatchTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.KubernetesWatchTrigger), err
return obj.(*v1.KubernetesWatchTrigger), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied kubernetesWatchTrigger.
func (c *FakeKubernetesWatchTriggers) Apply(ctx context.Context, _kubernetesWatchTrigger *corev1.KubernetesWatchTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.KubernetesWatchTrigger, err error) {
if _kubernetesWatchTrigger == nil {
return nil, fmt.Errorf("_kubernetesWatchTrigger provided to Apply must not be nil")
}
data, err := json.Marshal(_kubernetesWatchTrigger)
if err != nil {
return nil, err
}
name := _kubernetesWatchTrigger.Name
if name == nil {
return nil, fmt.Errorf("_kubernetesWatchTrigger.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(kuberneteswatchtriggersResource, c.ns, *name, types.ApplyPatchType, data), &v1.KubernetesWatchTrigger{})
if obj == nil {
return nil, err
}
return obj.(*v1.KubernetesWatchTrigger), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_messagequeuetrigger.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeMessageQueueTriggers struct {
ns string
}
var messagequeuetriggersResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "messagequeuetriggers"}
var messagequeuetriggersResource = v1.SchemeGroupVersion.WithResource("messagequeuetriggers")
var messagequeuetriggersKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "MessageQueueTrigger"}
var messagequeuetriggersKind = v1.SchemeGroupVersion.WithKind("MessageQueueTrigger")
// Get takes name of the _messageQueueTrigger, and returns the corresponding messageQueueTrigger object, and an error if there is any.
func (c *FakeMessageQueueTriggers) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.MessageQueueTrigger, err error) {
func (c *FakeMessageQueueTriggers) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.MessageQueueTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(messagequeuetriggersResource, c.ns, name), &corev1.MessageQueueTrigger{})
Invokes(testing.NewGetAction(messagequeuetriggersResource, c.ns, name), &v1.MessageQueueTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.MessageQueueTrigger), err
return obj.(*v1.MessageQueueTrigger), err
}
// List takes label and field selectors, and returns the list of MessageQueueTriggers that match those selectors.
func (c *FakeMessageQueueTriggers) List(ctx context.Context, opts v1.ListOptions) (result *corev1.MessageQueueTriggerList, err error) {
func (c *FakeMessageQueueTriggers) List(ctx context.Context, opts metav1.ListOptions) (result *v1.MessageQueueTriggerList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(messagequeuetriggersResource, messagequeuetriggersKind, c.ns, opts), &corev1.MessageQueueTriggerList{})
Invokes(testing.NewListAction(messagequeuetriggersResource, messagequeuetriggersKind, c.ns, opts), &v1.MessageQueueTriggerList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeMessageQueueTriggers) List(ctx context.Context, opts v1.ListOptions
if label == nil {
label = labels.Everything()
}
list := &corev1.MessageQueueTriggerList{ListMeta: obj.(*corev1.MessageQueueTriggerList).ListMeta}
for _, item := range obj.(*corev1.MessageQueueTriggerList).Items {
list := &v1.MessageQueueTriggerList{ListMeta: obj.(*v1.MessageQueueTriggerList).ListMeta}
for _, item := range obj.(*v1.MessageQueueTriggerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeMessageQueueTriggers) List(ctx context.Context, opts v1.ListOptions
}
// Watch returns a watch.Interface that watches the requested messageQueueTriggers.
func (c *FakeMessageQueueTriggers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeMessageQueueTriggers) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(messagequeuetriggersResource, c.ns, opts))
}
// Create takes the representation of a _messageQueueTrigger and creates it. Returns the server's representation of the messageQueueTrigger, and an error, if there is any.
func (c *FakeMessageQueueTriggers) Create(ctx context.Context, _messageQueueTrigger *corev1.MessageQueueTrigger, opts v1.CreateOptions) (result *corev1.MessageQueueTrigger, err error) {
func (c *FakeMessageQueueTriggers) Create(ctx context.Context, _messageQueueTrigger *v1.MessageQueueTrigger, opts metav1.CreateOptions) (result *v1.MessageQueueTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(messagequeuetriggersResource, c.ns, _messageQueueTrigger), &corev1.MessageQueueTrigger{})
Invokes(testing.NewCreateAction(messagequeuetriggersResource, c.ns, _messageQueueTrigger), &v1.MessageQueueTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.MessageQueueTrigger), err
return obj.(*v1.MessageQueueTrigger), err
}
// Update takes the representation of a _messageQueueTrigger and updates it. Returns the server's representation of the messageQueueTrigger, and an error, if there is any.
func (c *FakeMessageQueueTriggers) Update(ctx context.Context, _messageQueueTrigger *corev1.MessageQueueTrigger, opts v1.UpdateOptions) (result *corev1.MessageQueueTrigger, err error) {
func (c *FakeMessageQueueTriggers) Update(ctx context.Context, _messageQueueTrigger *v1.MessageQueueTrigger, opts metav1.UpdateOptions) (result *v1.MessageQueueTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(messagequeuetriggersResource, c.ns, _messageQueueTrigger), &corev1.MessageQueueTrigger{})
Invokes(testing.NewUpdateAction(messagequeuetriggersResource, c.ns, _messageQueueTrigger), &v1.MessageQueueTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.MessageQueueTrigger), err
return obj.(*v1.MessageQueueTrigger), err
}
// Delete takes name of the _messageQueueTrigger and deletes it. Returns an error if one occurs.
func (c *FakeMessageQueueTriggers) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeMessageQueueTriggers) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(messagequeuetriggersResource, c.ns, name, opts), &corev1.MessageQueueTrigger{})
Invokes(testing.NewDeleteActionWithOptions(messagequeuetriggersResource, c.ns, name, opts), &v1.MessageQueueTrigger{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeMessageQueueTriggers) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeMessageQueueTriggers) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(messagequeuetriggersResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.MessageQueueTriggerList{})
_, err := c.Fake.Invokes(action, &v1.MessageQueueTriggerList{})
return err
}
// Patch applies the patch and returns the patched messageQueueTrigger.
func (c *FakeMessageQueueTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.MessageQueueTrigger, err error) {
func (c *FakeMessageQueueTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.MessageQueueTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(messagequeuetriggersResource, c.ns, name, pt, data, subresources...), &corev1.MessageQueueTrigger{})
Invokes(testing.NewPatchSubresourceAction(messagequeuetriggersResource, c.ns, name, pt, data, subresources...), &v1.MessageQueueTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.MessageQueueTrigger), err
return obj.(*v1.MessageQueueTrigger), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied messageQueueTrigger.
func (c *FakeMessageQueueTriggers) Apply(ctx context.Context, _messageQueueTrigger *corev1.MessageQueueTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.MessageQueueTrigger, err error) {
if _messageQueueTrigger == nil {
return nil, fmt.Errorf("_messageQueueTrigger provided to Apply must not be nil")
}
data, err := json.Marshal(_messageQueueTrigger)
if err != nil {
return nil, err
}
name := _messageQueueTrigger.Name
if name == nil {
return nil, fmt.Errorf("_messageQueueTrigger.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(messagequeuetriggersResource, c.ns, *name, types.ApplyPatchType, data), &v1.MessageQueueTrigger{})
if obj == nil {
return nil, err
}
return obj.(*v1.MessageQueueTrigger), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_package.go
+76 -29
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakePackages struct {
ns string
}
var packagesResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "packages"}
var packagesResource = v1.SchemeGroupVersion.WithResource("packages")
var packagesKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "Package"}
var packagesKind = v1.SchemeGroupVersion.WithKind("Package")
// Get takes name of the _package, and returns the corresponding package object, and an error if there is any.
func (c *FakePackages) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.Package, err error) {
func (c *FakePackages) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.Package, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(packagesResource, c.ns, name), &corev1.Package{})
Invokes(testing.NewGetAction(packagesResource, c.ns, name), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Package), err
return obj.(*v1.Package), err
}
// List takes label and field selectors, and returns the list of Packages that match those selectors.
func (c *FakePackages) List(ctx context.Context, opts v1.ListOptions) (result *corev1.PackageList, err error) {
func (c *FakePackages) List(ctx context.Context, opts metav1.ListOptions) (result *v1.PackageList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(packagesResource, packagesKind, c.ns, opts), &corev1.PackageList{})
Invokes(testing.NewListAction(packagesResource, packagesKind, c.ns, opts), &v1.PackageList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakePackages) List(ctx context.Context, opts v1.ListOptions) (result *c
if label == nil {
label = labels.Everything()
}
list := &corev1.PackageList{ListMeta: obj.(*corev1.PackageList).ListMeta}
for _, item := range obj.(*corev1.PackageList).Items {
list := &v1.PackageList{ListMeta: obj.(*v1.PackageList).ListMeta}
for _, item := range obj.(*v1.PackageList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,69 +76,114 @@ func (c *FakePackages) List(ctx context.Context, opts v1.ListOptions) (result *c
}
// Watch returns a watch.Interface that watches the requested packages.
func (c *FakePackages) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakePackages) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(packagesResource, c.ns, opts))
}
// Create takes the representation of a _package and creates it. Returns the server's representation of the package, and an error, if there is any.
func (c *FakePackages) Create(ctx context.Context, _package *corev1.Package, opts v1.CreateOptions) (result *corev1.Package, err error) {
func (c *FakePackages) Create(ctx context.Context, _package *v1.Package, opts metav1.CreateOptions) (result *v1.Package, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(packagesResource, c.ns, _package), &corev1.Package{})
Invokes(testing.NewCreateAction(packagesResource, c.ns, _package), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Package), err
return obj.(*v1.Package), err
}
// Update takes the representation of a _package and updates it. Returns the server's representation of the package, and an error, if there is any.
func (c *FakePackages) Update(ctx context.Context, _package *corev1.Package, opts v1.UpdateOptions) (result *corev1.Package, err error) {
func (c *FakePackages) Update(ctx context.Context, _package *v1.Package, opts metav1.UpdateOptions) (result *v1.Package, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(packagesResource, c.ns, _package), &corev1.Package{})
Invokes(testing.NewUpdateAction(packagesResource, c.ns, _package), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Package), err
return obj.(*v1.Package), 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 *FakePackages) UpdateStatus(ctx context.Context, _package *corev1.Package, opts v1.UpdateOptions) (*corev1.Package, error) {
func (c *FakePackages) UpdateStatus(ctx context.Context, _package *v1.Package, opts metav1.UpdateOptions) (*v1.Package, error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateSubresourceAction(packagesResource, "status", c.ns, _package), &corev1.Package{})
Invokes(testing.NewUpdateSubresourceAction(packagesResource, "status", c.ns, _package), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Package), err
return obj.(*v1.Package), err
}
// Delete takes name of the _package and deletes it. Returns an error if one occurs.
func (c *FakePackages) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakePackages) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(packagesResource, c.ns, name, opts), &corev1.Package{})
Invokes(testing.NewDeleteActionWithOptions(packagesResource, c.ns, name, opts), &v1.Package{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakePackages) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakePackages) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(packagesResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.PackageList{})
_, err := c.Fake.Invokes(action, &v1.PackageList{})
return err
}
// Patch applies the patch and returns the patched package.
func (c *FakePackages) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.Package, err error) {
func (c *FakePackages) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Package, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(packagesResource, c.ns, name, pt, data, subresources...), &corev1.Package{})
Invokes(testing.NewPatchSubresourceAction(packagesResource, c.ns, name, pt, data, subresources...), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*corev1.Package), err
return obj.(*v1.Package), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied package.
func (c *FakePackages) Apply(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error) {
if _package == nil {
return nil, fmt.Errorf("_package provided to Apply must not be nil")
}
data, err := json.Marshal(_package)
if err != nil {
return nil, err
}
name := _package.Name
if name == nil {
return nil, fmt.Errorf("_package.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(packagesResource, c.ns, *name, types.ApplyPatchType, data), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*v1.Package), err
}
// ApplyStatus was generated because the type contains a Status member.
// Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
func (c *FakePackages) ApplyStatus(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error) {
if _package == nil {
return nil, fmt.Errorf("_package provided to Apply must not be nil")
}
data, err := json.Marshal(_package)
if err != nil {
return nil, err
}
name := _package.Name
if name == nil {
return nil, fmt.Errorf("_package.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(packagesResource, c.ns, *name, types.ApplyPatchType, data, "status"), &v1.Package{})
if obj == nil {
return nil, err
}
return obj.(*v1.Package), err
}
pkg/generated/clientset/versioned/typed/core/v1/fake/fake_timetrigger.go
+50 -26
View File
@@ -20,11 +20,13 @@ package fake
import (
"context"
json "encoding/json"
"fmt"
corev1 "github.com/fission/fission/pkg/apis/core/v1"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
labels "k8s.io/apimachinery/pkg/labels"
schema "k8s.io/apimachinery/pkg/runtime/schema"
types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch"
testing "k8s.io/client-go/testing"
@@ -36,25 +38,25 @@ type FakeTimeTriggers struct {
ns string
}
var timetriggersResource = schema.GroupVersionResource{Group: "fission.io", Version: "v1", Resource: "timetriggers"}
var timetriggersResource = v1.SchemeGroupVersion.WithResource("timetriggers")
var timetriggersKind = schema.GroupVersionKind{Group: "fission.io", Version: "v1", Kind: "TimeTrigger"}
var timetriggersKind = v1.SchemeGroupVersion.WithKind("TimeTrigger")
// Get takes name of the _timeTrigger, and returns the corresponding timeTrigger object, and an error if there is any.
func (c *FakeTimeTriggers) Get(ctx context.Context, name string, options v1.GetOptions) (result *corev1.TimeTrigger, err error) {
func (c *FakeTimeTriggers) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.TimeTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(timetriggersResource, c.ns, name), &corev1.TimeTrigger{})
Invokes(testing.NewGetAction(timetriggersResource, c.ns, name), &v1.TimeTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.TimeTrigger), err
return obj.(*v1.TimeTrigger), err
}
// List takes label and field selectors, and returns the list of TimeTriggers that match those selectors.
func (c *FakeTimeTriggers) List(ctx context.Context, opts v1.ListOptions) (result *corev1.TimeTriggerList, err error) {
func (c *FakeTimeTriggers) List(ctx context.Context, opts metav1.ListOptions) (result *v1.TimeTriggerList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(timetriggersResource, timetriggersKind, c.ns, opts), &corev1.TimeTriggerList{})
Invokes(testing.NewListAction(timetriggersResource, timetriggersKind, c.ns, opts), &v1.TimeTriggerList{})
if obj == nil {
return nil, err
@@ -64,8 +66,8 @@ func (c *FakeTimeTriggers) List(ctx context.Context, opts v1.ListOptions) (resul
if label == nil {
label = labels.Everything()
}
list := &corev1.TimeTriggerList{ListMeta: obj.(*corev1.TimeTriggerList).ListMeta}
for _, item := range obj.(*corev1.TimeTriggerList).Items {
list := &v1.TimeTriggerList{ListMeta: obj.(*v1.TimeTriggerList).ListMeta}
for _, item := range obj.(*v1.TimeTriggerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
@@ -74,57 +76,79 @@ func (c *FakeTimeTriggers) List(ctx context.Context, opts v1.ListOptions) (resul
}
// Watch returns a watch.Interface that watches the requested timeTriggers.
func (c *FakeTimeTriggers) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
func (c *FakeTimeTriggers) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(timetriggersResource, c.ns, opts))
}
// Create takes the representation of a _timeTrigger and creates it. Returns the server's representation of the timeTrigger, and an error, if there is any.
func (c *FakeTimeTriggers) Create(ctx context.Context, _timeTrigger *corev1.TimeTrigger, opts v1.CreateOptions) (result *corev1.TimeTrigger, err error) {
func (c *FakeTimeTriggers) Create(ctx context.Context, _timeTrigger *v1.TimeTrigger, opts metav1.CreateOptions) (result *v1.TimeTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(timetriggersResource, c.ns, _timeTrigger), &corev1.TimeTrigger{})
Invokes(testing.NewCreateAction(timetriggersResource, c.ns, _timeTrigger), &v1.TimeTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.TimeTrigger), err
return obj.(*v1.TimeTrigger), err
}
// Update takes the representation of a _timeTrigger and updates it. Returns the server's representation of the timeTrigger, and an error, if there is any.
func (c *FakeTimeTriggers) Update(ctx context.Context, _timeTrigger *corev1.TimeTrigger, opts v1.UpdateOptions) (result *corev1.TimeTrigger, err error) {
func (c *FakeTimeTriggers) Update(ctx context.Context, _timeTrigger *v1.TimeTrigger, opts metav1.UpdateOptions) (result *v1.TimeTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(timetriggersResource, c.ns, _timeTrigger), &corev1.TimeTrigger{})
Invokes(testing.NewUpdateAction(timetriggersResource, c.ns, _timeTrigger), &v1.TimeTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.TimeTrigger), err
return obj.(*v1.TimeTrigger), err
}
// Delete takes name of the _timeTrigger and deletes it. Returns an error if one occurs.
func (c *FakeTimeTriggers) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
func (c *FakeTimeTriggers) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteActionWithOptions(timetriggersResource, c.ns, name, opts), &corev1.TimeTrigger{})
Invokes(testing.NewDeleteActionWithOptions(timetriggersResource, c.ns, name, opts), &v1.TimeTrigger{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeTimeTriggers) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
func (c *FakeTimeTriggers) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
action := testing.NewDeleteCollectionAction(timetriggersResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &corev1.TimeTriggerList{})
_, err := c.Fake.Invokes(action, &v1.TimeTriggerList{})
return err
}
// Patch applies the patch and returns the patched timeTrigger.
func (c *FakeTimeTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *corev1.TimeTrigger, err error) {
func (c *FakeTimeTriggers) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.TimeTrigger, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(timetriggersResource, c.ns, name, pt, data, subresources...), &corev1.TimeTrigger{})
Invokes(testing.NewPatchSubresourceAction(timetriggersResource, c.ns, name, pt, data, subresources...), &v1.TimeTrigger{})
if obj == nil {
return nil, err
}
return obj.(*corev1.TimeTrigger), err
return obj.(*v1.TimeTrigger), err
}
// Apply takes the given apply declarative configuration, applies it and returns the applied timeTrigger.
func (c *FakeTimeTriggers) Apply(ctx context.Context, _timeTrigger *corev1.TimeTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.TimeTrigger, err error) {
if _timeTrigger == nil {
return nil, fmt.Errorf("_timeTrigger provided to Apply must not be nil")
}
data, err := json.Marshal(_timeTrigger)
if err != nil {
return nil, err
}
name := _timeTrigger.Name
if name == nil {
return nil, fmt.Errorf("_timeTrigger.Name must be provided to Apply")
}
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(timetriggersResource, c.ns, *name, types.ApplyPatchType, data), &v1.TimeTrigger{})
if obj == nil {
return nil, err
}
return obj.(*v1.TimeTrigger), err
}
pkg/generated/clientset/versioned/typed/core/v1/function.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type FunctionInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.FunctionList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Function, err error)
Apply(ctx context.Context, _function *corev1.FunctionApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Function, err error)
FunctionExpansion
}
@@ -176,3 +180,29 @@ func (c *functions) Patch(ctx context.Context, name string, pt types.PatchType,
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied function.
func (c *functions) Apply(ctx context.Context, _function *corev1.FunctionApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Function, err error) {
if _function == nil {
return nil, fmt.Errorf("_function provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_function)
if err != nil {
return nil, err
}
name := _function.Name
if name == nil {
return nil, fmt.Errorf("_function.Name must be provided to Apply")
}
result = &v1.Function{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("functions").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/httptrigger.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type HTTPTriggerInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.HTTPTriggerList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.HTTPTrigger, err error)
Apply(ctx context.Context, _hTTPTrigger *corev1.HTTPTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.HTTPTrigger, err error)
HTTPTriggerExpansion
}
@@ -176,3 +180,29 @@ func (c *hTTPTriggers) Patch(ctx context.Context, name string, pt types.PatchTyp
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied hTTPTrigger.
func (c *hTTPTriggers) Apply(ctx context.Context, _hTTPTrigger *corev1.HTTPTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.HTTPTrigger, err error) {
if _hTTPTrigger == nil {
return nil, fmt.Errorf("_hTTPTrigger provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_hTTPTrigger)
if err != nil {
return nil, err
}
name := _hTTPTrigger.Name
if name == nil {
return nil, fmt.Errorf("_hTTPTrigger.Name must be provided to Apply")
}
result = &v1.HTTPTrigger{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("httptriggers").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/kuberneteswatchtrigger.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type KubernetesWatchTriggerInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.KubernetesWatchTriggerList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.KubernetesWatchTrigger, err error)
Apply(ctx context.Context, _kubernetesWatchTrigger *corev1.KubernetesWatchTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.KubernetesWatchTrigger, err error)
KubernetesWatchTriggerExpansion
}
@@ -176,3 +180,29 @@ func (c *kubernetesWatchTriggers) Patch(ctx context.Context, name string, pt typ
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied kubernetesWatchTrigger.
func (c *kubernetesWatchTriggers) Apply(ctx context.Context, _kubernetesWatchTrigger *corev1.KubernetesWatchTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.KubernetesWatchTrigger, err error) {
if _kubernetesWatchTrigger == nil {
return nil, fmt.Errorf("_kubernetesWatchTrigger provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_kubernetesWatchTrigger)
if err != nil {
return nil, err
}
name := _kubernetesWatchTrigger.Name
if name == nil {
return nil, fmt.Errorf("_kubernetesWatchTrigger.Name must be provided to Apply")
}
result = &v1.KubernetesWatchTrigger{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("kuberneteswatchtriggers").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/messagequeuetrigger.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type MessageQueueTriggerInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.MessageQueueTriggerList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.MessageQueueTrigger, err error)
Apply(ctx context.Context, _messageQueueTrigger *corev1.MessageQueueTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.MessageQueueTrigger, err error)
MessageQueueTriggerExpansion
}
@@ -176,3 +180,29 @@ func (c *messageQueueTriggers) Patch(ctx context.Context, name string, pt types.
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied messageQueueTrigger.
func (c *messageQueueTriggers) Apply(ctx context.Context, _messageQueueTrigger *corev1.MessageQueueTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.MessageQueueTrigger, err error) {
if _messageQueueTrigger == nil {
return nil, fmt.Errorf("_messageQueueTrigger provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_messageQueueTrigger)
if err != nil {
return nil, err
}
name := _messageQueueTrigger.Name
if name == nil {
return nil, fmt.Errorf("_messageQueueTrigger.Name must be provided to Apply")
}
result = &v1.MessageQueueTrigger{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("messagequeuetriggers").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/package.go
+61
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -47,6 +50,8 @@ type PackageInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.PackageList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Package, err error)
Apply(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error)
ApplyStatus(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error)
PackageExpansion
}
@@ -193,3 +198,59 @@ func (c *packages) Patch(ctx context.Context, name string, pt types.PatchType, d
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied package.
func (c *packages) Apply(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error) {
if _package == nil {
return nil, fmt.Errorf("_package provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_package)
if err != nil {
return nil, err
}
name := _package.Name
if name == nil {
return nil, fmt.Errorf("_package.Name must be provided to Apply")
}
result = &v1.Package{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("packages").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
// ApplyStatus was generated because the type contains a Status member.
// Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
func (c *packages) ApplyStatus(ctx context.Context, _package *corev1.PackageApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Package, err error) {
if _package == nil {
return nil, fmt.Errorf("_package provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_package)
if err != nil {
return nil, err
}
name := _package.Name
if name == nil {
return nil, fmt.Errorf("_package.Name must be provided to Apply")
}
result = &v1.Package{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("packages").
Name(*name).
SubResource("status").
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/generated/clientset/versioned/typed/core/v1/timetrigger.go
+30
View File
@@ -20,9 +20,12 @@ package v1
import (
"context"
json "encoding/json"
"fmt"
"time"
v1 "github.com/fission/fission/pkg/apis/core/v1"
corev1 "github.com/fission/fission/pkg/generated/applyconfiguration/core/v1"
scheme "github.com/fission/fission/pkg/generated/clientset/versioned/scheme"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
types "k8s.io/apimachinery/pkg/types"
@@ -46,6 +49,7 @@ type TimeTriggerInterface interface {
List(ctx context.Context, opts metav1.ListOptions) (*v1.TimeTriggerList, error)
Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.TimeTrigger, err error)
Apply(ctx context.Context, _timeTrigger *corev1.TimeTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.TimeTrigger, err error)
TimeTriggerExpansion
}
@@ -176,3 +180,29 @@ func (c *timeTriggers) Patch(ctx context.Context, name string, pt types.PatchTyp
Into(result)
return
}
// Apply takes the given apply declarative configuration, applies it and returns the applied timeTrigger.
func (c *timeTriggers) Apply(ctx context.Context, _timeTrigger *corev1.TimeTriggerApplyConfiguration, opts metav1.ApplyOptions) (result *v1.TimeTrigger, err error) {
if _timeTrigger == nil {
return nil, fmt.Errorf("_timeTrigger provided to Apply must not be nil")
}
patchOpts := opts.ToPatchOptions()
data, err := json.Marshal(_timeTrigger)
if err != nil {
return nil, err
}
name := _timeTrigger.Name
if name == nil {
return nil, fmt.Errorf("_timeTrigger.Name must be provided to Apply")
}
result = &v1.TimeTrigger{}
err = c.client.Patch(types.ApplyPatchType).
Namespace(c.ns).
Resource("timetriggers").
Name(*name).
VersionedParams(&patchOpts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}