config

Documentation

Index

• type Config
  • func GetConfigFromEnv() (*Config, error)
  • func GetConfigFromEnvPrefixWithoutTopic(prefix string) (*Config, error)
  • func GetConfigFromEnvWithoutTopic() (*Config, error)
  • func GetConfigFromYaml(file string, service string) (*Config, error)
  • func (c *Config) AddTopics(topics ...string)
  • func (c *Config) IsRawdata() bool
  • func (c *Config) SetAuth(user string, pass []byte)

Types

type Config

type Config struct {
	ServerURL *url.URL // MQTT server URL
	Auth      *authConf
	Group     string
	ClientID  string   // Client ID to use when connecting to server
	Topics    []string // Topic on which to publish messaged
	Qos       byte     // QOS to use when publishing

	KeepAlive         uint16        // seconds between keepalive packets
	ConnectRetryDelay time.Duration // Period between connection attempts

	QueuePath  string
	EnableGzip bool

	Debug bool // autopaho and paho debug output requested

	Logger *log.Logger
}

config holds the configuration

func GetConfigFromEnv

func GetConfigFromEnv() (*Config, error)

getConfig - Retrieves the configuration from the environment

func GetConfigFromEnvPrefixWithoutTopic

func GetConfigFromEnvPrefixWithoutTopic(prefix string) (*Config, error)

func GetConfigFromEnvWithoutTopic

func GetConfigFromEnvWithoutTopic() (*Config, error)

func GetConfigFromYaml

func GetConfigFromYaml(file string, service string) (*Config, error)

func (*Config) AddTopics

func (c *Config) AddTopics(topics ...string)

func (*Config) IsRawdata

func (c *Config) IsRawdata() bool

func (*Config) SetAuth

func (c *Config) SetAuth(user string, pass []byte)