rabbitmqamqp

type AMQPBinding struct {
	// contains filtered or unexported fields
}

type AMQPBindingInfo struct {
}

type AmqpAddress struct {
	// the address of the AMQP server
	// it is in the form of amqp://<host>:<port>
	// or amqps://<host>:<port>
	// the port is optional
	// the default port is 5672
	// the default protocol is amqp
	// the default host is localhost
	// the default virtual host is "/"
	// the default user is guest
	// the default password is guest
	// the default SASL type is SASLTypeAnonymous
	Address string
	// Options: Additional options for the connection
	Options *AmqpConnOptions
}

type AmqpConnOptions struct {
	// wrapper for amqp.ConnOptions
	ContainerID string

	// wrapper for amqp.ConnOptions
	HostName string
	// wrapper for amqp.ConnOptions
	IdleTimeout time.Duration

	// wrapper for amqp.ConnOptions
	MaxFrameSize uint32

	// wrapper for amqp.ConnOptions
	MaxSessions uint16

	// wrapper for amqp.ConnOptions
	Properties map[string]any

	// wrapper for amqp.ConnOptions
	SASLType amqp.SASLType

	// wrapper for amqp.ConnOptions
	TLSConfig *tls.Config

	// wrapper for amqp.ConnOptions
	WriteTimeout time.Duration

	// RecoveryConfiguration is used to configure the recovery behavior of the connection.
	// when the connection is closed unexpectedly.
	RecoveryConfiguration *RecoveryConfiguration

	// The OAuth2Options is used to configure the connection with OAuth2 token.
	OAuth2Options *OAuth2Options

	// Local connection identifier (not sent to the server)
	// if not provided, a random UUID is generated
	Id string
}

type AmqpConnection struct {
	// contains filtered or unexported fields
}

type AmqpExchange struct {
	// contains filtered or unexported fields
}

type AmqpExchangeInfo struct {
	// contains filtered or unexported fields
}

type AmqpManagement struct {
	// contains filtered or unexported fields
}

type AmqpQueue struct {
	// contains filtered or unexported fields
}

type AmqpQueueInfo struct {
	// contains filtered or unexported fields
}

type AutoGeneratedQueueSpecification struct {
	IsAutoDelete   bool
	IsExclusive    bool
	MaxLength      int64
	MaxLengthBytes int64
}

type BalancedLeaderLocator struct {
}

type ClassicQueueSpecification struct {
	Name                 string
	IsAutoDelete         bool
	IsExclusive          bool
	AutoExpire           int64
	MessageTTL           int64
	OverflowStrategy     IOverflowStrategy
	SingleActiveConsumer bool
	DeadLetterExchange   string
	DeadLetterRoutingKey string
	MaxLength            int64
	MaxLengthBytes       int64
	MaxPriority          int64
	LeaderLocator        ILeaderLocator
}

type ClientLocalLeaderLocator struct {
}

type Consumer struct {
	// contains filtered or unexported fields
}

type ConsumerOptions struct {
	//ReceiverLinkName: see the IConsumerOptions interface
	ReceiverLinkName string
	//InitialCredits: see the IConsumerOptions interface
	InitialCredits int32
	// The id of the consumer
	Id string
}

type CustomExchangeSpecification struct {
	Name             string
	IsAutoDelete     bool
	ExchangeTypeName string
	Arguments        map[string]any
}

type DeliveryContext struct {
	// contains filtered or unexported fields
}

type DeliveryState = amqp.DeliveryState

type DirectExchangeSpecification struct {
	Name         string
	IsAutoDelete bool
	Arguments    map[string]any
}

type DropHeadOverflowStrategy struct {
}

type Endpoint struct {
	Address string
	Options *AmqpConnOptions
}

type Environment struct {
	EndPointStrategy TEndPointStrategy
	// contains filtered or unexported fields
}

type ExchangeAddress struct {
	Exchange string // The name of the exchange
	Key      string // The routing key. Can be empty
}

type ExchangeToExchangeBindingSpecification struct {
	SourceExchange      string
	DestinationExchange string
	BindingKey          string
}

type ExchangeToQueueBindingSpecification struct {
	SourceExchange   string
	DestinationQueue string
	BindingKey       string
}

type ExchangeType struct {
	Type TExchangeType
}

type FanOutExchangeSpecification struct {
	Name         string
	IsAutoDelete bool
	Arguments    map[string]any
}

