Imports
- github.com/IBM/sarama
- github.com/ThreeDotsLabs/watermill
- github.com/ThreeDotsLabs/watermill-kafka/v3/pkg/kafka
- github.com/ThreeDotsLabs/watermill/message
- github.com/prometheus/client_golang/prometheus
- github.com/prometheus/client_golang/prometheus/promauto
- google.golang.org/protobuf/proto
- gopkg.in/mgo.v2/bson
Imports in module “github.com/agalue/onms-kafka-ipc-receiver”
- github.com/agalue/onms-kafka-ipc-receiver/protobuf/netflow
- github.com/agalue/onms-kafka-ipc-receiver/protobuf/rpc
- github.com/agalue/onms-kafka-ipc-receiver/protobuf/sink
- github.com/agalue/onms-kafka-ipc-receiver/protobuf/telemetry