goamqp

type Channel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

type Option func(options *Options)

type Options struct {
	Endpoints                        []string                 // amqp节点地址，可传入多个
	ConnectTimeout                   time.Duration            // 连接超时时间
	MaximumConnectionCount           int                      // 最大连接数，0为不限制
	MaximumChannelCountPerConnection int                      // 每个连接最大通道数，0为不限制
	ConnectionAliveDuration          time.Duration            // 连接存活时间，超过这个时间的空闲连接在保证空闲连接数情况下会被回收关闭，若配置为0则不回收
	ChannelAliveDuration             time.Duration            // 通道存活时间，超过这个时间的空闲通道在保证空闲连接数情况下会被回收关闭，若配置为0则不回收
	IdleConnectionCount              int                      // 空闲连接数
	IdleChannelCountPerConnection    int                      // 每个连接空闲通道数
	AMQPConfig                       amqp.Config              // 可传入amqp的配置，其中最大通道限制、连接地址、连接超时时间将被上面的节点地址、连接超时时间、每个连接最大通道数所覆盖
	Logger                           logrus.FieldLogger       // 可传入实现此接口的日志
	Blocking                         bool                     // 是否阻塞模式，非阻塞模式将在获取通道时等候
	RetryPolicy                      retry_policy.RetryPolicy // 重试策略
	ScanConnectionIdleDuration       time.Duration            // 扫描连接空闲间隔
}

type Pool interface {

	// GetChannel 从连接池中获取一个通道
	// 使用后需要 PutChannel 放回
	// 当连接池中没有空闲的通道时，将会建立一个新的连接，并生成通道返回
	// 但当连接已经达到最大的连接数限制，则会返回一个 ErrChannelMaximum 的错误
	GetChannel() (*Channel, error)

	// PutChannel 将通道放回连接池中
	PutChannel(channel *Channel) bool

	// Execute 通过传入函数，使用一个通道，此方式将自动的获取通道并使用后自动放回
	// 其调用过程等于 GetChannel() -> fn() -> PutChannel
	Execute(fn func(channel *Channel) error) error

	// Close 实现io.Closer接口，完成对连接池的关闭
	Close() error

	// Cap 连接池容量
	Cap() int

	// Size 连接池当前连接数
	Size() int
}