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
	SendSettled bool
	ReleaseRate int
	RejectRate  int
}

type Config

type Config struct {
	PublisherUri         []string
	ConsumerUri          []string
	Publishers           int
	Consumers            int
	SpreadConnections    bool
	PublishCount         int
	ConsumeCount         int
	PublishTo            string
	ConsumeFrom          string
	ConsumerCredits      int
	ConsumerLatency      time.Duration
	Size                 int
	Rate                 float32
	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
	ConsumerPriority     int32
	Amqp                 AmqpOptions
	MqttPublisher        MqttOptions
	MqttConsumer         MqttOptions
	MetricTags           map[string]string
	LogOutOfOrder        bool
	ConsumerStartupDelay time.Duration
}

func NewConfig

func NewConfig() Config

type MqttOptions

type MqttOptions struct {
	QoS          int
	CleanSession bool
}