throttle

Documentation

Index

• func NewThrottler(config *ServiceOperationsThrottleConfig) *throttler
• type Condition
• type ServiceOperationsThrottleConfig
  • func NewDefaultServiceOperationsThrottleConfig() *ServiceOperationsThrottleConfig
  • func (c *ServiceOperationsThrottleConfig) Set(val string) error
  • func (c *ServiceOperationsThrottleConfig) String() string
  • func (c *ServiceOperationsThrottleConfig) Type() string

Functions

func NewThrottler

func NewThrottler(config *ServiceOperationsThrottleConfig) *throttler

NewThrottler constructs new request throttler instance.

Types

type Condition

type Condition func(r *request.Request) bool

type ServiceOperationsThrottleConfig

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

serviceOperationsThrottleConfig is throttleConfig for each service's operations. It supports to be configured using flags with format like "${serviceID}:${operationRegex}={rate}:{burst}" e.g. "appmesh:DescribeMesh=1.3:5,appmesh:Create.*=1.7:3" Note: default throttle for each service will be cleared if any override is set for that service.

func NewDefaultServiceOperationsThrottleConfig

func NewDefaultServiceOperationsThrottleConfig() *ServiceOperationsThrottleConfig

NewDefaultServiceOperationsThrottleConfig returns a ServiceOperationsThrottleConfig with default settings.

func (*ServiceOperationsThrottleConfig) Set

func (c *ServiceOperationsThrottleConfig) Set(val string) error

func (*ServiceOperationsThrottleConfig) String

func (c *ServiceOperationsThrottleConfig) String() string

func (*ServiceOperationsThrottleConfig) Type

func (c *ServiceOperationsThrottleConfig) Type() string