Showing 9 of 18 total issues
File events.go
has 538 lines of code (exceeds 500 allowed). Consider refactoring. Open
Open
/*
* Nuts event octopus
* Copyright (C) 2019. Nuts community
*
* This program is free software: you can redistribute it and/or modify
EventOctopus
has 23 methods (exceeds 20 allowed). Consider refactoring. Open
Open
type EventOctopus struct {
Name string
Config EventOctopusConfig
configOnce sync.Once
stanServer *natsServer.StanServer
Method EventOctopus.startSubscribers
has 56 lines of code (exceeds 50 allowed). Consider refactoring. Open
Open
func (octopus *EventOctopus) startSubscribers() error {
logrus.Tracef("Connecting to Stan-Streaming server @ nats://localhost:%d", octopus.Config.NatsPort)
sc, err := octopus.client(ClientID)
if err != nil {
Method EventOctopus.startSubscribers
has 8 return statements (exceeds 4 allowed). Open
Open
func (octopus *EventOctopus) startSubscribers() error {
logrus.Tracef("Connecting to Stan-Streaming server @ nats://localhost:%d", octopus.Config.NatsPort)
sc, err := octopus.client(ClientID)
if err != nil {
Function NewDelayedConsumerSet
has 6 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewDelayedConsumerSet(consumeSubject string, publishSubject string, count int, interval time.Duration, exponent int, conn stan.Conn) []*DelayedConsumer {
Method EventOctopus.Start
has 7 return statements (exceeds 4 allowed). Open
Open
func (octopus *EventOctopus) Start() error {
var err error
if octopus.Config.GetMode() != core.ServerEngineMode {
return nil
Function RestoreAsset
has 6 return statements (exceeds 4 allowed). Open
Open
func RestoreAsset(dir, name string) error {
data, err := Asset(name)
if err != nil {
return err
}
Method EventOctopus.configure
has 5 return statements (exceeds 4 allowed). Open
Open
func (octopus *EventOctopus) configure() error {
var (
err error
)
Method EventOctopus.RunMigrations
has 5 return statements (exceeds 4 allowed). Open
Open
func (octopus *EventOctopus) RunMigrations(db *sql.DB) error {
driver, err := sqlite3.WithInstance(db, &sqlite3.Config{})
// wrap assets into Resource
s := bindata.Resource(migrations.AssetNames(),