rabbitmq

type QueueInput struct {
	helper.InputOperator
	// contains filtered or unexported fields
}

type QueueInputConfig struct {
	helper.InputConfig `yaml:",inline"`

	// required
	Username   string `json:"username,omitempty" yaml:"username,omitempty"`
	Password   string `json:"password,omitempty" yaml:"password,omitempty"`
	Address    string `json:"address,omitempty" yaml:"address,omitempty"`
	RoutingKey string `json:"routing_key,omitempty" yaml:"routing_key,omitempty"`

	// optional
	Port  string `json:"port,omitempty" yaml:"port,omitempty"`
	VHost string `json:"vhost,omitempty" yaml:"vhost,omitempty"`
	Tag   string `json:"tag,omitempty" yaml:"tag,omitempty"`
}

type Rabbitmq struct {
	// contains filtered or unexported fields
}