transit/pubsub/pubsub.go
PubSub
has 42 methods (exceeds 20 allowed). Consider refactoring. Open
Open
type PubSub struct {
logger *log.Entry
transport transit.Transport
broker *moleculer.BrokerDelegates
isConnected bool
File pubsub.go
has 646 lines of code (exceeds 500 allowed). Consider refactoring. Open
Open
package pubsub
import (
"errors"
"fmt"
Avoid deeply nested control flow statements. Open
Open
} else if isKafka(pubsub.broker.Config.Transporter) {
pubsub.logger.Info("Transporter: KafkaTransporter")
transport = pubsub.createKafkaTransporter()
} else {
pubsub.logger.Info("Transporter: Memory")