filter

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_filter_http_connection_manager_proto protoreflect.FileDescriptor
View Source 
var File_api_filter_ratelimit_proto protoreflect.FileDescriptor
View Source 
var File_api_filter_tcp_proxy_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type HttpConnectionManager 

type HttpConnectionManager struct {

	// Types that are assignable to RouteSpecifier:
	//
	//	*HttpConnectionManager_RouteConfigName
	//	*HttpConnectionManager_RouteConfig
	RouteSpecifier isHttpConnectionManager_RouteSpecifier `protobuf_oneof:"route_specifier"`
	// contains filtered or unexported fields
}

func (*HttpConnectionManager) Descriptor deprecated 

func (*HttpConnectionManager) Descriptor() ([]byte, []int)

Deprecated: Use HttpConnectionManager.ProtoReflect.Descriptor instead.

func (*HttpConnectionManager) GetRouteConfig 

func (x *HttpConnectionManager) GetRouteConfig() *route.RouteConfiguration

func (*HttpConnectionManager) GetRouteConfigName 

func (x *HttpConnectionManager) GetRouteConfigName() string

func (*HttpConnectionManager) GetRouteSpecifier 

func (m *HttpConnectionManager) GetRouteSpecifier() isHttpConnectionManager_RouteSpecifier

func (*HttpConnectionManager) ProtoMessage 

func (*HttpConnectionManager) ProtoMessage()

func (*HttpConnectionManager) ProtoReflect 

func (x *HttpConnectionManager) ProtoReflect() protoreflect.Message

func (*HttpConnectionManager) Reset 

func (x *HttpConnectionManager) Reset()

func (*HttpConnectionManager) String 

func (x *HttpConnectionManager) String() string

type HttpConnectionManager_RouteConfig 

type HttpConnectionManager_RouteConfig struct {
	RouteConfig *route.RouteConfiguration `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
}

type HttpConnectionManager_RouteConfigName 

type HttpConnectionManager_RouteConfigName struct {
	RouteConfigName string `protobuf:"bytes,2,opt,name=route_config_name,json=routeConfigName,proto3,oneof"`
}

type LocalRateLimit added in v1.0.0 

type LocalRateLimit struct {

	// The token bucket configuration for the rate limiter.
	TokenBucket *TokenBucket `protobuf:"bytes,1,opt,name=token_bucket,json=tokenBucket,proto3" json:"token_bucket,omitempty"`
	// contains filtered or unexported fields
}

LocalRateLimit defines parameters for local rate limiting. https://www.envoyproxy.io/docs/envoy/latest/api-v3/extensions/filters/http/local_ratelimit/v3/local_rate_limit.proto#envoy-v3-api-msg-extensions-filters-http-local-ratelimit-v3-localratelimit { "token_bucket": {...}, }

func (*LocalRateLimit) Descriptor deprecated added in v1.0.0 

func (*LocalRateLimit) Descriptor() ([]byte, []int)

Deprecated: Use LocalRateLimit.ProtoReflect.Descriptor instead.

func (*LocalRateLimit) GetTokenBucket added in v1.0.0 

func (x *LocalRateLimit) GetTokenBucket() *TokenBucket

func (*LocalRateLimit) ProtoMessage added in v1.0.0 

func (*LocalRateLimit) ProtoMessage()

func (*LocalRateLimit) ProtoReflect added in v1.0.0 

func (x *LocalRateLimit) ProtoReflect() protoreflect.Message

func (*LocalRateLimit) Reset added in v1.0.0 

func (x *LocalRateLimit) Reset()

func (*LocalRateLimit) String added in v1.0.0 

func (x *LocalRateLimit) String() string

type TcpProxy 

type TcpProxy struct {

	// The prefix to use when emitting :ref:`statistics
	StatPrefix string `protobuf:"bytes,1,opt,name=stat_prefix,json=statPrefix,proto3" json:"stat_prefix,omitempty"`
	// Types that are assignable to ClusterSpecifier:
	//
	//	*TcpProxy_Cluster
	//	*TcpProxy_WeightedClusters
	ClusterSpecifier   isTcpProxy_ClusterSpecifier `protobuf_oneof:"cluster_specifier"`
	MaxConnectAttempts uint32                      `protobuf:"varint,7,opt,name=max_connect_attempts,json=maxConnectAttempts,proto3" json:"max_connect_attempts,omitempty"`
	// contains filtered or unexported fields
}

func (*TcpProxy) Descriptor deprecated 

func (*TcpProxy) Descriptor() ([]byte, []int)

Deprecated: Use TcpProxy.ProtoReflect.Descriptor instead.

func (*TcpProxy) GetCluster 

func (x *TcpProxy) GetCluster() string

func (*TcpProxy) GetClusterSpecifier 

func (m *TcpProxy) GetClusterSpecifier() isTcpProxy_ClusterSpecifier

func (*TcpProxy) GetMaxConnectAttempts 

func (x *TcpProxy) GetMaxConnectAttempts() uint32

func (*TcpProxy) GetStatPrefix 

func (x *TcpProxy) GetStatPrefix() string

func (*TcpProxy) GetWeightedClusters 

func (x *TcpProxy) GetWeightedClusters() *TcpProxy_WeightedCluster

func (*TcpProxy) ProtoMessage 

func (*TcpProxy) ProtoMessage()

func (*TcpProxy) ProtoReflect 

func (x *TcpProxy) ProtoReflect() protoreflect.Message

func (*TcpProxy) Reset 

