Help us shape the future of Go! Take the 2026 Go Developer Survey

runner

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2026 License: Apache-2.0 Imports: 15 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.