config

type Amqp091Options struct {
	Mandatory       bool
	HeaderTemplates map[string]*template.Template
}

type AmqpDurabilityMode enumflag.Flag

type AmqpOptions struct {
	Subjects               []string
	To                     []string
	SendSettled            bool
	PropertyFilters        map[string]string
	AppPropertyTemplates   map[string]*template.Template
	MsgAnnotationTemplates map[string]*template.Template
	AppPropertyFilters     map[string]string
	SQLFilter              string
}

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
	PublishToTemplate       *template.Template
	ConsumeFrom             string
	ConsumeFromTemplate     *template.Template
	Queues                  QueueType
	Exchange                string
	BindingKey              string
	CleanupQueues           bool
	ConsumerCredits         int
	ConsumerLatencyTemplate *template.Template
	Size                    int
	SizeTemplate            *template.Template
	Rate                    float32
	MaxInFlight             int
	Duration                time.Duration
	UseMillis               bool
	QueueDurability         AmqpDurabilityMode
	MessageDurability       bool
	MessagePriorityTemplate *template.Template
	MessageTTL              time.Duration
	StreamOffset            any
	StreamFilterValues      string
	StreamFilterValueSet    string
	ConsumerPriority        int32
	Amqp                    AmqpOptions
	Amqp091                 Amqp091Options
	MqttPublisher           MqttOptions
	MqttConsumer            MqttOptions
	MetricTags              map[string]string
	LogOutOfOrder           bool
	PrintAllMetrics         bool
	ConsumerStartupDelay    time.Duration
	RequeueWhenPriority     []int
	DiscardWhenPriority     []int
	RequeueRate             int
	DiscardRate             int
}

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

type Protocol int

type QueueType enumflag.Flag