config.go

package redis

import (
	"errors"
	"fmt"
	"time"

	"github.com/elastic/beats/libbeat/logp"
	"github.com/elastic/beats/libbeat/outputs"
	"github.com/elastic/beats/libbeat/outputs/transport"
)

type redisConfig struct {
	Password    string                `config:"password"`
	Index       string                `config:"index"`
	Key         string                `config:"key"`
	Port        int                   `config:"port"`
	LoadBalance bool                  `config:"loadbalance"`
	Timeout     time.Duration         `config:"timeout"`
	MaxRetries  int                   `config:"max_retries"`
	TLS         *outputs.TLSConfig    `config:"ssl"`
	Proxy       transport.ProxyConfig `config:",inline"`

	Db       int    `config:"db"`
	DataType string `config:"datatype"`

	HostTopology     string              `config:"host_topology"`
	PasswordTopology string              `config:"password_topology"`
	DbTopology       int                 `config:"db_topology"`
	Codec            outputs.CodecConfig `config:"codec"`
}

var (
	defaultConfig = redisConfig{
		Port:             6379,
		LoadBalance:      true,
		Timeout:          5 * time.Second,
		MaxRetries:       3,
		TLS:              nil,
		Db:               0,
		DataType:         "list",
		HostTopology:     "",
		PasswordTopology: "",
		DbTopology:       1,
	}
)

func (c *redisConfig) Validate() error {
	switch c.DataType {
	case "", "list", "channel":
	default:
		return fmt.Errorf("redis data type %v not supported", c.DataType)
	}

	if c.Key != "" && c.Index != "" {
		return errors.New("Cannot use both `output.redis.key` and `output.redis.index` configuration options." +
			" Set only `output.redis.key`")
	}

	if c.Key == "" && c.Index != "" {
		c.Key = c.Index
		logp.Warn("The `output.redis.index` configuration setting is deprecated. Use `output.redis.key` instead.")
	}

	return nil
}