goflow
goflow copied to clipboard
The high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.
Firstly, thank you for the library. In the **goflow/utils/sflow.go** file, there are the following blocks of code: 1) Defining "ts": ``` ts := uint64(time.Now().UTC().Unix()) if pkt.SetTime { ts = uint64(pkt.RecvTime.UTC().Unix())...
Hello Team, We have used cloudflare/goflow docker container image and set up it in our Kubernetes to collect Netflow data. We wanted to understand the output from goflow first from...
I was trying to run goflow to capture netflow data and push into Kafka, but I've been running into a segfault: ``` panic: runtime error: invalid memory address or nil...
Bumps [github.com/prometheus/client_golang](https://github.com/prometheus/client_golang) from 0.9.2 to 1.11.1. Release notes Sourced from github.com/prometheus/client_golang's releases. 1.11.1 / 2022-02-15 [SECURITY FIX] promhttp: Check validity of method and code label values prometheus/client_golang#987 (Addressed CVE-2022-21698) What's...
Refactor goflow package to escape allocations while parsing NetFlow/IPFIX packets. Benchmark results before refactoring: ```bash goos: linux goarch: amd64 cpu: Intel(R) Core(TM) i7-10510U CPU @ 1.80GHz BenchmarkNetFlow2-8 54494 22757 ns/op...
NATS is now supported by clickhouse, so I decided it would be a lot nicer to lab up nats for proof of concept work than a full kafka cluster. This...
when use binary.Read() method decode a struct with a slice, binary.Read: invalid type *sflow.SampledIP_Base will cause, so i fix it#129
as i say, I use golang 1.21, when i decode ipv4 data binary.Read: invalid type *sflow.SampledIP_Base apper. i found when binary.Read decode into a struct and the struct have a...
