projects moved from github.com/bwNetFlow to github.com/BelWue

README.md

@@ -1,6 +1,6 @@
 # Flow Pipeline
 
-[godoc](https://pkg.go.dev/github.com/bwNetFlow/flowpipeline)
+[godoc](https://pkg.go.dev/github.com/BelWue/flowpipeline)
 
 ## About The Project
 
@@ -17,10 +17,10 @@ processing stack into a single piece of software which can be configured to
 serve any function:
 
 * accepting raw Netflow (using [goflow2](https://github.com/netsampler/goflow2))
-* enriching the resulting flow messages ([examples/enricher](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/enricher))
-* writing to and reading from Kafka ([examples/localkafka](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/localkafka))
-* dumping flows to cli (e.g. [flowdump](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/flowdump))
-* providing metrics and insights ([examples/prometheus](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/prometheus))
+* enriching the resulting flow messages ([examples/enricher](https://github.com/BelWue/flowpipeline/tree/master/examples/enricher))
+* writing to and reading from Kafka ([examples/localkafka](https://github.com/BelWue/flowpipeline/tree/master/examples/localkafka))
+* dumping flows to cli (e.g. [flowdump](https://github.com/BelWue/flowpipeline/tree/master/examples/flowdump))
+* providing metrics and insights ([examples/prometheus](https://github.com/BelWue/flowpipeline/tree/master/examples/prometheus))
 * and many more...
 
 ## Getting Started
@@ -35,19 +35,19 @@ you'll either want to create one or call it from any example directory (and
 maybe follow the instructions there).
 
 ### Binary Releases
-Download our [latest release](https://github.com/bwNetFlow/flowpipeline/releases)
+Download our [latest release](https://github.com/BelWue/flowpipeline/releases)
 and run it, same as if you compiled it yourself.
 
 The default, dynamically linked version requires a reasonably recent system
 (glibc 2.32+, linux 5.11+ for `bpf`, ...) and comes with all features.
 As a fallback option, the static binaries will work in older environments
 (CentOS 7, Debian 10, ...), but come without the segments that require
 CGO/dynamically linked code (`bpf`, `sqlite`, and plugin support, check
-[CONFIGURATION.md](https://github.com/bwNetFlow/flowpipeline/blob/master/CONFIGURATION.md)).
+[CONFIGURATION.md](https://github.com/BelWue/flowpipeline/blob/master/CONFIGURATION.md)).
 
 ### Container Releases
 A ready to use container is provided as `bwnetflow/flowpipeline`, you can check
-it out on [GitHub container registry](https://github.com/bwNetFlow/flowpipeline/pkgs/container/flowpipeline).
+it out on [GitHub container registry](https://github.com/BelWue/flowpipeline/pkgs/container/flowpipeline).
 
 Configurations referencing other files (geolocation databases for instance)
 will work in a container without extra edits. This is because the volume
@@ -62,7 +62,7 @@ docker run -v ./examples/xy:/config flowpipeline
 
 ## Configuration
 
-Refer to [CONFIGURATION.md](https://github.com/bwNetFlow/flowpipeline/blob/master/CONFIGURATION.md)
+Refer to [CONFIGURATION.md](https://github.com/BelWue/flowpipeline/blob/master/CONFIGURATION.md)
 for the full guide. Other than that, looking at the examples should give you a
 good idea what the config looks like in detail and what the possible
 applications are. For sake of completeness, here's another minimal example
@@ -85,7 +85,7 @@ If you find that the existing segments lack some functionality or you require
 some very specific behaviour, it is possible to include segments as a plugin.
 This is done using the `-p yourplugin.so` commandline option and your own
 custom module. See
-[examples/plugin](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/plugin)
+[examples/plugin](https://github.com/BelWue/flowpipeline/tree/master/examples/plugin)
 for a basic example and instructions on how to compile your plugin.
 
 Note that this requires CGO and thus will not work using the static binary

examples/README.md

@@ -2,7 +2,7 @@
 
 This collection of example configs is supposed to help users get started using
 different use cases. A grouped and alphabetically sorted
-[reference](https://github.com/bwNetFlow/flowpipeline/blob/master/CONFIGURATION.md),
+[reference](https://github.com/BelWue/flowpipeline/blob/master/CONFIGURATION.md),
 might be the best resource when trying to achieve a specific outcome, this
 short guide however tries to give new users some idea of what is possible with
 this tool and present existing users with additional options.
@@ -17,25 +17,25 @@ all inputs.
 This segment accesses local network interfaces using raw sockets, as for instance tcpdump does.
 
 Relevant examples are:
-* [./flowdump/bpf.yml](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/flowdump/bpf.yml) -- create a tcpdump style view with custom filtering from CLI using local
+* [./flowdump/bpf.yml](https://github.com/BelWue/flowpipeline/tree/master/examples/flowdump/bpf.yml) -- create a tcpdump style view with custom filtering from CLI using local
   interfaces
 
 
 ## `goflow`
 This segment allows listening for raw IPFIX, Netflow, or sFlow by using goflow2's API.
 
 Relevant examples are:
-* [./localkafka/write.yml](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/localkafka) -- emulate plain goflow2 and write flows to a Kafka topic for the following section to use
+* [./localkafka/write.yml](https://github.com/BelWue/flowpipeline/tree/master/examples/localkafka) -- emulate plain goflow2 and write flows to a Kafka topic for the following section to use
 
 
 ## `kafkaconsumer`
 This segment accesses streams of flows generated by another pipeline using
 `kafkaproducer` or [goflow2](https://github.com/netsampler/goflow2).
 
 Relevant examples are:
-* [./flowdump/kafkaflowdump.yml](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/flowdump/kafkaflowdump.yml) -- create a tcpdump style view with custom filtering from CLI
-* [./flowdump/highlight.yml](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/flowdump/highlight.yml) -- create a tcpdump style view but use the filtering conditional to highlight desired flows instead of dropping undesired flows
-* [./enricher](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/enricher) -- enrich flows with various bits of data and store them back in Kafka
-* [./reducer](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/reducer) -- strip flows of fields and store them back in Kafka
-* [./splitter](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/splitter) -- distribute flows to multiple Kafka topics based on a field
-* [./anonymizer](https://github.com/bwNetFlow/flowpipeline/tree/master/examples/anonymizer) -- anonymize IP addresses using Crypto PAn
+* [./flowdump/kafkaflowdump.yml](https://github.com/BelWue/flowpipeline/tree/master/examples/flowdump/kafkaflowdump.yml) -- create a tcpdump style view with custom filtering from CLI
+* [./flowdump/highlight.yml](https://github.com/BelWue/flowpipeline/tree/master/examples/flowdump/highlight.yml) -- create a tcpdump style view but use the filtering conditional to highlight desired flows instead of dropping undesired flows
+* [./enricher](https://github.com/BelWue/flowpipeline/tree/master/examples/enricher) -- enrich flows with various bits of data and store them back in Kafka
+* [./reducer](https://github.com/BelWue/flowpipeline/tree/master/examples/reducer) -- strip flows of fields and store them back in Kafka
+* [./splitter](https://github.com/BelWue/flowpipeline/tree/master/examples/splitter) -- distribute flows to multiple Kafka topics based on a field
+* [./anonymizer](https://github.com/BelWue/flowpipeline/tree/master/examples/anonymizer) -- anonymize IP addresses using Crypto PAn

examples/plugin/printcustom.go

@@ -6,7 +6,7 @@ import (
 	"fmt"
 	"sync"
 
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 // This is a short example on how to write custom segments and load them as a plugin.

go.mod

@@ -1,4 +1,4 @@
-module github.com/bwNetFlow/flowpipeline
+module github.com/BelWue/flowpipeline
 
 go 1.20
 
@@ -11,7 +11,7 @@ require (
 	github.com/asecurityteam/rolling v2.0.4+incompatible
 	github.com/banviktor/asnlookup v0.1.0
 	github.com/bwNetFlow/bpf_flowexport v0.0.0-20220515112212-cd8128615c05
-	github.com/bwNetFlow/flowfilter v0.0.0-20221025122858-60746fa15915
+	github.com/BelWue/flowfilter v0.0.0-20221025122858-60746fa15915
 	github.com/bwNetFlow/ip_prefix_trie v0.0.0-20210830112018-b360b7b65c04
 	github.com/bwNetFlow/protobuf/go v0.0.0-20211004083441-61e193b4b342
 	github.com/dustin/go-humanize v1.0.1

go.sum

@@ -91,8 +91,8 @@ github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6r
 github.com/bmatcuk/doublestar v1.1.1/go.mod h1:UD6OnuiIn0yFxxA2le/rnRU1G4RaI4UvFv1sNto9p6w=
 github.com/bwNetFlow/bpf_flowexport v0.0.0-20220515112212-cd8128615c05 h1:/H/qIQ0bo3uVWV9ILwv7dIR6r4MsHmqk+Nc7zGT4/0s=
 github.com/bwNetFlow/bpf_flowexport v0.0.0-20220515112212-cd8128615c05/go.mod h1:DuJLqsHWPJZpyo1yfuHEMjSlQlPjXWntTjGAHJCt4ns=
-github.com/bwNetFlow/flowfilter v0.0.0-20221025122858-60746fa15915 h1:RN9oNbfTMlAlVznyp0pI5LOZnB+rjnB/Lmzd23UVyQY=
-github.com/bwNetFlow/flowfilter v0.0.0-20221025122858-60746fa15915/go.mod h1:g+jR9KOBdcsGSdRLf8Q5ii7FgwumWPs83gU8pbBQ/4k=
+github.com/BelWue/flowfilter v0.0.0-20221025122858-60746fa15915 h1:RN9oNbfTMlAlVznyp0pI5LOZnB+rjnB/Lmzd23UVyQY=
+github.com/BelWue/flowfilter v0.0.0-20221025122858-60746fa15915/go.mod h1:g+jR9KOBdcsGSdRLf8Q5ii7FgwumWPs83gU8pbBQ/4k=
 github.com/bwNetFlow/ip_prefix_trie v0.0.0-20210830112018-b360b7b65c04 h1:mm0/N8cMAdc5TRsmAkrhnPIdOm0ZqbT7uUC9Wt/21mk=
 github.com/bwNetFlow/ip_prefix_trie v0.0.0-20210830112018-b360b7b65c04/go.mod h1:rtoxrzCig192Z9SYgF7J58r3qgnJ09yI3pnPVPf9+3U=
 github.com/bwNetFlow/protobuf/go v0.0.0-20211004083441-61e193b4b342 h1:CrEmmSVFs3Ssceezrj/KyLuTvelGH8CZkNLgVxYrQ4o=

main.go

@@ -14,55 +14,55 @@ import (
 	"plugin"
 	"strings"
 
-	"github.com/bwNetFlow/flowpipeline/pipeline"
+	"github.com/BelWue/flowpipeline/pipeline"
 	"github.com/hashicorp/logutils"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/alert/http"
+	_ "github.com/BelWue/flowpipeline/segments/alert/http"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/controlflow/branch"
+	_ "github.com/BelWue/flowpipeline/segments/controlflow/branch"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/export/clickhouse"
-	_ "github.com/bwNetFlow/flowpipeline/segments/export/influx"
-	_ "github.com/bwNetFlow/flowpipeline/segments/export/prometheus"
+	_ "github.com/BelWue/flowpipeline/segments/export/clickhouse"
+	_ "github.com/BelWue/flowpipeline/segments/export/influx"
+	_ "github.com/BelWue/flowpipeline/segments/export/prometheus"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/filter/drop"
-	_ "github.com/bwNetFlow/flowpipeline/segments/filter/elephant"
+	_ "github.com/BelWue/flowpipeline/segments/filter/drop"
+	_ "github.com/BelWue/flowpipeline/segments/filter/elephant"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/filter/flowfilter"
+	_ "github.com/BelWue/flowpipeline/segments/filter/flowfilter"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/input/bpf"
-	_ "github.com/bwNetFlow/flowpipeline/segments/input/goflow"
-	_ "github.com/bwNetFlow/flowpipeline/segments/input/kafkaconsumer"
-	_ "github.com/bwNetFlow/flowpipeline/segments/input/packet"
-	_ "github.com/bwNetFlow/flowpipeline/segments/input/stdin"
+	_ "github.com/BelWue/flowpipeline/segments/input/bpf"
+	_ "github.com/BelWue/flowpipeline/segments/input/goflow"
+	_ "github.com/BelWue/flowpipeline/segments/input/kafkaconsumer"
+	_ "github.com/BelWue/flowpipeline/segments/input/packet"
+	_ "github.com/BelWue/flowpipeline/segments/input/stdin"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/addcid"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/addrstrings"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/anonymize"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/aslookup"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/bgp"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/dropfields"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/geolocation"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/normalize"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/protomap"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/remoteaddress"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/reversedns"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/snmp"
+	_ "github.com/BelWue/flowpipeline/segments/modify/addcid"
+	_ "github.com/BelWue/flowpipeline/segments/modify/addrstrings"
+	_ "github.com/BelWue/flowpipeline/segments/modify/anonymize"
+	_ "github.com/BelWue/flowpipeline/segments/modify/aslookup"
+	_ "github.com/BelWue/flowpipeline/segments/modify/bgp"
+	_ "github.com/BelWue/flowpipeline/segments/modify/dropfields"
+	_ "github.com/BelWue/flowpipeline/segments/modify/geolocation"
+	_ "github.com/BelWue/flowpipeline/segments/modify/normalize"
+	_ "github.com/BelWue/flowpipeline/segments/modify/protomap"
+	_ "github.com/BelWue/flowpipeline/segments/modify/remoteaddress"
+	_ "github.com/BelWue/flowpipeline/segments/modify/reversedns"
+	_ "github.com/BelWue/flowpipeline/segments/modify/snmp"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/pass"
+	_ "github.com/BelWue/flowpipeline/segments/pass"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/output/csv"
-	_ "github.com/bwNetFlow/flowpipeline/segments/output/json"
-	_ "github.com/bwNetFlow/flowpipeline/segments/output/kafkaproducer"
-	_ "github.com/bwNetFlow/flowpipeline/segments/output/lumberjack"
-	_ "github.com/bwNetFlow/flowpipeline/segments/output/sqlite"
+	_ "github.com/BelWue/flowpipeline/segments/output/csv"
+	_ "github.com/BelWue/flowpipeline/segments/output/json"
+	_ "github.com/BelWue/flowpipeline/segments/output/kafkaproducer"
+	_ "github.com/BelWue/flowpipeline/segments/output/lumberjack"
+	_ "github.com/BelWue/flowpipeline/segments/output/sqlite"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/print/count"
-	_ "github.com/bwNetFlow/flowpipeline/segments/print/printdots"
-	_ "github.com/bwNetFlow/flowpipeline/segments/print/printflowdump"
-	_ "github.com/bwNetFlow/flowpipeline/segments/print/toptalkers"
+	_ "github.com/BelWue/flowpipeline/segments/print/count"
+	_ "github.com/BelWue/flowpipeline/segments/print/printdots"
+	_ "github.com/BelWue/flowpipeline/segments/print/printflowdump"
+	_ "github.com/BelWue/flowpipeline/segments/print/toptalkers"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/analysis/toptalkers_metrics"
+	_ "github.com/BelWue/flowpipeline/segments/analysis/toptalkers_metrics"
 )
 
 var Version string

pb/enrichedflow.proto

@@ -1,6 +1,6 @@
 syntax = "proto3";
 package flowpb;
-option go_package = "github.com/bwNetFlow/flowpipeline/pb;";
+option go_package = "github.com/BelWue/flowpipeline/pb;";
 
 message EnrichedFlow {
 

pipeline/config.go

@@ -6,8 +6,8 @@ import (
 	"os"
 	"strconv"
 
-	"github.com/bwNetFlow/flowpipeline/segments"
-	"github.com/bwNetFlow/flowpipeline/segments/controlflow/branch"
+	"github.com/BelWue/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments/controlflow/branch"
 	"gopkg.in/yaml.v2"
 )
 

pipeline/pipeline.go

@@ -5,12 +5,12 @@ import (
 	"log"
 	"sync"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
-	"github.com/bwNetFlow/flowpipeline/segments/filter/drop"
-	"github.com/bwNetFlow/flowpipeline/segments/filter/elephant"
-	"github.com/bwNetFlow/flowpipeline/segments/filter/flowfilter"
-	"github.com/bwNetFlow/flowpipeline/segments/pass"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments/filter/drop"
+	"github.com/BelWue/flowpipeline/segments/filter/elephant"
+	"github.com/BelWue/flowpipeline/segments/filter/flowfilter"
+	"github.com/BelWue/flowpipeline/segments/pass"
 )
 
 // Basically a list of segments. It further exposes the In and Out channels of

pipeline/pipeline_test.go

@@ -3,14 +3,14 @@ package pipeline
 import (
 	"testing"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
-	"github.com/bwNetFlow/flowpipeline/segments/pass"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments/pass"
 
-	_ "github.com/bwNetFlow/flowpipeline/segments/filter/drop"
-	_ "github.com/bwNetFlow/flowpipeline/segments/filter/flowfilter"
-	_ "github.com/bwNetFlow/flowpipeline/segments/modify/dropfields"
-	_ "github.com/bwNetFlow/flowpipeline/segments/testing/generator"
+	_ "github.com/BelWue/flowpipeline/segments/filter/drop"
+	_ "github.com/BelWue/flowpipeline/segments/filter/flowfilter"
+	_ "github.com/BelWue/flowpipeline/segments/modify/dropfields"
+	_ "github.com/BelWue/flowpipeline/segments/testing/generator"
 )
 
 func TestPipelineBuild(t *testing.T) {

segments/alert/http/http.go

@@ -8,7 +8,7 @@ import (
 	"net/url"
 	"sync"
 
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments"
 	"google.golang.org/protobuf/encoding/protojson"
 )
 

segments/alert/http/http_test.go

@@ -3,8 +3,8 @@ package http
 import (
 	"testing"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 // Http Segment test, passthrough test

segments/analysis/toptalkers_metrics/toptalkers_metrics.go

@@ -9,7 +9,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/segments"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 )

segments/controlflow/branch/branch.go

@@ -4,8 +4,8 @@ import (
 	"log"
 	"sync"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 // This mirrors the proper implementation in the pipeline package. This

segments/controlflow/branch/branch_test.go

@@ -5,8 +5,8 @@ import (
 	"sync"
 	"testing"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 // Branch Segment test, passthrough test

segments/export/clickhouse/clickhouse.go

@@ -11,8 +11,8 @@ import (
 	"sync"
 	"time"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 
 	_ "github.com/ClickHouse/clickhouse-go/v2"
 )

segments/export/clickhouse/clickhouse_test.go

@@ -1,5 +1,5 @@
 package clickhouse_segment
 
-// "github.com/bwNetFlow/flowpipeline/segments"
+// "github.com/BelWue/flowpipeline/segments"
 
 // Clickhouse Segment test, TODO: mock clickhouse

segments/export/influx/connector.go

@@ -9,7 +9,7 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/pb"
 	influxdb2 "github.com/influxdata/influxdb-client-go/v2"
 	"github.com/influxdata/influxdb-client-go/v2/api/write"
 )

segments/export/influx/influx.go

@@ -12,8 +12,8 @@ import (
 	"strings"
 	"sync"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 type Influx struct {

segments/export/influx/influx_test.go

@@ -3,8 +3,8 @@ package influx
 import (
 	"testing"
 
-	"github.com/bwNetFlow/flowpipeline/pb"
-	"github.com/bwNetFlow/flowpipeline/segments"
+	"github.com/BelWue/flowpipeline/pb"
+	"github.com/BelWue/flowpipeline/segments"
 )
 
 // Influx Segment test, passthrough test only