q

package
v1.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	//ErrClosed close
	ErrClosed = errors.New("pipe.q.closed")

	//ErrReqQFull req q full
	ErrReqQFull = errors.New("pipe.q.req.full")

	//ErrSync never gonna happen
	ErrSync = errors.New("never.gonna.happen.crazy")
)

Functions

This section is empty.

Types

type Option 

type Option func(o *_Option)

Option : option function

func WithSize 

func WithSize(num int) Option

WithSize setup max queue number of request queue if max is 0, which means no limit

type Q 

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

Q actor queue structure define

func NewQ 

func NewQ(options ...Option) *Q

NewQ new queue

func (*Q) AddPriorReq 

func (a *Q) AddPriorReq(req any) error

AddPriorReq add normal request to the normal queue first place.

func (*Q) AddReq 

func (a *Q) AddReq(req any) error

AddReq add normal request to the normal queue end place.

func (*Q) AddReqAnyway 

func (a *Q) AddReqAnyway(req any, ts time.Duration) error

AddReqAnyway add normal request to the normal queue end place anyway if queue full, sleep then try

func (*Q) Close 

func (a *Q) Close()

Close : close the queue

func (*Q) Pop 

func (a *Q) Pop() (any, error)

Pop consume an item, if list is empty, it's been blocked

func (*Q) PopAnyway 

func (a *Q) PopAnyway() (any, error)

PopAnyway consume an item like Pop, but it can consume even the queue is closed.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.