func (x *TcpProxy) Reset()

func (*TcpProxy) String 

func (x *TcpProxy) String() string

type TcpProxy_Cluster 

type TcpProxy_Cluster struct {
	// cluster name to connect to.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3,oneof"`
}

type TcpProxy_WeightedCluster 

type TcpProxy_WeightedCluster struct {

	// Specifies one or more upstream clusters.
	Clusters []*TcpProxy_WeightedCluster_ClusterWeight `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

cluster based on weights.

func (*TcpProxy_WeightedCluster) Descriptor deprecated 

func (*TcpProxy_WeightedCluster) Descriptor() ([]byte, []int)

Deprecated: Use TcpProxy_WeightedCluster.ProtoReflect.Descriptor instead.

func (*TcpProxy_WeightedCluster) GetClusters 

func (x *TcpProxy_WeightedCluster) GetClusters() []*TcpProxy_WeightedCluster_ClusterWeight

func (*TcpProxy_WeightedCluster) ProtoMessage 

func (*TcpProxy_WeightedCluster) ProtoMessage()

func (*TcpProxy_WeightedCluster) ProtoReflect 

func (x *TcpProxy_WeightedCluster) ProtoReflect() protoreflect.Message

func (*TcpProxy_WeightedCluster) Reset 

func (x *TcpProxy_WeightedCluster) Reset()

func (*TcpProxy_WeightedCluster) String 

func (x *TcpProxy_WeightedCluster) String() string

type TcpProxy_WeightedCluster_ClusterWeight 

type TcpProxy_WeightedCluster_ClusterWeight struct {

	// cluster name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the choice of an cluster is determined by its weight
	Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

func (*TcpProxy_WeightedCluster_ClusterWeight) Descriptor deprecated 

func (*TcpProxy_WeightedCluster_ClusterWeight) Descriptor() ([]byte, []int)

Deprecated: Use TcpProxy_WeightedCluster_ClusterWeight.ProtoReflect.Descriptor instead.

func (*TcpProxy_WeightedCluster_ClusterWeight) GetName 

func (x *TcpProxy_WeightedCluster_ClusterWeight) GetName() string

func (*TcpProxy_WeightedCluster_ClusterWeight) GetWeight 

func (x *TcpProxy_WeightedCluster_ClusterWeight) GetWeight() uint32

func (*TcpProxy_WeightedCluster_ClusterWeight) ProtoMessage 

func (*TcpProxy_WeightedCluster_ClusterWeight) ProtoMessage()

func (*TcpProxy_WeightedCluster_ClusterWeight) ProtoReflect 

func (x *TcpProxy_WeightedCluster_ClusterWeight) ProtoReflect() protoreflect.Message

func (*TcpProxy_WeightedCluster_ClusterWeight) Reset 

func (x *TcpProxy_WeightedCluster_ClusterWeight) Reset()

func (*TcpProxy_WeightedCluster_ClusterWeight) String 

func (x *TcpProxy_WeightedCluster_ClusterWeight) String() string

type TcpProxy_WeightedClusters 

type TcpProxy_WeightedClusters struct {
	// Multiple upstream clusters can be specified for a given route. The
	// request is routed to one of the upstream clusters based on weights
	// assigned to each cluster.
	WeightedClusters *TcpProxy_WeightedCluster `protobuf:"bytes,10,opt,name=weighted_clusters,json=weightedClusters,proto3,oneof"`
}

type TokenBucket added in v1.0.0 

type TokenBucket struct {

	// The maximum number of tokens in the bucket.
	MaxTokens int64 `protobuf:"varint,1,opt,name=max_tokens,json=maxTokens,proto3" json:"max_tokens,omitempty"`
	// The number of tokens added to the bucket during each fill interval.
	TokensPerFill int64 `protobuf:"varint,2,opt,name=tokens_per_fill,json=tokensPerFill,proto3" json:"tokens_per_fill,omitempty"`
	// The interval at which the bucket is refilled in nanoseconds.
	FillInterval int64 `protobuf:"varint,3,opt,name=fill_interval,json=fillInterval,proto3" json:"fill_interval,omitempty"`
	// contains filtered or unexported fields
}

TokenBucket defines parameters for a token bucket rate limiter. https://www.envoyproxy.io/docs/envoy/latest/api-v3/type/v3/token_bucket.proto#envoy-v3-api-msg-type-v3-tokenbucket { "max_tokens": ..., "tokens_per_fill": {...}, "fill_interval": {...} }

func (*TokenBucket) Descriptor deprecated added in v1.0.0 

func (*TokenBucket) Descriptor() ([]byte, []int)

Deprecated: Use TokenBucket.ProtoReflect.Descriptor instead.

func (*TokenBucket) GetFillInterval added in v1.0.0 

func (x *TokenBucket) GetFillInterval() int64

func (*TokenBucket) GetMaxTokens added in v1.0.0 

func (x *TokenBucket) GetMaxTokens() int64

func (*TokenBucket) GetTokensPerFill added in v1.0.0 

func (x *TokenBucket) GetTokensPerFill() int64

func (*TokenBucket) ProtoMessage added in v1.0.0 

func (*TokenBucket) ProtoMessage()

func (*TokenBucket) ProtoReflect added in v1.0.0 

func (x *TokenBucket) ProtoReflect() protoreflect.Message

func (*TokenBucket) Reset added in v1.0.0 

func (x *TokenBucket) Reset()

func (*TokenBucket) String added in v1.0.0 

func (x *TokenBucket) String() string

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.