queue

type InMemoryQueueStorage struct {
	// MaxSize 请求容量
	MaxSize int
	// contains filtered or unexported fields
}

type Queue struct {
	// 并发请求数
	Threads int
	// contains filtered or unexported fields
}

type Storage interface {
	// Init 初始化
	Init() error

	// AddRequest 向队列中添加序列化的Request
	AddRequest([]byte) error

	// GetRequest 从队列中获取序列化的Request
	GetRequest() ([]byte, error)

	// QueueSize 队列大小
	QueueSize() (int, error)
}