code: func (b *redisBroker) Init(opts ...broker.Option) error {
  	if b.pool != nil {
  		return errors.New("redis: cannot init while connected")
  	}
  
  	for _, o := range opts {
  		o(&b.opts)
  	}
  
  	return nil
  }
docs: // Init sets or overrides broker options.