github/flagger
1
0
Fork 0
mirror of https://github.com/fluxcd/flagger.git synced 2026-04-15 06:57:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Generate AppMesh v1beta2 client

Browse Source
This commit is contained in:
stefanprodan
2020-05-05 19:31:03 +03:00
parent 55c89770d7
commit 7686b4b01a
21 changed files with 0 additions and 1527 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/apis/appmesh/v1beta2/virtualnode_types.go
-1
View File
@@ -338,7 +338,6 @@ type VirtualNode struct {
Status VirtualNodeStatus `json:"status,omitempty"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// VirtualNodeList contains a list of VirtualNode
pkg/apis/appmesh/v1beta2/virtualrouter_types.go
-1
View File
@@ -359,7 +359,6 @@ type VirtualRouter struct {
Status VirtualRouterStatus `json:"status,omitempty"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// VirtualRouterList contains a list of VirtualRouter
pkg/apis/appmesh/v1beta2/virtualservice_types.go
-1
View File
@@ -108,7 +108,6 @@ type VirtualService struct {
Status VirtualServiceStatus `json:"status,omitempty"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// VirtualServiceList contains a list of VirtualService
pkg/client/clientset/versioned/typed/appmesh/v1beta2/appmesh_client.go
-15
View File
@@ -27,11 +27,8 @@ import (
type AppmeshV1beta2Interface interface {
RESTClient() rest.Interface
VirtualNodesGetter
VirtualNodeListsGetter
VirtualRoutersGetter
VirtualRouterListsGetter
VirtualServicesGetter
VirtualServiceListsGetter
}
// AppmeshV1beta2Client is used to interact with features provided by the appmesh.k8s.aws group.
@@ -43,26 +40,14 @@ func (c *AppmeshV1beta2Client) VirtualNodes(namespace string) VirtualNodeInterfa
return newVirtualNodes(c, namespace)
}
func (c *AppmeshV1beta2Client) VirtualNodeLists(namespace string) VirtualNodeListInterface {
return newVirtualNodeLists(c, namespace)
}
func (c *AppmeshV1beta2Client) VirtualRouters(namespace string) VirtualRouterInterface {
return newVirtualRouters(c, namespace)
}
func (c *AppmeshV1beta2Client) VirtualRouterLists(namespace string) VirtualRouterListInterface {
return newVirtualRouterLists(c, namespace)
}
func (c *AppmeshV1beta2Client) VirtualServices(namespace string) VirtualServiceInterface {
return newVirtualServices(c, namespace)
}
func (c *AppmeshV1beta2Client) VirtualServiceLists(namespace string) VirtualServiceListInterface {
return newVirtualServiceLists(c, namespace)
}
// NewForConfig creates a new AppmeshV1beta2Client for the given config.
func NewForConfig(c *rest.Config) (*AppmeshV1beta2Client, error) {
config := *c
pkg/client/clientset/versioned/typed/appmesh/v1beta2/fake/fake_appmesh_client.go
-12
View File
@@ -32,26 +32,14 @@ func (c *FakeAppmeshV1beta2) VirtualNodes(namespace string) v1beta2.VirtualNodeI
return &FakeVirtualNodes{c, namespace}
}
func (c *FakeAppmeshV1beta2) VirtualNodeLists(namespace string) v1beta2.VirtualNodeListInterface {
return &FakeVirtualNodeLists{c, namespace}
}
func (c *FakeAppmeshV1beta2) VirtualRouters(namespace string) v1beta2.VirtualRouterInterface {
return &FakeVirtualRouters{c, namespace}
}
func (c *FakeAppmeshV1beta2) VirtualRouterLists(namespace string) v1beta2.VirtualRouterListInterface {
return &FakeVirtualRouterLists{c, namespace}
}
func (c *FakeAppmeshV1beta2) VirtualServices(namespace string) v1beta2.VirtualServiceInterface {
return &FakeVirtualServices{c, namespace}
}
func (c *FakeAppmeshV1beta2) VirtualServiceLists(namespace string) v1beta2.VirtualServiceListInterface {
return &FakeVirtualServiceLists{c, namespace}
}
// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func (c *FakeAppmeshV1beta2) RESTClient() rest.Interface {
pkg/client/clientset/versioned/typed/appmesh/v1beta2/fake/fake_virtualnodelist.go
-118
View File
@@ -1,118 +0,0 @@
/*
Copyright The Flagger 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.
package fake
import (
"context"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
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"
)
// FakeVirtualNodeLists implements VirtualNodeListInterface
type FakeVirtualNodeLists struct {
Fake *FakeAppmeshV1beta2
ns string
}
var virtualnodelistsResource = schema.GroupVersionResource{Group: "appmesh.k8s.aws", Version: "v1beta2", Resource: "virtualnodelists"}
var virtualnodelistsKind = schema.GroupVersionKind{Group: "appmesh.k8s.aws", Version: "v1beta2", Kind: "VirtualNodeList"}
// Get takes name of the virtualNodeList, and returns the corresponding virtualNodeList object, and an error if there is any.
func (c *FakeVirtualNodeLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualNodeList, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(virtualnodelistsResource, c.ns, name), &v1beta2.VirtualNodeList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualNodeList), err
}
// List takes label and field selectors, and returns the list of VirtualNodeLists that match those selectors.
func (c *FakeVirtualNodeLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualNodeListList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(virtualnodelistsResource, virtualnodelistsKind, c.ns, opts), &v1beta2.VirtualNodeListList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualNodeListList), err
}
// Watch returns a watch.Interface that watches the requested virtualNodeLists.
func (c *FakeVirtualNodeLists) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(virtualnodelistsResource, c.ns, opts))
}
// Create takes the representation of a virtualNodeList and creates it. Returns the server's representation of the virtualNodeList, and an error, if there is any.
func (c *FakeVirtualNodeLists) Create(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.CreateOptions) (result *v1beta2.VirtualNodeList, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(virtualnodelistsResource, c.ns, virtualNodeList), &v1beta2.VirtualNodeList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualNodeList), err
}
// Update takes the representation of a virtualNodeList and updates it. Returns the server's representation of the virtualNodeList, and an error, if there is any.
func (c *FakeVirtualNodeLists) Update(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.UpdateOptions) (result *v1beta2.VirtualNodeList, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(virtualnodelistsResource, c.ns, virtualNodeList), &v1beta2.VirtualNodeList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualNodeList), err
}
// Delete takes name of the virtualNodeList and deletes it. Returns an error if one occurs.
func (c *FakeVirtualNodeLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteAction(virtualnodelistsResource, c.ns, name), &v1beta2.VirtualNodeList{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeVirtualNodeLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
action := testing.NewDeleteCollectionAction(virtualnodelistsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &v1beta2.VirtualNodeListList{})
return err
}
// Patch applies the patch and returns the patched virtualNodeList.
func (c *FakeVirtualNodeLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualNodeList, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(virtualnodelistsResource, c.ns, name, pt, data, subresources...), &v1beta2.VirtualNodeList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualNodeList), err
}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/fake/fake_virtualrouterlist.go
-118
View File
@@ -1,118 +0,0 @@
/*
Copyright The Flagger 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.
package fake
import (
"context"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
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"
)
// FakeVirtualRouterLists implements VirtualRouterListInterface
type FakeVirtualRouterLists struct {
Fake *FakeAppmeshV1beta2
ns string
}
var virtualrouterlistsResource = schema.GroupVersionResource{Group: "appmesh.k8s.aws", Version: "v1beta2", Resource: "virtualrouterlists"}
var virtualrouterlistsKind = schema.GroupVersionKind{Group: "appmesh.k8s.aws", Version: "v1beta2", Kind: "VirtualRouterList"}
// Get takes name of the virtualRouterList, and returns the corresponding virtualRouterList object, and an error if there is any.
func (c *FakeVirtualRouterLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualRouterList, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(virtualrouterlistsResource, c.ns, name), &v1beta2.VirtualRouterList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualRouterList), err
}
// List takes label and field selectors, and returns the list of VirtualRouterLists that match those selectors.
func (c *FakeVirtualRouterLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualRouterListList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(virtualrouterlistsResource, virtualrouterlistsKind, c.ns, opts), &v1beta2.VirtualRouterListList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualRouterListList), err
}
// Watch returns a watch.Interface that watches the requested virtualRouterLists.
func (c *FakeVirtualRouterLists) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(virtualrouterlistsResource, c.ns, opts))
}
// Create takes the representation of a virtualRouterList and creates it. Returns the server's representation of the virtualRouterList, and an error, if there is any.
func (c *FakeVirtualRouterLists) Create(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.CreateOptions) (result *v1beta2.VirtualRouterList, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(virtualrouterlistsResource, c.ns, virtualRouterList), &v1beta2.VirtualRouterList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualRouterList), err
}
// Update takes the representation of a virtualRouterList and updates it. Returns the server's representation of the virtualRouterList, and an error, if there is any.
func (c *FakeVirtualRouterLists) Update(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.UpdateOptions) (result *v1beta2.VirtualRouterList, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(virtualrouterlistsResource, c.ns, virtualRouterList), &v1beta2.VirtualRouterList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualRouterList), err
}
// Delete takes name of the virtualRouterList and deletes it. Returns an error if one occurs.
func (c *FakeVirtualRouterLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteAction(virtualrouterlistsResource, c.ns, name), &v1beta2.VirtualRouterList{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeVirtualRouterLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
action := testing.NewDeleteCollectionAction(virtualrouterlistsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &v1beta2.VirtualRouterListList{})
return err
}
// Patch applies the patch and returns the patched virtualRouterList.
func (c *FakeVirtualRouterLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualRouterList, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(virtualrouterlistsResource, c.ns, name, pt, data, subresources...), &v1beta2.VirtualRouterList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualRouterList), err
}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/fake/fake_virtualservicelist.go
-118
View File
@@ -1,118 +0,0 @@
/*
Copyright The Flagger 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.
package fake
import (
"context"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
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"
)
// FakeVirtualServiceLists implements VirtualServiceListInterface
type FakeVirtualServiceLists struct {
Fake *FakeAppmeshV1beta2
ns string
}
var virtualservicelistsResource = schema.GroupVersionResource{Group: "appmesh.k8s.aws", Version: "v1beta2", Resource: "virtualservicelists"}
var virtualservicelistsKind = schema.GroupVersionKind{Group: "appmesh.k8s.aws", Version: "v1beta2", Kind: "VirtualServiceList"}
// Get takes name of the virtualServiceList, and returns the corresponding virtualServiceList object, and an error if there is any.
func (c *FakeVirtualServiceLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualServiceList, err error) {
obj, err := c.Fake.
Invokes(testing.NewGetAction(virtualservicelistsResource, c.ns, name), &v1beta2.VirtualServiceList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualServiceList), err
}
// List takes label and field selectors, and returns the list of VirtualServiceLists that match those selectors.
func (c *FakeVirtualServiceLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualServiceListList, err error) {
obj, err := c.Fake.
Invokes(testing.NewListAction(virtualservicelistsResource, virtualservicelistsKind, c.ns, opts), &v1beta2.VirtualServiceListList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualServiceListList), err
}
// Watch returns a watch.Interface that watches the requested virtualServiceLists.
func (c *FakeVirtualServiceLists) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
return c.Fake.
InvokesWatch(testing.NewWatchAction(virtualservicelistsResource, c.ns, opts))
}
// Create takes the representation of a virtualServiceList and creates it. Returns the server's representation of the virtualServiceList, and an error, if there is any.
func (c *FakeVirtualServiceLists) Create(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.CreateOptions) (result *v1beta2.VirtualServiceList, err error) {
obj, err := c.Fake.
Invokes(testing.NewCreateAction(virtualservicelistsResource, c.ns, virtualServiceList), &v1beta2.VirtualServiceList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualServiceList), err
}
// Update takes the representation of a virtualServiceList and updates it. Returns the server's representation of the virtualServiceList, and an error, if there is any.
func (c *FakeVirtualServiceLists) Update(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.UpdateOptions) (result *v1beta2.VirtualServiceList, err error) {
obj, err := c.Fake.
Invokes(testing.NewUpdateAction(virtualservicelistsResource, c.ns, virtualServiceList), &v1beta2.VirtualServiceList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualServiceList), err
}
// Delete takes name of the virtualServiceList and deletes it. Returns an error if one occurs.
func (c *FakeVirtualServiceLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
_, err := c.Fake.
Invokes(testing.NewDeleteAction(virtualservicelistsResource, c.ns, name), &v1beta2.VirtualServiceList{})
return err
}
// DeleteCollection deletes a collection of objects.
func (c *FakeVirtualServiceLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
action := testing.NewDeleteCollectionAction(virtualservicelistsResource, c.ns, listOpts)
_, err := c.Fake.Invokes(action, &v1beta2.VirtualServiceListList{})
return err
}
// Patch applies the patch and returns the patched virtualServiceList.
func (c *FakeVirtualServiceLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualServiceList, err error) {
obj, err := c.Fake.
Invokes(testing.NewPatchSubresourceAction(virtualservicelistsResource, c.ns, name, pt, data, subresources...), &v1beta2.VirtualServiceList{})
if obj == nil {
return nil, err
}
return obj.(*v1beta2.VirtualServiceList), err
}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/generated_expansion.go
-6
View File
@@ -20,12 +20,6 @@ package v1beta2
type VirtualNodeExpansion interface{}
type VirtualNodeListExpansion interface{}
type VirtualRouterExpansion interface{}
type VirtualRouterListExpansion interface{}
type VirtualServiceExpansion interface{}
type VirtualServiceListExpansion interface{}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/virtualnodelist.go
-178
View File
@@ -1,178 +0,0 @@
/*
Copyright The Flagger 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.
package v1beta2
import (
"context"
"time"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
scheme "github.com/weaveworks/flagger/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"
)
// VirtualNodeListsGetter has a method to return a VirtualNodeListInterface.
// A group's client should implement this interface.
type VirtualNodeListsGetter interface {
VirtualNodeLists(namespace string) VirtualNodeListInterface
}
// VirtualNodeListInterface has methods to work with VirtualNodeList resources.
type VirtualNodeListInterface interface {
Create(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.CreateOptions) (*v1beta2.VirtualNodeList, error)
Update(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.UpdateOptions) (*v1beta2.VirtualNodeList, error)
Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta2.VirtualNodeList, error)
List(ctx context.Context, opts v1.ListOptions) (*v1beta2.VirtualNodeListList, error)
Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualNodeList, err error)
VirtualNodeListExpansion
}
// virtualNodeLists implements VirtualNodeListInterface
type virtualNodeLists struct {
client rest.Interface
ns string
}
// newVirtualNodeLists returns a VirtualNodeLists
func newVirtualNodeLists(c *AppmeshV1beta2Client, namespace string) *virtualNodeLists {
return &virtualNodeLists{
client: c.RESTClient(),
ns: namespace,
}
}
// Get takes name of the virtualNodeList, and returns the corresponding virtualNodeList object, and an error if there is any.
func (c *virtualNodeLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualNodeList, err error) {
result = &v1beta2.VirtualNodeList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualnodelists").
Name(name).
VersionedParams(&options, scheme.ParameterCodec).
Do(ctx).
Into(result)
return
}
// List takes label and field selectors, and returns the list of VirtualNodeLists that match those selectors.
func (c *virtualNodeLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualNodeListList, err error) {
var timeout time.Duration
if opts.TimeoutSeconds != nil {
timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
}
result = &v1beta2.VirtualNodeListList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualnodelists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Do(ctx).
Into(result)
return
}
// Watch returns a watch.Interface that watches the requested virtualNodeLists.
func (c *virtualNodeLists) 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("virtualnodelists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Watch(ctx)
}
// Create takes the representation of a virtualNodeList and creates it. Returns the server's representation of the virtualNodeList, and an error, if there is any.
func (c *virtualNodeLists) Create(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.CreateOptions) (result *v1beta2.VirtualNodeList, err error) {
result = &v1beta2.VirtualNodeList{}
err = c.client.Post().
Namespace(c.ns).
Resource("virtualnodelists").
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualNodeList).
Do(ctx).
Into(result)
return
}
// Update takes the representation of a virtualNodeList and updates it. Returns the server's representation of the virtualNodeList, and an error, if there is any.
func (c *virtualNodeLists) Update(ctx context.Context, virtualNodeList *v1beta2.VirtualNodeList, opts v1.UpdateOptions) (result *v1beta2.VirtualNodeList, err error) {
result = &v1beta2.VirtualNodeList{}
err = c.client.Put().
Namespace(c.ns).
Resource("virtualnodelists").
Name(virtualNodeList.Name).
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualNodeList).
Do(ctx).
Into(result)
return
}
// Delete takes name of the virtualNodeList and deletes it. Returns an error if one occurs.
func (c *virtualNodeLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
return c.client.Delete().
Namespace(c.ns).
Resource("virtualnodelists").
Name(name).
Body(&opts).
Do(ctx).
Error()
}
// DeleteCollection deletes a collection of objects.
func (c *virtualNodeLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
var timeout time.Duration
if listOpts.TimeoutSeconds != nil {
timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
}
return c.client.Delete().
Namespace(c.ns).
Resource("virtualnodelists").
VersionedParams(&listOpts, scheme.ParameterCodec).
Timeout(timeout).
Body(&opts).
Do(ctx).
Error()
}
// Patch applies the patch and returns the patched virtualNodeList.
func (c *virtualNodeLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualNodeList, err error) {
result = &v1beta2.VirtualNodeList{}
err = c.client.Patch(pt).
Namespace(c.ns).
Resource("virtualnodelists").
Name(name).
SubResource(subresources...).
VersionedParams(&opts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/virtualrouterlist.go
-178
View File
@@ -1,178 +0,0 @@
/*
Copyright The Flagger 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.
package v1beta2
import (
"context"
"time"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
scheme "github.com/weaveworks/flagger/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"
)
// VirtualRouterListsGetter has a method to return a VirtualRouterListInterface.
// A group's client should implement this interface.
type VirtualRouterListsGetter interface {
VirtualRouterLists(namespace string) VirtualRouterListInterface
}
// VirtualRouterListInterface has methods to work with VirtualRouterList resources.
type VirtualRouterListInterface interface {
Create(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.CreateOptions) (*v1beta2.VirtualRouterList, error)
Update(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.UpdateOptions) (*v1beta2.VirtualRouterList, error)
Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta2.VirtualRouterList, error)
List(ctx context.Context, opts v1.ListOptions) (*v1beta2.VirtualRouterListList, error)
Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualRouterList, err error)
VirtualRouterListExpansion
}
// virtualRouterLists implements VirtualRouterListInterface
type virtualRouterLists struct {
client rest.Interface
ns string
}
// newVirtualRouterLists returns a VirtualRouterLists
func newVirtualRouterLists(c *AppmeshV1beta2Client, namespace string) *virtualRouterLists {
return &virtualRouterLists{
client: c.RESTClient(),
ns: namespace,
}
}
// Get takes name of the virtualRouterList, and returns the corresponding virtualRouterList object, and an error if there is any.
func (c *virtualRouterLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualRouterList, err error) {
result = &v1beta2.VirtualRouterList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualrouterlists").
Name(name).
VersionedParams(&options, scheme.ParameterCodec).
Do(ctx).
Into(result)
return
}
// List takes label and field selectors, and returns the list of VirtualRouterLists that match those selectors.
func (c *virtualRouterLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualRouterListList, err error) {
var timeout time.Duration
if opts.TimeoutSeconds != nil {
timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
}
result = &v1beta2.VirtualRouterListList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualrouterlists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Do(ctx).
Into(result)
return
}
// Watch returns a watch.Interface that watches the requested virtualRouterLists.
func (c *virtualRouterLists) 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("virtualrouterlists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Watch(ctx)
}
// Create takes the representation of a virtualRouterList and creates it. Returns the server's representation of the virtualRouterList, and an error, if there is any.
func (c *virtualRouterLists) Create(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.CreateOptions) (result *v1beta2.VirtualRouterList, err error) {
result = &v1beta2.VirtualRouterList{}
err = c.client.Post().
Namespace(c.ns).
Resource("virtualrouterlists").
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualRouterList).
Do(ctx).
Into(result)
return
}
// Update takes the representation of a virtualRouterList and updates it. Returns the server's representation of the virtualRouterList, and an error, if there is any.
func (c *virtualRouterLists) Update(ctx context.Context, virtualRouterList *v1beta2.VirtualRouterList, opts v1.UpdateOptions) (result *v1beta2.VirtualRouterList, err error) {
result = &v1beta2.VirtualRouterList{}
err = c.client.Put().
Namespace(c.ns).
Resource("virtualrouterlists").
Name(virtualRouterList.Name).
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualRouterList).
Do(ctx).
Into(result)
return
}
// Delete takes name of the virtualRouterList and deletes it. Returns an error if one occurs.
func (c *virtualRouterLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
return c.client.Delete().
Namespace(c.ns).
Resource("virtualrouterlists").
Name(name).
Body(&opts).
Do(ctx).
Error()
}
// DeleteCollection deletes a collection of objects.
func (c *virtualRouterLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
var timeout time.Duration
if listOpts.TimeoutSeconds != nil {
timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
}
return c.client.Delete().
Namespace(c.ns).
Resource("virtualrouterlists").
VersionedParams(&listOpts, scheme.ParameterCodec).
Timeout(timeout).
Body(&opts).
Do(ctx).
Error()
}
// Patch applies the patch and returns the patched virtualRouterList.
func (c *virtualRouterLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualRouterList, err error) {
result = &v1beta2.VirtualRouterList{}
err = c.client.Patch(pt).
Namespace(c.ns).
Resource("virtualrouterlists").
Name(name).
SubResource(subresources...).
VersionedParams(&opts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/client/clientset/versioned/typed/appmesh/v1beta2/virtualservicelist.go
-178
View File
@@ -1,178 +0,0 @@
/*
Copyright The Flagger 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.
package v1beta2
import (
"context"
"time"
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
scheme "github.com/weaveworks/flagger/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"
)
// VirtualServiceListsGetter has a method to return a VirtualServiceListInterface.
// A group's client should implement this interface.
type VirtualServiceListsGetter interface {
VirtualServiceLists(namespace string) VirtualServiceListInterface
}
// VirtualServiceListInterface has methods to work with VirtualServiceList resources.
type VirtualServiceListInterface interface {
Create(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.CreateOptions) (*v1beta2.VirtualServiceList, error)
Update(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.UpdateOptions) (*v1beta2.VirtualServiceList, error)
Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta2.VirtualServiceList, error)
List(ctx context.Context, opts v1.ListOptions) (*v1beta2.VirtualServiceListList, error)
Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualServiceList, err error)
VirtualServiceListExpansion
}
// virtualServiceLists implements VirtualServiceListInterface
type virtualServiceLists struct {
client rest.Interface
ns string
}
// newVirtualServiceLists returns a VirtualServiceLists
func newVirtualServiceLists(c *AppmeshV1beta2Client, namespace string) *virtualServiceLists {
return &virtualServiceLists{
client: c.RESTClient(),
ns: namespace,
}
}
// Get takes name of the virtualServiceList, and returns the corresponding virtualServiceList object, and an error if there is any.
func (c *virtualServiceLists) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.VirtualServiceList, err error) {
result = &v1beta2.VirtualServiceList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualservicelists").
Name(name).
VersionedParams(&options, scheme.ParameterCodec).
Do(ctx).
Into(result)
return
}
// List takes label and field selectors, and returns the list of VirtualServiceLists that match those selectors.
func (c *virtualServiceLists) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.VirtualServiceListList, err error) {
var timeout time.Duration
if opts.TimeoutSeconds != nil {
timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
}
result = &v1beta2.VirtualServiceListList{}
err = c.client.Get().
Namespace(c.ns).
Resource("virtualservicelists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Do(ctx).
Into(result)
return
}
// Watch returns a watch.Interface that watches the requested virtualServiceLists.
func (c *virtualServiceLists) 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("virtualservicelists").
VersionedParams(&opts, scheme.ParameterCodec).
Timeout(timeout).
Watch(ctx)
}
// Create takes the representation of a virtualServiceList and creates it. Returns the server's representation of the virtualServiceList, and an error, if there is any.
func (c *virtualServiceLists) Create(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.CreateOptions) (result *v1beta2.VirtualServiceList, err error) {
result = &v1beta2.VirtualServiceList{}
err = c.client.Post().
Namespace(c.ns).
Resource("virtualservicelists").
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualServiceList).
Do(ctx).
Into(result)
return
}
// Update takes the representation of a virtualServiceList and updates it. Returns the server's representation of the virtualServiceList, and an error, if there is any.
func (c *virtualServiceLists) Update(ctx context.Context, virtualServiceList *v1beta2.VirtualServiceList, opts v1.UpdateOptions) (result *v1beta2.VirtualServiceList, err error) {
result = &v1beta2.VirtualServiceList{}
err = c.client.Put().
Namespace(c.ns).
Resource("virtualservicelists").
Name(virtualServiceList.Name).
VersionedParams(&opts, scheme.ParameterCodec).
Body(virtualServiceList).
Do(ctx).
Into(result)
return
}
// Delete takes name of the virtualServiceList and deletes it. Returns an error if one occurs.
func (c *virtualServiceLists) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
return c.client.Delete().
Namespace(c.ns).
Resource("virtualservicelists").
Name(name).
Body(&opts).
Do(ctx).
Error()
}
// DeleteCollection deletes a collection of objects.
func (c *virtualServiceLists) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
var timeout time.Duration
if listOpts.TimeoutSeconds != nil {
timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
}
return c.client.Delete().
Namespace(c.ns).
Resource("virtualservicelists").
VersionedParams(&listOpts, scheme.ParameterCodec).
Timeout(timeout).
Body(&opts).
Do(ctx).
Error()
}
// Patch applies the patch and returns the patched virtualServiceList.
func (c *virtualServiceLists) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.VirtualServiceList, err error) {
result = &v1beta2.VirtualServiceList{}
err = c.client.Patch(pt).
Namespace(c.ns).
Resource("virtualservicelists").
Name(name).
SubResource(subresources...).
VersionedParams(&opts, scheme.ParameterCodec).
Body(data).
Do(ctx).
Into(result)
return
}
pkg/client/informers/externalversions/appmesh/v1beta2/interface.go
-21
View File
@@ -26,16 +26,10 @@ import (
type Interface interface {
// VirtualNodes returns a VirtualNodeInformer.
VirtualNodes() VirtualNodeInformer
// VirtualNodeLists returns a VirtualNodeListInformer.
VirtualNodeLists() VirtualNodeListInformer
// VirtualRouters returns a VirtualRouterInformer.
VirtualRouters() VirtualRouterInformer
// VirtualRouterLists returns a VirtualRouterListInformer.
VirtualRouterLists() VirtualRouterListInformer
// VirtualServices returns a VirtualServiceInformer.
VirtualServices() VirtualServiceInformer
// VirtualServiceLists returns a VirtualServiceListInformer.
VirtualServiceLists() VirtualServiceListInformer
}
type version struct {
@@ -54,27 +48,12 @@ func (v *version) VirtualNodes() VirtualNodeInformer {
return &virtualNodeInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
// VirtualNodeLists returns a VirtualNodeListInformer.
func (v *version) VirtualNodeLists() VirtualNodeListInformer {
return &virtualNodeListInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
// VirtualRouters returns a VirtualRouterInformer.
func (v *version) VirtualRouters() VirtualRouterInformer {
return &virtualRouterInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
// VirtualRouterLists returns a VirtualRouterListInformer.
func (v *version) VirtualRouterLists() VirtualRouterListInformer {
return &virtualRouterListInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
// VirtualServices returns a VirtualServiceInformer.
func (v *version) VirtualServices() VirtualServiceInformer {
return &virtualServiceInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
// VirtualServiceLists returns a VirtualServiceListInformer.
func (v *version) VirtualServiceLists() VirtualServiceListInformer {
return &virtualServiceListInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
}
pkg/client/informers/externalversions/appmesh/v1beta2/virtualnodelist.go
-90
View File
@@ -1,90 +0,0 @@
/*
Copyright The Flagger 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 informer-gen. DO NOT EDIT.
package v1beta2
import (
"context"
time "time"
appmeshv1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
versioned "github.com/weaveworks/flagger/pkg/client/clientset/versioned"
internalinterfaces "github.com/weaveworks/flagger/pkg/client/informers/externalversions/internalinterfaces"
v1beta2 "github.com/weaveworks/flagger/pkg/client/listers/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
watch "k8s.io/apimachinery/pkg/watch"
cache "k8s.io/client-go/tools/cache"
)
// VirtualNodeListInformer provides access to a shared informer and lister for
// VirtualNodeLists.
type VirtualNodeListInformer interface {
Informer() cache.SharedIndexInformer
Lister() v1beta2.VirtualNodeListLister
}
type virtualNodeListInformer struct {
factory internalinterfaces.SharedInformerFactory
tweakListOptions internalinterfaces.TweakListOptionsFunc
namespace string
}
// NewVirtualNodeListInformer constructs a new informer for VirtualNodeList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewVirtualNodeListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
return NewFilteredVirtualNodeListInformer(client, namespace, resyncPeriod, indexers, nil)
}
// NewFilteredVirtualNodeListInformer constructs a new informer for VirtualNodeList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredVirtualNodeListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualNodeLists(namespace).List(context.TODO(), options)
},
WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualNodeLists(namespace).Watch(context.TODO(), options)
},
},
&appmeshv1beta2.VirtualNodeList{},
resyncPeriod,
indexers,
)
}
func (f *virtualNodeListInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
return NewFilteredVirtualNodeListInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
}
func (f *virtualNodeListInformer) Informer() cache.SharedIndexInformer {
return f.factory.InformerFor(&appmeshv1beta2.VirtualNodeList{}, f.defaultInformer)
}
func (f *virtualNodeListInformer) Lister() v1beta2.VirtualNodeListLister {
return v1beta2.NewVirtualNodeListLister(f.Informer().GetIndexer())
}
pkg/client/informers/externalversions/appmesh/v1beta2/virtualrouterlist.go
-90
View File
@@ -1,90 +0,0 @@
/*
Copyright The Flagger 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 informer-gen. DO NOT EDIT.
package v1beta2
import (
"context"
time "time"
appmeshv1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
versioned "github.com/weaveworks/flagger/pkg/client/clientset/versioned"
internalinterfaces "github.com/weaveworks/flagger/pkg/client/informers/externalversions/internalinterfaces"
v1beta2 "github.com/weaveworks/flagger/pkg/client/listers/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
watch "k8s.io/apimachinery/pkg/watch"
cache "k8s.io/client-go/tools/cache"
)
// VirtualRouterListInformer provides access to a shared informer and lister for
// VirtualRouterLists.
type VirtualRouterListInformer interface {
Informer() cache.SharedIndexInformer
Lister() v1beta2.VirtualRouterListLister
}
type virtualRouterListInformer struct {
factory internalinterfaces.SharedInformerFactory
tweakListOptions internalinterfaces.TweakListOptionsFunc
namespace string
}
// NewVirtualRouterListInformer constructs a new informer for VirtualRouterList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewVirtualRouterListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
return NewFilteredVirtualRouterListInformer(client, namespace, resyncPeriod, indexers, nil)
}
// NewFilteredVirtualRouterListInformer constructs a new informer for VirtualRouterList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredVirtualRouterListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualRouterLists(namespace).List(context.TODO(), options)
},
WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualRouterLists(namespace).Watch(context.TODO(), options)
},
},
&appmeshv1beta2.VirtualRouterList{},
resyncPeriod,
indexers,
)
}
func (f *virtualRouterListInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
return NewFilteredVirtualRouterListInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
}
func (f *virtualRouterListInformer) Informer() cache.SharedIndexInformer {
return f.factory.InformerFor(&appmeshv1beta2.VirtualRouterList{}, f.defaultInformer)
}
func (f *virtualRouterListInformer) Lister() v1beta2.VirtualRouterListLister {
return v1beta2.NewVirtualRouterListLister(f.Informer().GetIndexer())
}
pkg/client/informers/externalversions/appmesh/v1beta2/virtualservicelist.go
-90
View File
@@ -1,90 +0,0 @@
/*
Copyright The Flagger 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 informer-gen. DO NOT EDIT.
package v1beta2
import (
"context"
time "time"
appmeshv1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
versioned "github.com/weaveworks/flagger/pkg/client/clientset/versioned"
internalinterfaces "github.com/weaveworks/flagger/pkg/client/informers/externalversions/internalinterfaces"
v1beta2 "github.com/weaveworks/flagger/pkg/client/listers/appmesh/v1beta2"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
watch "k8s.io/apimachinery/pkg/watch"
cache "k8s.io/client-go/tools/cache"
)
// VirtualServiceListInformer provides access to a shared informer and lister for
// VirtualServiceLists.
type VirtualServiceListInformer interface {
Informer() cache.SharedIndexInformer
Lister() v1beta2.VirtualServiceListLister
}
type virtualServiceListInformer struct {
factory internalinterfaces.SharedInformerFactory
tweakListOptions internalinterfaces.TweakListOptionsFunc
namespace string
}
// NewVirtualServiceListInformer constructs a new informer for VirtualServiceList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewVirtualServiceListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
return NewFilteredVirtualServiceListInformer(client, namespace, resyncPeriod, indexers, nil)
}
// NewFilteredVirtualServiceListInformer constructs a new informer for VirtualServiceList type.
// Always prefer using an informer factory to get a shared informer instead of getting an independent
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredVirtualServiceListInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualServiceLists(namespace).List(context.TODO(), options)
},
WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.AppmeshV1beta2().VirtualServiceLists(namespace).Watch(context.TODO(), options)
},
},
&appmeshv1beta2.VirtualServiceList{},
resyncPeriod,
indexers,
)
}
func (f *virtualServiceListInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
return NewFilteredVirtualServiceListInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
}
func (f *virtualServiceListInformer) Informer() cache.SharedIndexInformer {
return f.factory.InformerFor(&appmeshv1beta2.VirtualServiceList{}, f.defaultInformer)
}
func (f *virtualServiceListInformer) Lister() v1beta2.VirtualServiceListLister {
return v1beta2.NewVirtualServiceListLister(f.Informer().GetIndexer())
}
pkg/client/informers/externalversions/generic.go
-6
View File
@@ -70,16 +70,10 @@ func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource
// Group=appmesh.k8s.aws, Version=v1beta2
case v1beta2.SchemeGroupVersion.WithResource("virtualnodes"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualNodes().Informer()}, nil
case v1beta2.SchemeGroupVersion.WithResource("virtualnodelists"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualNodeLists().Informer()}, nil
case v1beta2.SchemeGroupVersion.WithResource("virtualrouters"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualRouters().Informer()}, nil
case v1beta2.SchemeGroupVersion.WithResource("virtualrouterlists"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualRouterLists().Informer()}, nil
case v1beta2.SchemeGroupVersion.WithResource("virtualservices"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualServices().Informer()}, nil
case v1beta2.SchemeGroupVersion.WithResource("virtualservicelists"):
return &genericInformer{resource: resource.GroupResource(), informer: f.Appmesh().V1beta2().VirtualServiceLists().Informer()}, nil
// Group=flagger.app, Version=v1beta1
case flaggerv1beta1.SchemeGroupVersion.WithResource("alertproviders"):
pkg/client/listers/appmesh/v1beta2/expansion_generated.go
-24
View File
@@ -26,14 +26,6 @@ type VirtualNodeListerExpansion interface{}
// VirtualNodeNamespaceLister.
type VirtualNodeNamespaceListerExpansion interface{}
// VirtualNodeListListerExpansion allows custom methods to be added to
// VirtualNodeListLister.
type VirtualNodeListListerExpansion interface{}
// VirtualNodeListNamespaceListerExpansion allows custom methods to be added to
// VirtualNodeListNamespaceLister.
type VirtualNodeListNamespaceListerExpansion interface{}
// VirtualRouterListerExpansion allows custom methods to be added to
// VirtualRouterLister.
type VirtualRouterListerExpansion interface{}
@@ -42,14 +34,6 @@ type VirtualRouterListerExpansion interface{}
// VirtualRouterNamespaceLister.
type VirtualRouterNamespaceListerExpansion interface{}
// VirtualRouterListListerExpansion allows custom methods to be added to
// VirtualRouterListLister.
type VirtualRouterListListerExpansion interface{}
// VirtualRouterListNamespaceListerExpansion allows custom methods to be added to
// VirtualRouterListNamespaceLister.
type VirtualRouterListNamespaceListerExpansion interface{}
// VirtualServiceListerExpansion allows custom methods to be added to
// VirtualServiceLister.
type VirtualServiceListerExpansion interface{}
@@ -57,11 +41,3 @@ type VirtualServiceListerExpansion interface{}
// VirtualServiceNamespaceListerExpansion allows custom methods to be added to
// VirtualServiceNamespaceLister.
type VirtualServiceNamespaceListerExpansion interface{}
// VirtualServiceListListerExpansion allows custom methods to be added to
// VirtualServiceListLister.
type VirtualServiceListListerExpansion interface{}
// VirtualServiceListNamespaceListerExpansion allows custom methods to be added to
// VirtualServiceListNamespaceLister.
type VirtualServiceListNamespaceListerExpansion interface{}
pkg/client/listers/appmesh/v1beta2/virtualnodelist.go
-94
View File
@@ -1,94 +0,0 @@
/*
Copyright The Flagger 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 lister-gen. DO NOT EDIT.
package v1beta2
import (
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
)
// VirtualNodeListLister helps list VirtualNodeLists.
type VirtualNodeListLister interface {
// List lists all VirtualNodeLists in the indexer.
List(selector labels.Selector) (ret []*v1beta2.VirtualNodeList, err error)
// VirtualNodeLists returns an object that can list and get VirtualNodeLists.
VirtualNodeLists(namespace string) VirtualNodeListNamespaceLister
VirtualNodeListListerExpansion
}
// virtualNodeListLister implements the VirtualNodeListLister interface.
type virtualNodeListLister struct {
indexer cache.Indexer
}
// NewVirtualNodeListLister returns a new VirtualNodeListLister.
func NewVirtualNodeListLister(indexer cache.Indexer) VirtualNodeListLister {
return &virtualNodeListLister{indexer: indexer}
}
// List lists all VirtualNodeLists in the indexer.
func (s *virtualNodeListLister) List(selector labels.Selector) (ret []*v1beta2.VirtualNodeList, err error) {
err = cache.ListAll(s.indexer, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualNodeList))
})
return ret, err
}
// VirtualNodeLists returns an object that can list and get VirtualNodeLists.
func (s *virtualNodeListLister) VirtualNodeLists(namespace string) VirtualNodeListNamespaceLister {
return virtualNodeListNamespaceLister{indexer: s.indexer, namespace: namespace}
}
// VirtualNodeListNamespaceLister helps list and get VirtualNodeLists.
type VirtualNodeListNamespaceLister interface {
// List lists all VirtualNodeLists in the indexer for a given namespace.
List(selector labels.Selector) (ret []*v1beta2.VirtualNodeList, err error)
// Get retrieves the VirtualNodeList from the indexer for a given namespace and name.
Get(name string) (*v1beta2.VirtualNodeList, error)
VirtualNodeListNamespaceListerExpansion
}
// virtualNodeListNamespaceLister implements the VirtualNodeListNamespaceLister
// interface.
type virtualNodeListNamespaceLister struct {
indexer cache.Indexer
namespace string
}
// List lists all VirtualNodeLists in the indexer for a given namespace.
func (s virtualNodeListNamespaceLister) List(selector labels.Selector) (ret []*v1beta2.VirtualNodeList, err error) {
err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualNodeList))
})
return ret, err
}
// Get retrieves the VirtualNodeList from the indexer for a given namespace and name.
func (s virtualNodeListNamespaceLister) Get(name string) (*v1beta2.VirtualNodeList, error) {
obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
if err != nil {
return nil, err
}
if !exists {
return nil, errors.NewNotFound(v1beta2.Resource("virtualnodelist"), name)
}
return obj.(*v1beta2.VirtualNodeList), nil
}
pkg/client/listers/appmesh/v1beta2/virtualrouterlist.go
-94
View File
@@ -1,94 +0,0 @@
/*
Copyright The Flagger 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 lister-gen. DO NOT EDIT.
package v1beta2
import (
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
)
// VirtualRouterListLister helps list VirtualRouterLists.
type VirtualRouterListLister interface {
// List lists all VirtualRouterLists in the indexer.
List(selector labels.Selector) (ret []*v1beta2.VirtualRouterList, err error)
// VirtualRouterLists returns an object that can list and get VirtualRouterLists.
VirtualRouterLists(namespace string) VirtualRouterListNamespaceLister
VirtualRouterListListerExpansion
}
// virtualRouterListLister implements the VirtualRouterListLister interface.
type virtualRouterListLister struct {
indexer cache.Indexer
}
// NewVirtualRouterListLister returns a new VirtualRouterListLister.
func NewVirtualRouterListLister(indexer cache.Indexer) VirtualRouterListLister {
return &virtualRouterListLister{indexer: indexer}
}
// List lists all VirtualRouterLists in the indexer.
func (s *virtualRouterListLister) List(selector labels.Selector) (ret []*v1beta2.VirtualRouterList, err error) {
err = cache.ListAll(s.indexer, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualRouterList))
})
return ret, err
}
// VirtualRouterLists returns an object that can list and get VirtualRouterLists.
func (s *virtualRouterListLister) VirtualRouterLists(namespace string) VirtualRouterListNamespaceLister {
return virtualRouterListNamespaceLister{indexer: s.indexer, namespace: namespace}
}
// VirtualRouterListNamespaceLister helps list and get VirtualRouterLists.
type VirtualRouterListNamespaceLister interface {
// List lists all VirtualRouterLists in the indexer for a given namespace.
List(selector labels.Selector) (ret []*v1beta2.VirtualRouterList, err error)
// Get retrieves the VirtualRouterList from the indexer for a given namespace and name.
Get(name string) (*v1beta2.VirtualRouterList, error)
VirtualRouterListNamespaceListerExpansion
}
// virtualRouterListNamespaceLister implements the VirtualRouterListNamespaceLister
// interface.
type virtualRouterListNamespaceLister struct {
indexer cache.Indexer
namespace string
}
// List lists all VirtualRouterLists in the indexer for a given namespace.
func (s virtualRouterListNamespaceLister) List(selector labels.Selector) (ret []*v1beta2.VirtualRouterList, err error) {
err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualRouterList))
})
return ret, err
}
// Get retrieves the VirtualRouterList from the indexer for a given namespace and name.
func (s virtualRouterListNamespaceLister) Get(name string) (*v1beta2.VirtualRouterList, error) {
obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
if err != nil {
return nil, err
}
if !exists {
return nil, errors.NewNotFound(v1beta2.Resource("virtualrouterlist"), name)
}
return obj.(*v1beta2.VirtualRouterList), nil
}
pkg/client/listers/appmesh/v1beta2/virtualservicelist.go
-94
View File
@@ -1,94 +0,0 @@
/*
Copyright The Flagger 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 lister-gen. DO NOT EDIT.
package v1beta2
import (
v1beta2 "github.com/weaveworks/flagger/pkg/apis/appmesh/v1beta2"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
)
// VirtualServiceListLister helps list VirtualServiceLists.
type VirtualServiceListLister interface {
// List lists all VirtualServiceLists in the indexer.
List(selector labels.Selector) (ret []*v1beta2.VirtualServiceList, err error)
// VirtualServiceLists returns an object that can list and get VirtualServiceLists.
VirtualServiceLists(namespace string) VirtualServiceListNamespaceLister
VirtualServiceListListerExpansion
}
// virtualServiceListLister implements the VirtualServiceListLister interface.
type virtualServiceListLister struct {
indexer cache.Indexer
}
// NewVirtualServiceListLister returns a new VirtualServiceListLister.
func NewVirtualServiceListLister(indexer cache.Indexer) VirtualServiceListLister {
return &virtualServiceListLister{indexer: indexer}
}
// List lists all VirtualServiceLists in the indexer.
func (s *virtualServiceListLister) List(selector labels.Selector) (ret []*v1beta2.VirtualServiceList, err error) {
err = cache.ListAll(s.indexer, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualServiceList))
})
return ret, err
}
// VirtualServiceLists returns an object that can list and get VirtualServiceLists.
func (s *virtualServiceListLister) VirtualServiceLists(namespace string) VirtualServiceListNamespaceLister {
return virtualServiceListNamespaceLister{indexer: s.indexer, namespace: namespace}
}
// VirtualServiceListNamespaceLister helps list and get VirtualServiceLists.
type VirtualServiceListNamespaceLister interface {
// List lists all VirtualServiceLists in the indexer for a given namespace.
List(selector labels.Selector) (ret []*v1beta2.VirtualServiceList, err error)
// Get retrieves the VirtualServiceList from the indexer for a given namespace and name.
Get(name string) (*v1beta2.VirtualServiceList, error)
VirtualServiceListNamespaceListerExpansion
}
// virtualServiceListNamespaceLister implements the VirtualServiceListNamespaceLister
// interface.
type virtualServiceListNamespaceLister struct {
indexer cache.Indexer
namespace string
}
// List lists all VirtualServiceLists in the indexer for a given namespace.
func (s virtualServiceListNamespaceLister) List(selector labels.Selector) (ret []*v1beta2.VirtualServiceList, err error) {
err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
ret = append(ret, m.(*v1beta2.VirtualServiceList))
})
return ret, err
}
// Get retrieves the VirtualServiceList from the indexer for a given namespace and name.
func (s virtualServiceListNamespaceLister) Get(name string) (*v1beta2.VirtualServiceList, error) {
obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
if err != nil {
return nil, err
}
if !exists {
return nil, errors.NewNotFound(v1beta2.Resource("virtualservicelist"), name)
}
return obj.(*v1beta2.VirtualServiceList), nil
}