config

Documentation

Index

• Variables
• type AmqpDurabilityMode
• type AmqpOptions
• type Config
  • func NewConfig() Config
• type MqttOptions

Variables

var AmqpDurabilityModes = map[AmqpDurabilityMode][]string{
	None:           {"none"},
	Configuration:  {"configuration"},
	UnsettledState: {"unsettled-state"},
}

Types

type AmqpDurabilityMode

type AmqpDurabilityMode enumflag.Flag

const (
	None AmqpDurabilityMode = iota
	Configuration
	UnsettledState
)

type AmqpOptions

type AmqpOptions struct {
	Subject string
}

type Config

type Config struct {
	PublisherUri         string
	ConsumerUri          string
	Publishers           int
	Consumers            int
	PublishCount         int
	ConsumeCount         int
	PublishTo            string
	ConsumeFrom          string
	ConsumerCredits      int
	ConsumerLatency      time.Duration
	Size                 int
	Rate                 int
	Duration             time.Duration
	UseMillis            bool
	QueueDurability      AmqpDurabilityMode
	MessageDurability    bool
	MessagePriority      string // to allow for "unset" value and STOMP takes strings anyway
	StreamOffset         string
	StreamFilterValues   string
	StreamFilterValueSet string
	Amqp                 AmqpOptions
	MqttPublisher        MqttOptions
	MqttConsumer         MqttOptions
	MetricTags           map[string]string
}

func NewConfig

func NewConfig() Config

type MqttOptions

type MqttOptions struct {
	QoS          int
	CleanSession bool
}