WIP: NETOBSERV-1151: move flp decode grpc pipe to netobserv agent

Signed-off-by: msherif1234 <[email protected]>
netobserv · Jul 31, 2023 · fe22d94 · fe22d94
1 parent 7513aa9
commit fe22d94
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 183 deletions.
diff --git a/pkg/pipeline/decode/decode.go b/pkg/pipeline/decode/decode.go
@@ -22,6 +22,7 @@ import (
 
 	"github.com/netobserv/flowlogs-pipeline/pkg/api"
 	"github.com/netobserv/flowlogs-pipeline/pkg/config"
+	"github.com/netobserv/netobserv-ebpf-agent/pkg/decode"
 )
 
 type Decoder interface {
@@ -33,7 +34,7 @@ func GetDecoder(params api.Decoder) (Decoder, error) {
 	case api.DecoderName("JSON"):
 		return NewDecodeJson()
 	case api.DecoderName("Protobuf"):
-		return NewProtobuf()
+		return decode.NewProtobuf()
 	}
 	panic(fmt.Sprintf("`decode` type %s not defined", params.Type))
 }
diff --git a/pkg/pipeline/decode/decode_protobuf_test.go b/pkg/pipeline/decode/decode_protobuf_test.go
diff --git a/pkg/pipeline/ingest/ingest_grpc.go b/pkg/pipeline/ingest/ingest_grpc.go
@@ -7,10 +7,11 @@ import (
 	"github.com/netobserv/flowlogs-pipeline/pkg/api"
 	"github.com/netobserv/flowlogs-pipeline/pkg/config"
 	"github.com/netobserv/flowlogs-pipeline/pkg/operational"
-	"github.com/netobserv/flowlogs-pipeline/pkg/pipeline/decode"
 	"github.com/netobserv/flowlogs-pipeline/pkg/pipeline/utils"
+	"github.com/netobserv/netobserv-ebpf-agent/pkg/decode"
 	"github.com/netobserv/netobserv-ebpf-agent/pkg/grpc"
 	"github.com/netobserv/netobserv-ebpf-agent/pkg/pbflow"
+
 	"github.com/sirupsen/logrus"
 	grpc2 "google.golang.org/grpc"
 	"google.golang.org/grpc/status"

diff --git a/pkg/pipeline/decode/decode_protobuf.go → ...-ebpf-agent/pkg/decode/decode_protobuf.go b/pkg/pipeline/decode/decode_protobuf.go → ...-ebpf-agent/pkg/decode/decode_protobuf.go