config

Documentation

Index

• Constants
• Variables
• type AmqpDurabilityMode
• type AmqpOptions
• type Config
  • func NewConfig() Config
• type MqttOptions
• type Protocol
• type QueueType

Constants

const (
	Predeclared = iota
	Classic
	Quorum
	Stream
)

Variables

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

var QueueTypes = map[QueueType][]string{
	Predeclared: {"predeclared"},
	Classic:     {"classic"},
	Quorum:      {"quorum"},
	Stream:      {"stream"},
}

Types

type AmqpDurabilityMode

type AmqpDurabilityMode enumflag.Flag

const (
	None AmqpDurabilityMode = iota
	Configuration
	UnsettledState
)

type AmqpOptions

type AmqpOptions struct {
	Subjects           []string
	ReleaseRate        int
	RejectRate         int
	PropertyFilters    map[string]string
	AppProperties      map[string][]string
	AppPropertyFilters map[string]string
}

type Config

type Config struct {
	ExpectedInstances    int
	SyncName             string
	ConsumerProto        Protocol
	PublisherProto       Protocol
	PublisherId          string
	ConsumerId           string
	Uri                  []string
	PublisherUri         []string
	ConsumerUri          []string
	ManagementUri        []string
	Publishers           int
	Consumers            int
	SpreadConnections    bool
	PublishCount         int
	ConsumeCount         int
	PublishTo            string
	ConsumeFrom          string
	Queues               QueueType
	Exchange             string
	BindingKey           string
	CleanupQueues        bool
	ConsumerCredits      int
	ConsumerLatency      time.Duration
	Size                 int
	Rate                 float32
	MaxInFlight          int
	Duration             time.Duration
	UseMillis            bool
	QueueDurability      AmqpDurabilityMode
	MessageDurability    bool
	MessagePriority      string // to allow for "unset" value and STOMP takes strings anyway
	MessageTTL           time.Duration
	StreamOffset         string
	StreamFilterValues   string
	StreamFilterValueSet string
	ConsumerPriority     int32
	Amqp                 AmqpOptions
	MqttPublisher        MqttOptions
	MqttConsumer         MqttOptions
	MetricTags           map[string]string
	LogOutOfOrder        bool
	PrintAllMetrics      bool
	ConsumerStartupDelay time.Duration
}

func NewConfig

func NewConfig() Config

type MqttOptions

type MqttOptions struct {
	Version               int
	QoS                   int
	CleanSession          bool
	SessionExpiryInterval time.Duration
}

type Protocol

type Protocol int

const (
	AMQP Protocol = iota
	STOMP
	MQTT
	MQTT5
)

type QueueType

type QueueType enumflag.Flag