runner

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// NodeID is the xDS node identifier that the rate limit service uses
	// when connecting to this xDS server.
	NodeID = "envoy-ai-gateway-ratelimit"

	// DefaultPort is the default listening port for the rate limit xDS config server.
	DefaultPort = 18002
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Runner 

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

Runner manages the xDS gRPC server that serves RateLimitConfig resources to the rate limit service. It is modeled after Envoy Gateway's internal/globalratelimit/runner/runner.go.

func New 

func New(logger logr.Logger, port int) *Runner

New creates a new rate limit xDS config server runner.

func (*Runner) Start 

func (r *Runner) Start(ctx context.Context) error

Start starts the xDS gRPC server. It blocks until ctx is cancelled.

func (*Runner) UpdateConfigs 

func (r *Runner) UpdateConfigs(ctx context.Context, configs []*rlsconfv3.RateLimitConfig) error

UpdateConfigs updates the xDS snapshot cache with the provided rate limit configurations. This is called by the QuotaPolicy controller whenever a QuotaPolicy is reconciled.

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.