mirror of
https://github.com/rancher/types.git
synced 2025-04-28 02:30:07 +00:00
Update generated code
This commit is contained in:
parent
a1fd824df3
commit
568afa007c
@ -1,257 +0,0 @@
|
||||
package v3
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/rancher/norman/controller"
|
||||
"github.com/rancher/norman/objectclient"
|
||||
"k8s.io/apimachinery/pkg/api/errors"
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
"k8s.io/apimachinery/pkg/labels"
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
"k8s.io/apimachinery/pkg/watch"
|
||||
"k8s.io/client-go/tools/cache"
|
||||
)
|
||||
|
||||
var (
|
||||
ClusterEventGroupVersionKind = schema.GroupVersionKind{
|
||||
Version: Version,
|
||||
Group: GroupName,
|
||||
Kind: "ClusterEvent",
|
||||
}
|
||||
ClusterEventResource = metav1.APIResource{
|
||||
Name: "clusterevents",
|
||||
SingularName: "clusterevent",
|
||||
Namespaced: true,
|
||||
|
||||
Kind: ClusterEventGroupVersionKind.Kind,
|
||||
}
|
||||
)
|
||||
|
||||
type ClusterEventList struct {
|
||||
metav1.TypeMeta `json:",inline"`
|
||||
metav1.ListMeta `json:"metadata,omitempty"`
|
||||
Items []ClusterEvent
|
||||
}
|
||||
|
||||
type ClusterEventHandlerFunc func(key string, obj *ClusterEvent) error
|
||||
|
||||
type ClusterEventLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterEvent, err error)
|
||||
Get(namespace, name string) (*ClusterEvent, error)
|
||||
}
|
||||
|
||||
type ClusterEventController interface {
|
||||
Generic() controller.GenericController
|
||||
Informer() cache.SharedIndexInformer
|
||||
Lister() ClusterEventLister
|
||||
AddHandler(name string, handler ClusterEventHandlerFunc)
|
||||
AddClusterScopedHandler(name, clusterName string, handler ClusterEventHandlerFunc)
|
||||
Enqueue(namespace, name string)
|
||||
Sync(ctx context.Context) error
|
||||
Start(ctx context.Context, threadiness int) error
|
||||
}
|
||||
|
||||
type ClusterEventInterface interface {
|
||||
ObjectClient() *objectclient.ObjectClient
|
||||
Create(*ClusterEvent) (*ClusterEvent, error)
|
||||
GetNamespaced(namespace, name string, opts metav1.GetOptions) (*ClusterEvent, error)
|
||||
Get(name string, opts metav1.GetOptions) (*ClusterEvent, error)
|
||||
Update(*ClusterEvent) (*ClusterEvent, error)
|
||||
Delete(name string, options *metav1.DeleteOptions) error
|
||||
DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error
|
||||
List(opts metav1.ListOptions) (*ClusterEventList, error)
|
||||
Watch(opts metav1.ListOptions) (watch.Interface, error)
|
||||
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
|
||||
Controller() ClusterEventController
|
||||
AddHandler(name string, sync ClusterEventHandlerFunc)
|
||||
AddLifecycle(name string, lifecycle ClusterEventLifecycle)
|
||||
AddClusterScopedHandler(name, clusterName string, sync ClusterEventHandlerFunc)
|
||||
AddClusterScopedLifecycle(name, clusterName string, lifecycle ClusterEventLifecycle)
|
||||
}
|
||||
|
||||
type clusterEventLister struct {
|
||||
controller *clusterEventController
|
||||
}
|
||||
|
||||
func (l *clusterEventLister) List(namespace string, selector labels.Selector) (ret []*ClusterEvent, err error) {
|
||||
err = cache.ListAllByNamespace(l.controller.Informer().GetIndexer(), namespace, selector, func(obj interface{}) {
|
||||
ret = append(ret, obj.(*ClusterEvent))
|
||||
})
|
||||
return
|
||||
}
|
||||
|
||||
func (l *clusterEventLister) Get(namespace, name string) (*ClusterEvent, error) {
|
||||
var key string
|
||||
if namespace != "" {
|
||||
key = namespace + "/" + name
|
||||
} else {
|
||||
key = name
|
||||
}
|
||||
obj, exists, err := l.controller.Informer().GetIndexer().GetByKey(key)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if !exists {
|
||||
return nil, errors.NewNotFound(schema.GroupResource{
|
||||
Group: ClusterEventGroupVersionKind.Group,
|
||||
Resource: "clusterEvent",
|
||||
}, key)
|
||||
}
|
||||
return obj.(*ClusterEvent), nil
|
||||
}
|
||||
|
||||
type clusterEventController struct {
|
||||
controller.GenericController
|
||||
}
|
||||
|
||||
func (c *clusterEventController) Generic() controller.GenericController {
|
||||
return c.GenericController
|
||||
}
|
||||
|
||||
func (c *clusterEventController) Lister() ClusterEventLister {
|
||||
return &clusterEventLister{
|
||||
controller: c,
|
||||
}
|
||||
}
|
||||
|
||||
func (c *clusterEventController) AddHandler(name string, handler ClusterEventHandlerFunc) {
|
||||
c.GenericController.AddHandler(name, func(key string) error {
|
||||
obj, exists, err := c.Informer().GetStore().GetByKey(key)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !exists {
|
||||
return handler(key, nil)
|
||||
}
|
||||
return handler(key, obj.(*ClusterEvent))
|
||||
})
|
||||
}
|
||||
|
||||
func (c *clusterEventController) AddClusterScopedHandler(name, cluster string, handler ClusterEventHandlerFunc) {
|
||||
c.GenericController.AddHandler(name, func(key string) error {
|
||||
obj, exists, err := c.Informer().GetStore().GetByKey(key)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !exists {
|
||||
return handler(key, nil)
|
||||
}
|
||||
|
||||
if !controller.ObjectInCluster(cluster, obj) {
|
||||
return nil
|
||||
}
|
||||
|
||||
return handler(key, obj.(*ClusterEvent))
|
||||
})
|
||||
}
|
||||
|
||||
type clusterEventFactory struct {
|
||||
}
|
||||
|
||||
func (c clusterEventFactory) Object() runtime.Object {
|
||||
return &ClusterEvent{}
|
||||
}
|
||||
|
||||
func (c clusterEventFactory) List() runtime.Object {
|
||||
return &ClusterEventList{}
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Controller() ClusterEventController {
|
||||
s.client.Lock()
|
||||
defer s.client.Unlock()
|
||||
|
||||
c, ok := s.client.clusterEventControllers[s.ns]
|
||||
if ok {
|
||||
return c
|
||||
}
|
||||
|
||||
genericController := controller.NewGenericController(ClusterEventGroupVersionKind.Kind+"Controller",
|
||||
s.objectClient)
|
||||
|
||||
c = &clusterEventController{
|
||||
GenericController: genericController,
|
||||
}
|
||||
|
||||
s.client.clusterEventControllers[s.ns] = c
|
||||
s.client.starters = append(s.client.starters, c)
|
||||
|
||||
return c
|
||||
}
|
||||
|
||||
type clusterEventClient struct {
|
||||
client *Client
|
||||
ns string
|
||||
objectClient *objectclient.ObjectClient
|
||||
controller ClusterEventController
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) ObjectClient() *objectclient.ObjectClient {
|
||||
return s.objectClient
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Create(o *ClusterEvent) (*ClusterEvent, error) {
|
||||
obj, err := s.objectClient.Create(o)
|
||||
return obj.(*ClusterEvent), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Get(name string, opts metav1.GetOptions) (*ClusterEvent, error) {
|
||||
obj, err := s.objectClient.Get(name, opts)
|
||||
return obj.(*ClusterEvent), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) GetNamespaced(namespace, name string, opts metav1.GetOptions) (*ClusterEvent, error) {
|
||||
obj, err := s.objectClient.GetNamespaced(namespace, name, opts)
|
||||
return obj.(*ClusterEvent), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Update(o *ClusterEvent) (*ClusterEvent, error) {
|
||||
obj, err := s.objectClient.Update(o.Name, o)
|
||||
return obj.(*ClusterEvent), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Delete(name string, options *metav1.DeleteOptions) error {
|
||||
return s.objectClient.Delete(name, options)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) DeleteNamespaced(namespace, name string, options *metav1.DeleteOptions) error {
|
||||
return s.objectClient.DeleteNamespaced(namespace, name, options)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) List(opts metav1.ListOptions) (*ClusterEventList, error) {
|
||||
obj, err := s.objectClient.List(opts)
|
||||
return obj.(*ClusterEventList), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) Watch(opts metav1.ListOptions) (watch.Interface, error) {
|
||||
return s.objectClient.Watch(opts)
|
||||
}
|
||||
|
||||
// Patch applies the patch and returns the patched deployment.
|
||||
func (s *clusterEventClient) Patch(o *ClusterEvent, data []byte, subresources ...string) (*ClusterEvent, error) {
|
||||
obj, err := s.objectClient.Patch(o.Name, o, data, subresources...)
|
||||
return obj.(*ClusterEvent), err
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error {
|
||||
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) AddHandler(name string, sync ClusterEventHandlerFunc) {
|
||||
s.Controller().AddHandler(name, sync)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) AddLifecycle(name string, lifecycle ClusterEventLifecycle) {
|
||||
sync := NewClusterEventLifecycleAdapter(name, false, s, lifecycle)
|
||||
s.AddHandler(name, sync)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) AddClusterScopedHandler(name, clusterName string, sync ClusterEventHandlerFunc) {
|
||||
s.Controller().AddClusterScopedHandler(name, clusterName, sync)
|
||||
}
|
||||
|
||||
func (s *clusterEventClient) AddClusterScopedLifecycle(name, clusterName string, lifecycle ClusterEventLifecycle) {
|
||||
sync := NewClusterEventLifecycleAdapter(name+"_"+clusterName, true, s, lifecycle)
|
||||
s.AddClusterScopedHandler(name, clusterName, sync)
|
||||
}
|
@ -1,51 +0,0 @@
|
||||
package v3
|
||||
|
||||
import (
|
||||
"github.com/rancher/norman/lifecycle"
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
)
|
||||
|
||||
type ClusterEventLifecycle interface {
|
||||
Create(obj *ClusterEvent) (*ClusterEvent, error)
|
||||
Remove(obj *ClusterEvent) (*ClusterEvent, error)
|
||||
Updated(obj *ClusterEvent) (*ClusterEvent, error)
|
||||
}
|
||||
|
||||
type clusterEventLifecycleAdapter struct {
|
||||
lifecycle ClusterEventLifecycle
|
||||
}
|
||||
|
||||
func (w *clusterEventLifecycleAdapter) Create(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Create(obj.(*ClusterEvent))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func (w *clusterEventLifecycleAdapter) Finalize(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Remove(obj.(*ClusterEvent))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func (w *clusterEventLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error) {
|
||||
o, err := w.lifecycle.Updated(obj.(*ClusterEvent))
|
||||
if o == nil {
|
||||
return nil, err
|
||||
}
|
||||
return o, err
|
||||
}
|
||||
|
||||
func NewClusterEventLifecycleAdapter(name string, clusterScoped bool, client ClusterEventInterface, l ClusterEventLifecycle) ClusterEventHandlerFunc {
|
||||
adapter := &clusterEventLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterEvent) error {
|
||||
if obj == nil {
|
||||
return syncFn(key, nil)
|
||||
}
|
||||
return syncFn(key, obj)
|
||||
}
|
||||
}
|
@ -927,65 +927,6 @@ func (in *ClusterCondition) DeepCopy() *ClusterCondition {
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *ClusterEvent) DeepCopyInto(out *ClusterEvent) {
|
||||
*out = *in
|
||||
out.Namespaced = in.Namespaced
|
||||
in.Event.DeepCopyInto(&out.Event)
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEvent.
|
||||
func (in *ClusterEvent) DeepCopy() *ClusterEvent {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(ClusterEvent)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
||||
func (in *ClusterEvent) DeepCopyObject() runtime.Object {
|
||||
if c := in.DeepCopy(); c != nil {
|
||||
return c
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *ClusterEventList) DeepCopyInto(out *ClusterEventList) {
|
||||
*out = *in
|
||||
out.TypeMeta = in.TypeMeta
|
||||
out.ListMeta = in.ListMeta
|
||||
if in.Items != nil {
|
||||
in, out := &in.Items, &out.Items
|
||||
*out = make([]ClusterEvent, len(*in))
|
||||
for i := range *in {
|
||||
(*in)[i].DeepCopyInto(&(*out)[i])
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEventList.
|
||||
func (in *ClusterEventList) DeepCopy() *ClusterEventList {
|
||||
if in == nil {
|
||||
return nil
|
||||
}
|
||||
out := new(ClusterEventList)
|
||||
in.DeepCopyInto(out)
|
||||
return out
|
||||
}
|
||||
|
||||
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
||||
func (in *ClusterEventList) DeepCopyObject() runtime.Object {
|
||||
if c := in.DeepCopy(); c != nil {
|
||||
return c
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||
func (in *ClusterList) DeepCopyInto(out *ClusterList) {
|
||||
*out = *in
|
||||
|
@ -30,7 +30,6 @@ type Interface interface {
|
||||
ClusterRoleTemplateBindingsGetter
|
||||
ProjectRoleTemplateBindingsGetter
|
||||
ClustersGetter
|
||||
ClusterEventsGetter
|
||||
ClusterRegistrationTokensGetter
|
||||
CatalogsGetter
|
||||
TemplatesGetter
|
||||
@ -77,7 +76,6 @@ type Client struct {
|
||||
clusterRoleTemplateBindingControllers map[string]ClusterRoleTemplateBindingController
|
||||
projectRoleTemplateBindingControllers map[string]ProjectRoleTemplateBindingController
|
||||
clusterControllers map[string]ClusterController
|
||||
clusterEventControllers map[string]ClusterEventController
|
||||
clusterRegistrationTokenControllers map[string]ClusterRegistrationTokenController
|
||||
catalogControllers map[string]CatalogController
|
||||
templateControllers map[string]TemplateController
|
||||
@ -145,7 +143,6 @@ func NewForConfig(config rest.Config) (Interface, error) {
|
||||
clusterRoleTemplateBindingControllers: map[string]ClusterRoleTemplateBindingController{},
|
||||
projectRoleTemplateBindingControllers: map[string]ProjectRoleTemplateBindingController{},
|
||||
clusterControllers: map[string]ClusterController{},
|
||||
clusterEventControllers: map[string]ClusterEventController{},
|
||||
clusterRegistrationTokenControllers: map[string]ClusterRegistrationTokenController{},
|
||||
catalogControllers: map[string]CatalogController{},
|
||||
templateControllers: map[string]TemplateController{},
|
||||
@ -356,19 +353,6 @@ func (c *Client) Clusters(namespace string) ClusterInterface {
|
||||
}
|
||||
}
|
||||
|
||||
type ClusterEventsGetter interface {
|
||||
ClusterEvents(namespace string) ClusterEventInterface
|
||||
}
|
||||
|
||||
func (c *Client) ClusterEvents(namespace string) ClusterEventInterface {
|
||||
objectClient := objectclient.NewObjectClient(namespace, c.restClient, &ClusterEventResource, ClusterEventGroupVersionKind, clusterEventFactory{})
|
||||
return &clusterEventClient{
|
||||
ns: namespace,
|
||||
client: c,
|
||||
objectClient: objectClient,
|
||||
}
|
||||
}
|
||||
|
||||
type ClusterRegistrationTokensGetter interface {
|
||||
ClusterRegistrationTokens(namespace string) ClusterRegistrationTokenInterface
|
||||
}
|
||||
|
@ -59,8 +59,6 @@ func addKnownTypes(scheme *runtime.Scheme) error {
|
||||
&ProjectRoleTemplateBindingList{},
|
||||
&Cluster{},
|
||||
&ClusterList{},
|
||||
&ClusterEvent{},
|
||||
&ClusterEventList{},
|
||||
&ClusterRegistrationToken{},
|
||||
&ClusterRegistrationTokenList{},
|
||||
&Catalog{},
|
||||
|
@ -20,7 +20,6 @@ type Client struct {
|
||||
ClusterRoleTemplateBinding ClusterRoleTemplateBindingOperations
|
||||
ProjectRoleTemplateBinding ProjectRoleTemplateBindingOperations
|
||||
Cluster ClusterOperations
|
||||
ClusterEvent ClusterEventOperations
|
||||
ClusterRegistrationToken ClusterRegistrationTokenOperations
|
||||
Catalog CatalogOperations
|
||||
Template TemplateOperations
|
||||
@ -71,7 +70,6 @@ func NewClient(opts *clientbase.ClientOpts) (*Client, error) {
|
||||
client.ClusterRoleTemplateBinding = newClusterRoleTemplateBindingClient(client)
|
||||
client.ProjectRoleTemplateBinding = newProjectRoleTemplateBindingClient(client)
|
||||
client.Cluster = newClusterClient(client)
|
||||
client.ClusterEvent = newClusterEventClient(client)
|
||||
client.ClusterRegistrationToken = newClusterRegistrationTokenClient(client)
|
||||
client.Catalog = newCatalogClient(client)
|
||||
client.Template = newTemplateClient(client)
|
||||
|
@ -1,131 +0,0 @@
|
||||
package client
|
||||
|
||||
import (
|
||||
"github.com/rancher/norman/types"
|
||||
)
|
||||
|
||||
const (
|
||||
ClusterEventType = "clusterEvent"
|
||||
ClusterEventFieldAction = "action"
|
||||
ClusterEventFieldAnnotations = "annotations"
|
||||
ClusterEventFieldClusterID = "clusterId"
|
||||
ClusterEventFieldCount = "count"
|
||||
ClusterEventFieldCreated = "created"
|
||||
ClusterEventFieldCreatorID = "creatorId"
|
||||
ClusterEventFieldEventTime = "eventTime"
|
||||
ClusterEventFieldEventType = "eventType"
|
||||
ClusterEventFieldFirstTimestamp = "firstTimestamp"
|
||||
ClusterEventFieldInvolvedObject = "involvedObject"
|
||||
ClusterEventFieldLabels = "labels"
|
||||
ClusterEventFieldLastTimestamp = "lastTimestamp"
|
||||
ClusterEventFieldMessage = "message"
|
||||
ClusterEventFieldName = "name"
|
||||
ClusterEventFieldNamespaceId = "namespaceId"
|
||||
ClusterEventFieldOwnerReferences = "ownerReferences"
|
||||
ClusterEventFieldReason = "reason"
|
||||
ClusterEventFieldRelated = "related"
|
||||
ClusterEventFieldRemoved = "removed"
|
||||
ClusterEventFieldReportingController = "reportingComponent"
|
||||
ClusterEventFieldReportingInstance = "reportingInstance"
|
||||
ClusterEventFieldSeries = "series"
|
||||
ClusterEventFieldSource = "source"
|
||||
ClusterEventFieldUUID = "uuid"
|
||||
)
|
||||
|
||||
type ClusterEvent struct {
|
||||
types.Resource
|
||||
Action string `json:"action,omitempty" yaml:"action,omitempty"`
|
||||
Annotations map[string]string `json:"annotations,omitempty" yaml:"annotations,omitempty"`
|
||||
ClusterID string `json:"clusterId,omitempty" yaml:"clusterId,omitempty"`
|
||||
Count int64 `json:"count,omitempty" yaml:"count,omitempty"`
|
||||
Created string `json:"created,omitempty" yaml:"created,omitempty"`
|
||||
CreatorID string `json:"creatorId,omitempty" yaml:"creatorId,omitempty"`
|
||||
EventTime *MicroTime `json:"eventTime,omitempty" yaml:"eventTime,omitempty"`
|
||||
EventType string `json:"eventType,omitempty" yaml:"eventType,omitempty"`
|
||||
FirstTimestamp string `json:"firstTimestamp,omitempty" yaml:"firstTimestamp,omitempty"`
|
||||
InvolvedObject *ObjectReference `json:"involvedObject,omitempty" yaml:"involvedObject,omitempty"`
|
||||
Labels map[string]string `json:"labels,omitempty" yaml:"labels,omitempty"`
|
||||
LastTimestamp string `json:"lastTimestamp,omitempty" yaml:"lastTimestamp,omitempty"`
|
||||
Message string `json:"message,omitempty" yaml:"message,omitempty"`
|
||||
Name string `json:"name,omitempty" yaml:"name,omitempty"`
|
||||
NamespaceId string `json:"namespaceId,omitempty" yaml:"namespaceId,omitempty"`
|
||||
OwnerReferences []OwnerReference `json:"ownerReferences,omitempty" yaml:"ownerReferences,omitempty"`
|
||||
Reason string `json:"reason,omitempty" yaml:"reason,omitempty"`
|
||||
Related *ObjectReference `json:"related,omitempty" yaml:"related,omitempty"`
|
||||
Removed string `json:"removed,omitempty" yaml:"removed,omitempty"`
|
||||
ReportingController string `json:"reportingComponent,omitempty" yaml:"reportingComponent,omitempty"`
|
||||
ReportingInstance string `json:"reportingInstance,omitempty" yaml:"reportingInstance,omitempty"`
|
||||
Series *EventSeries `json:"series,omitempty" yaml:"series,omitempty"`
|
||||
Source *EventSource `json:"source,omitempty" yaml:"source,omitempty"`
|
||||
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
|
||||
}
|
||||
|
||||
type ClusterEventCollection struct {
|
||||
types.Collection
|
||||
Data []ClusterEvent `json:"data,omitempty"`
|
||||
client *ClusterEventClient
|
||||
}
|
||||
|
||||
type ClusterEventClient struct {
|
||||
apiClient *Client
|
||||
}
|
||||
|
||||
type ClusterEventOperations interface {
|
||||
List(opts *types.ListOpts) (*ClusterEventCollection, error)
|
||||
Create(opts *ClusterEvent) (*ClusterEvent, error)
|
||||
Update(existing *ClusterEvent, updates interface{}) (*ClusterEvent, error)
|
||||
Replace(existing *ClusterEvent) (*ClusterEvent, error)
|
||||
ByID(id string) (*ClusterEvent, error)
|
||||
Delete(container *ClusterEvent) error
|
||||
}
|
||||
|
||||
func newClusterEventClient(apiClient *Client) *ClusterEventClient {
|
||||
return &ClusterEventClient{
|
||||
apiClient: apiClient,
|
||||
}
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) Create(container *ClusterEvent) (*ClusterEvent, error) {
|
||||
resp := &ClusterEvent{}
|
||||
err := c.apiClient.Ops.DoCreate(ClusterEventType, container, resp)
|
||||
return resp, err
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) Update(existing *ClusterEvent, updates interface{}) (*ClusterEvent, error) {
|
||||
resp := &ClusterEvent{}
|
||||
err := c.apiClient.Ops.DoUpdate(ClusterEventType, &existing.Resource, updates, resp)
|
||||
return resp, err
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) Replace(obj *ClusterEvent) (*ClusterEvent, error) {
|
||||
resp := &ClusterEvent{}
|
||||
err := c.apiClient.Ops.DoReplace(ClusterEventType, &obj.Resource, obj, resp)
|
||||
return resp, err
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) List(opts *types.ListOpts) (*ClusterEventCollection, error) {
|
||||
resp := &ClusterEventCollection{}
|
||||
err := c.apiClient.Ops.DoList(ClusterEventType, opts, resp)
|
||||
resp.client = c
|
||||
return resp, err
|
||||
}
|
||||
|
||||
func (cc *ClusterEventCollection) Next() (*ClusterEventCollection, error) {
|
||||
if cc != nil && cc.Pagination != nil && cc.Pagination.Next != "" {
|
||||
resp := &ClusterEventCollection{}
|
||||
err := cc.client.apiClient.Ops.DoNext(cc.Pagination.Next, resp)
|
||||
resp.client = cc.client
|
||||
return resp, err
|
||||
}
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) ByID(id string) (*ClusterEvent, error) {
|
||||
resp := &ClusterEvent{}
|
||||
err := c.apiClient.Ops.DoByID(ClusterEventType, id, resp)
|
||||
return resp, err
|
||||
}
|
||||
|
||||
func (c *ClusterEventClient) Delete(container *ClusterEvent) error {
|
||||
return c.apiClient.Ops.DoResourceDelete(ClusterEventType, &container.Resource)
|
||||
}
|
@ -1,14 +0,0 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
EventSeriesType = "eventSeries"
|
||||
EventSeriesFieldCount = "count"
|
||||
EventSeriesFieldLastObservedTime = "lastObservedTime"
|
||||
EventSeriesFieldState = "state"
|
||||
)
|
||||
|
||||
type EventSeries struct {
|
||||
Count int64 `json:"count,omitempty" yaml:"count,omitempty"`
|
||||
LastObservedTime *MicroTime `json:"lastObservedTime,omitempty" yaml:"lastObservedTime,omitempty"`
|
||||
State string `json:"state,omitempty" yaml:"state,omitempty"`
|
||||
}
|
@ -1,12 +0,0 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
EventSourceType = "eventSource"
|
||||
EventSourceFieldComponent = "component"
|
||||
EventSourceFieldHost = "host"
|
||||
)
|
||||
|
||||
type EventSource struct {
|
||||
Component string `json:"component,omitempty" yaml:"component,omitempty"`
|
||||
Host string `json:"host,omitempty" yaml:"host,omitempty"`
|
||||
}
|
@ -1,8 +0,0 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
MicroTimeType = "microTime"
|
||||
)
|
||||
|
||||
type MicroTime struct {
|
||||
}
|
@ -1,22 +0,0 @@
|
||||
package client
|
||||
|
||||
const (
|
||||
ObjectReferenceType = "objectReference"
|
||||
ObjectReferenceFieldAPIVersion = "apiVersion"
|
||||
ObjectReferenceFieldFieldPath = "fieldPath"
|
||||
ObjectReferenceFieldKind = "kind"
|
||||
ObjectReferenceFieldName = "name"
|
||||
ObjectReferenceFieldNamespace = "namespace"
|
||||
ObjectReferenceFieldResourceVersion = "resourceVersion"
|
||||
ObjectReferenceFieldUID = "uid"
|
||||
)
|
||||
|
||||
type ObjectReference struct {
|
||||
APIVersion string `json:"apiVersion,omitempty" yaml:"apiVersion,omitempty"`
|
||||
FieldPath string `json:"fieldPath,omitempty" yaml:"fieldPath,omitempty"`
|
||||
Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`
|
||||
Name string `json:"name,omitempty" yaml:"name,omitempty"`
|
||||
Namespace string `json:"namespace,omitempty" yaml:"namespace,omitempty"`
|
||||
ResourceVersion string `json:"resourceVersion,omitempty" yaml:"resourceVersion,omitempty"`
|
||||
UID string `json:"uid,omitempty" yaml:"uid,omitempty"`
|
||||
}
|
@ -22,7 +22,6 @@ type Config struct {
|
||||
ClusterRoleTemplateBindings map[string]managementClient.ClusterRoleTemplateBinding `json:"clusterRoleTemplateBindings,omitempty" yaml:"clusterRoleTemplateBindings,omitempty"`
|
||||
ProjectRoleTemplateBindings map[string]managementClient.ProjectRoleTemplateBinding `json:"projectRoleTemplateBindings,omitempty" yaml:"projectRoleTemplateBindings,omitempty"`
|
||||
Clusters map[string]managementClient.Cluster `json:"clusters,omitempty" yaml:"clusters,omitempty"`
|
||||
ClusterEvents map[string]managementClient.ClusterEvent `json:"clusterEvents,omitempty" yaml:"clusterEvents,omitempty"`
|
||||
ClusterRegistrationTokens map[string]managementClient.ClusterRegistrationToken `json:"clusterRegistrationTokens,omitempty" yaml:"clusterRegistrationTokens,omitempty"`
|
||||
Catalogs map[string]managementClient.Catalog `json:"catalogs,omitempty" yaml:"catalogs,omitempty"`
|
||||
Templates map[string]managementClient.Template `json:"templates,omitempty" yaml:"templates,omitempty"`
|
||||
|
Loading…
Reference in New Issue
Block a user