1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package v1
22
23 import (
24 v1 "go.opentelemetry.io/proto/otlp/logs/v1"
25 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
26 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
27 reflect "reflect"
28 sync "sync"
29 )
30
31 const (
32
33 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
34
35 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
36 )
37
38 type ExportLogsServiceRequest struct {
39 state protoimpl.MessageState
40 sizeCache protoimpl.SizeCache
41 unknownFields protoimpl.UnknownFields
42
43
44
45
46
47
48 ResourceLogs []*v1.ResourceLogs `protobuf:"bytes,1,rep,name=resource_logs,json=resourceLogs,proto3" json:"resource_logs,omitempty"`
49 }
50
51 func (x *ExportLogsServiceRequest) Reset() {
52 *x = ExportLogsServiceRequest{}
53 if protoimpl.UnsafeEnabled {
54 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[0]
55 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
56 ms.StoreMessageInfo(mi)
57 }
58 }
59
60 func (x *ExportLogsServiceRequest) String() string {
61 return protoimpl.X.MessageStringOf(x)
62 }
63
64 func (*ExportLogsServiceRequest) ProtoMessage() {}
65
66 func (x *ExportLogsServiceRequest) ProtoReflect() protoreflect.Message {
67 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[0]
68 if protoimpl.UnsafeEnabled && x != nil {
69 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
70 if ms.LoadMessageInfo() == nil {
71 ms.StoreMessageInfo(mi)
72 }
73 return ms
74 }
75 return mi.MessageOf(x)
76 }
77
78
79 func (*ExportLogsServiceRequest) Descriptor() ([]byte, []int) {
80 return file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescGZIP(), []int{0}
81 }
82
83 func (x *ExportLogsServiceRequest) GetResourceLogs() []*v1.ResourceLogs {
84 if x != nil {
85 return x.ResourceLogs
86 }
87 return nil
88 }
89
90 type ExportLogsServiceResponse struct {
91 state protoimpl.MessageState
92 sizeCache protoimpl.SizeCache
93 unknownFields protoimpl.UnknownFields
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110 PartialSuccess *ExportLogsPartialSuccess `protobuf:"bytes,1,opt,name=partial_success,json=partialSuccess,proto3" json:"partial_success,omitempty"`
111 }
112
113 func (x *ExportLogsServiceResponse) Reset() {
114 *x = ExportLogsServiceResponse{}
115 if protoimpl.UnsafeEnabled {
116 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[1]
117 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
118 ms.StoreMessageInfo(mi)
119 }
120 }
121
122 func (x *ExportLogsServiceResponse) String() string {
123 return protoimpl.X.MessageStringOf(x)
124 }
125
126 func (*ExportLogsServiceResponse) ProtoMessage() {}
127
128 func (x *ExportLogsServiceResponse) ProtoReflect() protoreflect.Message {
129 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[1]
130 if protoimpl.UnsafeEnabled && x != nil {
131 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
132 if ms.LoadMessageInfo() == nil {
133 ms.StoreMessageInfo(mi)
134 }
135 return ms
136 }
137 return mi.MessageOf(x)
138 }
139
140
141 func (*ExportLogsServiceResponse) Descriptor() ([]byte, []int) {
142 return file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescGZIP(), []int{1}
143 }
144
145 func (x *ExportLogsServiceResponse) GetPartialSuccess() *ExportLogsPartialSuccess {
146 if x != nil {
147 return x.PartialSuccess
148 }
149 return nil
150 }
151
152 type ExportLogsPartialSuccess struct {
153 state protoimpl.MessageState
154 sizeCache protoimpl.SizeCache
155 unknownFields protoimpl.UnknownFields
156
157
158
159
160
161 RejectedLogRecords int64 `protobuf:"varint,1,opt,name=rejected_log_records,json=rejectedLogRecords,proto3" json:"rejected_log_records,omitempty"`
162
163
164
165
166
167
168
169 ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
170 }
171
172 func (x *ExportLogsPartialSuccess) Reset() {
173 *x = ExportLogsPartialSuccess{}
174 if protoimpl.UnsafeEnabled {
175 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[2]
176 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
177 ms.StoreMessageInfo(mi)
178 }
179 }
180
181 func (x *ExportLogsPartialSuccess) String() string {
182 return protoimpl.X.MessageStringOf(x)
183 }
184
185 func (*ExportLogsPartialSuccess) ProtoMessage() {}
186
187 func (x *ExportLogsPartialSuccess) ProtoReflect() protoreflect.Message {
188 mi := &file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[2]
189 if protoimpl.UnsafeEnabled && x != nil {
190 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
191 if ms.LoadMessageInfo() == nil {
192 ms.StoreMessageInfo(mi)
193 }
194 return ms
195 }
196 return mi.MessageOf(x)
197 }
198
199
200 func (*ExportLogsPartialSuccess) Descriptor() ([]byte, []int) {
201 return file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescGZIP(), []int{2}
202 }
203
204 func (x *ExportLogsPartialSuccess) GetRejectedLogRecords() int64 {
205 if x != nil {
206 return x.RejectedLogRecords
207 }
208 return 0
209 }
210
211 func (x *ExportLogsPartialSuccess) GetErrorMessage() string {
212 if x != nil {
213 return x.ErrorMessage
214 }
215 return ""
216 }
217
218 var File_opentelemetry_proto_collector_logs_v1_logs_service_proto protoreflect.FileDescriptor
219
220 var file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDesc = []byte{
221 0x0a, 0x38, 0x6f, 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2f,
222 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2f,
223 0x6c, 0x6f, 0x67, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x6c, 0x6f, 0x67, 0x73, 0x5f, 0x73, 0x65, 0x72,
224 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x6f, 0x70, 0x65, 0x6e,
225 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e,
226 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x6c, 0x6f, 0x67, 0x73, 0x2e, 0x76,
227 0x31, 0x1a, 0x26, 0x6f, 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79,
228 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x6c, 0x6f, 0x67, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x6c,
229 0x6f, 0x67, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x6a, 0x0a, 0x18, 0x45, 0x78, 0x70,
230 0x6f, 0x72, 0x74, 0x4c, 0x6f, 0x67, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65,
231 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
232 0x65, 0x5f, 0x6c, 0x6f, 0x67, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x6f,
233 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f,
234 0x74, 0x6f, 0x2e, 0x6c, 0x6f, 0x67, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x6f, 0x75,
235 0x72, 0x63, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
236 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x22, 0x85, 0x01, 0x0a, 0x19, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74,
237 0x4c, 0x6f, 0x67, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f,
238 0x6e, 0x73, 0x65, 0x12, 0x68, 0x0a, 0x0f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x61, 0x6c, 0x5f, 0x73,
239 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3f, 0x2e, 0x6f,
240 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f,
241 0x74, 0x6f, 0x2e, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x6c, 0x6f, 0x67,
242 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x4c, 0x6f, 0x67, 0x73, 0x50,
243 0x61, 0x72, 0x74, 0x69, 0x61, 0x6c, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x52, 0x0e, 0x70,
244 0x61, 0x72, 0x74, 0x69, 0x61, 0x6c, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x22, 0x71, 0x0a,
245 0x18, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x4c, 0x6f, 0x67, 0x73, 0x50, 0x61, 0x72, 0x74, 0x69,
246 0x61, 0x6c, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x72, 0x65, 0x6a,
247 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x6c, 0x6f, 0x67, 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64,
248 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x12, 0x72, 0x65, 0x6a, 0x65, 0x63, 0x74, 0x65,
249 0x64, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x65,
250 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01,
251 0x28, 0x09, 0x52, 0x0c, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
252 0x32, 0x9d, 0x01, 0x0a, 0x0b, 0x4c, 0x6f, 0x67, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
253 0x12, 0x8d, 0x01, 0x0a, 0x06, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x3f, 0x2e, 0x6f, 0x70,
254 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74,
255 0x6f, 0x2e, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x6c, 0x6f, 0x67, 0x73,
256 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x4c, 0x6f, 0x67, 0x73, 0x53, 0x65,
257 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x40, 0x2e, 0x6f,
258 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f,
259 0x74, 0x6f, 0x2e, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x6c, 0x6f, 0x67,
260 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x4c, 0x6f, 0x67, 0x73, 0x53,
261 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00,
262 0x42, 0x98, 0x01, 0x0a, 0x28, 0x69, 0x6f, 0x2e, 0x6f, 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65,
263 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x63, 0x6f, 0x6c, 0x6c,
264 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x6c, 0x6f, 0x67, 0x73, 0x2e, 0x76, 0x31, 0x42, 0x10, 0x4c,
265 0x6f, 0x67, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50,
266 0x01, 0x5a, 0x30, 0x67, 0x6f, 0x2e, 0x6f, 0x70, 0x65, 0x6e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65,
267 0x74, 0x72, 0x79, 0x2e, 0x69, 0x6f, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x6f, 0x74, 0x6c,
268 0x70, 0x2f, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2f, 0x6c, 0x6f, 0x67, 0x73,
269 0x2f, 0x76, 0x31, 0xaa, 0x02, 0x25, 0x4f, 0x70, 0x65, 0x6e, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65,
270 0x74, 0x72, 0x79, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x6f, 0x6c, 0x6c, 0x65, 0x63,
271 0x74, 0x6f, 0x72, 0x2e, 0x4c, 0x6f, 0x67, 0x73, 0x2e, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f,
272 0x74, 0x6f, 0x33,
273 }
274
275 var (
276 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescOnce sync.Once
277 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescData = file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDesc
278 )
279
280 func file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescGZIP() []byte {
281 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescOnce.Do(func() {
282 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescData)
283 })
284 return file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDescData
285 }
286
287 var file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
288 var file_opentelemetry_proto_collector_logs_v1_logs_service_proto_goTypes = []interface{}{
289 (*ExportLogsServiceRequest)(nil),
290 (*ExportLogsServiceResponse)(nil),
291 (*ExportLogsPartialSuccess)(nil),
292 (*v1.ResourceLogs)(nil),
293 }
294 var file_opentelemetry_proto_collector_logs_v1_logs_service_proto_depIdxs = []int32{
295 3,
296 2,
297 0,
298 1,
299 3,
300 2,
301 2,
302 2,
303 0,
304 }
305
306 func init() { file_opentelemetry_proto_collector_logs_v1_logs_service_proto_init() }
307 func file_opentelemetry_proto_collector_logs_v1_logs_service_proto_init() {
308 if File_opentelemetry_proto_collector_logs_v1_logs_service_proto != nil {
309 return
310 }
311 if !protoimpl.UnsafeEnabled {
312 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
313 switch v := v.(*ExportLogsServiceRequest); i {
314 case 0:
315 return &v.state
316 case 1:
317 return &v.sizeCache
318 case 2:
319 return &v.unknownFields
320 default:
321 return nil
322 }
323 }
324 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
325 switch v := v.(*ExportLogsServiceResponse); i {
326 case 0:
327 return &v.state
328 case 1:
329 return &v.sizeCache
330 case 2:
331 return &v.unknownFields
332 default:
333 return nil
334 }
335 }
336 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
337 switch v := v.(*ExportLogsPartialSuccess); i {
338 case 0:
339 return &v.state
340 case 1:
341 return &v.sizeCache
342 case 2:
343 return &v.unknownFields
344 default:
345 return nil
346 }
347 }
348 }
349 type x struct{}
350 out := protoimpl.TypeBuilder{
351 File: protoimpl.DescBuilder{
352 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
353 RawDescriptor: file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDesc,
354 NumEnums: 0,
355 NumMessages: 3,
356 NumExtensions: 0,
357 NumServices: 1,
358 },
359 GoTypes: file_opentelemetry_proto_collector_logs_v1_logs_service_proto_goTypes,
360 DependencyIndexes: file_opentelemetry_proto_collector_logs_v1_logs_service_proto_depIdxs,
361 MessageInfos: file_opentelemetry_proto_collector_logs_v1_logs_service_proto_msgTypes,
362 }.Build()
363 File_opentelemetry_proto_collector_logs_v1_logs_service_proto = out.File
364 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_rawDesc = nil
365 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_goTypes = nil
366 file_opentelemetry_proto_collector_logs_v1_logs_service_proto_depIdxs = nil
367 }
368
View as plain text