1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package core
22
23 import (
24 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
25 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
26 reflect "reflect"
27 sync "sync"
28 )
29
30 const (
31
32 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
33
34 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
35 )
36
37 type Bucket struct {
38 state protoimpl.MessageState
39 sizeCache protoimpl.SizeCache
40 unknownFields protoimpl.UnknownFields
41
42 Start float64 `protobuf:"fixed64,1,opt,name=start,proto3" json:"start,omitempty"`
43 Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
44 }
45
46 func (x *Bucket) Reset() {
47 *x = Bucket{}
48 if protoimpl.UnsafeEnabled {
49 mi := &file_grpc_core_stats_proto_msgTypes[0]
50 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
51 ms.StoreMessageInfo(mi)
52 }
53 }
54
55 func (x *Bucket) String() string {
56 return protoimpl.X.MessageStringOf(x)
57 }
58
59 func (*Bucket) ProtoMessage() {}
60
61 func (x *Bucket) ProtoReflect() protoreflect.Message {
62 mi := &file_grpc_core_stats_proto_msgTypes[0]
63 if protoimpl.UnsafeEnabled && x != nil {
64 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
65 if ms.LoadMessageInfo() == nil {
66 ms.StoreMessageInfo(mi)
67 }
68 return ms
69 }
70 return mi.MessageOf(x)
71 }
72
73
74 func (*Bucket) Descriptor() ([]byte, []int) {
75 return file_grpc_core_stats_proto_rawDescGZIP(), []int{0}
76 }
77
78 func (x *Bucket) GetStart() float64 {
79 if x != nil {
80 return x.Start
81 }
82 return 0
83 }
84
85 func (x *Bucket) GetCount() uint64 {
86 if x != nil {
87 return x.Count
88 }
89 return 0
90 }
91
92 type Histogram struct {
93 state protoimpl.MessageState
94 sizeCache protoimpl.SizeCache
95 unknownFields protoimpl.UnknownFields
96
97 Buckets []*Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
98 }
99
100 func (x *Histogram) Reset() {
101 *x = Histogram{}
102 if protoimpl.UnsafeEnabled {
103 mi := &file_grpc_core_stats_proto_msgTypes[1]
104 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
105 ms.StoreMessageInfo(mi)
106 }
107 }
108
109 func (x *Histogram) String() string {
110 return protoimpl.X.MessageStringOf(x)
111 }
112
113 func (*Histogram) ProtoMessage() {}
114
115 func (x *Histogram) ProtoReflect() protoreflect.Message {
116 mi := &file_grpc_core_stats_proto_msgTypes[1]
117 if protoimpl.UnsafeEnabled && x != nil {
118 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
119 if ms.LoadMessageInfo() == nil {
120 ms.StoreMessageInfo(mi)
121 }
122 return ms
123 }
124 return mi.MessageOf(x)
125 }
126
127
128 func (*Histogram) Descriptor() ([]byte, []int) {
129 return file_grpc_core_stats_proto_rawDescGZIP(), []int{1}
130 }
131
132 func (x *Histogram) GetBuckets() []*Bucket {
133 if x != nil {
134 return x.Buckets
135 }
136 return nil
137 }
138
139 type Metric struct {
140 state protoimpl.MessageState
141 sizeCache protoimpl.SizeCache
142 unknownFields protoimpl.UnknownFields
143
144 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
145
146
147
148
149 Value isMetric_Value `protobuf_oneof:"value"`
150 }
151
152 func (x *Metric) Reset() {
153 *x = Metric{}
154 if protoimpl.UnsafeEnabled {
155 mi := &file_grpc_core_stats_proto_msgTypes[2]
156 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
157 ms.StoreMessageInfo(mi)
158 }
159 }
160
161 func (x *Metric) String() string {
162 return protoimpl.X.MessageStringOf(x)
163 }
164
165 func (*Metric) ProtoMessage() {}
166
167 func (x *Metric) ProtoReflect() protoreflect.Message {
168 mi := &file_grpc_core_stats_proto_msgTypes[2]
169 if protoimpl.UnsafeEnabled && x != nil {
170 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
171 if ms.LoadMessageInfo() == nil {
172 ms.StoreMessageInfo(mi)
173 }
174 return ms
175 }
176 return mi.MessageOf(x)
177 }
178
179
180 func (*Metric) Descriptor() ([]byte, []int) {
181 return file_grpc_core_stats_proto_rawDescGZIP(), []int{2}
182 }
183
184 func (x *Metric) GetName() string {
185 if x != nil {
186 return x.Name
187 }
188 return ""
189 }
190
191 func (m *Metric) GetValue() isMetric_Value {
192 if m != nil {
193 return m.Value
194 }
195 return nil
196 }
197
198 func (x *Metric) GetCount() uint64 {
199 if x, ok := x.GetValue().(*Metric_Count); ok {
200 return x.Count
201 }
202 return 0
203 }
204
205 func (x *Metric) GetHistogram() *Histogram {
206 if x, ok := x.GetValue().(*Metric_Histogram); ok {
207 return x.Histogram
208 }
209 return nil
210 }
211
212 type isMetric_Value interface {
213 isMetric_Value()
214 }
215
216 type Metric_Count struct {
217 Count uint64 `protobuf:"varint,10,opt,name=count,proto3,oneof"`
218 }
219
220 type Metric_Histogram struct {
221 Histogram *Histogram `protobuf:"bytes,11,opt,name=histogram,proto3,oneof"`
222 }
223
224 func (*Metric_Count) isMetric_Value() {}
225
226 func (*Metric_Histogram) isMetric_Value() {}
227
228 type Stats struct {
229 state protoimpl.MessageState
230 sizeCache protoimpl.SizeCache
231 unknownFields protoimpl.UnknownFields
232
233 Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
234 }
235
236 func (x *Stats) Reset() {
237 *x = Stats{}
238 if protoimpl.UnsafeEnabled {
239 mi := &file_grpc_core_stats_proto_msgTypes[3]
240 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
241 ms.StoreMessageInfo(mi)
242 }
243 }
244
245 func (x *Stats) String() string {
246 return protoimpl.X.MessageStringOf(x)
247 }
248
249 func (*Stats) ProtoMessage() {}
250
251 func (x *Stats) ProtoReflect() protoreflect.Message {
252 mi := &file_grpc_core_stats_proto_msgTypes[3]
253 if protoimpl.UnsafeEnabled && x != nil {
254 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
255 if ms.LoadMessageInfo() == nil {
256 ms.StoreMessageInfo(mi)
257 }
258 return ms
259 }
260 return mi.MessageOf(x)
261 }
262
263
264 func (*Stats) Descriptor() ([]byte, []int) {
265 return file_grpc_core_stats_proto_rawDescGZIP(), []int{3}
266 }
267
268 func (x *Stats) GetMetrics() []*Metric {
269 if x != nil {
270 return x.Metrics
271 }
272 return nil
273 }
274
275 var File_grpc_core_stats_proto protoreflect.FileDescriptor
276
277 var file_grpc_core_stats_proto_rawDesc = []byte{
278 0x0a, 0x15, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x73, 0x74, 0x61, 0x74,
279 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x09, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x63, 0x6f,
280 0x72, 0x65, 0x22, 0x34, 0x0a, 0x06, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x14, 0x0a, 0x05,
281 0x73, 0x74, 0x61, 0x72, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x01, 0x52, 0x05, 0x73, 0x74, 0x61,
282 0x72, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28,
283 0x04, 0x52, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x38, 0x0a, 0x09, 0x48, 0x69, 0x73, 0x74,
284 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x12, 0x2b, 0x0a, 0x07, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73,
285 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x63, 0x6f,
286 0x72, 0x65, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x07, 0x62, 0x75, 0x63, 0x6b, 0x65,
287 0x74, 0x73, 0x22, 0x73, 0x0a, 0x06, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x12, 0x12, 0x0a, 0x04,
288 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
289 0x12, 0x16, 0x0a, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x04, 0x48,
290 0x00, 0x52, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x34, 0x0a, 0x09, 0x68, 0x69, 0x73, 0x74,
291 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72,
292 0x70, 0x63, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61,
293 0x6d, 0x48, 0x00, 0x52, 0x09, 0x68, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x42, 0x07,
294 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x34, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x73,
295 0x12, 0x2b, 0x0a, 0x07, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
296 0x0b, 0x32, 0x11, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x4d, 0x65,
297 0x74, 0x72, 0x69, 0x63, 0x52, 0x07, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x62, 0x06, 0x70,
298 0x72, 0x6f, 0x74, 0x6f, 0x33,
299 }
300
301 var (
302 file_grpc_core_stats_proto_rawDescOnce sync.Once
303 file_grpc_core_stats_proto_rawDescData = file_grpc_core_stats_proto_rawDesc
304 )
305
306 func file_grpc_core_stats_proto_rawDescGZIP() []byte {
307 file_grpc_core_stats_proto_rawDescOnce.Do(func() {
308 file_grpc_core_stats_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_core_stats_proto_rawDescData)
309 })
310 return file_grpc_core_stats_proto_rawDescData
311 }
312
313 var file_grpc_core_stats_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
314 var file_grpc_core_stats_proto_goTypes = []interface{}{
315 (*Bucket)(nil),
316 (*Histogram)(nil),
317 (*Metric)(nil),
318 (*Stats)(nil),
319 }
320 var file_grpc_core_stats_proto_depIdxs = []int32{
321 0,
322 1,
323 2,
324 3,
325 3,
326 3,
327 3,
328 0,
329 }
330
331 func init() { file_grpc_core_stats_proto_init() }
332 func file_grpc_core_stats_proto_init() {
333 if File_grpc_core_stats_proto != nil {
334 return
335 }
336 if !protoimpl.UnsafeEnabled {
337 file_grpc_core_stats_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
338 switch v := v.(*Bucket); i {
339 case 0:
340 return &v.state
341 case 1:
342 return &v.sizeCache
343 case 2:
344 return &v.unknownFields
345 default:
346 return nil
347 }
348 }
349 file_grpc_core_stats_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
350 switch v := v.(*Histogram); i {
351 case 0:
352 return &v.state
353 case 1:
354 return &v.sizeCache
355 case 2:
356 return &v.unknownFields
357 default:
358 return nil
359 }
360 }
361 file_grpc_core_stats_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
362 switch v := v.(*Metric); i {
363 case 0:
364 return &v.state
365 case 1:
366 return &v.sizeCache
367 case 2:
368 return &v.unknownFields
369 default:
370 return nil
371 }
372 }
373 file_grpc_core_stats_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
374 switch v := v.(*Stats); i {
375 case 0:
376 return &v.state
377 case 1:
378 return &v.sizeCache
379 case 2:
380 return &v.unknownFields
381 default:
382 return nil
383 }
384 }
385 }
386 file_grpc_core_stats_proto_msgTypes[2].OneofWrappers = []interface{}{
387 (*Metric_Count)(nil),
388 (*Metric_Histogram)(nil),
389 }
390 type x struct{}
391 out := protoimpl.TypeBuilder{
392 File: protoimpl.DescBuilder{
393 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
394 RawDescriptor: file_grpc_core_stats_proto_rawDesc,
395 NumEnums: 0,
396 NumMessages: 4,
397 NumExtensions: 0,
398 NumServices: 0,
399 },
400 GoTypes: file_grpc_core_stats_proto_goTypes,
401 DependencyIndexes: file_grpc_core_stats_proto_depIdxs,
402 MessageInfos: file_grpc_core_stats_proto_msgTypes,
403 }.Build()
404 File_grpc_core_stats_proto = out.File
405 file_grpc_core_stats_proto_rawDesc = nil
406 file_grpc_core_stats_proto_goTypes = nil
407 file_grpc_core_stats_proto_depIdxs = nil
408 }
409
View as plain text