rmq

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

type ChannelImpl interface {
	PublisherBuilder(exchange string, routingKey string) PublisherBuilderImpl
	ConsumerBuilder(name, queue string) ConsumerBuilderImpl
	QueueBuilder() QueueBuilderImpl
	ExchangeBuilder(name string) ExchangeBuilderImpl
	FanoutExchangeBuilder(name string) ExchangeBuilderImpl
	DirectExchangeBuilder(name string) ExchangeBuilderImpl
	TopicExchangeBuilder(name string) ExchangeBuilderImpl
	CloseChan() <-chan error
	Close() error
	IsHealthy() bool
}

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

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

type ConsumerBuilderImpl interface {
	SetAutoAck() ConsumerBuilderImpl
	SetExclusive() ConsumerBuilderImpl
	SetNoLocal() ConsumerBuilderImpl
	SetNoWait() ConsumerBuilderImpl
	SetPrefetch(prefetch int) ConsumerBuilderImpl
	AddArg(key string, val interface{}) ConsumerBuilderImpl
	Build() (ConsumerImpl, error)
}

type ConsumerImpl interface {
	Messages() <-chan amqp091.Delivery
	ErrorChan() <-chan error
	Cancel() error
	Close() error
}

type Delivery struct {
	*amqp091.Delivery
	// contains filtered or unexported fields
}

type DeliveryImpl interface {
	Ack(multiple bool) error
	Nack(multiple, requeue bool) error
	Reject(requeue bool) error
}

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

type ExchangeBuilderImpl interface {
	DeleteOnDeclare(ifUnused, noWait bool) ExchangeBuilderImpl
	SetDurable() ExchangeBuilderImpl
	SetAutoDelete() ExchangeBuilderImpl
	SetInternal() ExchangeBuilderImpl
	SetNoWait() ExchangeBuilderImpl
	AddArg(key string, val interface{}) ExchangeBuilderImpl
	Declare() error
}

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

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

type PublishFieldsImpl interface {
	SetDataTypeBytes() PublisherBuilderImpl
	SetDataTypeJSON() PublisherBuilderImpl
	SetContentType(contentType string) PublisherBuilderImpl
	DeliveryModePersistent() PublisherBuilderImpl
	DeliveryModeTransient() PublisherBuilderImpl
	AddHeader(key string, val interface{}) PublisherBuilderImpl
	SetCorrelationID(id string) PublisherBuilderImpl
	SetReplyToID(id string) PublisherBuilderImpl
	SetExpiration(dur time.Duration) PublisherBuilderImpl
	SetMandatory() PublisherBuilderImpl
	SetImmediate() PublisherBuilderImpl
}

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

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

type PublisherBuilderImpl interface {
	WithFields(fields *PublishFields) PublisherBuilderImpl
	New() PublisherImpl
	NewWithDefaultFields() PublisherImpl
}

type PublisherImpl interface {
	WithFields(fields *PublishFields) PublisherImpl
	Fields() *PublishFields
	Publish(ctx context.Context, data interface{}) error
	PublishAwaitResponse(
		ctx context.Context,
		data interface{},
		responseMap *genericSync.Map[chan amqp091.Delivery],
	) (amqp091.Delivery, error)
	PublishWithConfirmation(ctx context.Context, data interface{}) (bool, error)
}

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

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

type QueueBuilderImpl interface {
	SetName(name string) QueueBuilderImpl
	SetDurable() QueueBuilderImpl
	SetAutoDelete() QueueBuilderImpl
	SetExclusive() QueueBuilderImpl
	SetNoWait() QueueBuilderImpl
	AddArg(key string, val interface{}) QueueBuilderImpl
	Declare() (QueueImpl, error)
}

type QueueImpl interface {
	Name() string
	BindToExchange(
		exchange string,
		routingKey string,
		noWait bool,
		args map[string]interface{},
	) error
}

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

type RmqImpl interface {
	SetOnError(onError func(err error))
	Connect(retryCount int, retryDelay time.Duration, onRetryError func(err error)) (<-chan error, error)
	Close() error
	NewChannel() (ChannelImpl, error)
	NewChannelWithConfirm() (ChannelImpl, error)
	IsConnected() bool
	IsHealthy() bool
}

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