config

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

type AmqpDurabilityMode enumflag.Flag

type AmqpModifyOptions struct {
	DeliveryFailed      *template.Template
	UndeliverableHere   *template.Template
	AnnotationTemplates []AnnotationTemplate
}

type AmqpOptions struct {
	Subjects               []string
	To                     []string
	SendSettled            bool
	ConsumeSettled         bool
	PropertyFilters        map[string]string
	AppPropertyTemplates   map[string]*template.Template
	MsgAnnotationTemplates map[string]*template.Template
	AppPropertyFilters     map[string]string
	SQLFilter              string
	JMSSelectorFilter      string
	Browse                 bool
	ModifyOptions          AmqpModifyOptions
	ModifyRate             int
}

type AnnotationTemplate struct {
	Key   *template.Template
	Value *template.Template
}

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
	MessageTTLTemplate          *template.Template
	StreamOffset                any
	StreamFilterValues          string
	StreamFilterValueSet        []string
	StreamSingleActiveConsumer  bool
	StreamSuperStream           bool
	StreamSuperStreamPartitions int
	ConsumerPriorityTemplate    *template.Template
	Amqp                        AmqpOptions
	Amqp091                     Amqp091Options
	MqttPublisher               MqttOptions
	MqttConsumer                MqttOptions
	MetricTags                  map[string]string
	DetectOutOfOrder            bool
	DetectGaps                  bool
	PrintAllMetrics             bool
	ConsumerStartupDelay        time.Duration
	RequeueWhenPriority         []int
	DiscardWhenPriority         []int
	RequeueRate                 int
	DiscardRate                 int
	ParallelPublishers          bool
	ParallelConsumers           bool
	PublisherBatchSize          int
	ConsumerBatchSize           int
	PublisherBatchWait          time.Duration
	ConsumerBatchWait           time.Duration
	InsecureSkipTLSVerify       bool
	QueueArgs                   map[string]any
}

type MqttOptions struct {
	Version                  int
	QoS                      int
	CleanSession             bool
	SessionExpiryInterval    time.Duration
	SubscriptionsPerConsumer int
	UserPropertyTemplates    map[string]*template.Template
}

type Protocol int

type QueueType enumflag.Flag