network

Documentation

Index

• Constants
• Variables
• func CallStack(recoverRes any, topLevelFunctionName string, lastCallstackMethod string, ...) (callStack []string)
• func MakeHTTPBacklogQueueLimiter(downstream http.Handler, gauge gauge, limit uint64, logger *log.Entry) *backlogHTTPQLimiter
• func MakeHTTPRequestDurationLimiter(downstream http.Handler, warningThreshold time.Duration, ...) *httpRequestDurationLimiter
• func MakeJrpcBacklogQueueLimiter(downstream jrpc2.Handler, gauge gauge, limit uint64, logger *log.Entry) *backlogJrpcQLimiter
• func MakeJrpcRequestDurationLimiter(downstream jrpc2.Handler, warningThreshold time.Duration, ...) *rpcRequestDurationLimiter

Constants

const RequestBacklogQueueNoLimit = maxUint

const RequestDurationLimiterNoLimit = maxDuration

Variables

var ErrFailToProcessDueToInternalIssue = jrpc2.Error{
	Code:    -32003,
	Message: "request failed to process due to internal issue",
}

var ErrRequestExceededProcessingLimitThreshold = jrpc2.Error{
	Code:    -32001,
	Message: "request exceeded processing limit threshold",
}

Functions

func CallStack

func CallStack(recoverRes any, topLevelFunctionName string, lastCallstackMethod string, unwindStackLines int) (callStack []string)

CallStack returns an array of strings representing the current call stack. The method is tuned for the purpose of panic handler, and used as a helper in contructing the list of entries we want to write to the log / stderr / telemetry.

func MakeHTTPBacklogQueueLimiter

func MakeHTTPBacklogQueueLimiter(downstream http.Handler, gauge gauge, limit uint64, logger *log.Entry) *backlogHTTPQLimiter

func MakeHTTPRequestDurationLimiter

func MakeHTTPRequestDurationLimiter(
	downstream http.Handler,
	warningThreshold time.Duration,
	limitThreshold time.Duration,
	warningCounter increasingCounter,
	limitCounter increasingCounter,
	logger *log.Entry) *httpRequestDurationLimiter

func MakeJrpcBacklogQueueLimiter

func MakeJrpcBacklogQueueLimiter(downstream jrpc2.Handler, gauge gauge, limit uint64, logger *log.Entry) *backlogJrpcQLimiter

func MakeJrpcRequestDurationLimiter

func MakeJrpcRequestDurationLimiter(
	downstream jrpc2.Handler,
	warningThreshold time.Duration,
	limitThreshold time.Duration,
	warningCounter increasingCounter,
	limitCounter increasingCounter,
	logger *log.Entry) *rpcRequestDurationLimiter