go_amqp_lib

type AmqpConfig struct {
	Host     string
	Port     string
	Username string
	Password string
	VHost    string
}

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

type Consume struct {
	Name, QueueName                string
	Channel                        *amqp.Channel
	QueueTable                     amqp.Table
	Durable, Exclusive, AutoDelete bool
	Delivery                       <-chan amqp.Delivery
}

type Consumer interface {
	GetQueueName() string
	IsQuorum() bool
	Handle(ctx context.Context, channel *amqp.Channel, delivery *amqp.Delivery, amqp *Client)
}

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

type Request[T any] struct {
	Id        uuid.UUID `json:"id"`
	CreatedAt time.Time `json:"createdAt"`
	ExpiresAt time.Time `json:"expiresAt"`
	Payload   T         `json:"payload"`
}

type Response[T any] struct {
	Success bool   `json:"success"`
	Message string `json:"message"`
	Payload T      `json:"payload"`
}