buffer

package

v1.0.7-alpha Latest Latest Go to latest Published: Jun 15, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Buffer interface {
	// 请求逻辑
	Put(req *stream.HttpRequest) error
	Get() (*stream.HttpRequest, error)

	Size() int
	Cap() int

	Close() error
}

func ShortQueue() Buffer

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

CAS 队列

func (q *Queue) Cap() int

无穷大

func (q *Queue) Close() error

func (q *Queue) Get() (*stream.HttpRequest, error)

func (q *Queue) Put(req *stream.HttpRequest) error

请求逻辑

func (q *Queue) Size() int