From ef134ba4693a8cb7758256957f669bf76c95e097 Mon Sep 17 00:00:00 2001 From: Chance Zibolski Date: Wed, 22 Jan 2025 09:39:45 -0800 Subject: [PATCH] Prepare for v1.16.6 release Signed-off-by: Chance Zibolski --- CHANGELOG.md | 11 + go.mod | 2 +- go.sum | 4 +- vendor/github.com/cilium/cilium/AUTHORS | 6 +- .../cilium/cilium/api/v1/flow/flow.pb.go | 548 +++++++++--------- .../cilium/api/v1/observer/observer.pb.go | 210 +++---- .../api/v1/observer/observer_grpc.pb.go | 2 +- .../cilium/cilium/api/v1/peer/peer.pb.go | 26 +- .../cilium/cilium/api/v1/peer/peer_grpc.pb.go | 2 +- .../cilium/api/v1/recorder/recorder.pb.go | 136 +++-- .../api/v1/recorder/recorder_grpc.pb.go | 2 +- .../cilium/cilium/api/v1/relay/relay.pb.go | 13 +- .../cilium/cilium/pkg/monitor/api/types.go | 25 +- vendor/modules.txt | 2 +- 14 files changed, 499 insertions(+), 490 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 4d9f05a10..907208433 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,17 @@ All notable changes to this project will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/) and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). +## [v1.16.6] - 2025-01-22 +[v1.16.6]: https://github.com/cilium/cilium/compare/v1.16.5...v1.16.6 + +**Misc Changes:** +* chore(deps): update all github action dependencies (minor) (cilium/hubble#1638, @renovate[bot]) +* chore(deps): update all github action dependencies (patch) (cilium/hubble#1637, @renovate[bot]) +* chore(deps): update dependency helm/helm to v3.17.0 (cilium/hubble#1641, @renovate[bot]) +* chore(deps): update helm/kind-action action to v1.12.0 (cilium/hubble#1639, @renovate[bot]) +* chore(deps): update module golang.org/x/net to v0.33.0 [security] (cilium/hubble#1636, @renovate[bot]) +* Update readme/stable.txt to v1.16.5 (cilium/hubble#1635, @chancez) + ## [v1.16.5] - 2024-12-18 [v1.16.5]: https://github.com/cilium/cilium/compare/v1.16.4...v1.16.5 diff --git a/go.mod b/go.mod index e4f2bf1c6..67aed3ad1 100644 --- a/go.mod +++ b/go.mod @@ -2,7 +2,7 @@ module github.com/cilium/hubble go 1.22.2 -require github.com/cilium/cilium v1.16.5 +require github.com/cilium/cilium v1.16.6 require ( github.com/antlr4-go/antlr/v4 v4.13.0 // indirect diff --git a/go.sum b/go.sum index a7f1325c1..0c64d3dce 100644 --- a/go.sum +++ b/go.sum @@ -8,8 +8,8 @@ github.com/blang/semver/v4 v4.0.0 h1:1PFHFE6yCCTv8C1TeyNNarDzntLi7wMI5i/pzqYIsAM github.com/blang/semver/v4 v4.0.0/go.mod h1:IbckMUScFkM3pff0VJDNKRiT6TG/YpiHIM2yvyW5YoQ= github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs= github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= -github.com/cilium/cilium v1.16.5 h1:ecjhh98fl6Ki641+8Cdb0oynsy3toQ+oPLCSI3d+KLE= -github.com/cilium/cilium v1.16.5/go.mod h1:EqOosPzJuv28Hz3Ulz6cCXfYKbll7vbIwMGZU5houOw= +github.com/cilium/cilium v1.16.6 h1:KRQn5knO48ERxB6SusQo02nYmE0NO0qiLlvqhwBTXbI= +github.com/cilium/cilium v1.16.6/go.mod h1:NnDWQiYmPef24+pX2U/V85uL8eUTJSFUUjMEy41lGPA= github.com/cilium/ebpf v0.15.0 h1:7NxJhNiBT3NG8pZJ3c+yfrVdHY8ScgKD27sScgjLMMk= github.com/cilium/ebpf v0.15.0/go.mod h1:DHp1WyrLeiBh19Cf/tfiSMhqheEiK8fXFZ4No0P1Hso= github.com/cilium/hive v0.0.0-20240529072208-d997f86e4219 h1:iX4v9lg63iTv8x8MWUMVbeWqtAGcV6yh/w3Zp9sP3ME= diff --git a/vendor/github.com/cilium/cilium/AUTHORS b/vendor/github.com/cilium/cilium/AUTHORS index 0a9bb7a03..e4805da2a 100644 --- a/vendor/github.com/cilium/cilium/AUTHORS +++ b/vendor/github.com/cilium/cilium/AUTHORS @@ -27,6 +27,7 @@ Alexandre Barone abalexandrebarone@gmail.com Alexandre Perrin alex@isovalent.com Alexei Starovoitov alexei.starovoitov@gmail.com Alexey Grevtsev alexey.grevtcev@gmail.com +Alexis La Goutte alexis.lagoutte@gmail.com Alex Katsman alexkats@google.com Alex Romanov alex@romanov.ws Alex Szakaly alex.szakaly@gmail.com @@ -343,7 +344,7 @@ ishuar ishansharma887@gmail.com Ivan Makarychev i.makarychev@tinkoff.ru Ivar Lazzaro ivarlazzaro@gmail.com Jack-R-lantern tjdfkr2421@gmail.com -Jacob Henner henner@arcesium.com +Jacob Henner code@ventricle.us Jacopo Nardiello jnardiello@users.noreply.github.com Jaff Cheng jaff.cheng.sh@gmail.com Jaime Caamaño Ruiz jcaamano@suse.com @@ -388,6 +389,7 @@ John Fastabend john.fastabend@gmail.com John Gardiner Myers jgmyers@proofpoint.com John Howard howardjohn@google.com John Karoyannis karoyannis@yahoo.com +john-r-swyftx john.roche@swyftx.com.au John Watson johnw@planetscale.com John Zheng johnzhengaz@gmail.com Jomen Xiao jomenxiao@gmail.com @@ -792,6 +794,7 @@ Vadim Ponomarev velizarx@gmail.com vakr vakr@microsoft.com Valas Valancius valas@google.com Vance Li vanceli@tencent.com +verysonglaa 39988258+verysonglaa@users.noreply.github.com Vigneshwaren Sunder vickymailed@gmail.com viktor-kurchenko viktor.kurchenko@isovalent.com Viktor Kurchenko viktor.kurchenko@isovalent.com @@ -860,6 +863,7 @@ Zhang Qiang qiangzhang@qiyi.com Zhiyuan Hou zhiyuan2048@linux.alibaba.com zhouhaibing089 zhouhaibing089@gmail.com Zhu Yan hackzhuyan@gmail.com +Zijian Zhang zz2795@columbia.edu Zisis Lianas zl@consol.de 尤理衡 (Li-Heng Yu) 007seadog@gmail.com diff --git a/vendor/github.com/cilium/cilium/api/v1/flow/flow.pb.go b/vendor/github.com/cilium/cilium/api/v1/flow/flow.pb.go index 929a81bd0..08c6ef512 100644 --- a/vendor/github.com/cilium/cilium/api/v1/flow/flow.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/flow/flow.pb.go @@ -3,8 +3,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 -// protoc v5.29.1 +// protoc-gen-go v1.36.3 +// protoc v5.29.3 // source: flow/flow.proto package flow @@ -1370,11 +1370,8 @@ func (DebugEventType) EnumDescriptor() ([]byte, []int) { } type Flow struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` // uuid is a universally unique identifier for this flow. Uuid string `protobuf:"bytes,34,opt,name=uuid,proto3" json:"uuid,omitempty"` Verdict Verdict `protobuf:"varint,2,opt,name=verdict,proto3,enum=flow.Verdict" json:"verdict,omitempty"` @@ -1468,6 +1465,8 @@ type Flow struct { EgressDeniedBy []*Policy `protobuf:"bytes,21004,rep,name=egress_denied_by,json=egressDeniedBy,proto3" json:"egress_denied_by,omitempty"` // The CiliumNetworkPolicies denying the ingress of the flow. IngressDeniedBy []*Policy `protobuf:"bytes,21005,rep,name=ingress_denied_by,json=ingressDeniedBy,proto3" json:"ingress_denied_by,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Flow) Reset() { @@ -1777,18 +1776,17 @@ func (x *Flow) GetIngressDeniedBy() []*Policy { } type Layer4 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to Protocol: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to Protocol: // // *Layer4_TCP // *Layer4_UDP // *Layer4_ICMPv4 // *Layer4_ICMPv6 // *Layer4_SCTP - Protocol isLayer4_Protocol `protobuf_oneof:"protocol"` + Protocol isLayer4_Protocol `protobuf_oneof:"protocol"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Layer4) Reset() { @@ -1821,44 +1819,54 @@ func (*Layer4) Descriptor() ([]byte, []int) { return file_flow_flow_proto_rawDescGZIP(), []int{1} } -func (m *Layer4) GetProtocol() isLayer4_Protocol { - if m != nil { - return m.Protocol +func (x *Layer4) GetProtocol() isLayer4_Protocol { + if x != nil { + return x.Protocol } return nil } func (x *Layer4) GetTCP() *TCP { - if x, ok := x.GetProtocol().(*Layer4_TCP); ok { - return x.TCP + if x != nil { + if x, ok := x.Protocol.(*Layer4_TCP); ok { + return x.TCP + } } return nil } func (x *Layer4) GetUDP() *UDP { - if x, ok := x.GetProtocol().(*Layer4_UDP); ok { - return x.UDP + if x != nil { + if x, ok := x.Protocol.(*Layer4_UDP); ok { + return x.UDP + } } return nil } func (x *Layer4) GetICMPv4() *ICMPv4 { - if x, ok := x.GetProtocol().(*Layer4_ICMPv4); ok { - return x.ICMPv4 + if x != nil { + if x, ok := x.Protocol.(*Layer4_ICMPv4); ok { + return x.ICMPv4 + } } return nil } func (x *Layer4) GetICMPv6() *ICMPv6 { - if x, ok := x.GetProtocol().(*Layer4_ICMPv6); ok { - return x.ICMPv6 + if x != nil { + if x, ok := x.Protocol.(*Layer4_ICMPv6); ok { + return x.ICMPv6 + } } return nil } func (x *Layer4) GetSCTP() *SCTP { - if x, ok := x.GetProtocol().(*Layer4_SCTP); ok { - return x.SCTP + if x != nil { + if x, ok := x.Protocol.(*Layer4_SCTP); ok { + return x.SCTP + } } return nil } @@ -1900,21 +1908,20 @@ func (*Layer4_SCTP) isLayer4_Protocol() {} // Message for L7 flow, which roughly corresponds to Cilium's accesslog [LogRecord](https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L141): type Layer7 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Type L7FlowType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.L7FlowType" json:"type,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Type L7FlowType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.L7FlowType" json:"type,omitempty"` // Latency of the response LatencyNs uint64 `protobuf:"varint,2,opt,name=latency_ns,json=latencyNs,proto3" json:"latency_ns,omitempty"` // L7 field. This field is set if and only if FlowType is L7. // - // Types that are assignable to Record: + // Types that are valid to be assigned to Record: // // *Layer7_Dns // *Layer7_Http // *Layer7_Kafka - Record isLayer7_Record `protobuf_oneof:"record"` + Record isLayer7_Record `protobuf_oneof:"record"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Layer7) Reset() { @@ -1961,30 +1968,36 @@ func (x *Layer7) GetLatencyNs() uint64 { return 0 } -func (m *Layer7) GetRecord() isLayer7_Record { - if m != nil { - return m.Record +func (x *Layer7) GetRecord() isLayer7_Record { + if x != nil { + return x.Record } return nil } func (x *Layer7) GetDns() *DNS { - if x, ok := x.GetRecord().(*Layer7_Dns); ok { - return x.Dns + if x != nil { + if x, ok := x.Record.(*Layer7_Dns); ok { + return x.Dns + } } return nil } func (x *Layer7) GetHttp() *HTTP { - if x, ok := x.GetRecord().(*Layer7_Http); ok { - return x.Http + if x != nil { + if x, ok := x.Record.(*Layer7_Http); ok { + return x.Http + } } return nil } func (x *Layer7) GetKafka() *Kafka { - if x, ok := x.GetRecord().(*Layer7_Kafka); ok { - return x.Kafka + if x != nil { + if x, ok := x.Record.(*Layer7_Kafka); ok { + return x.Kafka + } } return nil } @@ -2015,12 +2028,11 @@ func (*Layer7_Kafka) isLayer7_Record() {} // distributed trace. // For more information about trace context, check the [W3C Trace Context specification](https://www.w3.org/TR/trace-context/). type TraceContext struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // parent identifies the incoming request in a tracing system. - Parent *TraceParent `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` + Parent *TraceParent `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TraceContext) Reset() { @@ -2062,13 +2074,12 @@ func (x *TraceContext) GetParent() *TraceParent { // TraceParent identifies the incoming request in a tracing system. type TraceParent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // trace_id is a unique value that identifies a trace. It is a byte array // represented as a hex string. - TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` + TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TraceParent) Reset() { @@ -2109,18 +2120,17 @@ func (x *TraceParent) GetTraceId() string { } type Endpoint struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` - Identity uint32 `protobuf:"varint,2,opt,name=identity,proto3" json:"identity,omitempty"` - ClusterName string `protobuf:"bytes,7,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` - Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` + Identity uint32 `protobuf:"varint,2,opt,name=identity,proto3" json:"identity,omitempty"` + ClusterName string `protobuf:"bytes,7,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` + Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` // labels in `foo=bar` format. - Labels []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` - PodName string `protobuf:"bytes,5,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` - Workloads []*Workload `protobuf:"bytes,6,rep,name=workloads,proto3" json:"workloads,omitempty"` + Labels []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` + PodName string `protobuf:"bytes,5,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` + Workloads []*Workload `protobuf:"bytes,6,rep,name=workloads,proto3" json:"workloads,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Endpoint) Reset() { @@ -2203,12 +2213,11 @@ func (x *Endpoint) GetWorkloads() []*Workload { } type Workload struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Workload) Reset() { @@ -2256,13 +2265,12 @@ func (x *Workload) GetKind() string { } type TCP struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` - DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` - Flags *TCPFlags `protobuf:"bytes,3,opt,name=flags,proto3" json:"flags,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` + DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` + Flags *TCPFlags `protobuf:"bytes,3,opt,name=flags,proto3" json:"flags,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TCP) Reset() { @@ -2317,11 +2325,8 @@ func (x *TCP) GetFlags() *TCPFlags { } type IP struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // source_xlated is the post translation source IP when the flow was SNATed // (and in that case source is the the original source IP). SourceXlated string `protobuf:"bytes,5,opt,name=source_xlated,json=sourceXlated,proto3" json:"source_xlated,omitempty"` @@ -2329,7 +2334,9 @@ type IP struct { IpVersion IPVersion `protobuf:"varint,3,opt,name=ipVersion,proto3,enum=flow.IPVersion" json:"ipVersion,omitempty"` // This field indicates whether the TraceReasonEncryptMask is set or not. // https://github.com/cilium/cilium/blob/ba0ed147bd5bb342f67b1794c2ad13c6e99d5236/pkg/monitor/datapath_trace.go#L27 - Encrypted bool `protobuf:"varint,4,opt,name=encrypted,proto3" json:"encrypted,omitempty"` + Encrypted bool `protobuf:"varint,4,opt,name=encrypted,proto3" json:"encrypted,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *IP) Reset() { @@ -2398,12 +2405,11 @@ func (x *IP) GetEncrypted() bool { } type Ethernet struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` + Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` unknownFields protoimpl.UnknownFields - - Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` - Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Ethernet) Reset() { @@ -2451,19 +2457,18 @@ func (x *Ethernet) GetDestination() string { } type TCPFlags struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + FIN bool `protobuf:"varint,1,opt,name=FIN,proto3" json:"FIN,omitempty"` + SYN bool `protobuf:"varint,2,opt,name=SYN,proto3" json:"SYN,omitempty"` + RST bool `protobuf:"varint,3,opt,name=RST,proto3" json:"RST,omitempty"` + PSH bool `protobuf:"varint,4,opt,name=PSH,proto3" json:"PSH,omitempty"` + ACK bool `protobuf:"varint,5,opt,name=ACK,proto3" json:"ACK,omitempty"` + URG bool `protobuf:"varint,6,opt,name=URG,proto3" json:"URG,omitempty"` + ECE bool `protobuf:"varint,7,opt,name=ECE,proto3" json:"ECE,omitempty"` + CWR bool `protobuf:"varint,8,opt,name=CWR,proto3" json:"CWR,omitempty"` + NS bool `protobuf:"varint,9,opt,name=NS,proto3" json:"NS,omitempty"` unknownFields protoimpl.UnknownFields - - FIN bool `protobuf:"varint,1,opt,name=FIN,proto3" json:"FIN,omitempty"` - SYN bool `protobuf:"varint,2,opt,name=SYN,proto3" json:"SYN,omitempty"` - RST bool `protobuf:"varint,3,opt,name=RST,proto3" json:"RST,omitempty"` - PSH bool `protobuf:"varint,4,opt,name=PSH,proto3" json:"PSH,omitempty"` - ACK bool `protobuf:"varint,5,opt,name=ACK,proto3" json:"ACK,omitempty"` - URG bool `protobuf:"varint,6,opt,name=URG,proto3" json:"URG,omitempty"` - ECE bool `protobuf:"varint,7,opt,name=ECE,proto3" json:"ECE,omitempty"` - CWR bool `protobuf:"varint,8,opt,name=CWR,proto3" json:"CWR,omitempty"` - NS bool `protobuf:"varint,9,opt,name=NS,proto3" json:"NS,omitempty"` + sizeCache protoimpl.SizeCache } func (x *TCPFlags) Reset() { @@ -2560,12 +2565,11 @@ func (x *TCPFlags) GetNS() bool { } type UDP struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` - DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` + DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *UDP) Reset() { @@ -2613,12 +2617,11 @@ func (x *UDP) GetDestinationPort() uint32 { } type SCTP struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` - DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` + DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *SCTP) Reset() { @@ -2666,12 +2669,11 @@ func (x *SCTP) GetDestinationPort() uint32 { } type ICMPv4 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` + Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` unknownFields protoimpl.UnknownFields - - Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` - Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ICMPv4) Reset() { @@ -2719,12 +2721,11 @@ func (x *ICMPv4) GetCode() uint32 { } type ICMPv6 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` + Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` unknownFields protoimpl.UnknownFields - - Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` - Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ICMPv6) Reset() { @@ -2772,14 +2773,13 @@ func (x *ICMPv6) GetCode() uint32 { } type Policy struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` + Labels []string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` + Revision uint64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` - Labels []string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` - Revision uint64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Policy) Reset() { @@ -2842,10 +2842,7 @@ func (x *Policy) GetRevision() uint64 { // EventTypeFilter is a filter describing a particular event type. type EventTypeFilter struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // type is the primary flow type as defined by: // github.com/cilium/cilium/pkg/monitor/api.MessageType* Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` @@ -2854,7 +2851,9 @@ type EventTypeFilter struct { MatchSubType bool `protobuf:"varint,2,opt,name=match_sub_type,json=matchSubType,proto3" json:"match_sub_type,omitempty"` // sub_type is the secondary type, e.g. // - github.com/cilium/cilium/pkg/monitor/api.Trace* - SubType int32 `protobuf:"varint,3,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"` + SubType int32 `protobuf:"varint,3,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *EventTypeFilter) Reset() { @@ -2910,10 +2909,7 @@ func (x *EventTypeFilter) GetSubType() int32 { // CiliumEventType from which the flow originated. type CiliumEventType struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // type of event the flow originated from, i.e. // github.com/cilium/cilium/pkg/monitor/api.MessageType* Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` @@ -2921,7 +2917,9 @@ type CiliumEventType struct { // - github.com/cilium/cilium/pkg/monitor/api.Trace* // - github.com/cilium/cilium/pkg/monitor/api.Drop* // - github.com/cilium/cilium/pkg/monitor/api.DbgCapture* - SubType int32 `protobuf:"varint,2,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"` + SubType int32 `protobuf:"varint,2,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *CiliumEventType) Reset() { @@ -2971,10 +2969,7 @@ func (x *CiliumEventType) GetSubType() int32 { // FlowFilter represent an individual flow filter. All fields are optional. If // multiple fields are set, then all fields must match for the filter to match. type FlowFilter struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // uuid filters by a list of flow uuids. Uuid []string `protobuf:"bytes,29,rep,name=uuid,proto3" json:"uuid,omitempty"` // source_ip filters by a list of source ips. Each of the source ips can be @@ -3066,7 +3061,9 @@ type FlowFilter struct { TraceId []string `protobuf:"bytes,28,rep,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // experimental contains filters that are not stable yet. Support for // experimental features is always optional and subject to change. - Experimental *FlowFilter_Experimental `protobuf:"bytes,999,opt,name=experimental,proto3" json:"experimental,omitempty"` + Experimental *FlowFilter_Experimental `protobuf:"bytes,999,opt,name=experimental,proto3" json:"experimental,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *FlowFilter) Reset() { @@ -3360,10 +3357,7 @@ func (x *FlowFilter) GetExperimental() *FlowFilter_Experimental { // DNS flow. This is basically directly mapped from Cilium's [LogRecordDNS](https://github.com/cilium/cilium/blob/04f3889d627774f79e56d14ddbc165b3169e2d01/pkg/proxy/accesslog/record.go#L264): type DNS struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // DNS name that's being looked up: e.g. "isovalent.com." Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // List of IP addresses in the DNS response. @@ -3386,7 +3380,9 @@ type DNS struct { Qtypes []string `protobuf:"bytes,7,rep,name=qtypes,proto3" json:"qtypes,omitempty"` // String representation of rrtypes defined in: // https://www.iana.org/assignments/dns-parameters/dns-parameters.xhtml#dns-parameters-4 - Rrtypes []string `protobuf:"bytes,8,rep,name=rrtypes,proto3" json:"rrtypes,omitempty"` + Rrtypes []string `protobuf:"bytes,8,rep,name=rrtypes,proto3" json:"rrtypes,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *DNS) Reset() { @@ -3476,12 +3472,11 @@ func (x *DNS) GetRrtypes() []string { } type HTTPHeader struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` + Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` unknownFields protoimpl.UnknownFields - - Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` - Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` + sizeCache protoimpl.SizeCache } func (x *HTTPHeader) Reset() { @@ -3530,15 +3525,14 @@ func (x *HTTPHeader) GetValue() string { // L7 information for HTTP flows. It corresponds to Cilium's [accesslog.LogRecordHTTP](https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L206) type. type HTTP struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` + Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` + Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"` + Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"` + Headers []*HTTPHeader `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"` unknownFields protoimpl.UnknownFields - - Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` - Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` - Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"` - Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"` - Headers []*HTTPHeader `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"` + sizeCache protoimpl.SizeCache } func (x *HTTP) Reset() { @@ -3608,15 +3602,14 @@ func (x *HTTP) GetHeaders() []*HTTPHeader { // L7 information for Kafka flows. It corresponds to Cilium's [accesslog.LogRecordKafka](https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L229) type. type Kafka struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + ErrorCode int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` + ApiVersion int32 `protobuf:"varint,2,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` + ApiKey string `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` + CorrelationId int32 `protobuf:"varint,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` + Topic string `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"` unknownFields protoimpl.UnknownFields - - ErrorCode int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` - ApiVersion int32 `protobuf:"varint,2,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` - ApiKey string `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` - CorrelationId int32 `protobuf:"varint,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` - Topic string `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Kafka) Reset() { @@ -3685,12 +3678,11 @@ func (x *Kafka) GetTopic() string { } type Service struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Service) Reset() { @@ -3740,17 +3732,16 @@ func (x *Service) GetNamespace() string { // LostEvent is a message which notifies consumers about a loss of events // that happened before the events were captured by Hubble. type LostEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // source is the location where events got lost. Source LostEventSource `protobuf:"varint,1,opt,name=source,proto3,enum=flow.LostEventSource" json:"source,omitempty"` // num_events_lost is the number of events that haven been lost at source. NumEventsLost uint64 `protobuf:"varint,2,opt,name=num_events_lost,json=numEventsLost,proto3" json:"num_events_lost,omitempty"` // cpu on which the event was lost if the source of lost events is // PERF_EVENT_RING_BUFFER. - Cpu *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=cpu,proto3" json:"cpu,omitempty"` + Cpu *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=cpu,proto3" json:"cpu,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *LostEvent) Reset() { @@ -3805,12 +3796,9 @@ func (x *LostEvent) GetCpu() *wrapperspb.Int32Value { } type AgentEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Type AgentEventType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.AgentEventType" json:"type,omitempty"` - // Types that are assignable to Notification: + state protoimpl.MessageState `protogen:"open.v1"` + Type AgentEventType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.AgentEventType" json:"type,omitempty"` + // Types that are valid to be assigned to Notification: // // *AgentEvent_Unknown // *AgentEvent_AgentStart @@ -3820,7 +3808,9 @@ type AgentEvent struct { // *AgentEvent_IpcacheUpdate // *AgentEvent_ServiceUpsert // *AgentEvent_ServiceDelete - Notification isAgentEvent_Notification `protobuf_oneof:"notification"` + Notification isAgentEvent_Notification `protobuf_oneof:"notification"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *AgentEvent) Reset() { @@ -3860,65 +3850,81 @@ func (x *AgentEvent) GetType() AgentEventType { return AgentEventType_AGENT_EVENT_UNKNOWN } -func (m *AgentEvent) GetNotification() isAgentEvent_Notification { - if m != nil { - return m.Notification +func (x *AgentEvent) GetNotification() isAgentEvent_Notification { + if x != nil { + return x.Notification } return nil } func (x *AgentEvent) GetUnknown() *AgentEventUnknown { - if x, ok := x.GetNotification().(*AgentEvent_Unknown); ok { - return x.Unknown + if x != nil { + if x, ok := x.Notification.(*AgentEvent_Unknown); ok { + return x.Unknown + } } return nil } func (x *AgentEvent) GetAgentStart() *TimeNotification { - if x, ok := x.GetNotification().(*AgentEvent_AgentStart); ok { - return x.AgentStart + if x != nil { + if x, ok := x.Notification.(*AgentEvent_AgentStart); ok { + return x.AgentStart + } } return nil } func (x *AgentEvent) GetPolicyUpdate() *PolicyUpdateNotification { - if x, ok := x.GetNotification().(*AgentEvent_PolicyUpdate); ok { - return x.PolicyUpdate + if x != nil { + if x, ok := x.Notification.(*AgentEvent_PolicyUpdate); ok { + return x.PolicyUpdate + } } return nil } func (x *AgentEvent) GetEndpointRegenerate() *EndpointRegenNotification { - if x, ok := x.GetNotification().(*AgentEvent_EndpointRegenerate); ok { - return x.EndpointRegenerate + if x != nil { + if x, ok := x.Notification.(*AgentEvent_EndpointRegenerate); ok { + return x.EndpointRegenerate + } } return nil } func (x *AgentEvent) GetEndpointUpdate() *EndpointUpdateNotification { - if x, ok := x.GetNotification().(*AgentEvent_EndpointUpdate); ok { - return x.EndpointUpdate + if x != nil { + if x, ok := x.Notification.(*AgentEvent_EndpointUpdate); ok { + return x.EndpointUpdate + } } return nil } func (x *AgentEvent) GetIpcacheUpdate() *IPCacheNotification { - if x, ok := x.GetNotification().(*AgentEvent_IpcacheUpdate); ok { - return x.IpcacheUpdate + if x != nil { + if x, ok := x.Notification.(*AgentEvent_IpcacheUpdate); ok { + return x.IpcacheUpdate + } } return nil } func (x *AgentEvent) GetServiceUpsert() *ServiceUpsertNotification { - if x, ok := x.GetNotification().(*AgentEvent_ServiceUpsert); ok { - return x.ServiceUpsert + if x != nil { + if x, ok := x.Notification.(*AgentEvent_ServiceUpsert); ok { + return x.ServiceUpsert + } } return nil } func (x *AgentEvent) GetServiceDelete() *ServiceDeleteNotification { - if x, ok := x.GetNotification().(*AgentEvent_ServiceDelete); ok { - return x.ServiceDelete + if x != nil { + if x, ok := x.Notification.(*AgentEvent_ServiceDelete); ok { + return x.ServiceDelete + } } return nil } @@ -3980,12 +3986,11 @@ func (*AgentEvent_ServiceUpsert) isAgentEvent_Notification() {} func (*AgentEvent_ServiceDelete) isAgentEvent_Notification() {} type AgentEventUnknown struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` + Notification string `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` unknownFields protoimpl.UnknownFields - - Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` - Notification string `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` + sizeCache protoimpl.SizeCache } func (x *AgentEventUnknown) Reset() { @@ -4033,11 +4038,10 @@ func (x *AgentEventUnknown) GetNotification() string { } type TimeNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` unknownFields protoimpl.UnknownFields - - Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` + sizeCache protoimpl.SizeCache } func (x *TimeNotification) Reset() { @@ -4078,13 +4082,12 @@ func (x *TimeNotification) GetTime() *timestamppb.Timestamp { } type PolicyUpdateNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Labels []string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` + Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"` + RuleCount int64 `protobuf:"varint,3,opt,name=rule_count,json=ruleCount,proto3" json:"rule_count,omitempty"` unknownFields protoimpl.UnknownFields - - Labels []string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` - Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"` - RuleCount int64 `protobuf:"varint,3,opt,name=rule_count,json=ruleCount,proto3" json:"rule_count,omitempty"` + sizeCache protoimpl.SizeCache } func (x *PolicyUpdateNotification) Reset() { @@ -4139,13 +4142,12 @@ func (x *PolicyUpdateNotification) GetRuleCount() int64 { } type EndpointRegenNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` + Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` unknownFields protoimpl.UnknownFields - - Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` - Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` - Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` + sizeCache protoimpl.SizeCache } func (x *EndpointRegenNotification) Reset() { @@ -4200,15 +4202,14 @@ func (x *EndpointRegenNotification) GetError() string { } type EndpointUpdateNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` + Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` + PodName string `protobuf:"bytes,4,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` + Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"` unknownFields protoimpl.UnknownFields - - Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` - Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` - Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` - PodName string `protobuf:"bytes,4,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` - Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"` + sizeCache protoimpl.SizeCache } func (x *EndpointUpdateNotification) Reset() { @@ -4277,18 +4278,17 @@ func (x *EndpointUpdateNotification) GetNamespace() string { } type IPCacheNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3" json:"cidr,omitempty"` + Identity uint32 `protobuf:"varint,2,opt,name=identity,proto3" json:"identity,omitempty"` + OldIdentity *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=old_identity,json=oldIdentity,proto3" json:"old_identity,omitempty"` + HostIp string `protobuf:"bytes,4,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"` + OldHostIp string `protobuf:"bytes,5,opt,name=old_host_ip,json=oldHostIp,proto3" json:"old_host_ip,omitempty"` + EncryptKey uint32 `protobuf:"varint,6,opt,name=encrypt_key,json=encryptKey,proto3" json:"encrypt_key,omitempty"` + Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` + PodName string `protobuf:"bytes,8,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` unknownFields protoimpl.UnknownFields - - Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3" json:"cidr,omitempty"` - Identity uint32 `protobuf:"varint,2,opt,name=identity,proto3" json:"identity,omitempty"` - OldIdentity *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=old_identity,json=oldIdentity,proto3" json:"old_identity,omitempty"` - HostIp string `protobuf:"bytes,4,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"` - OldHostIp string `protobuf:"bytes,5,opt,name=old_host_ip,json=oldHostIp,proto3" json:"old_host_ip,omitempty"` - EncryptKey uint32 `protobuf:"varint,6,opt,name=encrypt_key,json=encryptKey,proto3" json:"encrypt_key,omitempty"` - Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` - PodName string `protobuf:"bytes,8,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *IPCacheNotification) Reset() { @@ -4378,12 +4378,11 @@ func (x *IPCacheNotification) GetPodName() string { } type ServiceUpsertNotificationAddr struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` + Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` unknownFields protoimpl.UnknownFields - - Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` - Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ServiceUpsertNotificationAddr) Reset() { @@ -4431,10 +4430,7 @@ func (x *ServiceUpsertNotificationAddr) GetPort() uint32 { } type ServiceUpsertNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` FrontendAddress *ServiceUpsertNotificationAddr `protobuf:"bytes,2,opt,name=frontend_address,json=frontendAddress,proto3" json:"frontend_address,omitempty"` BackendAddresses []*ServiceUpsertNotificationAddr `protobuf:"bytes,3,rep,name=backend_addresses,json=backendAddresses,proto3" json:"backend_addresses,omitempty"` @@ -4445,6 +4441,8 @@ type ServiceUpsertNotification struct { Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` ExtTrafficPolicy string `protobuf:"bytes,8,opt,name=ext_traffic_policy,json=extTrafficPolicy,proto3" json:"ext_traffic_policy,omitempty"` IntTrafficPolicy string `protobuf:"bytes,9,opt,name=int_traffic_policy,json=intTrafficPolicy,proto3" json:"int_traffic_policy,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ServiceUpsertNotification) Reset() { @@ -4542,11 +4540,10 @@ func (x *ServiceUpsertNotification) GetIntTrafficPolicy() string { } type ServiceDeleteNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` unknownFields protoimpl.UnknownFields - - Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + sizeCache protoimpl.SizeCache } func (x *ServiceDeleteNotification) Reset() { @@ -4587,12 +4584,11 @@ func (x *ServiceDeleteNotification) GetId() uint32 { } type NetworkInterface struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` + Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` - Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *NetworkInterface) Reset() { @@ -4640,18 +4636,17 @@ func (x *NetworkInterface) GetName() string { } type DebugEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Type DebugEventType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.DebugEventType" json:"type,omitempty"` + Source *Endpoint `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` + Hash *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` + Arg1 *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=arg1,proto3" json:"arg1,omitempty"` + Arg2 *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=arg2,proto3" json:"arg2,omitempty"` + Arg3 *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=arg3,proto3" json:"arg3,omitempty"` + Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"` + Cpu *wrapperspb.Int32Value `protobuf:"bytes,8,opt,name=cpu,proto3" json:"cpu,omitempty"` unknownFields protoimpl.UnknownFields - - Type DebugEventType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.DebugEventType" json:"type,omitempty"` - Source *Endpoint `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` - Hash *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` - Arg1 *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=arg1,proto3" json:"arg1,omitempty"` - Arg2 *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=arg2,proto3" json:"arg2,omitempty"` - Arg3 *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=arg3,proto3" json:"arg3,omitempty"` - Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"` - Cpu *wrapperspb.Int32Value `protobuf:"bytes,8,opt,name=cpu,proto3" json:"cpu,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DebugEvent) Reset() { @@ -4743,10 +4738,7 @@ func (x *DebugEvent) GetCpu() *wrapperspb.Int32Value { // Experimental contains filters that are not stable yet. Support for // experimental features is always optional and subject to change. type FlowFilter_Experimental struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // cel_expression takes a common expression language (CEL) expression // returning a boolean to determine if the filter matched or not. // You can use the `_flow` variable to access fields on the flow using @@ -4757,6 +4749,8 @@ type FlowFilter_Experimental struct { // using non-CEL filters when possible, and try to specify CEL filters // last in the list of FlowFilters. CelExpression []string `protobuf:"bytes,1,rep,name=cel_expression,json=celExpression,proto3" json:"cel_expression,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *FlowFilter_Experimental) Reset() { diff --git a/vendor/github.com/cilium/cilium/api/v1/observer/observer.pb.go b/vendor/github.com/cilium/cilium/api/v1/observer/observer.pb.go index 217110151..5cd7b5f9e 100644 --- a/vendor/github.com/cilium/cilium/api/v1/observer/observer.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/observer/observer.pb.go @@ -3,8 +3,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 -// protoc v5.29.1 +// protoc-gen-go v1.36.3 +// protoc v5.29.3 // source: observer/observer.proto package observer @@ -399,9 +399,9 @@ type DebugEvent = flow.DebugEvent type FlowFilter_Experimental = flow.FlowFilter_Experimental type ServerStatusRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ServerStatusRequest) Reset() { @@ -435,10 +435,7 @@ func (*ServerStatusRequest) Descriptor() ([]byte, []int) { } type ServerStatusResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // number of currently captured flows // In a multi-node context, this is the cumulative count of all captured // flows. @@ -466,7 +463,9 @@ type ServerStatusResponse struct { Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"` // Approximate rate of flows seen by Hubble per second over the last minute. // In a multi-node context, this is the sum of all flows rates. - FlowsRate float64 `protobuf:"fixed64,9,opt,name=flows_rate,json=flowsRate,proto3" json:"flows_rate,omitempty"` + FlowsRate float64 `protobuf:"fixed64,9,opt,name=flows_rate,json=flowsRate,proto3" json:"flows_rate,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ServerStatusResponse) Reset() { @@ -563,10 +562,7 @@ func (x *ServerStatusResponse) GetFlowsRate() float64 { } type GetFlowsRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Number of flows that should be returned. Incompatible with `since/until`. // Defaults to the most recent (last) `number` flows, unless `first` is // true, then it will return the earliest `number` flows. @@ -603,7 +599,9 @@ type GetFlowsRequest struct { // extensions can be used to add arbitrary additional metadata to GetFlowsRequest. // This can be used to extend functionality for other Hubble compatible // APIs, or experiment with new functionality without needing to change the public API. - Extensions *anypb.Any `protobuf:"bytes,150000,opt,name=extensions,proto3" json:"extensions,omitempty"` + Extensions *anypb.Any `protobuf:"bytes,150000,opt,name=extensions,proto3" json:"extensions,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetFlowsRequest) Reset() { @@ -708,11 +706,8 @@ func (x *GetFlowsRequest) GetExtensions() *anypb.Any { // GetFlowsResponse contains either a flow or a protocol message. type GetFlowsResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to ResponseTypes: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to ResponseTypes: // // *GetFlowsResponse_Flow // *GetFlowsResponse_NodeStatus @@ -721,7 +716,9 @@ type GetFlowsResponse struct { // Name of the node where this event was observed. NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // Timestamp at which this event was observed. - Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetFlowsResponse) Reset() { @@ -754,30 +751,36 @@ func (*GetFlowsResponse) Descriptor() ([]byte, []int) { return file_observer_observer_proto_rawDescGZIP(), []int{3} } -func (m *GetFlowsResponse) GetResponseTypes() isGetFlowsResponse_ResponseTypes { - if m != nil { - return m.ResponseTypes +func (x *GetFlowsResponse) GetResponseTypes() isGetFlowsResponse_ResponseTypes { + if x != nil { + return x.ResponseTypes } return nil } func (x *GetFlowsResponse) GetFlow() *flow.Flow { - if x, ok := x.GetResponseTypes().(*GetFlowsResponse_Flow); ok { - return x.Flow + if x != nil { + if x, ok := x.ResponseTypes.(*GetFlowsResponse_Flow); ok { + return x.Flow + } } return nil } func (x *GetFlowsResponse) GetNodeStatus() *relay.NodeStatusEvent { - if x, ok := x.GetResponseTypes().(*GetFlowsResponse_NodeStatus); ok { - return x.NodeStatus + if x != nil { + if x, ok := x.ResponseTypes.(*GetFlowsResponse_NodeStatus); ok { + return x.NodeStatus + } } return nil } func (x *GetFlowsResponse) GetLostEvents() *flow.LostEvent { - if x, ok := x.GetResponseTypes().(*GetFlowsResponse_LostEvents); ok { - return x.LostEvents + if x != nil { + if x, ok := x.ResponseTypes.(*GetFlowsResponse_LostEvents); ok { + return x.LostEvents + } } return nil } @@ -823,10 +826,7 @@ func (*GetFlowsResponse_NodeStatus) isGetFlowsResponse_ResponseTypes() {} func (*GetFlowsResponse_LostEvents) isGetFlowsResponse_ResponseTypes() {} type GetAgentEventsRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Number of flows that should be returned. Incompatible with `since/until`. // Defaults to the most recent (last) `number` events, unless `first` is // true, then it will return the earliest `number` events. @@ -840,7 +840,9 @@ type GetAgentEventsRequest struct { // Since this time for returned agent events. Incompatible with `number`. Since *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"` // Until this time for returned agent events. Incompatible with `number`. - Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"` + Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetAgentEventsRequest) Reset() { @@ -910,15 +912,14 @@ func (x *GetAgentEventsRequest) GetUntil() *timestamppb.Timestamp { // GetAgentEventsResponse contains an event received from the Cilium agent. type GetAgentEventsResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - AgentEvent *flow.AgentEvent `protobuf:"bytes,1,opt,name=agent_event,json=agentEvent,proto3" json:"agent_event,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + AgentEvent *flow.AgentEvent `protobuf:"bytes,1,opt,name=agent_event,json=agentEvent,proto3" json:"agent_event,omitempty"` // Name of the node where this event was observed. NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // Timestamp at which this event was observed. - Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetAgentEventsResponse) Reset() { @@ -973,10 +974,7 @@ func (x *GetAgentEventsResponse) GetTime() *timestamppb.Timestamp { } type GetDebugEventsRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Number of events that should be returned. Incompatible with `since/until`. // Defaults to the most recent (last) `number` events, unless `first` is // true, then it will return the earliest `number` events. @@ -990,7 +988,9 @@ type GetDebugEventsRequest struct { // Since this time for returned debug events. Incompatible with `number`. Since *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"` // Until this time for returned debug events. Incompatible with `number`. - Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"` + Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDebugEventsRequest) Reset() { @@ -1060,15 +1060,14 @@ func (x *GetDebugEventsRequest) GetUntil() *timestamppb.Timestamp { // GetDebugEventsResponse contains a Cilium datapath debug events. type GetDebugEventsResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - DebugEvent *flow.DebugEvent `protobuf:"bytes,1,opt,name=debug_event,json=debugEvent,proto3" json:"debug_event,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + DebugEvent *flow.DebugEvent `protobuf:"bytes,1,opt,name=debug_event,json=debugEvent,proto3" json:"debug_event,omitempty"` // Name of the node where this event was observed. NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // Timestamp at which this event was observed. - Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDebugEventsResponse) Reset() { @@ -1123,9 +1122,9 @@ func (x *GetDebugEventsResponse) GetTime() *timestamppb.Timestamp { } type GetNodesRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetNodesRequest) Reset() { @@ -1160,12 +1159,11 @@ func (*GetNodesRequest) Descriptor() ([]byte, []int) { // GetNodesResponse contains the list of nodes. type GetNodesResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Nodes is an exhaustive list of nodes. - Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` + Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetNodesResponse) Reset() { @@ -1207,10 +1205,7 @@ func (x *GetNodesResponse) GetNodes() []*Node { // Node represents a cluster node. type Node struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Name is the name of the node. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Version is the version of Cilium/Hubble as reported by the node. @@ -1228,7 +1223,9 @@ type Node struct { // maximum capacity of the ring buffer MaxFlows uint64 `protobuf:"varint,8,opt,name=max_flows,json=maxFlows,proto3" json:"max_flows,omitempty"` // total amount of flows observed since the observer was started - SeenFlows uint64 `protobuf:"varint,9,opt,name=seen_flows,json=seenFlows,proto3" json:"seen_flows,omitempty"` + SeenFlows uint64 `protobuf:"varint,9,opt,name=seen_flows,json=seenFlows,proto3" json:"seen_flows,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Node) Reset() { @@ -1326,15 +1323,14 @@ func (x *Node) GetSeenFlows() uint64 { // TLS represents TLS information. type TLS struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Enabled reports whether TLS is enabled or not. Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // ServerName is the TLS server name that can be used as part of the TLS // cert validation process. - ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TLS) Reset() { @@ -1382,9 +1378,9 @@ func (x *TLS) GetServerName() string { } type GetNamespacesRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetNamespacesRequest) Reset() { @@ -1419,12 +1415,11 @@ func (*GetNamespacesRequest) Descriptor() ([]byte, []int) { // GetNamespacesResponse contains the list of namespaces. type GetNamespacesResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Namespaces is a list of namespaces with flows - Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` + Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetNamespacesResponse) Reset() { @@ -1465,12 +1460,11 @@ func (x *GetNamespacesResponse) GetNamespaces() []*Namespace { } type Namespace struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` + Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` unknownFields protoimpl.UnknownFields - - Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Namespace) Reset() { @@ -1520,11 +1514,8 @@ func (x *Namespace) GetNamespace() string { // ExportEvent contains an event to be exported. Not to be used outside of the // exporter feature. type ExportEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to ResponseTypes: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to ResponseTypes: // // *ExportEvent_Flow // *ExportEvent_NodeStatus @@ -1535,7 +1526,9 @@ type ExportEvent struct { // Name of the node where this event was observed. NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // Timestamp at which this event was observed. - Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ExportEvent) Reset() { @@ -1568,44 +1561,54 @@ func (*ExportEvent) Descriptor() ([]byte, []int) { return file_observer_observer_proto_rawDescGZIP(), []int{15} } -func (m *ExportEvent) GetResponseTypes() isExportEvent_ResponseTypes { - if m != nil { - return m.ResponseTypes +func (x *ExportEvent) GetResponseTypes() isExportEvent_ResponseTypes { + if x != nil { + return x.ResponseTypes } return nil } func (x *ExportEvent) GetFlow() *flow.Flow { - if x, ok := x.GetResponseTypes().(*ExportEvent_Flow); ok { - return x.Flow + if x != nil { + if x, ok := x.ResponseTypes.(*ExportEvent_Flow); ok { + return x.Flow + } } return nil } func (x *ExportEvent) GetNodeStatus() *relay.NodeStatusEvent { - if x, ok := x.GetResponseTypes().(*ExportEvent_NodeStatus); ok { - return x.NodeStatus + if x != nil { + if x, ok := x.ResponseTypes.(*ExportEvent_NodeStatus); ok { + return x.NodeStatus + } } return nil } func (x *ExportEvent) GetLostEvents() *flow.LostEvent { - if x, ok := x.GetResponseTypes().(*ExportEvent_LostEvents); ok { - return x.LostEvents + if x != nil { + if x, ok := x.ResponseTypes.(*ExportEvent_LostEvents); ok { + return x.LostEvents + } } return nil } func (x *ExportEvent) GetAgentEvent() *flow.AgentEvent { - if x, ok := x.GetResponseTypes().(*ExportEvent_AgentEvent); ok { - return x.AgentEvent + if x != nil { + if x, ok := x.ResponseTypes.(*ExportEvent_AgentEvent); ok { + return x.AgentEvent + } } return nil } func (x *ExportEvent) GetDebugEvent() *flow.DebugEvent { - if x, ok := x.GetResponseTypes().(*ExportEvent_DebugEvent); ok { - return x.DebugEvent + if x != nil { + if x, ok := x.ResponseTypes.(*ExportEvent_DebugEvent); ok { + return x.DebugEvent + } } return nil } @@ -1668,10 +1671,7 @@ func (*ExportEvent_DebugEvent) isExportEvent_ResponseTypes() {} // Experimental contains fields that are not stable yet. Support for // experimental features is always optional and subject to change. type GetFlowsRequest_Experimental struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // FieldMask allows clients to limit flow's fields that will be returned. // For example, {paths: ["source.id", "destination.id"]} will return flows // with only these two fields set. @@ -1679,7 +1679,9 @@ type GetFlowsRequest_Experimental struct { // removed in v1.17. // // Deprecated: Marked as deprecated in observer/observer.proto. - FieldMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"` + FieldMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetFlowsRequest_Experimental) Reset() { diff --git a/vendor/github.com/cilium/cilium/api/v1/observer/observer_grpc.pb.go b/vendor/github.com/cilium/cilium/api/v1/observer/observer_grpc.pb.go index 8f2b6267a..e43b2d579 100644 --- a/vendor/github.com/cilium/cilium/api/v1/observer/observer_grpc.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/observer/observer_grpc.pb.go @@ -4,7 +4,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.29.1 +// - protoc v5.29.3 // source: observer/observer.proto package observer diff --git a/vendor/github.com/cilium/cilium/api/v1/peer/peer.pb.go b/vendor/github.com/cilium/cilium/api/v1/peer/peer.pb.go index c26188cac..64fc0dc3f 100644 --- a/vendor/github.com/cilium/cilium/api/v1/peer/peer.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/peer/peer.pb.go @@ -3,8 +3,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 -// protoc v5.29.1 +// protoc-gen-go v1.36.3 +// protoc v5.29.3 // source: peer/peer.proto package peer @@ -77,9 +77,9 @@ func (ChangeNotificationType) EnumDescriptor() ([]byte, []int) { } type NotifyRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *NotifyRequest) Reset() { @@ -114,10 +114,7 @@ func (*NotifyRequest) Descriptor() ([]byte, []int) { // ChangeNotification indicates a change regarding a hubble peer. type ChangeNotification struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Name is the name of the peer, typically the hostname. The name includes // the cluster name if a value other than default has been specified. // This value can be used to uniquely identify the host. @@ -135,7 +132,9 @@ type ChangeNotification struct { Type ChangeNotificationType `protobuf:"varint,3,opt,name=type,proto3,enum=peer.ChangeNotificationType" json:"type,omitempty"` // TLS provides information to connect to the Address with TLS enabled. // If not set, TLS shall be assumed to be disabled. - Tls *TLS `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"` + Tls *TLS `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *ChangeNotification) Reset() { @@ -198,12 +197,11 @@ func (x *ChangeNotification) GetTls() *TLS { // TLS provides information to establish a TLS connection to the peer. type TLS struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // ServerName is used to verify the hostname on the returned certificate. - ServerName string `protobuf:"bytes,1,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + ServerName string `protobuf:"bytes,1,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TLS) Reset() { diff --git a/vendor/github.com/cilium/cilium/api/v1/peer/peer_grpc.pb.go b/vendor/github.com/cilium/cilium/api/v1/peer/peer_grpc.pb.go index b627a8748..eee7d7211 100644 --- a/vendor/github.com/cilium/cilium/api/v1/peer/peer_grpc.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/peer/peer_grpc.pb.go @@ -4,7 +4,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.29.1 +// - protoc v5.29.3 // source: peer/peer.proto package peer diff --git a/vendor/github.com/cilium/cilium/api/v1/recorder/recorder.pb.go b/vendor/github.com/cilium/cilium/api/v1/recorder/recorder.pb.go index b37cd2b51..ce3abe6e7 100644 --- a/vendor/github.com/cilium/cilium/api/v1/recorder/recorder.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/recorder/recorder.pb.go @@ -3,8 +3,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 -// protoc v5.29.1 +// protoc-gen-go v1.36.3 +// protoc v5.29.3 // source: recorder/recorder.proto package recorder @@ -79,15 +79,14 @@ func (Protocol) EnumDescriptor() ([]byte, []int) { } type RecordRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to RequestType: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to RequestType: // // *RecordRequest_Start // *RecordRequest_Stop - RequestType isRecordRequest_RequestType `protobuf_oneof:"request_type"` + RequestType isRecordRequest_RequestType `protobuf_oneof:"request_type"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *RecordRequest) Reset() { @@ -120,23 +119,27 @@ func (*RecordRequest) Descriptor() ([]byte, []int) { return file_recorder_recorder_proto_rawDescGZIP(), []int{0} } -func (m *RecordRequest) GetRequestType() isRecordRequest_RequestType { - if m != nil { - return m.RequestType +func (x *RecordRequest) GetRequestType() isRecordRequest_RequestType { + if x != nil { + return x.RequestType } return nil } func (x *RecordRequest) GetStart() *StartRecording { - if x, ok := x.GetRequestType().(*RecordRequest_Start); ok { - return x.Start + if x != nil { + if x, ok := x.RequestType.(*RecordRequest_Start); ok { + return x.Start + } } return nil } func (x *RecordRequest) GetStop() *StopRecording { - if x, ok := x.GetRequestType().(*RecordRequest_Stop); ok { - return x.Stop + if x != nil { + if x, ok := x.RequestType.(*RecordRequest_Stop); ok { + return x.Stop + } } return nil } @@ -160,10 +163,7 @@ func (*RecordRequest_Start) isRecordRequest_RequestType() {} func (*RecordRequest_Stop) isRecordRequest_RequestType() {} type StartRecording struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // filesink configures the outfile of this recording // Future alternative sink configurations may be added as a // backwards-compatible change by moving this field into a oneof. @@ -177,6 +177,8 @@ type StartRecording struct { // stop_condition defines conditions which will cause the recording to // stop early after any of the stop conditions has been hit StopCondition *StopCondition `protobuf:"bytes,4,opt,name=stop_condition,json=stopCondition,proto3" json:"stop_condition,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *StartRecording) Reset() { @@ -242,10 +244,7 @@ func (x *StartRecording) GetStopCondition() *StopCondition { // absent or zero-valued. If multiple conditions are defined, the recording // stops after the first one is hit. type StopCondition struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // bytes_captured_count stops the recording after at least this many bytes // have been captured. Note: The resulting file might be slightly larger due // to added pcap headers. @@ -254,7 +253,9 @@ type StopCondition struct { // been captured. PacketsCapturedCount uint64 `protobuf:"varint,2,opt,name=packets_captured_count,json=packetsCapturedCount,proto3" json:"packets_captured_count,omitempty"` // time_elapsed stops the recording after this duration has elapsed. - TimeElapsed *durationpb.Duration `protobuf:"bytes,3,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"` + TimeElapsed *durationpb.Duration `protobuf:"bytes,3,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *StopCondition) Reset() { @@ -312,17 +313,16 @@ func (x *StopCondition) GetTimeElapsed() *durationpb.Duration { // might be the selection of the output volume. The initial implementation will // only support a single volume which is configured as a cilium-agent CLI flag. type FileSinkConfiguration struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // file_prefix is an optional prefix for the file name. // Defaults to `hubble` if empty. Must match the following regex if not // empty: ^[a-z][a-z0-9]{0,19}$ // The generated filename will be of format // // ___.pcap - FilePrefix string `protobuf:"bytes,1,opt,name=file_prefix,json=filePrefix,proto3" json:"file_prefix,omitempty"` + FilePrefix string `protobuf:"bytes,1,opt,name=file_prefix,json=filePrefix,proto3" json:"file_prefix,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *FileSinkConfiguration) Reset() { @@ -363,10 +363,7 @@ func (x *FileSinkConfiguration) GetFilePrefix() string { } type Filter struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // source_cidr. Must not be empty. // Set to 0.0.0.0/0 to match any IPv4 source address (::/0 for IPv6). SourceCidr string `protobuf:"bytes,1,opt,name=source_cidr,json=sourceCidr,proto3" json:"source_cidr,omitempty"` @@ -378,7 +375,9 @@ type Filter struct { // destination_port. Matches any destination port if empty. DestinationPort uint32 `protobuf:"varint,4,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` // protocol. Matches any protocol if empty. - Protocol Protocol `protobuf:"varint,5,opt,name=protocol,proto3,enum=recorder.Protocol" json:"protocol,omitempty"` + Protocol Protocol `protobuf:"varint,5,opt,name=protocol,proto3,enum=recorder.Protocol" json:"protocol,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Filter) Reset() { @@ -447,9 +446,9 @@ func (x *Filter) GetProtocol() Protocol { } type StopRecording struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *StopRecording) Reset() { @@ -483,10 +482,7 @@ func (*StopRecording) Descriptor() ([]byte, []int) { } type RecordResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // name of the node where this recording is happening NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // time at which this event was observed on the above node @@ -496,11 +492,13 @@ type RecordResponse struct { // It is a forward-compatible change to introduce additional more // granular or structured error responses here. // - // Types that are assignable to ResponseType: + // Types that are valid to be assigned to ResponseType: // // *RecordResponse_Running // *RecordResponse_Stopped - ResponseType isRecordResponse_ResponseType `protobuf_oneof:"response_type"` + ResponseType isRecordResponse_ResponseType `protobuf_oneof:"response_type"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *RecordResponse) Reset() { @@ -547,23 +545,27 @@ func (x *RecordResponse) GetTime() *timestamppb.Timestamp { return nil } -func (m *RecordResponse) GetResponseType() isRecordResponse_ResponseType { - if m != nil { - return m.ResponseType +func (x *RecordResponse) GetResponseType() isRecordResponse_ResponseType { + if x != nil { + return x.ResponseType } return nil } func (x *RecordResponse) GetRunning() *RecordingRunningResponse { - if x, ok := x.GetResponseType().(*RecordResponse_Running); ok { - return x.Running + if x != nil { + if x, ok := x.ResponseType.(*RecordResponse_Running); ok { + return x.Running + } } return nil } func (x *RecordResponse) GetStopped() *RecordingStoppedResponse { - if x, ok := x.GetResponseType().(*RecordResponse_Stopped); ok { - return x.Stopped + if x != nil { + if x, ok := x.ResponseType.(*RecordResponse_Stopped); ok { + return x.Stopped + } } return nil } @@ -588,10 +590,7 @@ func (*RecordResponse_Running) isRecordResponse_ResponseType() {} func (*RecordResponse_Stopped) isRecordResponse_ResponseType() {} type RecordingStatistics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // bytes_captured is the total amount of bytes captured in the recording BytesCaptured uint64 `protobuf:"varint,1,opt,name=bytes_captured,json=bytesCaptured,proto3" json:"bytes_captured,omitempty"` // packets_captured is the total amount of packets captured the recording @@ -601,7 +600,9 @@ type RecordingStatistics struct { PacketsLost uint64 `protobuf:"varint,3,opt,name=packets_lost,json=packetsLost,proto3" json:"packets_lost,omitempty"` // bytes_lost is the total amount of bytes matching the filter during // the recording, but never written to the sink because it was overloaded. - BytesLost uint64 `protobuf:"varint,4,opt,name=bytes_lost,json=bytesLost,proto3" json:"bytes_lost,omitempty"` + BytesLost uint64 `protobuf:"varint,4,opt,name=bytes_lost,json=bytesLost,proto3" json:"bytes_lost,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *RecordingStatistics) Reset() { @@ -663,12 +664,11 @@ func (x *RecordingStatistics) GetBytesLost() uint64 { } type RecordingRunningResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // stats for the running recording - Stats *RecordingStatistics `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` + Stats *RecordingStatistics `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *RecordingRunningResponse) Reset() { @@ -709,14 +709,13 @@ func (x *RecordingRunningResponse) GetStats() *RecordingStatistics { } type RecordingStoppedResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // stats for the recording Stats *RecordingStatistics `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // filesink contains the path to the captured file - Filesink *FileSinkResult `protobuf:"bytes,2,opt,name=filesink,proto3" json:"filesink,omitempty"` + Filesink *FileSinkResult `protobuf:"bytes,2,opt,name=filesink,proto3" json:"filesink,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *RecordingStoppedResponse) Reset() { @@ -764,12 +763,11 @@ func (x *RecordingStoppedResponse) GetFilesink() *FileSinkResult { } type FileSinkResult struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // file_path is the absolute path to the captured pcap file - FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"` + FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *FileSinkResult) Reset() { diff --git a/vendor/github.com/cilium/cilium/api/v1/recorder/recorder_grpc.pb.go b/vendor/github.com/cilium/cilium/api/v1/recorder/recorder_grpc.pb.go index 867e4e33c..2ede983bb 100644 --- a/vendor/github.com/cilium/cilium/api/v1/recorder/recorder_grpc.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/recorder/recorder_grpc.pb.go @@ -4,7 +4,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.29.1 +// - protoc v5.29.3 // source: recorder/recorder.proto package recorder diff --git a/vendor/github.com/cilium/cilium/api/v1/relay/relay.pb.go b/vendor/github.com/cilium/cilium/api/v1/relay/relay.pb.go index 3238ac08e..abf656c07 100644 --- a/vendor/github.com/cilium/cilium/api/v1/relay/relay.pb.go +++ b/vendor/github.com/cilium/cilium/api/v1/relay/relay.pb.go @@ -3,8 +3,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 -// protoc v5.29.1 +// protoc-gen-go v1.36.3 +// protoc v5.29.3 // source: relay/relay.proto package relay @@ -92,17 +92,16 @@ func (NodeState) EnumDescriptor() ([]byte, []int) { // NodeStatusEvent is a message sent by hubble-relay to inform clients about // the state of a particular node. type NodeStatusEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // state_change contains the new node state StateChange NodeState `protobuf:"varint,1,opt,name=state_change,json=stateChange,proto3,enum=relay.NodeState" json:"state_change,omitempty"` // node_names is the list of nodes for which the above state changes applies NodeNames []string `protobuf:"bytes,2,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"` // message is an optional message attached to the state change (e.g. an // error message). The message applies to all nodes in node_names. - Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` + Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *NodeStatusEvent) Reset() { diff --git a/vendor/github.com/cilium/cilium/pkg/monitor/api/types.go b/vendor/github.com/cilium/cilium/pkg/monitor/api/types.go index 94afb9492..364b2bfb5 100644 --- a/vendor/github.com/cilium/cilium/pkg/monitor/api/types.go +++ b/vendor/github.com/cilium/cilium/pkg/monitor/api/types.go @@ -455,8 +455,9 @@ type ServiceUpsertNotificationAddr struct { type ServiceUpsertNotification struct { ID uint32 `json:"id"` - Frontend ServiceUpsertNotificationAddr `json:"frontend-address"` - Backends []ServiceUpsertNotificationAddr `json:"backend-addresses"` + Frontend ServiceUpsertNotificationAddr `json:"frontend-address"` + Backends []ServiceUpsertNotificationAddr `json:"backend-addresses"` + NumBackendsOmitted int `json:"num-backends-omitted,omitempty"` Type string `json:"type,omitempty"` // Deprecated: superseded by ExtTrafficPolicy. @@ -473,18 +474,20 @@ func ServiceUpsertMessage( id uint32, frontend ServiceUpsertNotificationAddr, backends []ServiceUpsertNotificationAddr, + numBackendsOmitted int, svcType, svcExtTrafficPolicy, svcIntTrafficPolicy, svcName, svcNamespace string, ) AgentNotifyMessage { notification := ServiceUpsertNotification{ - ID: id, - Frontend: frontend, - Backends: backends, - Type: svcType, - TrafficPolicy: svcExtTrafficPolicy, - ExtTrafficPolicy: svcExtTrafficPolicy, - IntTrafficPolicy: svcIntTrafficPolicy, - Name: svcName, - Namespace: svcNamespace, + ID: id, + Frontend: frontend, + Backends: backends, + NumBackendsOmitted: numBackendsOmitted, + Type: svcType, + TrafficPolicy: svcExtTrafficPolicy, + ExtTrafficPolicy: svcExtTrafficPolicy, + IntTrafficPolicy: svcIntTrafficPolicy, + Name: svcName, + Namespace: svcNamespace, } return AgentNotifyMessage{ diff --git a/vendor/modules.txt b/vendor/modules.txt index 41b785154..ccfe7e735 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -7,7 +7,7 @@ github.com/asaskevich/govalidator # github.com/blang/semver/v4 v4.0.0 ## explicit; go 1.14 github.com/blang/semver/v4 -# github.com/cilium/cilium v1.16.5 +# github.com/cilium/cilium v1.16.6 ## explicit; go 1.22.0 github.com/cilium/cilium/api/v1/flow github.com/cilium/cilium/api/v1/models