rabbit

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

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

type ChannelService interface {
	Publish(data *PublishData) error
}

type ConnPoolOptions struct {
	ConnNum    int
	Url        string
	ChannelNum int
}

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

type ConnectionConfig struct {
	ChanNum int
	Url     string
}

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

type Consumer interface {
	Consume(name string) error
}

type ConsumerService struct {
	Rabbit RabbitService
	// contains filtered or unexported fields
}

type Exchange struct {
	Name       string
	Kind       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

type Job interface {
	RabbitService
}

type JobService struct {
	RabbitService
	// contains filtered or unexported fields
}

type Message struct {
	ID          string
	Body        []byte
	ContentType string
	RoutingKey  string
	Headers     amqp.Table
	Attempt     int
	D           amqp.Delivery
}

type Options struct {
	MaxConnection int
	Host          string
	MaxChannels   int
}

type Producer interface {
	Publish(ctx context.Context, exchange *Exchange, message *Message) error
}

type ProducerService struct {
	Rabbit RabbitService
}

type PublishData struct {
	Exchange  string
	Key       string
	Mandatory bool // 如果没有队列 true 返回给生产者 false 会丢掉
	Immediate bool // 如果没有消费者 true 返回给生产者，false 丢入队列
	Msg       *amqp.Publishing
}

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}

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

type RabbitService interface {
	ExchangeDeclare(ch *Channel, exchange *Exchange) error
	QueueDeclare(ch *Channel, queue *Queue) error
	BindQueue(ch *Channel, exchangeName, key, queueName string) error
	GetConnectionPool() *ConnectionPool
}