type HeadersExchangeSpecification struct {
	Name         string
	IsAutoDelete bool
	Arguments    map[string]any
}

type IBindingSpecification interface {
	// contains filtered or unexported methods
}

type IConsumerOptions interface {
	// contains filtered or unexported methods
}

type IExchangeSpecification interface {
	// contains filtered or unexported methods
}

type ILeaderLocator interface {
	// contains filtered or unexported methods
}

type ILifeCycleState interface {
	// contains filtered or unexported methods
}

type IOffsetSpecification interface {
	// contains filtered or unexported methods
}

type IOverflowStrategy interface {
	// contains filtered or unexported methods
}

type IPublisherOptions interface {
	// contains filtered or unexported methods
}

type IQueueSpecification interface {
	// contains filtered or unexported methods
}

type ITargetAddress interface {
	// contains filtered or unexported methods
}

type LifeCycle struct {
	// contains filtered or unexported fields
}

type OAuth2Options struct {
	Token string
}

type OffsetFirst struct {
}

type OffsetLast struct {
}

type OffsetNext struct {
}

type OffsetValue struct {
	Offset uint64
}

type PublishResult struct {
	Outcome DeliveryState
	Message *amqp.Message
}

type Publisher struct {
	// contains filtered or unexported fields
}

type PublisherOptions struct {
	Id             string
	SenderLinkName string
}

type QueueAddress struct {
	Queue      string // The name of the queue
	Parameters string // Additional parameters not related to the queue. Most of the time it is empty
}

type QueueType struct {
	Type TQueueType
}

type QuorumQueueSpecification struct {
	Name                   string
	AutoExpire             int64
	MessageTTL             int64
	OverflowStrategy       IOverflowStrategy
	SingleActiveConsumer   bool
	DeadLetterExchange     string
	DeadLetterRoutingKey   string
	MaxLength              int64
	MaxLengthBytes         int64
	DeliveryLimit          int64
	TargetClusterSize      int64
	LeaderLocator          ILeaderLocator
	QuorumInitialGroupSize int
}

type RecoveryConfiguration struct {
	/*
		ActiveRecovery Define if the recovery is activated.
		If is not activated the connection will not try to createSender.
	*/
	ActiveRecovery bool

	/*
		BackOffReconnectInterval The time to wait before trying to createSender after a connection is closed.
		time will be increased exponentially with each attempt.
		Default is 5 seconds, each attempt will double the time.
		The minimum value is 1 second. Avoid setting a value low values since it can cause a high
		number of reconnection attempts.
	*/
	BackOffReconnectInterval time.Duration

	/*
		MaxReconnectAttempts The maximum number of reconnection attempts.
		Default is 5.
		The minimum value is 1.
	*/
	MaxReconnectAttempts int
}

type RejectPublishDlxOverflowStrategy struct {
}

type RejectPublishOverflowStrategy struct {
}

type StateAccepted = amqp.StateAccepted

type StateChanged struct {
	From ILifeCycleState
	To   ILifeCycleState
}

type StateClosed struct {
	// contains filtered or unexported fields
}

type StateClosing struct {
}

type StateModified = amqp.StateModified

type StateOpen struct {
}

type StateReconnecting struct {
}

type StateRejected = amqp.StateRejected

type StateReleased = amqp.StateReleased

type StreamConsumerOptions struct {
	//ReceiverLinkName: see the IConsumerOptions interface
	ReceiverLinkName string
	//InitialCredits: see the IConsumerOptions interface
	InitialCredits int32
	// The offset specification for the stream consumer
	// see the interface implementations
	Offset              IOffsetSpecification
	StreamFilterOptions *StreamFilterOptions

	Id string
}

type StreamFilterOptions struct {
	// Filter values.
	Values []string
	//
	MatchUnfiltered bool

	// Filter the data based on Application Property
	ApplicationProperties map[string]any

	// Filter the data based on Message Properties
	Properties *amqp.MessageProperties
}

type StreamQueueSpecification struct {
	Name               string
	MaxLengthBytes     int64
	InitialClusterSize int
}

type TEndPointStrategy int

type TExchangeType string

type TQueueType string

type TopicExchangeSpecification struct {
	Name         string
	IsAutoDelete bool
	Arguments    map[string]any
}

type URI struct {
	Scheme   string
	Host     string
	Port     int
	Username string
	Password string
	Vhost    string
}

type Version struct {
	Major int
	Minor int
	Patch int
}