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 {
	ConsumerCredits int
	Subject         string
}

type Config

type Config struct {
	PublisherUri      string
	ConsumerUri       string
	Publishers        int
	Consumers         int
	PublishCount      int
	ConsumeCount      int
	PublishTo         string
	ConsumeFrom       string
	Size              int
	Rate              int
	Duration          time.Duration
	UseMillis         bool
	QueueDurability   AmqpDurabilityMode
	MessageDurability bool
	Amqp              AmqpOptions
	MqttPublisher     MqttOptions
	MqttConsumer      MqttOptions
}

func NewConfig

func NewConfig() Config

type MqttOptions

type MqttOptions struct {
	QoS          int
	CleanSession bool
}