flowcontrol

Documentation

Index

• Variables
• func ResizeGlobalFlowControl(fc GlobalFlowControl, schema proxyv1alpha1.FlowControlSchema, upstream string)
• type GlobalFlowControl
  • func NewGlobalFlowControl(schema proxyv1alpha1.FlowControlSchema) GlobalFlowControl

Variables

var (
	RequestIDTooOld = errors.New("RequestIDTooOld")
)

Functions

func ResizeGlobalFlowControl

func ResizeGlobalFlowControl(fc GlobalFlowControl, schema proxyv1alpha1.FlowControlSchema, upstream string)

Types

type GlobalFlowControl

type GlobalFlowControl interface {
	TryAcquireN(instance string, token int32) bool
	SetState(instance string, requestId int64, current int32) (accept bool, latest int32, err error)
	String() string
	Resize(n int32, burst int32) bool
	Type() proxyv1alpha1.FlowControlSchemaType
	DebugInfo() string
}

func NewGlobalFlowControl

func NewGlobalFlowControl(schema proxyv1alpha1.FlowControlSchema) GlobalFlowControl