config

type AmqpDurabilityMode enumflag.Flag

type AmqpOptions struct {
	Subjects           []string
	To                 []string
	SendSettled        bool
	ReleaseRate        int
	RejectRate         int
	PropertyFilters    map[string]string
	AppProperties      map[string][]string
	MsgAnnotations     map[string][]string
	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
	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         any
	StreamFilterValues   string
	StreamFilterValueSet string
	ConsumerPriority     int32
	Amqp                 AmqpOptions
	MqttPublisher        MqttOptions
	MqttConsumer         MqttOptions
	MetricTags           map[string]string
	LogOutOfOrder        bool
	PrintAllMetrics      bool
	ConsumerStartupDelay time.Duration
}

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

type Protocol int

type QueueType enumflag.Flag