concurrency

Documentation

Index

• Variables
• func Concurrent(request *http.Request, result Result) (int, error)
• type ConcurrencyManager
• type ConcurrencyManagerLegacy
• type ConcurrencyStatus
• type Result
  • func ConcurrencyAgent(request *http.Request, replicas ...ConcurrencyManager) Result

Variables

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.