From cd597cb61e99a28f0c6912d03f53ad9fb7123257 Mon Sep 17 00:00:00 2001 From: "cilium-renovate[bot]" <134692979+cilium-renovate[bot]@users.noreply.github.com> Date: Mon, 13 Jan 2025 09:15:40 +0000 Subject: [PATCH] fix(deps): update all go dependencies main Signed-off-by: cilium-renovate[bot] <134692979+cilium-renovate[bot]@users.noreply.github.com> --- api/go.mod | 2 +- api/go.sum | 4 +- api/vendor/google.golang.org/grpc/version.go | 2 +- api/vendor/modules.txt | 2 +- contrib/tetragon-rthooks/go.mod | 2 +- contrib/tetragon-rthooks/go.sum | 4 +- .../vendor/google.golang.org/grpc/version.go | 2 +- contrib/tetragon-rthooks/vendor/modules.txt | 2 +- go.mod | 4 +- go.sum | 8 +- vendor/github.com/cilium/cilium/AUTHORS | 3 +- .../cilium/cilium/api/v1/flow/flow.pb.go | 559 +++++++++--------- vendor/google.golang.org/grpc/version.go | 2 +- vendor/modules.txt | 4 +- 14 files changed, 297 insertions(+), 303 deletions(-) diff --git a/api/go.mod b/api/go.mod index 1ec670a17f6..f7362d425ea 100644 --- a/api/go.mod +++ b/api/go.mod @@ -9,7 +9,7 @@ require ( github.com/cilium/tetragon v0.0.0-00010101000000-000000000000 github.com/sirupsen/logrus v1.9.3 github.com/stretchr/testify v1.10.0 - google.golang.org/grpc v1.69.2 + google.golang.org/grpc v1.69.4 google.golang.org/protobuf v1.36.2 sigs.k8s.io/yaml v1.4.0 ) diff --git a/api/go.sum b/api/go.sum index a50d2871fcd..72d835b2034 100644 --- a/api/go.sum +++ b/api/go.sum @@ -46,8 +46,8 @@ golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo= golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ= google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576 h1:8ZmaLZE4XWrtU3MyClkYqqtl6Oegr3235h7jxsDyqCY= google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576/go.mod h1:5uTbfoYQed2U9p3KIj2/Zzm02PYhndfdmML0qC3q3FU= -google.golang.org/grpc v1.69.2 h1:U3S9QEtbXC0bYNvRtcoklF3xGtLViumSYxWykJS+7AU= -google.golang.org/grpc v1.69.2/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= +google.golang.org/grpc v1.69.4 h1:MF5TftSMkd8GLw/m0KM6V8CMOCY6NZ1NQDPGFgbTt4A= +google.golang.org/grpc v1.69.4/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= google.golang.org/protobuf v1.36.2 h1:R8FeyR1/eLmkutZOM5CWghmo5itiG9z0ktFlTVLuTmU= google.golang.org/protobuf v1.36.2/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= diff --git a/api/vendor/google.golang.org/grpc/version.go b/api/vendor/google.golang.org/grpc/version.go index 6cbe116f247..d2bba7f3d9e 100644 --- a/api/vendor/google.golang.org/grpc/version.go +++ b/api/vendor/google.golang.org/grpc/version.go @@ -19,4 +19,4 @@ package grpc // Version is the current grpc version. -const Version = "1.69.2" +const Version = "1.69.4" diff --git a/api/vendor/modules.txt b/api/vendor/modules.txt index 9165ab41808..72840eb482e 100644 --- a/api/vendor/modules.txt +++ b/api/vendor/modules.txt @@ -38,7 +38,7 @@ golang.org/x/text/unicode/norm # google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576 ## explicit; go 1.21 google.golang.org/genproto/googleapis/rpc/status -# google.golang.org/grpc v1.69.2 +# google.golang.org/grpc v1.69.4 ## explicit; go 1.22 google.golang.org/grpc google.golang.org/grpc/attributes diff --git a/contrib/tetragon-rthooks/go.mod b/contrib/tetragon-rthooks/go.mod index 7c68cb55331..e513c87dcbc 100644 --- a/contrib/tetragon-rthooks/go.mod +++ b/contrib/tetragon-rthooks/go.mod @@ -18,7 +18,7 @@ require ( github.com/pelletier/go-toml v1.9.5 github.com/pelletier/go-toml/v2 v2.2.3 github.com/stretchr/testify v1.10.0 - google.golang.org/grpc v1.69.2 + google.golang.org/grpc v1.69.4 ) require ( diff --git a/contrib/tetragon-rthooks/go.sum b/contrib/tetragon-rthooks/go.sum index d774ecffbce..2e79c59dd8d 100644 --- a/contrib/tetragon-rthooks/go.sum +++ b/contrib/tetragon-rthooks/go.sum @@ -166,8 +166,8 @@ google.golang.org/genproto/googleapis/api v0.0.0-20241015192408-796eee8c2d53 h1: google.golang.org/genproto/googleapis/api v0.0.0-20241015192408-796eee8c2d53/go.mod h1:riSXTwQ4+nqmPGtobMFyW5FqVAmIs0St6VPp4Ug7CE4= google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576 h1:8ZmaLZE4XWrtU3MyClkYqqtl6Oegr3235h7jxsDyqCY= google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576/go.mod h1:5uTbfoYQed2U9p3KIj2/Zzm02PYhndfdmML0qC3q3FU= -google.golang.org/grpc v1.69.2 h1:U3S9QEtbXC0bYNvRtcoklF3xGtLViumSYxWykJS+7AU= -google.golang.org/grpc v1.69.2/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= +google.golang.org/grpc v1.69.4 h1:MF5TftSMkd8GLw/m0KM6V8CMOCY6NZ1NQDPGFgbTt4A= +google.golang.org/grpc v1.69.4/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= google.golang.org/protobuf v1.36.2 h1:R8FeyR1/eLmkutZOM5CWghmo5itiG9z0ktFlTVLuTmU= google.golang.org/protobuf v1.36.2/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= diff --git a/contrib/tetragon-rthooks/vendor/google.golang.org/grpc/version.go b/contrib/tetragon-rthooks/vendor/google.golang.org/grpc/version.go index 6cbe116f247..d2bba7f3d9e 100644 --- a/contrib/tetragon-rthooks/vendor/google.golang.org/grpc/version.go +++ b/contrib/tetragon-rthooks/vendor/google.golang.org/grpc/version.go @@ -19,4 +19,4 @@ package grpc // Version is the current grpc version. -const Version = "1.69.2" +const Version = "1.69.4" diff --git a/contrib/tetragon-rthooks/vendor/modules.txt b/contrib/tetragon-rthooks/vendor/modules.txt index 9781f740ad1..0dafa523b7a 100644 --- a/contrib/tetragon-rthooks/vendor/modules.txt +++ b/contrib/tetragon-rthooks/vendor/modules.txt @@ -214,7 +214,7 @@ google.golang.org/genproto/googleapis/api/expr/v1alpha1 # google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576 ## explicit; go 1.21 google.golang.org/genproto/googleapis/rpc/status -# google.golang.org/grpc v1.69.2 +# google.golang.org/grpc v1.69.4 ## explicit; go 1.22 google.golang.org/grpc google.golang.org/grpc/attributes diff --git a/go.mod b/go.mod index 788cf0c9814..795e8726a1b 100644 --- a/go.mod +++ b/go.mod @@ -8,7 +8,7 @@ toolchain go1.23.1 require ( github.com/alecthomas/kong v1.6.1 github.com/bombsimon/logrusr/v4 v4.1.0 - github.com/cilium/cilium v1.17.0-rc.0 + github.com/cilium/cilium v1.17.0-rc.1 github.com/cilium/ebpf v0.17.1 github.com/cilium/little-vm-helper v0.0.19 github.com/cilium/lumberjack/v2 v2.4.1 @@ -46,7 +46,7 @@ require ( golang.org/x/sys v0.29.0 golang.org/x/term v0.28.0 golang.org/x/time v0.9.0 - google.golang.org/grpc v1.69.2 + google.golang.org/grpc v1.69.4 google.golang.org/protobuf v1.36.2 gopkg.in/yaml.v3 v3.0.1 k8s.io/api v0.32.0 diff --git a/go.sum b/go.sum index c50f4a451a5..08eb30df952 100644 --- a/go.sum +++ b/go.sum @@ -38,8 +38,8 @@ github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= 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.17.0-rc.0 h1:hZOr+6rqHJ06vdjTZ/q1tOln2QxPSUQPdHrqVdqvbrg= -github.com/cilium/cilium v1.17.0-rc.0/go.mod h1:Z9TPDoKIIUfq8/U6KqGBFLYHPVbEXxHGdV1n4+FAZhw= +github.com/cilium/cilium v1.17.0-rc.1 h1:jUiwwJ2qyajW2YY8/sOqJSy8enMhClG4FT1Dq6MELTU= +github.com/cilium/cilium v1.17.0-rc.1/go.mod h1:UAK2rIorqcHHxtkCG33wcQ++jAtDUknXCa42hOvhrR4= github.com/cilium/ebpf v0.17.1 h1:G8mzU81R2JA1nE5/8SRubzqvBMmAmri2VL8BIZPWvV0= github.com/cilium/ebpf v0.17.1/go.mod h1:vay2FaYSmIlv3r8dNACd4mW/OCaZLJKJOo+IHBvCIO8= github.com/cilium/hive v0.0.0-20241213121623-605c1412b9b3 h1:RfmUH1ouzj0LzORYJRhp43e1rlGpx6GNv4NIRUakU2w= @@ -550,8 +550,8 @@ google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8 google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0= google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= google.golang.org/grpc v1.46.2/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= -google.golang.org/grpc v1.69.2 h1:U3S9QEtbXC0bYNvRtcoklF3xGtLViumSYxWykJS+7AU= -google.golang.org/grpc v1.69.2/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= +google.golang.org/grpc v1.69.4 h1:MF5TftSMkd8GLw/m0KM6V8CMOCY6NZ1NQDPGFgbTt4A= +google.golang.org/grpc v1.69.4/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM= diff --git a/vendor/github.com/cilium/cilium/AUTHORS b/vendor/github.com/cilium/cilium/AUTHORS index 4ae3420936d..0fae20c9626 100644 --- a/vendor/github.com/cilium/cilium/AUTHORS +++ b/vendor/github.com/cilium/cilium/AUTHORS @@ -30,6 +30,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 @@ -377,7 +378,7 @@ Ivan Makarychev i.makarychev@tinkoff.ru Ivar Lazzaro ivarlazzaro@gmail.com JabJ sajjadjafaribojd@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 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 a514552de48..199c59e375a 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.1 +// protoc v5.29.2 // 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"` @@ -1471,6 +1468,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() { @@ -1787,12 +1786,11 @@ func (x *Flow) GetIngressDeniedBy() []*Policy { } type FileInfo 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"` + Line uint32 `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Line uint32 `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"` + sizeCache protoimpl.SizeCache } func (x *FileInfo) Reset() { @@ -1840,18 +1838,17 @@ func (x *FileInfo) GetLine() uint32 { } 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() { @@ -1884,44 +1881,54 @@ func (*Layer4) Descriptor() ([]byte, []int) { return file_flow_flow_proto_rawDescGZIP(), []int{2} } -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 } @@ -1963,21 +1970,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() { @@ -2024,30 +2030,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 } @@ -2078,12 +2090,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() { @@ -2125,13 +2136,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() { @@ -2172,18 +2182,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() { @@ -2266,12 +2275,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() { @@ -2319,13 +2327,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() { @@ -2380,11 +2387,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. When "source_xlated" is set, the "source" field is populated // with the pre-translation source IP address. @@ -2393,7 +2397,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() { @@ -2462,12 +2468,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() { @@ -2515,19 +2520,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() { @@ -2624,12 +2628,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() { @@ -2677,12 +2680,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() { @@ -2730,12 +2732,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() { @@ -2783,12 +2784,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() { @@ -2836,15 +2836,14 @@ 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"` + Kind string `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,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"` - Kind string `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Policy) Reset() { @@ -2914,10 +2913,7 @@ func (x *Policy) GetKind() string { // 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"` @@ -2926,7 +2922,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() { @@ -2982,10 +2980,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"` @@ -2993,7 +2988,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() { @@ -3043,10 +3040,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 @@ -3142,7 +3136,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() { @@ -3450,10 +3446,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. @@ -3476,7 +3469,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() { @@ -3566,12 +3561,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() { @@ -3620,15 +3614,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() { @@ -3698,15 +3691,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() { @@ -3775,12 +3767,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() { @@ -3830,17 +3821,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() { @@ -3895,12 +3885,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 @@ -3910,7 +3897,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() { @@ -3950,65 +3939,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 } @@ -4070,12 +4075,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() { @@ -4123,11 +4127,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() { @@ -4168,13 +4171,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() { @@ -4229,13 +4231,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() { @@ -4290,15 +4291,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() { @@ -4367,18 +4367,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() { @@ -4468,12 +4467,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() { @@ -4521,10 +4519,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"` @@ -4535,6 +4530,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() { @@ -4632,11 +4629,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() { @@ -4677,12 +4673,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() { @@ -4730,18 +4725,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() { @@ -4833,10 +4827,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 @@ -4847,6 +4838,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/google.golang.org/grpc/version.go b/vendor/google.golang.org/grpc/version.go index 6cbe116f247..d2bba7f3d9e 100644 --- a/vendor/google.golang.org/grpc/version.go +++ b/vendor/google.golang.org/grpc/version.go @@ -19,4 +19,4 @@ package grpc // Version is the current grpc version. -const Version = "1.69.2" +const Version = "1.69.4" diff --git a/vendor/modules.txt b/vendor/modules.txt index 23a70bdcff0..7f7db5404cf 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -33,7 +33,7 @@ github.com/bombsimon/logrusr/v4 # github.com/cespare/xxhash/v2 v2.3.0 ## explicit; go 1.11 github.com/cespare/xxhash/v2 -# github.com/cilium/cilium v1.17.0-rc.0 +# github.com/cilium/cilium v1.17.0-rc.1 ## explicit; go 1.23.0 github.com/cilium/cilium/api/v1/flow github.com/cilium/cilium/api/v1/models @@ -703,7 +703,7 @@ google.golang.org/genproto/googleapis/api/expr/v1alpha1 # google.golang.org/genproto/googleapis/rpc v0.0.0-20241209162323-e6fa225c2576 ## explicit; go 1.21 google.golang.org/genproto/googleapis/rpc/status -# google.golang.org/grpc v1.69.2 +# google.golang.org/grpc v1.69.4 ## explicit; go 1.22 google.golang.org/grpc google.golang.org/grpc/attributes