concurrency

package
v0.0.0-...-dffa276 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Done       *uint32 = new(uint32)
	BusyWorker *int32  = new(int32)
)

Functions

func Concurrent

func Concurrent(request *http.Request, result Result) (int, error)

Concurrent.

Types

type ConcurrencyManager

type ConcurrencyManager func(request *http.Request) Result

type ConcurrencyManagerLegacy

type ConcurrencyManagerLegacy func(reader *multipart.Reader) ConcurrencyStatus

type ConcurrencyStatus

type ConcurrencyStatus bool

type Result

type Result struct {
	Code  int
	Error error
}

Result is the struct that contain http status code and error.

func ConcurrencyAgent

func ConcurrencyAgent(request *http.Request, replicas ...ConcurrencyManager) Result

ConcurrencyAgent is loadbalancer of concurrencier.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL