qos

package
v0.45.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAdjustOutgoingIOTagStreamClientInterceptor 

func NewAdjustOutgoingIOTagStreamClientInterceptor() grpc.StreamClientInterceptor

func NewAdjustOutgoingIOTagUnaryClientInterceptor 

func NewAdjustOutgoingIOTagUnaryClientInterceptor() grpc.UnaryClientInterceptor

func NewMaxActiveRPCLimiterStreamServerInterceptor 

func NewMaxActiveRPCLimiterStreamServerInterceptor(getLimiter func() limiting.Limiter) grpc.StreamServerInterceptor

func NewMaxActiveRPCLimiterUnaryServerInterceptor 

func NewMaxActiveRPCLimiterUnaryServerInterceptor(getLimiter func() limiting.Limiter) grpc.UnaryServerInterceptor

func NewSetCriticalIOTagUnaryServerInterceptor 

func NewSetCriticalIOTagUnaryServerInterceptor() grpc.UnaryServerInterceptor

Types

type IOTag 

type IOTag string
const (
	IOTagClient     IOTag = "client"
	IOTagInternal   IOTag = "internal"
	IOTagBackground IOTag = "background"
	IOTagWritecache IOTag = "writecache"
	IOTagPolicer    IOTag = "policer"
	IOTagCritical   IOTag = "critical"
)

func FromRawString 

func FromRawString(s string) (IOTag, error)

func (IOTag) String 

func (t IOTag) String() string

type Limiter 

type Limiter interface {
	ReadRequest(context.Context) (ReleaseFunc, error)
	WriteRequest(context.Context) (ReleaseFunc, error)
	Close()
}

func NewLimiter 

func NewLimiter(c *limits.Config) (Limiter, error)

func NewNoopLimiter 

func NewNoopLimiter() Limiter

type ReleaseFunc 

type ReleaseFunc scheduling.ReleaseFunc

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.