kubelatte-ce
Форк от sbertech/kubelatte-ce
113 строк · 3.7 Кб
1package clientset2
3import (4"context"5"gitverse.ru/synapse/kubelatte/pkg/api/v1alpha1"6metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"7"k8s.io/apimachinery/pkg/watch"8"k8s.io/client-go/kubernetes/scheme"9"k8s.io/client-go/rest"10)
11
12//go:generate go run github.com/vektra/mockery/v2@v2.20.2 --name=TriggerInstanceInterface
13type TriggerInstanceInterface interface {14List(ctx context.Context, ns string, opts metav1.ListOptions) (*v1alpha1.TriggerInstanceList, error)15Get(ctx context.Context, ns string, name string, options metav1.GetOptions) (*v1alpha1.TriggerInstance, error)16Update(ctx context.Context, ns string, triggerInstance *v1alpha1.TriggerInstance, opts metav1.UpdateOptions) (result *v1alpha1.TriggerInstance, err error)17UpdateStatus(ctx context.Context, ns string, hostEntry *v1alpha1.TriggerInstance, opts metav1.UpdateOptions) (*v1alpha1.TriggerInstance, error)18Create(ctx context.Context, ns string, triggerInstance *v1alpha1.TriggerInstance) (*v1alpha1.TriggerInstance, error)19Delete(ctx context.Context, ns string, name string, opts metav1.DeleteOptions) error20Watch(ctx context.Context, ns string, opts metav1.ListOptions) (watch.Interface, error)21}
22
23type triggerInstanceClient struct {24restClient rest.Interface25}
26
27func (c *triggerInstanceClient) List(ctx context.Context, ns string, opts metav1.ListOptions) (*v1alpha1.TriggerInstanceList, error) {28result := v1alpha1.TriggerInstanceList{}29err := c.restClient.30Get().31Namespace(ns).32Resource("triggerInstances").33VersionedParams(&opts, scheme.ParameterCodec).34Do(ctx).35Into(&result)36
37return &result, err38}
39
40func (c *triggerInstanceClient) Get(ctx context.Context, ns string, name string, opts metav1.GetOptions) (*v1alpha1.TriggerInstance, error) {41result := v1alpha1.TriggerInstance{}42err := c.restClient.43Get().44Namespace(ns).45Resource("triggerInstances").46Name(name).47VersionedParams(&opts, scheme.ParameterCodec).48Do(ctx).49Into(&result)50
51return &result, err52}
53
54func (c *triggerInstanceClient) Update(ctx context.Context, ns string, triggerInstance *v1alpha1.TriggerInstance, opts metav1.UpdateOptions) (result *v1alpha1.TriggerInstance, err error) {55result = &v1alpha1.TriggerInstance{}56err = c.restClient.Put().57Namespace(ns).58Resource("triggerInstances").59Name(triggerInstance.Name).60VersionedParams(&opts, scheme.ParameterCodec).61Body(triggerInstance).62Do(ctx).63Into(result)64return65}
66
67func (c *triggerInstanceClient) UpdateStatus(ctx context.Context, ns string, hostEntry *v1alpha1.TriggerInstance, opts metav1.UpdateOptions) (result *v1alpha1.TriggerInstance, err error) {68result = &v1alpha1.TriggerInstance{}69err = c.restClient.Put().70Namespace(ns).71Resource("triggerInstances").72Name(hostEntry.Name).73SubResource("status").74VersionedParams(&opts, scheme.ParameterCodec).75Body(hostEntry).76Do(ctx).77Into(result)78return79}
80
81func (c *triggerInstanceClient) Create(ctx context.Context, ns string, triggerInstance *v1alpha1.TriggerInstance) (*v1alpha1.TriggerInstance, error) {82result := v1alpha1.TriggerInstance{}83err := c.restClient.84Post().85Namespace(ns).86Resource("triggerInstances").87Body(triggerInstance).88Do(ctx).89Into(&result)90
91return &result, err92}
93
94func (c *triggerInstanceClient) Delete(ctx context.Context, ns string, name string, opts metav1.DeleteOptions) error {95return c.restClient.96Delete().97Namespace(ns).98Resource("triggerInstances").99Name(name).100Body(&opts).101Do(ctx).102Error()103}
104
105func (c *triggerInstanceClient) Watch(ctx context.Context, ns string, opts metav1.ListOptions) (watch.Interface, error) {106opts.Watch = true107return c.restClient.108Get().109Namespace(ns).110Resource("triggerInstance").111VersionedParams(&opts, scheme.ParameterCodec).112Watch(ctx)113}
114