johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-12 06:24:10 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fakeexporter: use a gaussian distribution for sizes

Browse Source
This commit is contained in:
Vincent Bernat
2022-07-08 15:49:45 +02:00
parent 743d032231
commit ac0faebf58
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fakeexporter/flows/generate.go
View File

@@ -106,7 +106,7 @@ func generateFlows(flowConfigs []FlowConfiguration, seed int64, now time.Time) [
if flowConfig.Size == 0 {
flow.Octets = uint32(r.Int31n(1200) + 300)
} else {
flow.Octets = uint32(float64(flowConfig.Size) * (0.9 + r.Float64()/5))
flow.Octets = uint32(float64(flowConfig.Size) * (r.NormFloat64()*0.3 + 1))
if flow.Octets > 9000 {
flow.Octets = 9000
} else if flow.Octets > 1500 && flowConfig.Size <= 1500 {

6
fakeexporter/flows/generate_test.go
View File

@@ -153,7 +153,7 @@ func TestGenerateFlows(t *testing.T) {
DstAddr: net.ParseIP("203.0.113.91"),
EType: 0x800,
IPFlow: IPFlow{
Octets: 1500,
Octets: 1365,
Packets: 1,
Proto: 6,
SrcPort: 443,
@@ -169,7 +169,7 @@ func TestGenerateFlows(t *testing.T) {
DstAddr: net.ParseIP("203.0.113.220"),
EType: 0x800,
IPFlow: IPFlow{
Octets: 1283,
Octets: 1500,
Packets: 1,
Proto: 6,
SrcPort: 443,
@@ -203,7 +203,7 @@ func TestGenerateFlows(t *testing.T) {
DstAddr: net.ParseIP("2001:db8:2:0:245b:11f7:351e:dc1a"),
EType: 0x86dd,
IPFlow: IPFlow{
Octets: 1312,
Octets: 1170,
Packets: 1,
Proto: 6,
SrcPort: 34045,