Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
FZambia committed Sep 23, 2024
1 parent 04ba621 commit 8b5c4b8
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions internal/runutil/engine.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package runutil

import (
"fmt"

"github.com/centrifugal/centrifugo/v5/internal/config"
"github.com/centrifugal/centrifugo/v5/internal/confighelpers"
"github.com/centrifugal/centrifugo/v5/internal/natsbroker"
Expand Down Expand Up @@ -44,15 +46,18 @@ func redisEngine(n *centrifuge.Node, cfgContainer *config.Container) (*centrifug
cfg := cfgContainer.Config()
redisShards, mode, err := confighelpers.CentrifugeRedisShards(n, cfg.Redis.Redis)
if err != nil {
return nil, nil, "", err
return nil, nil, "", fmt.Errorf("error creating Redis shards: %w", err)
}
broker, err := confighelpers.CentrifugeRedisBroker(
n, cfg.Redis.Prefix, redisShards, cfg.Redis.RedisBrokerCommon, cfg.Broker == "redisnats")
if err != nil {
return nil, nil, mode, err
return nil, nil, mode, fmt.Errorf("error creating Redis broker: %w", err)
}
presenceManager, err := confighelpers.CentrifugeRedisPresenceManager(
n, cfg.Redis.Prefix, redisShards, cfg.Redis.RedisPresenceManagerCommon)
if err != nil {
return nil, nil, mode, fmt.Errorf("error creating Redis presence manager: %w", err)
}

return broker, presenceManager, mode, nil
}

0 comments on commit 8b5c4b8

Please sign in to comment.