mirror of
https://github.com/hanzoai/cd.git
synced 2026-10-30 14:56:45 +00:00
zeekay
187be9e719
repository.proto and 11 sibling hand-written .proto files referenced generated.proto's application/v1alpha1 types under the pre-fork package path (github.com.argoproj.argo_cd.v3...); protoc silently kept compiling because generated.proto still carried that same stale package too. Point both at the real, mechanically-derived path (github.com.hanzoai.cd.pkg.apis.application.v1alpha1, no v3 segment) and regenerate everything protoc/go-to-protobuf own: generated.proto/pb.go, every pkg/apiclient and reposerver/cmpserver/commitserver *.pb.go, assets/swagger.json, and the CRD manifests. That regeneration surfaced a second, unrelated bug: hack/gen-crd-spec stamped app.kubernetes.io/part-of: cd on the CRDs, but util/settings.isSettingsObject (and the ConfigMap informer built on it) only ever recognizes part-of=hanzocd. The same wrong "cd" value was baked into cmd/cd/commands/admin/settings.go's setSettingsMeta and the shared test/testdata.go fixtures ~30 files import — util/settings' own test suite was panicking on an empty slice because its fixture was invisible to the informer it was supposedly seeding. Fixed the label everywhere it's produced or asserted in the settings path; left the ~90 unrelated part-of:"cd" literals in other packages' local test fixtures alone since they never touch this selector. Also dropped 25 "TODO: Remove deprecated <dead upstream issue link>" comments that duplicated the real explanation already sitting one line away (a proper `Deprecated:` godoc, a cobra Deprecated field, or a nolint:staticcheck marker) — kept the explanation, dropped the link, per the standing rule for these citations. And repointed the two Grafana dashboards' job selector from argocd-server-metrics, a Service the manifests never create, to hanzocd-server-metrics, the one they do.
2333 lines
57 KiB
Go
Generated
2333 lines
57 KiB
Go
Generated
// Code generated by protoc-gen-gogo. DO NOT EDIT.
|
|
// source: server/events/events.proto
|
|
|
|
// Events Service
|
|
//
|
|
// Events Service API performs query actions against Kubernetes core/v1 Event
|
|
// resources owned by Hanzo CD applications, application sets and projects.
|
|
|
|
package events
|
|
|
|
import (
|
|
fmt "fmt"
|
|
_ "github.com/gogo/protobuf/gogoproto"
|
|
proto "github.com/gogo/protobuf/proto"
|
|
io "io"
|
|
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
math "math"
|
|
math_bits "math/bits"
|
|
)
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ = proto.Marshal
|
|
var _ = fmt.Errorf
|
|
var _ = math.Inf
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the proto package it is being compiled against.
|
|
// A compilation error at this line likely means your copy of the
|
|
// proto package needs to be updated.
|
|
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
|
|
|
|
// EventList is a list of Hanzo CD Event messages. It mirrors corev1.EventList
|
|
// field-for-field but is defined in Hanzo CD's apiclient package to avoid
|
|
// pulling Kubernetes protobuf types into the public gRPC surface.
|
|
type EventList struct {
|
|
// Standard list metadata.
|
|
Metadata v1.ListMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata"`
|
|
// List of events.
|
|
Items []Event `protobuf:"bytes,2,rep,name=items,proto3" json:"items"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *EventList) Reset() { *m = EventList{} }
|
|
func (m *EventList) String() string { return proto.CompactTextString(m) }
|
|
func (*EventList) ProtoMessage() {}
|
|
func (*EventList) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_726ce87025e6c05d, []int{0}
|
|
}
|
|
func (m *EventList) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *EventList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_EventList.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *EventList) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_EventList.Merge(m, src)
|
|
}
|
|
func (m *EventList) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *EventList) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_EventList.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_EventList proto.InternalMessageInfo
|
|
|
|
func (m *EventList) GetMetadata() v1.ListMeta {
|
|
if m != nil {
|
|
return m.Metadata
|
|
}
|
|
return v1.ListMeta{}
|
|
}
|
|
|
|
func (m *EventList) GetItems() []Event {
|
|
if m != nil {
|
|
return m.Items
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Event mirrors corev1.Event and exposes the fields consumed by the Hanzo CD
|
|
// API and UI. Event is a report of an event somewhere in the cluster. Events
|
|
// have a limited retention time and triggers and messages may evolve with
|
|
// time. Event consumers should not rely on the timing of an event with a
|
|
// given Reason reflecting a consistent underlying trigger, or the continued
|
|
// existence of events with that Reason. Events should be treated as
|
|
// informative, best-effort, supplemental data.
|
|
type Event struct {
|
|
// Standard object's metadata.
|
|
Metadata v1.ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata"`
|
|
// The object that this event is about.
|
|
InvolvedObject ObjectReference `protobuf:"bytes,2,opt,name=involvedObject,proto3" json:"involvedObject"`
|
|
// This should be a short, machine understandable string that gives the
|
|
// reason for the transition into the object's current status.
|
|
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
|
|
// A human-readable description of the status of this operation.
|
|
Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
|
|
// The component reporting this event. Should be a short machine
|
|
// understandable string.
|
|
Source EventSource `protobuf:"bytes,5,opt,name=source,proto3" json:"source"`
|
|
// The time at which the event was first recorded. (Time of server receipt
|
|
// is in TypeMeta.)
|
|
FirstTimestamp v1.Time `protobuf:"bytes,6,opt,name=firstTimestamp,proto3" json:"firstTimestamp"`
|
|
// The time at which the most recent occurrence of this event was recorded.
|
|
LastTimestamp v1.Time `protobuf:"bytes,7,opt,name=lastTimestamp,proto3" json:"lastTimestamp"`
|
|
// The number of times this event has occurred.
|
|
Count int32 `protobuf:"varint,8,opt,name=count,proto3" json:"count,omitempty"`
|
|
// Type of this event (Normal, Warning), new types could be added in the
|
|
// future.
|
|
Type string `protobuf:"bytes,9,opt,name=type,proto3" json:"type,omitempty"`
|
|
// Time when this Event was first observed.
|
|
EventTime v1.MicroTime `protobuf:"bytes,10,opt,name=eventTime,proto3" json:"eventTime"`
|
|
// Data about the Event series this event represents or nil if it's a
|
|
// singleton Event.
|
|
Series *EventSeries `protobuf:"bytes,11,opt,name=series,proto3" json:"series,omitempty"`
|
|
// What action was taken/failed regarding to the Regarding object.
|
|
Action string `protobuf:"bytes,12,opt,name=action,proto3" json:"action,omitempty"`
|
|
// Optional secondary object for more complex actions.
|
|
Related *ObjectReference `protobuf:"bytes,13,opt,name=related,proto3" json:"related,omitempty"`
|
|
// Name of the controller that emitted this Event, e.g.
|
|
// `kubernetes.io/kubelet`.
|
|
ReportingController string `protobuf:"bytes,14,opt,name=reportingComponent,proto3" json:"reportingComponent,omitempty"`
|
|
// ID of the controller instance, e.g. `kubelet-xyzf`.
|
|
ReportingInstance string `protobuf:"bytes,15,opt,name=reportingInstance,proto3" json:"reportingInstance,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *Event) Reset() { *m = Event{} }
|
|
func (m *Event) String() string { return proto.CompactTextString(m) }
|
|
func (*Event) ProtoMessage() {}
|
|
func (*Event) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_726ce87025e6c05d, []int{1}
|
|
}
|
|
func (m *Event) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_Event.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *Event) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_Event.Merge(m, src)
|
|
}
|
|
func (m *Event) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *Event) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_Event.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_Event proto.InternalMessageInfo
|
|
|
|
func (m *Event) GetMetadata() v1.ObjectMeta {
|
|
if m != nil {
|
|
return m.Metadata
|
|
}
|
|
return v1.ObjectMeta{}
|
|
}
|
|
|
|
func (m *Event) GetInvolvedObject() ObjectReference {
|
|
if m != nil {
|
|
return m.InvolvedObject
|
|
}
|
|
return ObjectReference{}
|
|
}
|
|
|
|
func (m *Event) GetReason() string {
|
|
if m != nil {
|
|
return m.Reason
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *Event) GetMessage() string {
|
|
if m != nil {
|
|
return m.Message
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *Event) GetSource() EventSource {
|
|
if m != nil {
|
|
return m.Source
|
|
}
|
|
return EventSource{}
|
|
}
|
|
|
|
func (m *Event) GetFirstTimestamp() v1.Time {
|
|
if m != nil {
|
|
return m.FirstTimestamp
|
|
}
|
|
return v1.Time{}
|
|
}
|
|
|
|
func (m *Event) GetLastTimestamp() v1.Time {
|
|
if m != nil {
|
|
return m.LastTimestamp
|
|
}
|
|
return v1.Time{}
|
|
}
|
|
|
|
func (m *Event) GetCount() int32 {
|
|
if m != nil {
|
|
return m.Count
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *Event) GetType() string {
|
|
if m != nil {
|
|
return m.Type
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *Event) GetEventTime() v1.MicroTime {
|
|
if m != nil {
|
|
return m.EventTime
|
|
}
|
|
return v1.MicroTime{}
|
|
}
|
|
|
|
func (m *Event) GetSeries() *EventSeries {
|
|
if m != nil {
|
|
return m.Series
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Event) GetAction() string {
|
|
if m != nil {
|
|
return m.Action
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *Event) GetRelated() *ObjectReference {
|
|
if m != nil {
|
|
return m.Related
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Event) GetReportingController() string {
|
|
if m != nil {
|
|
return m.ReportingController
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *Event) GetReportingInstance() string {
|
|
if m != nil {
|
|
return m.ReportingInstance
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// EventSource contains information for an event.
|
|
type EventSource struct {
|
|
// Component from which the event is generated.
|
|
Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
|
|
// Node name on which the event is generated.
|
|
Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *EventSource) Reset() { *m = EventSource{} }
|
|
func (m *EventSource) String() string { return proto.CompactTextString(m) }
|
|
func (*EventSource) ProtoMessage() {}
|
|
func (*EventSource) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_726ce87025e6c05d, []int{2}
|
|
}
|
|
func (m *EventSource) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_EventSource.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *EventSource) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_EventSource.Merge(m, src)
|
|
}
|
|
func (m *EventSource) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *EventSource) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_EventSource.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_EventSource proto.InternalMessageInfo
|
|
|
|
func (m *EventSource) GetComponent() string {
|
|
if m != nil {
|
|
return m.Component
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *EventSource) GetHost() string {
|
|
if m != nil {
|
|
return m.Host
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// EventSeries contain information on series of events, i.e. thing that was/is
|
|
// happening continuously for some time.
|
|
type EventSeries struct {
|
|
// Number of occurrences in this series up to the last heartbeat time.
|
|
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
|
|
// Time of the last occurrence observed.
|
|
LastObservedTime v1.MicroTime `protobuf:"bytes,2,opt,name=lastObservedTime,proto3" json:"lastObservedTime"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *EventSeries) Reset() { *m = EventSeries{} }
|
|
func (m *EventSeries) String() string { return proto.CompactTextString(m) }
|
|
func (*EventSeries) ProtoMessage() {}
|
|
func (*EventSeries) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_726ce87025e6c05d, []int{3}
|
|
}
|
|
func (m *EventSeries) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *EventSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_EventSeries.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *EventSeries) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_EventSeries.Merge(m, src)
|
|
}
|
|
func (m *EventSeries) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *EventSeries) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_EventSeries.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_EventSeries proto.InternalMessageInfo
|
|
|
|
func (m *EventSeries) GetCount() int32 {
|
|
if m != nil {
|
|
return m.Count
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *EventSeries) GetLastObservedTime() v1.MicroTime {
|
|
if m != nil {
|
|
return m.LastObservedTime
|
|
}
|
|
return v1.MicroTime{}
|
|
}
|
|
|
|
// ObjectReference contains enough information to let you inspect or modify
|
|
// the referred object.
|
|
type ObjectReference struct {
|
|
// Kind of the referent.
|
|
Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
|
|
// Namespace of the referent.
|
|
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
|
|
// Name of the referent.
|
|
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
|
|
// UID of the referent.
|
|
UID string `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
|
|
// API version of the referent.
|
|
APIVersion string `protobuf:"bytes,5,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
|
|
// Specific resourceVersion to which this reference is made, if any.
|
|
ResourceVersion string `protobuf:"bytes,6,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
|
|
// If referring to a piece of an object instead of an entire object, this
|
|
// string should contain a valid JSON/Go field access statement, such as
|
|
// desiredState.manifest.containers[2]. For example, if the object reference
|
|
// is to a container within a pod, this would take on a value like:
|
|
// "spec.containers{name}" (where "name" refers to the name of the container
|
|
// that triggered the event) or if no container name is specified
|
|
// "spec.containers[2]" (container with index 2 in this pod).
|
|
FieldPath string `protobuf:"bytes,7,opt,name=fieldPath,proto3" json:"fieldPath,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *ObjectReference) Reset() { *m = ObjectReference{} }
|
|
func (m *ObjectReference) String() string { return proto.CompactTextString(m) }
|
|
func (*ObjectReference) ProtoMessage() {}
|
|
func (*ObjectReference) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_726ce87025e6c05d, []int{4}
|
|
}
|
|
func (m *ObjectReference) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *ObjectReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_ObjectReference.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *ObjectReference) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_ObjectReference.Merge(m, src)
|
|
}
|
|
func (m *ObjectReference) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *ObjectReference) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_ObjectReference.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_ObjectReference proto.InternalMessageInfo
|
|
|
|
func (m *ObjectReference) GetKind() string {
|
|
if m != nil {
|
|
return m.Kind
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetNamespace() string {
|
|
if m != nil {
|
|
return m.Namespace
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetName() string {
|
|
if m != nil {
|
|
return m.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetUID() string {
|
|
if m != nil {
|
|
return m.UID
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetAPIVersion() string {
|
|
if m != nil {
|
|
return m.APIVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetResourceVersion() string {
|
|
if m != nil {
|
|
return m.ResourceVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *ObjectReference) GetFieldPath() string {
|
|
if m != nil {
|
|
return m.FieldPath
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func init() {
|
|
proto.RegisterType((*EventList)(nil), "events.EventList")
|
|
proto.RegisterType((*Event)(nil), "events.Event")
|
|
proto.RegisterType((*EventSource)(nil), "events.EventSource")
|
|
proto.RegisterType((*EventSeries)(nil), "events.EventSeries")
|
|
proto.RegisterType((*ObjectReference)(nil), "events.ObjectReference")
|
|
}
|
|
|
|
func init() { proto.RegisterFile("server/events/events.proto", fileDescriptor_726ce87025e6c05d) }
|
|
|
|
var fileDescriptor_726ce87025e6c05d = []byte{
|
|
// 710 bytes of a gzipped FileDescriptorProto
|
|
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x54, 0xdd, 0x6e, 0x13, 0x3b,
|
|
0x10, 0x3e, 0xdb, 0x34, 0x9b, 0xc6, 0x39, 0x4d, 0xcf, 0x71, 0xab, 0x53, 0x9f, 0x0a, 0x35, 0x51,
|
|
0xae, 0x42, 0x41, 0xbb, 0xa4, 0x70, 0xd1, 0x3b, 0x44, 0xa0, 0x42, 0x95, 0xa8, 0x5a, 0x6d, 0xa1,
|
|
0x42, 0xdc, 0x39, 0xbb, 0xd3, 0x8d, 0x49, 0xd6, 0x5e, 0xd9, 0x4e, 0xa4, 0xf2, 0x00, 0x88, 0x37,
|
|
0xe1, 0x55, 0x7a, 0xc9, 0x13, 0x44, 0x28, 0x97, 0x3c, 0x05, 0xb2, 0xbd, 0xf9, 0xe9, 0x8f, 0x50,
|
|
0x05, 0x57, 0xeb, 0xf9, 0x66, 0xbe, 0x6f, 0xc6, 0x33, 0x3b, 0x46, 0x3b, 0x0a, 0xe4, 0x18, 0x64,
|
|
0x08, 0x63, 0xe0, 0x5a, 0x15, 0x9f, 0x20, 0x97, 0x42, 0x0b, 0xec, 0x3b, 0x6b, 0x67, 0x2b, 0x15,
|
|
0xa9, 0xb0, 0x50, 0x68, 0x4e, 0xce, 0xbb, 0xf3, 0x6c, 0x70, 0xa0, 0x02, 0x26, 0x42, 0x9a, 0xb3,
|
|
0x8c, 0xc6, 0x7d, 0xc6, 0x41, 0x5e, 0x86, 0xf9, 0x20, 0x35, 0x80, 0x0a, 0x33, 0xd0, 0x34, 0x1c,
|
|
0x77, 0xc2, 0x14, 0x38, 0x48, 0xaa, 0x21, 0x71, 0xac, 0xd6, 0x17, 0x0f, 0x55, 0x0f, 0x8d, 0xec,
|
|
0x1b, 0xa6, 0x34, 0x3e, 0x45, 0x6b, 0x26, 0x30, 0xa1, 0x9a, 0x12, 0xaf, 0xe9, 0xb5, 0x6b, 0xfb,
|
|
0x41, 0xe0, 0x64, 0x83, 0x65, 0xd9, 0x20, 0x1f, 0xa4, 0x06, 0x50, 0x81, 0x89, 0x0e, 0xc6, 0x9d,
|
|
0xc0, 0xb0, 0x8f, 0x41, 0xd3, 0xee, 0xea, 0xd5, 0xa4, 0xf1, 0x57, 0x34, 0x57, 0xc1, 0x0f, 0x51,
|
|
0x99, 0x69, 0xc8, 0x14, 0x59, 0x69, 0x96, 0xda, 0xb5, 0xfd, 0xf5, 0xa0, 0xb8, 0x91, 0xcd, 0x59,
|
|
0x44, 0xbb, 0x88, 0xd6, 0x57, 0x1f, 0x95, 0x2d, 0x8c, 0xa3, 0x5b, 0x65, 0x3c, 0xb9, 0x5f, 0x19,
|
|
0x27, 0xbd, 0x8f, 0x10, 0xdf, 0x5d, 0xc8, 0x21, 0xaa, 0x33, 0x3e, 0x16, 0xc3, 0x31, 0x24, 0x2e,
|
|
0x8a, 0xac, 0x58, 0xe5, 0xed, 0x59, 0x45, 0x0e, 0x8d, 0xe0, 0x02, 0x24, 0xf0, 0x18, 0x0a, 0x81,
|
|
0x1b, 0x24, 0xfc, 0x1f, 0xf2, 0x25, 0x50, 0x25, 0x38, 0x29, 0x35, 0xbd, 0x76, 0x35, 0x2a, 0x2c,
|
|
0x4c, 0x50, 0x25, 0x03, 0xa5, 0x68, 0x0a, 0x64, 0xd5, 0x3a, 0x66, 0x26, 0xee, 0x20, 0x5f, 0x89,
|
|
0x91, 0x8c, 0x81, 0x94, 0x6d, 0xc2, 0xcd, 0x6b, 0x2d, 0x38, 0xb3, 0xae, 0x22, 0x59, 0x11, 0x88,
|
|
0xdf, 0xa3, 0xfa, 0x05, 0x93, 0x4a, 0xbf, 0x65, 0x19, 0x28, 0x4d, 0xb3, 0x9c, 0xf8, 0x96, 0xba,
|
|
0x77, 0xbf, 0x2e, 0x18, 0xda, 0xac, 0xfc, 0xeb, 0x3a, 0xf8, 0x1c, 0xad, 0x0f, 0xe9, 0xb2, 0x70,
|
|
0xe5, 0x37, 0x85, 0xaf, 0xcb, 0xe0, 0x2d, 0x54, 0x8e, 0xc5, 0x88, 0x6b, 0xb2, 0xd6, 0xf4, 0xda,
|
|
0xe5, 0xc8, 0x19, 0x18, 0xa3, 0x55, 0x7d, 0x99, 0x03, 0xa9, 0xda, 0x8e, 0xd8, 0x33, 0x3e, 0x43,
|
|
0x55, 0x7b, 0x7f, 0xc3, 0x25, 0xc8, 0x66, 0x0f, 0xef, 0x97, 0xfd, 0x98, 0xc5, 0x52, 0x2c, 0x95,
|
|
0xb0, 0xd0, 0xc1, 0x8f, 0x90, 0xaf, 0x40, 0x32, 0x50, 0xa4, 0x76, 0x57, 0x8f, 0xad, 0x2b, 0x2a,
|
|
0x42, 0xcc, 0x08, 0x69, 0xac, 0x99, 0xe0, 0xe4, 0x6f, 0x37, 0x42, 0x67, 0xe1, 0x0e, 0xaa, 0x48,
|
|
0x18, 0x9a, 0xdd, 0x20, 0xeb, 0xbf, 0xfc, 0x35, 0xa2, 0x59, 0x1c, 0x7e, 0x8d, 0xb0, 0x84, 0x5c,
|
|
0x48, 0xcd, 0x78, 0xfa, 0x52, 0x64, 0xb9, 0xe0, 0xc0, 0x35, 0xa9, 0x1b, 0xd9, 0xee, 0xf6, 0x74,
|
|
0xd2, 0xd8, 0x8c, 0x16, 0x5e, 0xae, 0xa5, 0x18, 0x0e, 0x41, 0x46, 0x77, 0x50, 0xf0, 0x63, 0xf4,
|
|
0xef, 0x1c, 0x3d, 0xe2, 0x4a, 0x53, 0x1e, 0x03, 0xd9, 0xb0, 0xe5, 0xdd, 0x76, 0xb4, 0x9e, 0xa3,
|
|
0xda, 0xd2, 0xcf, 0x83, 0x1f, 0xa0, 0x6a, 0x3c, 0x4f, 0xee, 0x59, 0xd2, 0x02, 0x30, 0x43, 0xe8,
|
|
0x0b, 0xe5, 0x7e, 0xf7, 0x6a, 0x64, 0xcf, 0xad, 0xcf, 0xde, 0x4c, 0xc1, 0xb5, 0x64, 0x3e, 0x3e,
|
|
0x6f, 0x79, 0x7c, 0x14, 0xfd, 0x63, 0xa6, 0x7c, 0xd2, 0xb3, 0x6f, 0x52, 0x62, 0x27, 0xb6, 0xf2,
|
|
0x27, 0x13, 0xbb, 0x25, 0xd7, 0xfa, 0xe1, 0xa1, 0x8d, 0x1b, 0xdd, 0x35, 0x05, 0x0f, 0x18, 0x4f,
|
|
0x8a, 0x9b, 0xd8, 0xb3, 0xb9, 0x22, 0xa7, 0x19, 0xa8, 0x9c, 0xc6, 0x50, 0xdc, 0x64, 0x01, 0x18,
|
|
0x86, 0x31, 0x8a, 0x95, 0xb4, 0x67, 0xfc, 0x3f, 0x2a, 0x8d, 0x58, 0xe2, 0x96, 0xb1, 0x5b, 0x99,
|
|
0x4e, 0x1a, 0xa5, 0x77, 0x47, 0xaf, 0x22, 0x83, 0xe1, 0x00, 0x21, 0x9a, 0xb3, 0x73, 0x90, 0xca,
|
|
0xfc, 0x04, 0x65, 0x1b, 0x51, 0x9f, 0x4e, 0x1a, 0xe8, 0xc5, 0xe9, 0x51, 0x81, 0x46, 0x4b, 0x11,
|
|
0xb8, 0x8d, 0x36, 0x24, 0xb8, 0xd5, 0x9c, 0x91, 0x7c, 0x9b, 0xe9, 0x26, 0x6c, 0xca, 0xbc, 0x60,
|
|
0x30, 0x4c, 0x4e, 0xa9, 0xee, 0xdb, 0xd5, 0xaa, 0x46, 0x0b, 0xa0, 0x7b, 0x70, 0x35, 0xdd, 0xf5,
|
|
0xbe, 0x4d, 0x77, 0xbd, 0xef, 0xd3, 0x5d, 0xef, 0xc3, 0x5e, 0xca, 0x74, 0x7f, 0xd4, 0x0b, 0x62,
|
|
0x91, 0x85, 0x7d, 0xca, 0x3f, 0x09, 0xca, 0xc2, 0x38, 0x99, 0xbd, 0xd8, 0xf1, 0x90, 0x01, 0xd7,
|
|
0xc5, 0xfb, 0xdf, 0xf3, 0xed, 0x63, 0xfd, 0xf4, 0x67, 0x00, 0x00, 0x00, 0xff, 0xff, 0x43, 0x2d,
|
|
0x48, 0xc0, 0x1e, 0x06, 0x00, 0x00,
|
|
}
|
|
|
|
func (m *EventList) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *EventList) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *EventList) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.Items) > 0 {
|
|
for iNdEx := len(m.Items) - 1; iNdEx >= 0; iNdEx-- {
|
|
{
|
|
size, err := m.Items[iNdEx].MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
}
|
|
{
|
|
size, err := m.Metadata.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *Event) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *Event) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.ReportingInstance) > 0 {
|
|
i -= len(m.ReportingInstance)
|
|
copy(dAtA[i:], m.ReportingInstance)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.ReportingInstance)))
|
|
i--
|
|
dAtA[i] = 0x7a
|
|
}
|
|
if len(m.ReportingController) > 0 {
|
|
i -= len(m.ReportingController)
|
|
copy(dAtA[i:], m.ReportingController)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.ReportingController)))
|
|
i--
|
|
dAtA[i] = 0x72
|
|
}
|
|
if m.Related != nil {
|
|
{
|
|
size, err := m.Related.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x6a
|
|
}
|
|
if len(m.Action) > 0 {
|
|
i -= len(m.Action)
|
|
copy(dAtA[i:], m.Action)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Action)))
|
|
i--
|
|
dAtA[i] = 0x62
|
|
}
|
|
if m.Series != nil {
|
|
{
|
|
size, err := m.Series.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x5a
|
|
}
|
|
{
|
|
size, err := m.EventTime.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x52
|
|
if len(m.Type) > 0 {
|
|
i -= len(m.Type)
|
|
copy(dAtA[i:], m.Type)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Type)))
|
|
i--
|
|
dAtA[i] = 0x4a
|
|
}
|
|
if m.Count != 0 {
|
|
i = encodeVarintEvents(dAtA, i, uint64(m.Count))
|
|
i--
|
|
dAtA[i] = 0x40
|
|
}
|
|
{
|
|
size, err := m.LastTimestamp.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x3a
|
|
{
|
|
size, err := m.FirstTimestamp.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x32
|
|
{
|
|
size, err := m.Source.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x2a
|
|
if len(m.Message) > 0 {
|
|
i -= len(m.Message)
|
|
copy(dAtA[i:], m.Message)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Message)))
|
|
i--
|
|
dAtA[i] = 0x22
|
|
}
|
|
if len(m.Reason) > 0 {
|
|
i -= len(m.Reason)
|
|
copy(dAtA[i:], m.Reason)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Reason)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
{
|
|
size, err := m.InvolvedObject.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x12
|
|
{
|
|
size, err := m.Metadata.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *EventSource) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *EventSource) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *EventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.Host) > 0 {
|
|
i -= len(m.Host)
|
|
copy(dAtA[i:], m.Host)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Host)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if len(m.Component) > 0 {
|
|
i -= len(m.Component)
|
|
copy(dAtA[i:], m.Component)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Component)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *EventSeries) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *EventSeries) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *EventSeries) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
{
|
|
size, err := m.LastObservedTime.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintEvents(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0x12
|
|
if m.Count != 0 {
|
|
i = encodeVarintEvents(dAtA, i, uint64(m.Count))
|
|
i--
|
|
dAtA[i] = 0x8
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *ObjectReference) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *ObjectReference) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *ObjectReference) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.FieldPath) > 0 {
|
|
i -= len(m.FieldPath)
|
|
copy(dAtA[i:], m.FieldPath)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.FieldPath)))
|
|
i--
|
|
dAtA[i] = 0x3a
|
|
}
|
|
if len(m.ResourceVersion) > 0 {
|
|
i -= len(m.ResourceVersion)
|
|
copy(dAtA[i:], m.ResourceVersion)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.ResourceVersion)))
|
|
i--
|
|
dAtA[i] = 0x32
|
|
}
|
|
if len(m.APIVersion) > 0 {
|
|
i -= len(m.APIVersion)
|
|
copy(dAtA[i:], m.APIVersion)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.APIVersion)))
|
|
i--
|
|
dAtA[i] = 0x2a
|
|
}
|
|
if len(m.UID) > 0 {
|
|
i -= len(m.UID)
|
|
copy(dAtA[i:], m.UID)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.UID)))
|
|
i--
|
|
dAtA[i] = 0x22
|
|
}
|
|
if len(m.Name) > 0 {
|
|
i -= len(m.Name)
|
|
copy(dAtA[i:], m.Name)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Name)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
if len(m.Namespace) > 0 {
|
|
i -= len(m.Namespace)
|
|
copy(dAtA[i:], m.Namespace)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Namespace)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if len(m.Kind) > 0 {
|
|
i -= len(m.Kind)
|
|
copy(dAtA[i:], m.Kind)
|
|
i = encodeVarintEvents(dAtA, i, uint64(len(m.Kind)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func encodeVarintEvents(dAtA []byte, offset int, v uint64) int {
|
|
offset -= sovEvents(v)
|
|
base := offset
|
|
for v >= 1<<7 {
|
|
dAtA[offset] = uint8(v&0x7f | 0x80)
|
|
v >>= 7
|
|
offset++
|
|
}
|
|
dAtA[offset] = uint8(v)
|
|
return base
|
|
}
|
|
func (m *EventList) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = m.Metadata.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
if len(m.Items) > 0 {
|
|
for _, e := range m.Items {
|
|
l = e.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *Event) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = m.Metadata.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
l = m.InvolvedObject.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
l = len(m.Reason)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.Message)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = m.Source.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
l = m.FirstTimestamp.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
l = m.LastTimestamp.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
if m.Count != 0 {
|
|
n += 1 + sovEvents(uint64(m.Count))
|
|
}
|
|
l = len(m.Type)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = m.EventTime.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
if m.Series != nil {
|
|
l = m.Series.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.Action)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
if m.Related != nil {
|
|
l = m.Related.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.ReportingController)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.ReportingInstance)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *EventSource) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Component)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.Host)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *EventSeries) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if m.Count != 0 {
|
|
n += 1 + sovEvents(uint64(m.Count))
|
|
}
|
|
l = m.LastObservedTime.Size()
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *ObjectReference) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Kind)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.Namespace)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.Name)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.UID)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.APIVersion)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.ResourceVersion)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
l = len(m.FieldPath)
|
|
if l > 0 {
|
|
n += 1 + l + sovEvents(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func sovEvents(x uint64) (n int) {
|
|
return (math_bits.Len64(x|1) + 6) / 7
|
|
}
|
|
func sozEvents(x uint64) (n int) {
|
|
return sovEvents(uint64((x << 1) ^ uint64((int64(x) >> 63))))
|
|
}
|
|
func (m *EventList) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: EventList: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: EventList: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Metadata", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.Metadata.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Items", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Items = append(m.Items, Event{})
|
|
if err := m.Items[len(m.Items)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipEvents(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *Event) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: Event: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: Event: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Metadata", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.Metadata.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field InvolvedObject", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.InvolvedObject.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Reason", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Reason = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 4:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Message", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Message = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 5:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Source", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.Source.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 6:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field FirstTimestamp", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.FirstTimestamp.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 7:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field LastTimestamp", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.LastTimestamp.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 8:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Count", wireType)
|
|
}
|
|
m.Count = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.Count |= int32(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 9:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Type = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 10:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field EventTime", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.EventTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 11:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Series", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if m.Series == nil {
|
|
m.Series = &EventSeries{}
|
|
}
|
|
if err := m.Series.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 12:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Action", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Action = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 13:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Related", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if m.Related == nil {
|
|
m.Related = &ObjectReference{}
|
|
}
|
|
if err := m.Related.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 14:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field ReportingController", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.ReportingController = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 15:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field ReportingInstance", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.ReportingInstance = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipEvents(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *EventSource) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: EventSource: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: EventSource: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Component", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Component = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Host", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Host = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipEvents(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *EventSeries) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: EventSeries: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: EventSeries: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Count", wireType)
|
|
}
|
|
m.Count = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.Count |= int32(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field LastObservedTime", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if err := m.LastObservedTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipEvents(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *ObjectReference) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: ObjectReference: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: ObjectReference: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Kind", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Kind = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Namespace", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Namespace = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Name = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 4:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field UID", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.UID = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 5:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field APIVersion", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.APIVersion = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 6:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field ResourceVersion", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.ResourceVersion = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 7:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field FieldPath", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.FieldPath = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipEvents(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthEvents
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func skipEvents(dAtA []byte) (n int, err error) {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
depth := 0
|
|
for iNdEx < l {
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= (uint64(b) & 0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
wireType := int(wire & 0x7)
|
|
switch wireType {
|
|
case 0:
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
iNdEx++
|
|
if dAtA[iNdEx-1] < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 1:
|
|
iNdEx += 8
|
|
case 2:
|
|
var length int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowEvents
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
length |= (int(b) & 0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if length < 0 {
|
|
return 0, ErrInvalidLengthEvents
|
|
}
|
|
iNdEx += length
|
|
case 3:
|
|
depth++
|
|
case 4:
|
|
if depth == 0 {
|
|
return 0, ErrUnexpectedEndOfGroupEvents
|
|
}
|
|
depth--
|
|
case 5:
|
|
iNdEx += 4
|
|
default:
|
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
|
}
|
|
if iNdEx < 0 {
|
|
return 0, ErrInvalidLengthEvents
|
|
}
|
|
if depth == 0 {
|
|
return iNdEx, nil
|
|
}
|
|
}
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
|
|
var (
|
|
ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling")
|
|
ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow")
|
|
ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
|
|
)
|