diff options
Diffstat (limited to 'plugins/broadcast/root/config.go')
-rw-r--r-- | plugins/broadcast/root/config.go | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/plugins/broadcast/root/config.go b/plugins/broadcast/root/config.go deleted file mode 100644 index 8c732441..00000000 --- a/plugins/broadcast/root/config.go +++ /dev/null @@ -1,61 +0,0 @@ -package broadcast - -import ( - "errors" - - "github.com/go-redis/redis/v8" -) - -// Config configures the broadcast extension. -type Config struct { - // RedisConfig configures redis broker. - Redis *RedisConfig -} - -// Hydrate reads the configuration values from the source configuration. -//func (c *Config) Hydrate(cfg service.Config) error { -// if err := cfg.Unmarshal(c); err != nil { -// return err -// } -// -// if c.Redis != nil { -// return c.Redis.isValid() -// } -// -// return nil -//} - -// InitDefaults enables in memory broadcast configuration. -func (c *Config) InitDefaults() error { - return nil -} - -// RedisConfig configures redis broker. -type RedisConfig struct { - // Addr of the redis server. - Addr string - - // Password to redis server. - Password string - - // DB index. - DB int -} - -// clusterOptions -func (cfg *RedisConfig) redisClient() redis.UniversalClient { - return redis.NewClient(&redis.Options{ - Addr: cfg.Addr, - Password: cfg.Password, - PoolSize: 2, - }) -} - -// check if redis config is valid. -func (cfg *RedisConfig) isValid() error { - if cfg.Addr == "" { - return errors.New("redis addr is required") - } - - return nil -} |