You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This is the specification of the network flows format, used both internally and when exporting flows to Kafka.
7
+
8
8
The document is organized in two main categories: _Labels_ and regular _Fields_. This distinction only matters when querying Loki. This is because _Labels_, unlike _Fields_, must be used in link:https://grafana.com/docs/loki/latest/logql/log_queries/#log-stream-selector[stream selectors].
9
9
10
-
If you are reading this specification as a reference for the Kafka export feature, you must treat all _Labels_ and _Fields_ as regualr fields and ignore any distinctions between them that are specific to Loki.
10
+
If you are reading this specification as a reference for the Kafka export feature, you must treat all _Labels_ and _Fields_ as regular fields and ignore any distinctions between them that are specific to Loki.
11
11
12
12
13
13
== Labels
14
14
15
-
'''
16
15
17
16
SrcK8S_Namespace::
18
17
@@ -48,7 +47,7 @@ Destination owner, such as Deployment, StatefulSet, etc.
48
47
49
48
FlowDirection::
50
49
51
-
• *FlowDirection*: see the following section, _Enumeration: FlowDirection_ for more details.
50
+
• *FlowDirection*: `FlowDirection` (see the following section, Enumeration: FlowDirection)
52
51
53
52
Flow direction from the node observation point
54
53
@@ -61,9 +60,9 @@ _RecordType::
61
60
Type of record: 'flowLog' for regular flow logs, or 'allConnections',
62
61
'newConnection', 'heartbeat', 'endConnection' for conversation tracking
63
62
63
+
64
64
== Fields
65
65
66
-
'''
67
66
68
67
SrcAddr::
69
68
@@ -131,15 +130,15 @@ Kind of the destination matched Kubernetes object, such as Pod name, Service nam
131
130
132
131
SrcPort::
133
132
134
-
• *SrcPort*: `number`
133
+
• `Optional` *SrcPort*: `number`
135
134
136
135
Source port
137
136
138
137
'''
139
138
140
139
DstPort::
141
140
142
-
• *DstPort*: `number`
141
+
• `Optional` *DstPort*: `number`
143
142
144
143
Destination port
145
144
@@ -208,12 +207,28 @@ Interface::
208
207
Network interface
209
208
210
209
'''
211
-
Packets::
212
210
213
-
• *Packets*: `number`
211
+
IfDirection::
214
212
215
-
Number of packets in this flow
213
+
• `Optional` *IfDirection*: `InterfaceDirection` (see the following section, Enumeration: InterfaceDirection)
216
214
215
+
Flow direction from the network interface observation point
216
+
217
+
'''
218
+
219
+
Flags::
220
+
221
+
• `Optional` *Flags*: `number`
222
+
223
+
TCP flags
224
+
225
+
'''
226
+
227
+
Packets::
228
+
229
+
• `Optional` *Packets*: `number`
230
+
231
+
Number of packets
217
232
218
233
'''
219
234
@@ -235,9 +250,9 @@ In conversation tracking, B to A packets counter per conversation
235
250
236
251
Bytes::
237
252
238
-
• *Bytes*: `number`
253
+
• `Optional` *Bytes*: `number`
239
254
240
-
Number of bytes in this flow
255
+
Number of bytes
241
256
242
257
'''
243
258
@@ -257,6 +272,126 @@ In conversation tracking, B to A bytes counter per conversation
257
272
258
273
'''
259
274
275
+
IcmpType::
276
+
277
+
• `Optional` *IcmpType*: `number`
278
+
279
+
ICMP type
280
+
281
+
'''
282
+
283
+
IcmpCode::
284
+
285
+
• `Optional` *IcmpCode*: `number`
286
+
287
+
ICMP code
288
+
289
+
'''
290
+
291
+
PktDropLatestState::
292
+
293
+
• `Optional` *PktDropLatestState*: `string`
294
+
295
+
Pkt TCP state for drops
296
+
297
+
'''
298
+
299
+
PktDropLatestDropCause::
300
+
301
+
• `Optional` *PktDropLatestDropCause*: `string`
302
+
303
+
Pkt cause for drops
304
+
305
+
'''
306
+
307
+
PktDropLatestFlags::
308
+
309
+
• `Optional` *PktDropLatestFlags*: `number`
310
+
311
+
Pkt TCP flags for drops
312
+
313
+
'''
314
+
315
+
PktDropPackets::
316
+
317
+
• `Optional` *PktDropPackets*: `number`
318
+
319
+
Number of packets dropped by the kernel
320
+
321
+
'''
322
+
323
+
PktDropPackets_AB::
324
+
325
+
• `Optional` *PktDropPackets_AB*: `number`
326
+
327
+
In conversation tracking, A to B packets dropped counter per conversation
328
+
329
+
'''
330
+
331
+
PktDropPackets_BA::
332
+
333
+
• `Optional` *PktDropPackets_BA*: `number`
334
+
335
+
In conversation tracking, B to A packets dropped counter per conversation
336
+
337
+
'''
338
+
339
+
PktDropBytes::
340
+
341
+
• `Optional` *PktDropBytes*: `number`
342
+
343
+
Number of bytes dropped by the kernel
344
+
345
+
'''
346
+
347
+
PktDropBytes_AB::
348
+
349
+
• `Optional` *PktDropBytes_AB*: `number`
350
+
351
+
In conversation tracking, A to B bytes dropped counter per conversation
352
+
353
+
'''
354
+
355
+
PktDropBytes_BA::
356
+
357
+
• `Optional` *PktDropBytes_BA*: `number`
358
+
359
+
In conversation tracking, B to A bytes dropped counter per conversation
360
+
361
+
'''
362
+
363
+
DnsId::
364
+
365
+
• `Optional` *DnsId*: `number`
366
+
367
+
DNS record id
368
+
369
+
'''
370
+
371
+
DnsFlags::
372
+
373
+
• `Optional` *DnsFlags*: `number`
374
+
375
+
DNS flags for DNS record
376
+
377
+
'''
378
+
379
+
DnsFlagsResponseCode::
380
+
381
+
• `Optional` *DnsFlagsResponseCode*: `string`
382
+
383
+
Parsed DNS header RCODEs name
384
+
385
+
'''
386
+
387
+
DnsLatencyMs::
388
+
389
+
• `Optional` *DnsLatencyMs*: `number`
390
+
391
+
Calculated time between response and request, in milliseconds
392
+
393
+
'''
394
+
260
395
TimeFlowStartMs::
261
396
262
397
• *TimeFlowStartMs*: `number`
@@ -281,6 +416,14 @@ Timestamp when this flow was received and processed by the flow collector, in se
281
416
282
417
'''
283
418
419
+
TimeFlowRttNs::
420
+
421
+
• `Optional` *TimeFlowRttNs*: `number`
422
+
423
+
Flow Round Trip Time (RTT) in nanoseconds
424
+
425
+
'''
426
+
284
427
_HashId::
285
428
286
429
• `Optional` *_HashId*: `string`
@@ -303,20 +446,28 @@ numFlowLogs::
303
446
304
447
In conversation tracking, a counter of flow logs per conversation
305
448
449
+
306
450
== Enumeration: FlowDirection
307
451
308
-
'''
309
452
310
453
Ingress::
311
454
312
455
• *Ingress* = `"0"`
313
456
314
-
Incoming traffic, from node observation point
457
+
Incoming traffic, from the node observation point
315
458
316
459
'''
317
460
318
461
Egress::
319
462
320
463
• *Egress* = `"1"`
321
464
322
-
Outgoing traffic, from node observation point
465
+
Outgoing traffic, from the node observation point
466
+
467
+
'''
468
+
469
+
Inner::
470
+
471
+
• *Inner* = `"2"`
472
+
473
+
Inner traffic, with the same source and destination node
0 commit comments