queue

package

v0.1.31 Latest Latest Go to latest Published: Dec 24, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RequestFunc func(client *http.Client, done chan<- RequestResult)

RequestFunc is a function that performs an HTTP request using the provided client, and sends its result to the given result channel.

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

func NewRequestQueue(rps int, burst int) *RequestQueue

NewRequestQueue creates a new rate-limited request queue. `rps` = requests per second, `burst` = burst capacity

func (q *RequestQueue) Enqueue(job RequestFunc) <-chan RequestResult

Enqueue adds a new request to the queue and returns a result channel.

func (q *RequestQueue) Shutdown()

Shutdown stops the queue and waits for the worker to finish.

type RequestResult struct {
	Body []byte
	Err  error
}

RequestResult holds the result of a queued request.