Documentation ¶
Index ¶
- Variables
- type Adapter
- type Address
- type ApiConfigSource
- func (*ApiConfigSource) Descriptor() ([]byte, []int)deprecated
- func (x *ApiConfigSource) GetAPITypeStr() string
- func (x *ApiConfigSource) GetClusterName() []string
- func (x *ApiConfigSource) GetRefreshDelay() string
- func (x *ApiConfigSource) GetRequestTimeout() string
- func (*ApiConfigSource) ProtoMessage()
- func (x *ApiConfigSource) ProtoReflect() protoreflect.Message
- func (x *ApiConfigSource) Reset()
- func (x *ApiConfigSource) String() string
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetEdsClusterConfig() *EdsClusterConfig
- func (x *Cluster) GetEndpoints() *Endpoint
- func (x *Cluster) GetHealthChecks() []*HealthCheck
- func (x *Cluster) GetLb() int32
- func (x *Cluster) GetLbStr() string
- func (x *Cluster) GetName() string
- func (x *Cluster) GetType() int32
- func (x *Cluster) GetTypeStr() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type CodecClientType
- func (CodecClientType) Descriptor() protoreflect.EnumDescriptor
- func (x CodecClientType) Enum() *CodecClientType
- func (CodecClientType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CodecClientType) Number() protoreflect.EnumNumber
- func (x CodecClientType) String() string
- func (CodecClientType) Type() protoreflect.EnumType
- type Config
- type ConfigSource
- func (*ConfigSource) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSource) GetApiConfigSource() *ApiConfigSource
- func (x *ConfigSource) GetPath() string
- func (*ConfigSource) ProtoMessage()
- func (x *ConfigSource) ProtoReflect() protoreflect.Message
- func (x *ConfigSource) Reset()
- func (x *ConfigSource) String() string
- type EdsClusterConfig
- func (*EdsClusterConfig) Descriptor() ([]byte, []int)deprecated
- func (x *EdsClusterConfig) GetEdsConfig() *ConfigSource
- func (x *EdsClusterConfig) GetServiceName() string
- func (*EdsClusterConfig) ProtoMessage()
- func (x *EdsClusterConfig) ProtoReflect() protoreflect.Message
- func (x *EdsClusterConfig) Reset()
- func (x *EdsClusterConfig) String() string
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)deprecated
- func (x *Endpoint) GetAddress() *SocketAddress
- func (x *Endpoint) GetId() string
- func (x *Endpoint) GetMetadata() map[string]string
- func (x *Endpoint) GetName() string
- func (*Endpoint) ProtoMessage()
- func (x *Endpoint) ProtoReflect() protoreflect.Message
- func (x *Endpoint) Reset()
- func (x *Endpoint) String() string
- type EventServiceConfig
- type FilterChain
- type HTTPFilter
- type HeaderValue
- type HeaderValueOption
- func (*HeaderValueOption) Descriptor() ([]byte, []int)deprecated
- func (x *HeaderValueOption) GetAppend() *wrapperspb.BoolValue
- func (x *HeaderValueOption) GetAppendAction() HeaderValueOption_HeaderAppendAction
- func (x *HeaderValueOption) GetHeader() *HealthyHeaderValue
- func (*HeaderValueOption) ProtoMessage()
- func (x *HeaderValueOption) ProtoReflect() protoreflect.Message
- func (x *HeaderValueOption) Reset()
- func (x *HeaderValueOption) String() string
- type HeaderValueOption_HeaderAppendAction
- func (HeaderValueOption_HeaderAppendAction) Descriptor() protoreflect.EnumDescriptor
- func (x HeaderValueOption_HeaderAppendAction) Enum() *HeaderValueOption_HeaderAppendAction
- func (HeaderValueOption_HeaderAppendAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x HeaderValueOption_HeaderAppendAction) Number() protoreflect.EnumNumber
- func (x HeaderValueOption_HeaderAppendAction) String() string
- func (HeaderValueOption_HeaderAppendAction) Type() protoreflect.EnumType
- type HealthCheck
- func (*HealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck) GetAltPort() *wrapperspb.UInt32Value
- func (x *HealthCheck) GetAlwaysLogHealthCheckFailures() bool
- func (x *HealthCheck) GetCustomHealthCheck() *HealthCheck_CustomHealthCheck
- func (x *HealthCheck) GetEventLogPath() string
- func (x *HealthCheck) GetEventService() *EventServiceConfig
- func (x *HealthCheck) GetGrpcHealthCheck() *HealthCheck_GrpcHealthCheck
- func (m *HealthCheck) GetHealthChecker() isHealthCheck_HealthChecker
- func (x *HealthCheck) GetHealthyEdgeInterval() *durationpb.Duration
- func (x *HealthCheck) GetHealthyThreshold() *wrapperspb.UInt32Value
- func (x *HealthCheck) GetHttpHealthCheck() *HealthCheck_HttpHealthCheck
- func (x *HealthCheck) GetInitialJitter() *durationpb.Duration
- func (x *HealthCheck) GetInterval() *durationpb.Duration
- func (x *HealthCheck) GetIntervalJitter() *durationpb.Duration
- func (x *HealthCheck) GetIntervalJitterPercent() uint32
- func (x *HealthCheck) GetNoTrafficHealthyInterval() *durationpb.Duration
- func (x *HealthCheck) GetNoTrafficInterval() *durationpb.Duration
- func (x *HealthCheck) GetReuseConnection() *wrapperspb.BoolValue
- func (x *HealthCheck) GetTcpHealthCheck() *HealthCheck_TcpHealthCheck
- func (x *HealthCheck) GetTimeout() *durationpb.Duration
- func (x *HealthCheck) GetTlsOptions() *HealthCheck_TlsOptions
- func (x *HealthCheck) GetTransportSocketMatchCriteria() *structpb.Struct
- func (x *HealthCheck) GetUnhealthyEdgeInterval() *durationpb.Duration
- func (x *HealthCheck) GetUnhealthyInterval() *durationpb.Duration
- func (x *HealthCheck) GetUnhealthyThreshold() *wrapperspb.UInt32Value
- func (*HealthCheck) ProtoMessage()
- func (x *HealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck) Reset()
- func (x *HealthCheck) String() string
- type HealthCheck_CustomHealthCheck
- func (*HealthCheck_CustomHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (m *HealthCheck_CustomHealthCheck) GetConfigType() isHealthCheck_CustomHealthCheck_ConfigType
- func (x *HealthCheck_CustomHealthCheck) GetName() string
- func (x *HealthCheck_CustomHealthCheck) GetTypedConfig() *anypb.Any
- func (*HealthCheck_CustomHealthCheck) ProtoMessage()
- func (x *HealthCheck_CustomHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_CustomHealthCheck) Reset()
- func (x *HealthCheck_CustomHealthCheck) String() string
- type HealthCheck_CustomHealthCheck_
- type HealthCheck_CustomHealthCheck_TypedConfig
- type HealthCheck_GrpcHealthCheck
- func (*HealthCheck_GrpcHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_GrpcHealthCheck) GetAuthority() string
- func (x *HealthCheck_GrpcHealthCheck) GetServiceName() string
- func (*HealthCheck_GrpcHealthCheck) ProtoMessage()
- func (x *HealthCheck_GrpcHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_GrpcHealthCheck) Reset()
- func (x *HealthCheck_GrpcHealthCheck) String() string
- type HealthCheck_GrpcHealthCheck_
- type HealthCheck_HttpHealthCheck
- func (*HealthCheck_HttpHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_HttpHealthCheck) GetCodecClientType() CodecClientType
- func (x *HealthCheck_HttpHealthCheck) GetExpectedStatuses() []*Int64Range
- func (x *HealthCheck_HttpHealthCheck) GetHost() string
- func (x *HealthCheck_HttpHealthCheck) GetPath() string
- func (x *HealthCheck_HttpHealthCheck) GetReceive() *HealthCheck_Payload
- func (x *HealthCheck_HttpHealthCheck) GetRequestHeadersToAdd() []*HeaderValueOption
- func (x *HealthCheck_HttpHealthCheck) GetRequestHeadersToRemove() []string
- func (x *HealthCheck_HttpHealthCheck) GetRetriableStatuses() []*Int64Range
- func (x *HealthCheck_HttpHealthCheck) GetSend() *HealthCheck_Payload
- func (x *HealthCheck_HttpHealthCheck) GetServiceNameMatcher() *StringMatcher
- func (*HealthCheck_HttpHealthCheck) ProtoMessage()
- func (x *HealthCheck_HttpHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_HttpHealthCheck) Reset()
- func (x *HealthCheck_HttpHealthCheck) String() string
- type HealthCheck_HttpHealthCheck_
- type HealthCheck_Payload
- func (*HealthCheck_Payload) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_Payload) GetBinary() []byte
- func (m *HealthCheck_Payload) GetPayload() isHealthCheck_Payload_Payload
- func (x *HealthCheck_Payload) GetText() string
- func (*HealthCheck_Payload) ProtoMessage()
- func (x *HealthCheck_Payload) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_Payload) Reset()
- func (x *HealthCheck_Payload) String() string
- type HealthCheck_Payload_Binary
- type HealthCheck_Payload_Text
- type HealthCheck_RedisHealthCheck
- func (*HealthCheck_RedisHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_RedisHealthCheck) GetKey() string
- func (*HealthCheck_RedisHealthCheck) ProtoMessage()
- func (x *HealthCheck_RedisHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_RedisHealthCheck) Reset()
- func (x *HealthCheck_RedisHealthCheck) String() string
- type HealthCheck_TcpHealthCheck
- func (*HealthCheck_TcpHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_TcpHealthCheck) GetReceive() []*HealthCheck_Payload
- func (x *HealthCheck_TcpHealthCheck) GetSend() *HealthCheck_Payload
- func (*HealthCheck_TcpHealthCheck) ProtoMessage()
- func (x *HealthCheck_TcpHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_TcpHealthCheck) Reset()
- func (x *HealthCheck_TcpHealthCheck) String() string
- type HealthCheck_TcpHealthCheck_
- type HealthCheck_TlsOptions
- func (*HealthCheck_TlsOptions) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck_TlsOptions) GetAlpnProtocols() []string
- func (*HealthCheck_TlsOptions) ProtoMessage()
- func (x *HealthCheck_TlsOptions) ProtoReflect() protoreflect.Message
- func (x *HealthCheck_TlsOptions) Reset()
- func (x *HealthCheck_TlsOptions) String() string
- type HealthStatus
- func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthStatus) Enum() *HealthStatus
- func (HealthStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthStatus) Number() protoreflect.EnumNumber
- func (x HealthStatus) String() string
- func (HealthStatus) Type() protoreflect.EnumType
- type HealthyHeaderValue
- func (*HealthyHeaderValue) Descriptor() ([]byte, []int)deprecated
- func (x *HealthyHeaderValue) GetKey() string
- func (x *HealthyHeaderValue) GetValue() string
- func (*HealthyHeaderValue) ProtoMessage()
- func (x *HealthyHeaderValue) ProtoReflect() protoreflect.Message
- func (x *HealthyHeaderValue) Reset()
- func (x *HealthyHeaderValue) String() string
- type Int64Range
- type Listener
- func (*Listener) Descriptor() ([]byte, []int)deprecated
- func (x *Listener) GetAddress() *Address
- func (x *Listener) GetFilterChain() *FilterChain
- func (x *Listener) GetName() string
- func (*Listener) ProtoMessage()
- func (x *Listener) ProtoReflect() protoreflect.Message
- func (x *Listener) Reset()
- func (x *Listener) String() string
- type Metric
- type NetworkFilter
- func (*NetworkFilter) Descriptor() ([]byte, []int)deprecated
- func (m *NetworkFilter) GetConfig() isNetworkFilter_Config
- func (x *NetworkFilter) GetJson() *Config
- func (x *NetworkFilter) GetName() string
- func (x *NetworkFilter) GetStruct() *structpb.Struct
- func (x *NetworkFilter) GetYaml() *Config
- func (*NetworkFilter) ProtoMessage()
- func (x *NetworkFilter) ProtoReflect() protoreflect.Message
- func (x *NetworkFilter) Reset()
- func (x *NetworkFilter) String() string
- type NetworkFilter_Json
- type NetworkFilter_Struct
- type NetworkFilter_Yaml
- type PixiuExtensionClusters
- func (*PixiuExtensionClusters) Descriptor() ([]byte, []int)deprecated
- func (x *PixiuExtensionClusters) GetClusters() []*Cluster
- func (*PixiuExtensionClusters) ProtoMessage()
- func (x *PixiuExtensionClusters) ProtoReflect() protoreflect.Message
- func (x *PixiuExtensionClusters) Reset()
- func (x *PixiuExtensionClusters) String() string
- type PixiuExtensionListeners
- func (*PixiuExtensionListeners) Descriptor() ([]byte, []int)deprecated
- func (x *PixiuExtensionListeners) GetListeners() []*Listener
- func (*PixiuExtensionListeners) ProtoMessage()
- func (x *PixiuExtensionListeners) ProtoReflect() protoreflect.Message
- func (x *PixiuExtensionListeners) Reset()
- func (x *PixiuExtensionListeners) String() string
- type PprofConf
- type RegexMatchAndSubstitute
- func (*RegexMatchAndSubstitute) Descriptor() ([]byte, []int)deprecated
- func (x *RegexMatchAndSubstitute) GetPattern() *RegexMatcher
- func (x *RegexMatchAndSubstitute) GetSubstitution() string
- func (*RegexMatchAndSubstitute) ProtoMessage()
- func (x *RegexMatchAndSubstitute) ProtoReflect() protoreflect.Message
- func (x *RegexMatchAndSubstitute) Reset()
- func (x *RegexMatchAndSubstitute) String() string
- type RegexMatcher
- func (*RegexMatcher) Descriptor() ([]byte, []int)deprecated
- func (m *RegexMatcher) GetEngineType() isRegexMatcher_EngineType
- func (x *RegexMatcher) GetGoogleRe2() *RegexMatcher_GoogleRE2
- func (x *RegexMatcher) GetRegex() string
- func (*RegexMatcher) ProtoMessage()
- func (x *RegexMatcher) ProtoReflect() protoreflect.Message
- func (x *RegexMatcher) Reset()
- func (x *RegexMatcher) String() string
- type RegexMatcher_GoogleRE2
- func (*RegexMatcher_GoogleRE2) Descriptor() ([]byte, []int)deprecated
- func (x *RegexMatcher_GoogleRE2) GetMaxProgramSize() *wrapperspb.UInt32Valuedeprecated
- func (*RegexMatcher_GoogleRE2) ProtoMessage()
- func (x *RegexMatcher_GoogleRE2) ProtoReflect() protoreflect.Message
- func (x *RegexMatcher_GoogleRE2) Reset()
- func (x *RegexMatcher_GoogleRE2) String() string
- type RegexMatcher_GoogleRe2
- type RouteAction
- func (*RouteAction) Descriptor() ([]byte, []int)deprecated
- func (x *RouteAction) GetCluster() string
- func (x *RouteAction) GetClusterNotFoundResponseCode() int64
- func (*RouteAction) ProtoMessage()
- func (x *RouteAction) ProtoReflect() protoreflect.Message
- func (x *RouteAction) Reset()
- func (x *RouteAction) String() string
- type RouteConfiguration
- func (*RouteConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *RouteConfiguration) GetDynamic() bool
- func (x *RouteConfiguration) GetRoutes() []*Router
- func (*RouteConfiguration) ProtoMessage()
- func (x *RouteConfiguration) ProtoReflect() protoreflect.Message
- func (x *RouteConfiguration) Reset()
- func (x *RouteConfiguration) String() string
- type Router
- func (*Router) Descriptor() ([]byte, []int)deprecated
- func (x *Router) GetId() string
- func (x *Router) GetMatch() *RouterMatch
- func (x *Router) GetRoute() *RouteAction
- func (*Router) ProtoMessage()
- func (x *Router) ProtoReflect() protoreflect.Message
- func (x *Router) Reset()
- func (x *Router) String() string
- type RouterMatch
- func (*RouterMatch) Descriptor() ([]byte, []int)deprecated
- func (x *RouterMatch) GetMethods() []string
- func (x *RouterMatch) GetPath() string
- func (x *RouterMatch) GetPrefix() string
- func (*RouterMatch) ProtoMessage()
- func (x *RouterMatch) ProtoReflect() protoreflect.Message
- func (x *RouterMatch) Reset()
- func (x *RouterMatch) String() string
- type ShutdownConfig
- func (*ShutdownConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ShutdownConfig) GetRejectPolicy() string
- func (x *ShutdownConfig) GetStepTimeout() string
- func (x *ShutdownConfig) GetTimeout() string
- func (*ShutdownConfig) ProtoMessage()
- func (x *ShutdownConfig) ProtoReflect() protoreflect.Message
- func (x *ShutdownConfig) Reset()
- func (x *ShutdownConfig) String() string
- type SocketAddress
- func (*SocketAddress) Descriptor() ([]byte, []int)deprecated
- func (x *SocketAddress) GetAddress() string
- func (x *SocketAddress) GetCertsDir() string
- func (x *SocketAddress) GetDomains() []string
- func (x *SocketAddress) GetPort() int64
- func (x *SocketAddress) GetResolverName() string
- func (*SocketAddress) ProtoMessage()
- func (x *SocketAddress) ProtoReflect() protoreflect.Message
- func (x *SocketAddress) Reset()
- func (x *SocketAddress) String() string
- type StaticResources
- func (*StaticResources) Descriptor() ([]byte, []int)deprecated
- func (x *StaticResources) GetAdapters() []*Adapter
- func (x *StaticResources) GetClusters() []*Cluster
- func (x *StaticResources) GetListeners() []*Listener
- func (x *StaticResources) GetPprofConf() *PprofConf
- func (x *StaticResources) GetShutdownConfig() *ShutdownConfig
- func (*StaticResources) ProtoMessage()
- func (x *StaticResources) ProtoReflect() protoreflect.Message
- func (x *StaticResources) Reset()
- func (x *StaticResources) String() string
- type StringMatcher
- func (*StringMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *StringMatcher) GetContains() string
- func (x *StringMatcher) GetExact() string
- func (x *StringMatcher) GetIgnoreCase() bool
- func (m *StringMatcher) GetMatchPattern() isStringMatcher_MatchPattern
- func (x *StringMatcher) GetPrefix() string
- func (x *StringMatcher) GetSafeRegex() *RegexMatcher
- func (x *StringMatcher) GetSuffix() string
- func (*StringMatcher) ProtoMessage()
- func (x *StringMatcher) ProtoReflect() protoreflect.Message
- func (x *StringMatcher) Reset()
- func (x *StringMatcher) String() string
- type StringMatcher_Contains
- type StringMatcher_Exact
- type StringMatcher_Prefix
- type StringMatcher_SafeRegex
- type StringMatcher_Suffix
Constants ¶
This section is empty.
Variables ¶
var ( HealthStatus_name = map[int32]string{ 0: "UNKNOWN", 1: "HEALTHY", 2: "UNHEALTHY", 3: "DRAINING", 4: "TIMEOUT", 5: "DEGRADED", } HealthStatus_value = map[string]int32{ "UNKNOWN": 0, "HEALTHY": 1, "UNHEALTHY": 2, "DRAINING": 3, "TIMEOUT": 4, "DEGRADED": 5, } )
Enum value maps for HealthStatus.
var ( CodecClientType_name = map[int32]string{ 0: "HTTP1", 1: "HTTP2", 2: "HTTP3", } CodecClientType_value = map[string]int32{ "HTTP1": 0, "HTTP2": 1, "HTTP3": 2, } )
Enum value maps for CodecClientType.
var ( HeaderValueOption_HeaderAppendAction_name = map[int32]string{ 0: "APPEND_IF_EXISTS_OR_ADD", 1: "ADD_IF_ABSENT", 2: "OVERWRITE_IF_EXISTS_OR_ADD", } HeaderValueOption_HeaderAppendAction_value = map[string]int32{ "APPEND_IF_EXISTS_OR_ADD": 0, "ADD_IF_ABSENT": 1, "OVERWRITE_IF_EXISTS_OR_ADD": 2, } )
Enum value maps for HeaderValueOption_HeaderAppendAction.
var File_adapter_proto protoreflect.FileDescriptor
var File_address_proto protoreflect.FileDescriptor
var File_bootstrap_proto protoreflect.FileDescriptor
var File_cluster_proto protoreflect.FileDescriptor
var File_extension_proto protoreflect.FileDescriptor
var File_filter_proto protoreflect.FileDescriptor
var File_health_check_proto protoreflect.FileDescriptor
var File_listener_proto protoreflect.FileDescriptor
var File_route_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Adapter the adapter plugin for manage cluster or router
func (*Adapter) Descriptor
deprecated
func (*Adapter) ProtoMessage ¶
func (*Adapter) ProtoMessage()
func (*Adapter) ProtoReflect ¶
func (x *Adapter) ProtoReflect() protoreflect.Message
type Address ¶
type Address struct { SocketAddress *SocketAddress `protobuf:"bytes,1,opt,name=socket_address,json=socketAddress,proto3" json:"socket_address,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Address the address
func (*Address) Descriptor
deprecated
func (*Address) GetSocketAddress ¶
func (x *Address) GetSocketAddress() *SocketAddress
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
type ApiConfigSource ¶
type ApiConfigSource struct { APITypeStr string `protobuf:"bytes,1,opt,name=API_type_str,json=APITypeStr,proto3" json:"API_type_str,omitempty"` ClusterName []string `protobuf:"bytes,2,rep,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` RefreshDelay string `protobuf:"bytes,3,opt,name=refresh_delay,json=refreshDelay,proto3" json:"refresh_delay,omitempty"` RequestTimeout string `protobuf:"bytes,4,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"` // contains filtered or unexported fields }
ApiConfigSource
func (*ApiConfigSource) Descriptor
deprecated
func (*ApiConfigSource) Descriptor() ([]byte, []int)
Deprecated: Use ApiConfigSource.ProtoReflect.Descriptor instead.
func (*ApiConfigSource) GetAPITypeStr ¶
func (x *ApiConfigSource) GetAPITypeStr() string
func (*ApiConfigSource) GetClusterName ¶
func (x *ApiConfigSource) GetClusterName() []string
func (*ApiConfigSource) GetRefreshDelay ¶
func (x *ApiConfigSource) GetRefreshDelay() string
func (*ApiConfigSource) GetRequestTimeout ¶
func (x *ApiConfigSource) GetRequestTimeout() string
func (*ApiConfigSource) ProtoMessage ¶
func (*ApiConfigSource) ProtoMessage()
func (*ApiConfigSource) ProtoReflect ¶
func (x *ApiConfigSource) ProtoReflect() protoreflect.Message
func (*ApiConfigSource) Reset ¶
func (x *ApiConfigSource) Reset()
func (*ApiConfigSource) String ¶
func (x *ApiConfigSource) String() string
type Cluster ¶
type Cluster struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` TypeStr string `protobuf:"bytes,2,opt,name=type_str,json=typeStr,proto3" json:"type_str,omitempty"` Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"` EdsClusterConfig *EdsClusterConfig `protobuf:"bytes,4,opt,name=eds_cluster_config,json=edsClusterConfig,proto3" json:"eds_cluster_config,omitempty"` LbStr string `protobuf:"bytes,5,opt,name=lb_str,json=lbStr,proto3" json:"lb_str,omitempty"` Lb int32 `protobuf:"varint,6,opt,name=lb,proto3" json:"lb,omitempty"` HealthChecks []*HealthCheck `protobuf:"bytes,7,rep,name=health_checks,json=healthChecks,proto3" json:"health_checks,omitempty"` Endpoints *Endpoint `protobuf:"bytes,8,opt,name=endpoints,proto3" json:"endpoints,omitempty"` // contains filtered or unexported fields }
Cluster a single upstream cluster
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetEdsClusterConfig ¶
func (x *Cluster) GetEdsClusterConfig() *EdsClusterConfig
func (*Cluster) GetEndpoints ¶
func (*Cluster) GetHealthChecks ¶
func (x *Cluster) GetHealthChecks() []*HealthCheck
func (*Cluster) GetTypeStr ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type CodecClientType ¶
type CodecClientType int32
const ( CodecClientType_HTTP1 CodecClientType = 0 CodecClientType_HTTP2 CodecClientType = 1 // [#not-implemented-hide:] QUIC implementation is not production ready yet. Use this enum with // caution to prevent accidental execution of QUIC code. I.e. `!= HTTP2` is no longer sufficient // to distinguish HTTP1 and HTTP2 traffic. CodecClientType_HTTP3 CodecClientType = 2 )
func (CodecClientType) Descriptor ¶
func (CodecClientType) Descriptor() protoreflect.EnumDescriptor
func (CodecClientType) Enum ¶
func (x CodecClientType) Enum() *CodecClientType
func (CodecClientType) EnumDescriptor
deprecated
func (CodecClientType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CodecClientType.Descriptor instead.
func (CodecClientType) Number ¶
func (x CodecClientType) Number() protoreflect.EnumNumber
func (CodecClientType) String ¶
func (x CodecClientType) String() string
func (CodecClientType) Type ¶
func (CodecClientType) Type() protoreflect.EnumType
type Config ¶
type Config struct { Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
Config string kind config(yaml or json such as) for NetworkFilter.
func (*Config) Descriptor
deprecated
func (*Config) GetContent ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
type ConfigSource ¶
type ConfigSource struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` ApiConfigSource *ApiConfigSource `protobuf:"bytes,2,opt,name=api_config_source,json=apiConfigSource,proto3" json:"api_config_source,omitempty"` // contains filtered or unexported fields }
ConfigSource api config from remote
func (*ConfigSource) Descriptor
deprecated
func (*ConfigSource) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSource.ProtoReflect.Descriptor instead.
func (*ConfigSource) GetApiConfigSource ¶
func (x *ConfigSource) GetApiConfigSource() *ApiConfigSource
func (*ConfigSource) GetPath ¶
func (x *ConfigSource) GetPath() string
func (*ConfigSource) ProtoMessage ¶
func (*ConfigSource) ProtoMessage()
func (*ConfigSource) ProtoReflect ¶
func (x *ConfigSource) ProtoReflect() protoreflect.Message
func (*ConfigSource) Reset ¶
func (x *ConfigSource) Reset()
func (*ConfigSource) String ¶
func (x *ConfigSource) String() string
type EdsClusterConfig ¶
type EdsClusterConfig struct { EdsConfig *ConfigSource `protobuf:"bytes,1,opt,name=eds_config,json=edsConfig,proto3" json:"eds_config,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // contains filtered or unexported fields }
EdsClusterConfig
func (*EdsClusterConfig) Descriptor
deprecated
func (*EdsClusterConfig) Descriptor() ([]byte, []int)
Deprecated: Use EdsClusterConfig.ProtoReflect.Descriptor instead.
func (*EdsClusterConfig) GetEdsConfig ¶
func (x *EdsClusterConfig) GetEdsConfig() *ConfigSource
func (*EdsClusterConfig) GetServiceName ¶
func (x *EdsClusterConfig) GetServiceName() string
func (*EdsClusterConfig) ProtoMessage ¶
func (*EdsClusterConfig) ProtoMessage()
func (*EdsClusterConfig) ProtoReflect ¶
func (x *EdsClusterConfig) ProtoReflect() protoreflect.Message
func (*EdsClusterConfig) Reset ¶
func (x *EdsClusterConfig) Reset()
func (*EdsClusterConfig) String ¶
func (x *EdsClusterConfig) String() string
type Endpoint ¶
type Endpoint struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Address *SocketAddress `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
Endpoint
func (*Endpoint) Descriptor
deprecated
func (*Endpoint) GetAddress ¶
func (x *Endpoint) GetAddress() *SocketAddress
func (*Endpoint) GetMetadata ¶
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type EventServiceConfig ¶
type EventServiceConfig struct {
// contains filtered or unexported fields
}
func (*EventServiceConfig) Descriptor
deprecated
func (*EventServiceConfig) Descriptor() ([]byte, []int)
Deprecated: Use EventServiceConfig.ProtoReflect.Descriptor instead.
func (*EventServiceConfig) ProtoMessage ¶
func (*EventServiceConfig) ProtoMessage()
func (*EventServiceConfig) ProtoReflect ¶
func (x *EventServiceConfig) ProtoReflect() protoreflect.Message
func (*EventServiceConfig) Reset ¶
func (x *EventServiceConfig) Reset()
func (*EventServiceConfig) String ¶
func (x *EventServiceConfig) String() string
type FilterChain ¶
type FilterChain struct { Filters []*NetworkFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` // contains filtered or unexported fields }
FilterChain filter chain
func (*FilterChain) Descriptor
deprecated
func (*FilterChain) Descriptor() ([]byte, []int)
Deprecated: Use FilterChain.ProtoReflect.Descriptor instead.
func (*FilterChain) GetFilters ¶
func (x *FilterChain) GetFilters() []*NetworkFilter
func (*FilterChain) ProtoMessage ¶
func (*FilterChain) ProtoMessage()
func (*FilterChain) ProtoReflect ¶
func (x *FilterChain) ProtoReflect() protoreflect.Message
func (*FilterChain) Reset ¶
func (x *FilterChain) Reset()
func (*FilterChain) String ¶
func (x *FilterChain) String() string
type HTTPFilter ¶
type HTTPFilter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
HTTPFilter http filter
func (*HTTPFilter) Descriptor
deprecated
func (*HTTPFilter) Descriptor() ([]byte, []int)
Deprecated: Use HTTPFilter.ProtoReflect.Descriptor instead.
func (*HTTPFilter) GetName ¶
func (x *HTTPFilter) GetName() string
func (*HTTPFilter) ProtoMessage ¶
func (*HTTPFilter) ProtoMessage()
func (*HTTPFilter) ProtoReflect ¶
func (x *HTTPFilter) ProtoReflect() protoreflect.Message
func (*HTTPFilter) Reset ¶
func (x *HTTPFilter) Reset()
func (*HTTPFilter) String ¶
func (x *HTTPFilter) String() string
type HeaderValue ¶
type HeaderValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
HeaderValue
func (*HeaderValue) Descriptor
deprecated
func (*HeaderValue) Descriptor() ([]byte, []int)
Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.
func (*HeaderValue) GetKey ¶
func (x *HeaderValue) GetKey() string
func (*HeaderValue) GetValue ¶
func (x *HeaderValue) GetValue() string
func (*HeaderValue) ProtoMessage ¶
func (*HeaderValue) ProtoMessage()
func (*HeaderValue) ProtoReflect ¶
func (x *HeaderValue) ProtoReflect() protoreflect.Message
func (*HeaderValue) Reset ¶
func (x *HeaderValue) Reset()
func (*HeaderValue) String ¶
func (x *HeaderValue) String() string
type HeaderValueOption ¶
type HeaderValueOption struct { // Header name/value pair that this option applies to. Header *HealthyHeaderValue `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Should the value be appended? If true (default), the value is appended to // existing values. Otherwise it replaces any existing values. Append *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=append,proto3" json:"append,omitempty"` // [#not-implemented-hide:] Describes the action taken to append/overwrite the given value for an existing header // or to only add this header if it's absent. Value defaults to :ref:`APPEND_IF_EXISTS_OR_ADD<envoy_v3_api_enum_value_config.core.v3.HeaderValueOption.HeaderAppendAction.APPEND_IF_EXISTS_OR_ADD>`. AppendAction HeaderValueOption_HeaderAppendAction `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Header name/value pair plus option to control append behavior.
func (*HeaderValueOption) Descriptor
deprecated
func (*HeaderValueOption) Descriptor() ([]byte, []int)
Deprecated: Use HeaderValueOption.ProtoReflect.Descriptor instead.
func (*HeaderValueOption) GetAppend ¶
func (x *HeaderValueOption) GetAppend() *wrapperspb.BoolValue
func (*HeaderValueOption) GetAppendAction ¶
func (x *HeaderValueOption) GetAppendAction() HeaderValueOption_HeaderAppendAction
func (*HeaderValueOption) GetHeader ¶
func (x *HeaderValueOption) GetHeader() *HealthyHeaderValue
func (*HeaderValueOption) ProtoMessage ¶
func (*HeaderValueOption) ProtoMessage()
func (*HeaderValueOption) ProtoReflect ¶
func (x *HeaderValueOption) ProtoReflect() protoreflect.Message
func (*HeaderValueOption) Reset ¶
func (x *HeaderValueOption) Reset()
func (*HeaderValueOption) String ¶
func (x *HeaderValueOption) String() string
type HeaderValueOption_HeaderAppendAction ¶
type HeaderValueOption_HeaderAppendAction int32
Describes the supported actions types for header append action.
const ( // This action will append the specified value to the existing values if the header // already exists. If the header doesn't exist then this will add the header with // specified key and value. HeaderValueOption_APPEND_IF_EXISTS_OR_ADD HeaderValueOption_HeaderAppendAction = 0 // This action will add the header if it doesn't already exist. If the header // already exists then this will be a no-op. HeaderValueOption_ADD_IF_ABSENT HeaderValueOption_HeaderAppendAction = 1 // This action will overwrite the specified value by discarding any existing values if // the header already exists. If the header doesn't exist then this will add the header // with specified key and value. HeaderValueOption_OVERWRITE_IF_EXISTS_OR_ADD HeaderValueOption_HeaderAppendAction = 2 )
func (HeaderValueOption_HeaderAppendAction) Descriptor ¶
func (HeaderValueOption_HeaderAppendAction) Descriptor() protoreflect.EnumDescriptor
func (HeaderValueOption_HeaderAppendAction) Enum ¶
func (x HeaderValueOption_HeaderAppendAction) Enum() *HeaderValueOption_HeaderAppendAction
func (HeaderValueOption_HeaderAppendAction) EnumDescriptor
deprecated
func (HeaderValueOption_HeaderAppendAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use HeaderValueOption_HeaderAppendAction.Descriptor instead.
func (HeaderValueOption_HeaderAppendAction) Number ¶
func (x HeaderValueOption_HeaderAppendAction) Number() protoreflect.EnumNumber
func (HeaderValueOption_HeaderAppendAction) String ¶
func (x HeaderValueOption_HeaderAppendAction) String() string
func (HeaderValueOption_HeaderAppendAction) Type ¶
func (HeaderValueOption_HeaderAppendAction) Type() protoreflect.EnumType
type HealthCheck ¶
type HealthCheck struct { // The time to wait for a health check response. If the timeout is reached the // health check attempt will be considered a failure. Timeout *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` // The interval between health checks. Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` // An optional jitter amount in milliseconds. If specified, Envoy will start health // checking after for a random time in ms between 0 and initial_jitter. This only // applies to the first health check. InitialJitter *durationpb.Duration `protobuf:"bytes,20,opt,name=initial_jitter,json=initialJitter,proto3" json:"initial_jitter,omitempty"` // An optional jitter amount in milliseconds. If specified, during every // interval Envoy will add interval_jitter to the wait time. IntervalJitter *durationpb.Duration `protobuf:"bytes,3,opt,name=interval_jitter,json=intervalJitter,proto3" json:"interval_jitter,omitempty"` // An optional jitter amount as a percentage of interval_ms. If specified, // during every interval Envoy will add interval_ms * // interval_jitter_percent / 100 to the wait time. // // If interval_jitter_ms and interval_jitter_percent are both set, both of // them will be used to increase the wait time. IntervalJitterPercent uint32 `` /* 128-byte string literal not displayed */ // The number of unhealthy health checks required before a host is marked // unhealthy. Note that for *http* health checking if a host responds with a code not in // :ref:`expected_statuses <envoy_v3_api_field_config.core.v3.HealthCheck.HttpHealthCheck.expected_statuses>` // or :ref:`retriable_statuses <envoy_v3_api_field_config.core.v3.HealthCheck.HttpHealthCheck.retriable_statuses>`, // this threshold is ignored and the host is considered immediately unhealthy. UnhealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"` // The number of healthy health checks required before a host is marked // healthy. Note that during startup, only a single successful health check is // required to mark a host healthy. HealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"` // [#not-implemented-hide:] Non-serving port for health checking. AltPort *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=alt_port,json=altPort,proto3" json:"alt_port,omitempty"` // Reuse health check connection between health checks. Default is true. ReuseConnection *wrapperspb.BoolValue `protobuf:"bytes,7,opt,name=reuse_connection,json=reuseConnection,proto3" json:"reuse_connection,omitempty"` // Types that are assignable to HealthChecker: // *HealthCheck_HttpHealthCheck_ // *HealthCheck_TcpHealthCheck_ // *HealthCheck_GrpcHealthCheck_ // *HealthCheck_CustomHealthCheck_ HealthChecker isHealthCheck_HealthChecker `protobuf_oneof:"health_checker"` // The "no traffic interval" is a special health check interval that is used when a cluster has // never had traffic routed to it. This lower interval allows cluster information to be kept up to // date, without sending a potentially large amount of active health checking traffic for no // reason. Once a cluster has been used for traffic routing, Envoy will shift back to using the // standard health check interval that is defined. Note that this interval takes precedence over // any other. // // The default value for "no traffic interval" is 60 seconds. NoTrafficInterval *durationpb.Duration `protobuf:"bytes,12,opt,name=no_traffic_interval,json=noTrafficInterval,proto3" json:"no_traffic_interval,omitempty"` // The "no traffic healthy interval" is a special health check interval that // is used for hosts that are currently passing active health checking // (including new hosts) when the cluster has received no traffic. // // This is useful for when we want to send frequent health checks with // `no_traffic_interval` but then revert to lower frequency `no_traffic_healthy_interval` once // a host in the cluster is marked as healthy. // // Once a cluster has been used for traffic routing, Envoy will shift back to using the // standard health check interval that is defined. // // If no_traffic_healthy_interval is not set, it will default to the // no traffic interval and send that interval regardless of health state. NoTrafficHealthyInterval *durationpb.Duration `` /* 138-byte string literal not displayed */ // The "unhealthy interval" is a health check interval that is used for hosts that are marked as // unhealthy. As soon as the host is marked as healthy, Envoy will shift back to using the // standard health check interval that is defined. // // The default value for "unhealthy interval" is the same as "interval". UnhealthyInterval *durationpb.Duration `protobuf:"bytes,14,opt,name=unhealthy_interval,json=unhealthyInterval,proto3" json:"unhealthy_interval,omitempty"` // The "unhealthy edge interval" is a special health check interval that is used for the first // health check right after a host is marked as unhealthy. For subsequent health checks // Envoy will shift back to using either "unhealthy interval" if present or the standard health // check interval that is defined. // // The default value for "unhealthy edge interval" is the same as "unhealthy interval". UnhealthyEdgeInterval *durationpb.Duration `` /* 127-byte string literal not displayed */ // The "healthy edge interval" is a special health check interval that is used for the first // health check right after a host is marked as healthy. For subsequent health checks // Envoy will shift back to using the standard health check interval that is defined. // // The default value for "healthy edge interval" is the same as the default interval. HealthyEdgeInterval *durationpb.Duration `protobuf:"bytes,16,opt,name=healthy_edge_interval,json=healthyEdgeInterval,proto3" json:"healthy_edge_interval,omitempty"` // Specifies the path to the :ref:`health check event log <arch_overview_health_check_logging>`. // If empty, no event log will be written. EventLogPath string `protobuf:"bytes,17,opt,name=event_log_path,json=eventLogPath,proto3" json:"event_log_path,omitempty"` // [#not-implemented-hide:] // The gRPC service for the health check event service. // If empty, health check events won't be sent to a remote endpoint. EventService *EventServiceConfig `protobuf:"bytes,22,opt,name=event_service,json=eventService,proto3" json:"event_service,omitempty"` // If set to true, health check failure events will always be logged. If set to false, only the // initial health check failure event will be logged. // The default value is false. AlwaysLogHealthCheckFailures bool `` /* 153-byte string literal not displayed */ // This allows overriding the cluster TLS settings, just for health check connections. TlsOptions *HealthCheck_TlsOptions `protobuf:"bytes,21,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty"` // Optional key/value pairs that will be used to match a transport socket from those specified in the cluster's // :ref:`tranport socket matches <envoy_v3_api_field_config.cluster.v3.Cluster.transport_socket_matches>`. // For example, the following match criteria // // .. code-block:: yaml // // transport_socket_match_criteria: // useMTLS: true // // Will match the following :ref:`cluster socket match <envoy_v3_api_msg_config.cluster.v3.Cluster.TransportSocketMatch>` // // .. code-block:: yaml // // transport_socket_matches: // - name: "useMTLS" // match: // useMTLS: true // transport_socket: // name: envoy.transport_sockets.tls // config: { ... } # tls socket configuration // // If this field is set, then for health checks it will supersede an entry of *envoy.transport_socket* in the // :ref:`LbEndpoint.Metadata <envoy_v3_api_field_config.endpoint.v3.LbEndpoint.metadata>`. // This allows using different transport socket capabilities for health checking versus proxying to the // endpoint. // // If the key/values pairs specified do not match any // :ref:`transport socket matches <envoy_v3_api_field_config.cluster.v3.Cluster.transport_socket_matches>`, // the cluster's :ref:`transport socket <envoy_v3_api_field_config.cluster.v3.Cluster.transport_socket>` // will be used for health check socket configuration. TransportSocketMatchCriteria *structpb.Struct `` /* 150-byte string literal not displayed */ // contains filtered or unexported fields }
[#next-free-field: 25]
func (*HealthCheck) Descriptor
deprecated
func (*HealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck) GetAltPort ¶
func (x *HealthCheck) GetAltPort() *wrapperspb.UInt32Value
func (*HealthCheck) GetAlwaysLogHealthCheckFailures ¶
func (x *HealthCheck) GetAlwaysLogHealthCheckFailures() bool
func (*HealthCheck) GetCustomHealthCheck ¶
func (x *HealthCheck) GetCustomHealthCheck() *HealthCheck_CustomHealthCheck
func (*HealthCheck) GetEventLogPath ¶
func (x *HealthCheck) GetEventLogPath() string
func (*HealthCheck) GetEventService ¶
func (x *HealthCheck) GetEventService() *EventServiceConfig
func (*HealthCheck) GetGrpcHealthCheck ¶
func (x *HealthCheck) GetGrpcHealthCheck() *HealthCheck_GrpcHealthCheck
func (*HealthCheck) GetHealthChecker ¶
func (m *HealthCheck) GetHealthChecker() isHealthCheck_HealthChecker
func (*HealthCheck) GetHealthyEdgeInterval ¶
func (x *HealthCheck) GetHealthyEdgeInterval() *durationpb.Duration
func (*HealthCheck) GetHealthyThreshold ¶
func (x *HealthCheck) GetHealthyThreshold() *wrapperspb.UInt32Value
func (*HealthCheck) GetHttpHealthCheck ¶
func (x *HealthCheck) GetHttpHealthCheck() *HealthCheck_HttpHealthCheck
func (*HealthCheck) GetInitialJitter ¶
func (x *HealthCheck) GetInitialJitter() *durationpb.Duration
func (*HealthCheck) GetInterval ¶
func (x *HealthCheck) GetInterval() *durationpb.Duration
func (*HealthCheck) GetIntervalJitter ¶
func (x *HealthCheck) GetIntervalJitter() *durationpb.Duration
func (*HealthCheck) GetIntervalJitterPercent ¶
func (x *HealthCheck) GetIntervalJitterPercent() uint32
func (*HealthCheck) GetNoTrafficHealthyInterval ¶
func (x *HealthCheck) GetNoTrafficHealthyInterval() *durationpb.Duration
func (*HealthCheck) GetNoTrafficInterval ¶
func (x *HealthCheck) GetNoTrafficInterval() *durationpb.Duration
func (*HealthCheck) GetReuseConnection ¶
func (x *HealthCheck) GetReuseConnection() *wrapperspb.BoolValue
func (*HealthCheck) GetTcpHealthCheck ¶
func (x *HealthCheck) GetTcpHealthCheck() *HealthCheck_TcpHealthCheck
func (*HealthCheck) GetTimeout ¶
func (x *HealthCheck) GetTimeout() *durationpb.Duration
func (*HealthCheck) GetTlsOptions ¶
func (x *HealthCheck) GetTlsOptions() *HealthCheck_TlsOptions
func (*HealthCheck) GetTransportSocketMatchCriteria ¶
func (x *HealthCheck) GetTransportSocketMatchCriteria() *structpb.Struct
func (*HealthCheck) GetUnhealthyEdgeInterval ¶
func (x *HealthCheck) GetUnhealthyEdgeInterval() *durationpb.Duration
func (*HealthCheck) GetUnhealthyInterval ¶
func (x *HealthCheck) GetUnhealthyInterval() *durationpb.Duration
func (*HealthCheck) GetUnhealthyThreshold ¶
func (x *HealthCheck) GetUnhealthyThreshold() *wrapperspb.UInt32Value
func (*HealthCheck) ProtoMessage ¶
func (*HealthCheck) ProtoMessage()
func (*HealthCheck) ProtoReflect ¶
func (x *HealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck) Reset ¶
func (x *HealthCheck) Reset()
func (*HealthCheck) String ¶
func (x *HealthCheck) String() string
type HealthCheck_CustomHealthCheck ¶
type HealthCheck_CustomHealthCheck struct { // The registered name of the custom health checker. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // A custom health checker specific configuration which depends on the custom health checker // being instantiated. See :api:`envoy/config/health_checker` for reference. // [#extension-category: envoy.health_checkers] // // Types that are assignable to ConfigType: // *HealthCheck_CustomHealthCheck_TypedConfig ConfigType isHealthCheck_CustomHealthCheck_ConfigType `protobuf_oneof:"config_type"` // contains filtered or unexported fields }
Custom health check.
func (*HealthCheck_CustomHealthCheck) Descriptor
deprecated
func (*HealthCheck_CustomHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_CustomHealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck_CustomHealthCheck) GetConfigType ¶
func (m *HealthCheck_CustomHealthCheck) GetConfigType() isHealthCheck_CustomHealthCheck_ConfigType
func (*HealthCheck_CustomHealthCheck) GetName ¶
func (x *HealthCheck_CustomHealthCheck) GetName() string
func (*HealthCheck_CustomHealthCheck) GetTypedConfig ¶
func (x *HealthCheck_CustomHealthCheck) GetTypedConfig() *anypb.Any
func (*HealthCheck_CustomHealthCheck) ProtoMessage ¶
func (*HealthCheck_CustomHealthCheck) ProtoMessage()
func (*HealthCheck_CustomHealthCheck) ProtoReflect ¶
func (x *HealthCheck_CustomHealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck_CustomHealthCheck) Reset ¶
func (x *HealthCheck_CustomHealthCheck) Reset()
func (*HealthCheck_CustomHealthCheck) String ¶
func (x *HealthCheck_CustomHealthCheck) String() string
type HealthCheck_CustomHealthCheck_ ¶
type HealthCheck_CustomHealthCheck_ struct { // Custom health check. CustomHealthCheck *HealthCheck_CustomHealthCheck `protobuf:"bytes,13,opt,name=custom_health_check,json=customHealthCheck,proto3,oneof"` }
type HealthCheck_GrpcHealthCheck ¶
type HealthCheck_GrpcHealthCheck struct { // An optional service name parameter which will be sent to gRPC service in // `grpc.health.v1.HealthCheckRequest // <https://github.com/grpc/grpc/blob/master/src/proto/grpc/health/v1/health.proto#L20>`_. // message. See `gRPC health-checking overview // <https://github.com/grpc/grpc/blob/master/doc/health-checking.md>`_ for more information. ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // The value of the :authority header in the gRPC health check request. If // left empty (default value), the name of the cluster this health check is associated // with will be used. The authority header can be customized for a specific endpoint by setting // the :ref:`hostname <envoy_v3_api_field_config.endpoint.v3.Endpoint.HealthCheckConfig.hostname>` field. Authority string `protobuf:"bytes,2,opt,name=authority,proto3" json:"authority,omitempty"` // contains filtered or unexported fields }
`grpc.health.v1.Health <https://github.com/grpc/grpc/blob/master/src/proto/grpc/health/v1/health.proto>`_-based healthcheck. See `gRPC doc <https://github.com/grpc/grpc/blob/master/doc/health-checking.md>`_ for details.
func (*HealthCheck_GrpcHealthCheck) Descriptor
deprecated
func (*HealthCheck_GrpcHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_GrpcHealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck_GrpcHealthCheck) GetAuthority ¶
func (x *HealthCheck_GrpcHealthCheck) GetAuthority() string
func (*HealthCheck_GrpcHealthCheck) GetServiceName ¶
func (x *HealthCheck_GrpcHealthCheck) GetServiceName() string
func (*HealthCheck_GrpcHealthCheck) ProtoMessage ¶
func (*HealthCheck_GrpcHealthCheck) ProtoMessage()
func (*HealthCheck_GrpcHealthCheck) ProtoReflect ¶
func (x *HealthCheck_GrpcHealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck_GrpcHealthCheck) Reset ¶
func (x *HealthCheck_GrpcHealthCheck) Reset()
func (*HealthCheck_GrpcHealthCheck) String ¶
func (x *HealthCheck_GrpcHealthCheck) String() string
type HealthCheck_GrpcHealthCheck_ ¶
type HealthCheck_GrpcHealthCheck_ struct { // gRPC health check. GrpcHealthCheck *HealthCheck_GrpcHealthCheck `protobuf:"bytes,11,opt,name=grpc_health_check,json=grpcHealthCheck,proto3,oneof"` }
type HealthCheck_HttpHealthCheck ¶
type HealthCheck_HttpHealthCheck struct { // The value of the host header in the HTTP health check request. If // left empty (default value), the name of the cluster this health check is associated // with will be used. The host header can be customized for a specific endpoint by setting the // :ref:`hostname <envoy_v3_api_field_config.endpoint.v3.Endpoint.HealthCheckConfig.hostname>` field. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Specifies the HTTP path that will be requested during health checking. For example // */healthcheck*. Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // [#not-implemented-hide:] HTTP specific payload. Send *HealthCheck_Payload `protobuf:"bytes,3,opt,name=send,proto3" json:"send,omitempty"` // [#not-implemented-hide:] HTTP specific response. Receive *HealthCheck_Payload `protobuf:"bytes,4,opt,name=receive,proto3" json:"receive,omitempty"` // Specifies a list of HTTP headers that should be added to each request that is sent to the // health checked cluster. For more information, including details on header value syntax, see // the documentation on :ref:`custom request headers // <config_http_conn_man_headers_custom_request_headers>`. RequestHeadersToAdd []*HeaderValueOption `protobuf:"bytes,6,rep,name=request_headers_to_add,json=requestHeadersToAdd,proto3" json:"request_headers_to_add,omitempty"` // Specifies a list of HTTP headers that should be removed from each request that is sent to the // health checked cluster. RequestHeadersToRemove []string `` /* 131-byte string literal not displayed */ // Specifies a list of HTTP response statuses considered healthy. If provided, replaces default // 200-only policy - 200 must be included explicitly as needed. Ranges follow half-open // semantics of :ref:`Int64Range <envoy_v3_api_msg_type.v3.Int64Range>`. The start and end of each // range are required. Only statuses in the range [100, 600) are allowed. ExpectedStatuses []*Int64Range `protobuf:"bytes,9,rep,name=expected_statuses,json=expectedStatuses,proto3" json:"expected_statuses,omitempty"` // Specifies a list of HTTP response statuses considered retriable. If provided, responses in this range // will count towards the configured :ref:`unhealthy_threshold <envoy_v3_api_field_config.core.v3.HealthCheck.unhealthy_threshold>`, // but will not result in the host being considered immediately unhealthy. Ranges follow half-open semantics of // :ref:`Int64Range <envoy_v3_api_msg_type.v3.Int64Range>`. The start and end of each range are required. // Only statuses in the range [100, 600) are allowed. The :ref:`expected_statuses <envoy_v3_api_field_config.core.v3.HealthCheck.HttpHealthCheck.expected_statuses>` // field takes precedence for any range overlaps with this field i.e. if status code 200 is both retriable and expected, a 200 response will // be considered a successful health check. By default all responses not in // :ref:`expected_statuses <envoy_v3_api_field_config.core.v3.HealthCheck.HttpHealthCheck.expected_statuses>` will result in // the host being considered immediately unhealthy i.e. if status code 200 is expected and there are no configured retriable statuses, any // non-200 response will result in the host being marked unhealthy. RetriableStatuses []*Int64Range `protobuf:"bytes,12,rep,name=retriable_statuses,json=retriableStatuses,proto3" json:"retriable_statuses,omitempty"` // Use specified application protocol for health checks. CodecClientType CodecClientType `` /* 144-byte string literal not displayed */ // An optional service name parameter which is used to validate the identity of // the health checked cluster using a :ref:`StringMatcher // <envoy_v3_api_msg_type.matcher.v3.StringMatcher>`. See the :ref:`architecture overview // <arch_overview_health_checking_identity>` for more information. ServiceNameMatcher *StringMatcher `protobuf:"bytes,11,opt,name=service_name_matcher,json=serviceNameMatcher,proto3" json:"service_name_matcher,omitempty"` // contains filtered or unexported fields }
[#next-free-field: 13]
func (*HealthCheck_HttpHealthCheck) Descriptor
deprecated
func (*HealthCheck_HttpHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_HttpHealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck_HttpHealthCheck) GetCodecClientType ¶
func (x *HealthCheck_HttpHealthCheck) GetCodecClientType() CodecClientType
func (*HealthCheck_HttpHealthCheck) GetExpectedStatuses ¶
func (x *HealthCheck_HttpHealthCheck) GetExpectedStatuses() []*Int64Range
func (*HealthCheck_HttpHealthCheck) GetHost ¶
func (x *HealthCheck_HttpHealthCheck) GetHost() string
func (*HealthCheck_HttpHealthCheck) GetPath ¶
func (x *HealthCheck_HttpHealthCheck) GetPath() string
func (*HealthCheck_HttpHealthCheck) GetReceive ¶
func (x *HealthCheck_HttpHealthCheck) GetReceive() *HealthCheck_Payload
func (*HealthCheck_HttpHealthCheck) GetRequestHeadersToAdd ¶
func (x *HealthCheck_HttpHealthCheck) GetRequestHeadersToAdd() []*HeaderValueOption
func (*HealthCheck_HttpHealthCheck) GetRequestHeadersToRemove ¶
func (x *HealthCheck_HttpHealthCheck) GetRequestHeadersToRemove() []string
func (*HealthCheck_HttpHealthCheck) GetRetriableStatuses ¶
func (x *HealthCheck_HttpHealthCheck) GetRetriableStatuses() []*Int64Range
func (*HealthCheck_HttpHealthCheck) GetSend ¶
func (x *HealthCheck_HttpHealthCheck) GetSend() *HealthCheck_Payload
func (*HealthCheck_HttpHealthCheck) GetServiceNameMatcher ¶
func (x *HealthCheck_HttpHealthCheck) GetServiceNameMatcher() *StringMatcher
func (*HealthCheck_HttpHealthCheck) ProtoMessage ¶
func (*HealthCheck_HttpHealthCheck) ProtoMessage()
func (*HealthCheck_HttpHealthCheck) ProtoReflect ¶
func (x *HealthCheck_HttpHealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck_HttpHealthCheck) Reset ¶
func (x *HealthCheck_HttpHealthCheck) Reset()
func (*HealthCheck_HttpHealthCheck) String ¶
func (x *HealthCheck_HttpHealthCheck) String() string
type HealthCheck_HttpHealthCheck_ ¶
type HealthCheck_HttpHealthCheck_ struct { // HTTP health check. HttpHealthCheck *HealthCheck_HttpHealthCheck `protobuf:"bytes,8,opt,name=http_health_check,json=httpHealthCheck,proto3,oneof"` }
type HealthCheck_Payload ¶
type HealthCheck_Payload struct { // Types that are assignable to Payload: // *HealthCheck_Payload_Text // *HealthCheck_Payload_Binary Payload isHealthCheck_Payload_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
Describes the encoding of the payload bytes in the payload.
func (*HealthCheck_Payload) Descriptor
deprecated
func (*HealthCheck_Payload) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_Payload.ProtoReflect.Descriptor instead.
func (*HealthCheck_Payload) GetBinary ¶
func (x *HealthCheck_Payload) GetBinary() []byte
func (*HealthCheck_Payload) GetPayload ¶
func (m *HealthCheck_Payload) GetPayload() isHealthCheck_Payload_Payload
func (*HealthCheck_Payload) GetText ¶
func (x *HealthCheck_Payload) GetText() string
func (*HealthCheck_Payload) ProtoMessage ¶
func (*HealthCheck_Payload) ProtoMessage()
func (*HealthCheck_Payload) ProtoReflect ¶
func (x *HealthCheck_Payload) ProtoReflect() protoreflect.Message
func (*HealthCheck_Payload) Reset ¶
func (x *HealthCheck_Payload) Reset()
func (*HealthCheck_Payload) String ¶
func (x *HealthCheck_Payload) String() string
type HealthCheck_Payload_Binary ¶
type HealthCheck_Payload_Binary struct { // [#not-implemented-hide:] Binary payload. Binary []byte `protobuf:"bytes,2,opt,name=binary,proto3,oneof"` }
type HealthCheck_Payload_Text ¶
type HealthCheck_Payload_Text struct { // Hex encoded payload. E.g., "000000FF". Text string `protobuf:"bytes,1,opt,name=text,proto3,oneof"` }
type HealthCheck_RedisHealthCheck ¶
type HealthCheck_RedisHealthCheck struct { // If set, optionally perform “EXISTS <key>“ instead of “PING“. A return value // from Redis of 0 (does not exist) is considered a passing healthcheck. A return value other // than 0 is considered a failure. This allows the user to mark a Redis instance for maintenance // by setting the specified key to any value and waiting for traffic to drain. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*HealthCheck_RedisHealthCheck) Descriptor
deprecated
func (*HealthCheck_RedisHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_RedisHealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck_RedisHealthCheck) GetKey ¶
func (x *HealthCheck_RedisHealthCheck) GetKey() string
func (*HealthCheck_RedisHealthCheck) ProtoMessage ¶
func (*HealthCheck_RedisHealthCheck) ProtoMessage()
func (*HealthCheck_RedisHealthCheck) ProtoReflect ¶
func (x *HealthCheck_RedisHealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck_RedisHealthCheck) Reset ¶
func (x *HealthCheck_RedisHealthCheck) Reset()
func (*HealthCheck_RedisHealthCheck) String ¶
func (x *HealthCheck_RedisHealthCheck) String() string
type HealthCheck_TcpHealthCheck ¶
type HealthCheck_TcpHealthCheck struct { // Empty payloads imply a connect-only health check. Send *HealthCheck_Payload `protobuf:"bytes,1,opt,name=send,proto3" json:"send,omitempty"` // When checking the response, “fuzzy” matching is performed such that each // binary block must be found, and in the order specified, but not // necessarily contiguous. Receive []*HealthCheck_Payload `protobuf:"bytes,2,rep,name=receive,proto3" json:"receive,omitempty"` // contains filtered or unexported fields }
func (*HealthCheck_TcpHealthCheck) Descriptor
deprecated
func (*HealthCheck_TcpHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_TcpHealthCheck.ProtoReflect.Descriptor instead.
func (*HealthCheck_TcpHealthCheck) GetReceive ¶
func (x *HealthCheck_TcpHealthCheck) GetReceive() []*HealthCheck_Payload
func (*HealthCheck_TcpHealthCheck) GetSend ¶
func (x *HealthCheck_TcpHealthCheck) GetSend() *HealthCheck_Payload
func (*HealthCheck_TcpHealthCheck) ProtoMessage ¶
func (*HealthCheck_TcpHealthCheck) ProtoMessage()
func (*HealthCheck_TcpHealthCheck) ProtoReflect ¶
func (x *HealthCheck_TcpHealthCheck) ProtoReflect() protoreflect.Message
func (*HealthCheck_TcpHealthCheck) Reset ¶
func (x *HealthCheck_TcpHealthCheck) Reset()
func (*HealthCheck_TcpHealthCheck) String ¶
func (x *HealthCheck_TcpHealthCheck) String() string
type HealthCheck_TcpHealthCheck_ ¶
type HealthCheck_TcpHealthCheck_ struct { // TCP health check. TcpHealthCheck *HealthCheck_TcpHealthCheck `protobuf:"bytes,9,opt,name=tcp_health_check,json=tcpHealthCheck,proto3,oneof"` }
type HealthCheck_TlsOptions ¶
type HealthCheck_TlsOptions struct { // Specifies the ALPN protocols for health check connections. This is useful if the // corresponding upstream is using ALPN-based :ref:`FilterChainMatch // <envoy_v3_api_msg_config.listener.v3.FilterChainMatch>` along with different protocols for health checks // versus data connections. If empty, no ALPN protocols will be set on health check connections. AlpnProtocols []string `protobuf:"bytes,1,rep,name=alpn_protocols,json=alpnProtocols,proto3" json:"alpn_protocols,omitempty"` // contains filtered or unexported fields }
Health checks occur over the transport socket specified for the cluster. This implies that if a cluster is using a TLS-enabled transport socket, the health check will also occur over TLS.
This allows overriding the cluster TLS settings, just for health check connections.
func (*HealthCheck_TlsOptions) Descriptor
deprecated
func (*HealthCheck_TlsOptions) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheck_TlsOptions.ProtoReflect.Descriptor instead.
func (*HealthCheck_TlsOptions) GetAlpnProtocols ¶
func (x *HealthCheck_TlsOptions) GetAlpnProtocols() []string
func (*HealthCheck_TlsOptions) ProtoMessage ¶
func (*HealthCheck_TlsOptions) ProtoMessage()
func (*HealthCheck_TlsOptions) ProtoReflect ¶
func (x *HealthCheck_TlsOptions) ProtoReflect() protoreflect.Message
func (*HealthCheck_TlsOptions) Reset ¶
func (x *HealthCheck_TlsOptions) Reset()
func (*HealthCheck_TlsOptions) String ¶
func (x *HealthCheck_TlsOptions) String() string
type HealthStatus ¶
type HealthStatus int32
Endpoint health status.
const ( // The health status is not known. This is interpreted by Envoy as *HEALTHY*. HealthStatus_UNKNOWN HealthStatus = 0 // Healthy. HealthStatus_HEALTHY HealthStatus = 1 // Unhealthy. HealthStatus_UNHEALTHY HealthStatus = 2 // Connection draining in progress. E.g., // `<https://aws.amazon.com/blogs/aws/elb-connection-draining-remove-instances-from-service-with-care/>`_ // or // `<https://cloud.google.com/compute/docs/load-balancing/enabling-connection-draining>`_. // This is interpreted by Envoy as *UNHEALTHY*. HealthStatus_DRAINING HealthStatus = 3 // Health check timed out. This is part of HDS and is interpreted by Envoy as // *UNHEALTHY*. HealthStatus_TIMEOUT HealthStatus = 4 // Degraded. HealthStatus_DEGRADED HealthStatus = 5 )
func (HealthStatus) Descriptor ¶
func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthStatus) Enum ¶
func (x HealthStatus) Enum() *HealthStatus
func (HealthStatus) EnumDescriptor
deprecated
func (HealthStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthStatus.Descriptor instead.
func (HealthStatus) Number ¶
func (x HealthStatus) Number() protoreflect.EnumNumber
func (HealthStatus) String ¶
func (x HealthStatus) String() string
func (HealthStatus) Type ¶
func (HealthStatus) Type() protoreflect.EnumType
type HealthyHeaderValue ¶
type HealthyHeaderValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
HeaderValue
func (*HealthyHeaderValue) Descriptor
deprecated
func (*HealthyHeaderValue) Descriptor() ([]byte, []int)
Deprecated: Use HealthyHeaderValue.ProtoReflect.Descriptor instead.
func (*HealthyHeaderValue) GetKey ¶
func (x *HealthyHeaderValue) GetKey() string
func (*HealthyHeaderValue) GetValue ¶
func (x *HealthyHeaderValue) GetValue() string
func (*HealthyHeaderValue) ProtoMessage ¶
func (*HealthyHeaderValue) ProtoMessage()
func (*HealthyHeaderValue) ProtoReflect ¶
func (x *HealthyHeaderValue) ProtoReflect() protoreflect.Message
func (*HealthyHeaderValue) Reset ¶
func (x *HealthyHeaderValue) Reset()
func (*HealthyHeaderValue) String ¶
func (x *HealthyHeaderValue) String() string
type Int64Range ¶
type Int64Range struct { // start of the range (inclusive) Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // end of the range (exclusive) End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*Int64Range) Descriptor
deprecated
func (*Int64Range) Descriptor() ([]byte, []int)
Deprecated: Use Int64Range.ProtoReflect.Descriptor instead.
func (*Int64Range) GetEnd ¶
func (x *Int64Range) GetEnd() int64
func (*Int64Range) GetStart ¶
func (x *Int64Range) GetStart() int64
func (*Int64Range) ProtoMessage ¶
func (*Int64Range) ProtoMessage()
func (*Int64Range) ProtoReflect ¶
func (x *Int64Range) ProtoReflect() protoreflect.Message
func (*Int64Range) Reset ¶
func (x *Int64Range) Reset()
func (*Int64Range) String ¶
func (x *Int64Range) String() string
type Listener ¶
type Listener struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Address *Address `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` FilterChain *FilterChain `protobuf:"bytes,3,opt,name=filter_chain,json=filterChain,proto3" json:"filter_chain,omitempty"` // contains filtered or unexported fields }
Listener is a server, listener a port
func (*Listener) Descriptor
deprecated
func (*Listener) GetAddress ¶
func (*Listener) GetFilterChain ¶
func (x *Listener) GetFilterChain() *FilterChain
func (*Listener) ProtoMessage ¶
func (*Listener) ProtoMessage()
func (*Listener) ProtoReflect ¶
func (x *Listener) ProtoReflect() protoreflect.Message
type Metric ¶
type Metric struct { Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"` PrometheusPort int64 `protobuf:"varint,2,opt,name=prometheus_port,json=prometheusPort,proto3" json:"prometheus_port,omitempty"` // contains filtered or unexported fields }
Metric config for otel metric.
func (*Metric) Descriptor
deprecated
func (*Metric) GetPrometheusPort ¶
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) ProtoReflect ¶
func (x *Metric) ProtoReflect() protoreflect.Message
type NetworkFilter ¶
type NetworkFilter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Config: // *NetworkFilter_Yaml // *NetworkFilter_Json // *NetworkFilter_Struct Config isNetworkFilter_Config `protobuf_oneof:"config"` // contains filtered or unexported fields }
Filter core struct, filter is extend by user
func (*NetworkFilter) Descriptor
deprecated
func (*NetworkFilter) Descriptor() ([]byte, []int)
Deprecated: Use NetworkFilter.ProtoReflect.Descriptor instead.
func (*NetworkFilter) GetConfig ¶
func (m *NetworkFilter) GetConfig() isNetworkFilter_Config
func (*NetworkFilter) GetJson ¶
func (x *NetworkFilter) GetJson() *Config
func (*NetworkFilter) GetName ¶
func (x *NetworkFilter) GetName() string
func (*NetworkFilter) GetStruct ¶
func (x *NetworkFilter) GetStruct() *structpb.Struct
func (*NetworkFilter) GetYaml ¶
func (x *NetworkFilter) GetYaml() *Config
func (*NetworkFilter) ProtoMessage ¶
func (*NetworkFilter) ProtoMessage()
func (*NetworkFilter) ProtoReflect ¶
func (x *NetworkFilter) ProtoReflect() protoreflect.Message
func (*NetworkFilter) Reset ¶
func (x *NetworkFilter) Reset()
func (*NetworkFilter) String ¶
func (x *NetworkFilter) String() string
type NetworkFilter_Json ¶
type NetworkFilter_Json struct {
Json *Config `protobuf:"bytes,3,opt,name=json,proto3,oneof"`
}
type NetworkFilter_Struct ¶
type NetworkFilter_Yaml ¶
type NetworkFilter_Yaml struct {
Yaml *Config `protobuf:"bytes,2,opt,name=yaml,proto3,oneof"`
}
type PixiuExtensionClusters ¶
type PixiuExtensionClusters struct { Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` // contains filtered or unexported fields }
Message map to dubbo-go.pixiu//v1/discovery:cluster
func (*PixiuExtensionClusters) Descriptor
deprecated
func (*PixiuExtensionClusters) Descriptor() ([]byte, []int)
Deprecated: Use PixiuExtensionClusters.ProtoReflect.Descriptor instead.
func (*PixiuExtensionClusters) GetClusters ¶
func (x *PixiuExtensionClusters) GetClusters() []*Cluster
func (*PixiuExtensionClusters) ProtoMessage ¶
func (*PixiuExtensionClusters) ProtoMessage()
func (*PixiuExtensionClusters) ProtoReflect ¶
func (x *PixiuExtensionClusters) ProtoReflect() protoreflect.Message
func (*PixiuExtensionClusters) Reset ¶
func (x *PixiuExtensionClusters) Reset()
func (*PixiuExtensionClusters) String ¶
func (x *PixiuExtensionClusters) String() string
type PixiuExtensionListeners ¶
type PixiuExtensionListeners struct { Listeners []*Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"` // contains filtered or unexported fields }
Message map to dubbo-go.pixiu//v1/discovery:listener
func (*PixiuExtensionListeners) Descriptor
deprecated
func (*PixiuExtensionListeners) Descriptor() ([]byte, []int)
Deprecated: Use PixiuExtensionListeners.ProtoReflect.Descriptor instead.
func (*PixiuExtensionListeners) GetListeners ¶
func (x *PixiuExtensionListeners) GetListeners() []*Listener
func (*PixiuExtensionListeners) ProtoMessage ¶
func (*PixiuExtensionListeners) ProtoMessage()
func (*PixiuExtensionListeners) ProtoReflect ¶
func (x *PixiuExtensionListeners) ProtoReflect() protoreflect.Message
func (*PixiuExtensionListeners) Reset ¶
func (x *PixiuExtensionListeners) Reset()
func (*PixiuExtensionListeners) String ¶
func (x *PixiuExtensionListeners) String() string
type PprofConf ¶
type PprofConf struct { Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"` Address *Address `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
PprofConf config how to connect to golang pprof
func (*PprofConf) Descriptor
deprecated
func (*PprofConf) GetAddress ¶
func (*PprofConf) ProtoMessage ¶
func (*PprofConf) ProtoMessage()
func (*PprofConf) ProtoReflect ¶
func (x *PprofConf) ProtoReflect() protoreflect.Message
type RegexMatchAndSubstitute ¶
type RegexMatchAndSubstitute struct { // The regular expression used to find portions of a string (hereafter called // the "subject string") that should be replaced. When a new string is // produced during the substitution operation, the new string is initially // the same as the subject string, but then all matches in the subject string // are replaced by the substitution string. If replacing all matches isn't // desired, regular expression anchors can be used to ensure a single match, // so as to replace just one occurrence of a pattern. Capture groups can be // used in the pattern to extract portions of the subject string, and then // referenced in the substitution string. Pattern *RegexMatcher `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"` // The string that should be substituted into matching portions of the // subject string during a substitution operation to produce a new string. // Capture groups in the pattern can be referenced in the substitution // string. Note, however, that the syntax for referring to capture groups is // defined by the chosen regular expression engine. Google's `RE2 // <https://github.com/google/re2>`_ regular expression engine uses a // backslash followed by the capture group number to denote a numbered // capture group. E.g., “\1“ refers to capture group 1, and “\2“ refers // to capture group 2. Substitution string `protobuf:"bytes,2,opt,name=substitution,proto3" json:"substitution,omitempty"` // contains filtered or unexported fields }
Describes how to match a string and then produce a new string using a regular expression and a substitution string.
func (*RegexMatchAndSubstitute) Descriptor
deprecated
func (*RegexMatchAndSubstitute) Descriptor() ([]byte, []int)
Deprecated: Use RegexMatchAndSubstitute.ProtoReflect.Descriptor instead.
func (*RegexMatchAndSubstitute) GetPattern ¶
func (x *RegexMatchAndSubstitute) GetPattern() *RegexMatcher
func (*RegexMatchAndSubstitute) GetSubstitution ¶
func (x *RegexMatchAndSubstitute) GetSubstitution() string
func (*RegexMatchAndSubstitute) ProtoMessage ¶
func (*RegexMatchAndSubstitute) ProtoMessage()
func (*RegexMatchAndSubstitute) ProtoReflect ¶
func (x *RegexMatchAndSubstitute) ProtoReflect() protoreflect.Message
func (*RegexMatchAndSubstitute) Reset ¶
func (x *RegexMatchAndSubstitute) Reset()
func (*RegexMatchAndSubstitute) String ¶
func (x *RegexMatchAndSubstitute) String() string
type RegexMatcher ¶
type RegexMatcher struct { // Types that are assignable to EngineType: // *RegexMatcher_GoogleRe2 EngineType isRegexMatcher_EngineType `protobuf_oneof:"engine_type"` // The regex match string. The string must be supported by the configured engine. Regex string `protobuf:"bytes,2,opt,name=regex,proto3" json:"regex,omitempty"` // contains filtered or unexported fields }
A regex matcher designed for safety when used with untrusted input.
func (*RegexMatcher) Descriptor
deprecated
func (*RegexMatcher) Descriptor() ([]byte, []int)
Deprecated: Use RegexMatcher.ProtoReflect.Descriptor instead.
func (*RegexMatcher) GetEngineType ¶
func (m *RegexMatcher) GetEngineType() isRegexMatcher_EngineType
func (*RegexMatcher) GetGoogleRe2 ¶
func (x *RegexMatcher) GetGoogleRe2() *RegexMatcher_GoogleRE2
func (*RegexMatcher) GetRegex ¶
func (x *RegexMatcher) GetRegex() string
func (*RegexMatcher) ProtoMessage ¶
func (*RegexMatcher) ProtoMessage()
func (*RegexMatcher) ProtoReflect ¶
func (x *RegexMatcher) ProtoReflect() protoreflect.Message
func (*RegexMatcher) Reset ¶
func (x *RegexMatcher) Reset()
func (*RegexMatcher) String ¶
func (x *RegexMatcher) String() string
type RegexMatcher_GoogleRE2 ¶
type RegexMatcher_GoogleRE2 struct { // This field controls the RE2 "program size" which is a rough estimate of how complex a // compiled regex is to evaluate. A regex that has a program size greater than the configured // value will fail to compile. In this case, the configured max program size can be increased // or the regex can be simplified. If not specified, the default is 100. // // This field is deprecated; regexp validation should be performed on the management server // instead of being done by each individual client. // // Deprecated: Do not use. MaxProgramSize *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=max_program_size,json=maxProgramSize,proto3" json:"max_program_size,omitempty"` // contains filtered or unexported fields }
Google's `RE2 <https://github.com/google/re2>`_ regex engine. The regex string must adhere to the documented `syntax <https://github.com/google/re2/wiki/Syntax>`_. The engine is designed to complete execution in linear time as well as limit the amount of memory used.
Envoy supports program size checking via runtime. The runtime keys `re2.max_program_size.error_level` and `re2.max_program_size.warn_level` can be set to integers as the maximum program size or complexity that a compiled regex can have before an exception is thrown or a warning is logged, respectively. `re2.max_program_size.error_level` defaults to 100, and `re2.max_program_size.warn_level` has no default if unset (will not check/log a warning).
Envoy emits two stats for tracking the program size of regexes: the histogram `re2.program_size`, which records the program size, and the counter `re2.exceeded_warn_level`, which is incremented each time the program size exceeds the warn level threshold.
func (*RegexMatcher_GoogleRE2) Descriptor
deprecated
func (*RegexMatcher_GoogleRE2) Descriptor() ([]byte, []int)
Deprecated: Use RegexMatcher_GoogleRE2.ProtoReflect.Descriptor instead.
func (*RegexMatcher_GoogleRE2) GetMaxProgramSize
deprecated
func (x *RegexMatcher_GoogleRE2) GetMaxProgramSize() *wrapperspb.UInt32Value
Deprecated: Do not use.
func (*RegexMatcher_GoogleRE2) ProtoMessage ¶
func (*RegexMatcher_GoogleRE2) ProtoMessage()
func (*RegexMatcher_GoogleRE2) ProtoReflect ¶
func (x *RegexMatcher_GoogleRE2) ProtoReflect() protoreflect.Message
func (*RegexMatcher_GoogleRE2) Reset ¶
func (x *RegexMatcher_GoogleRE2) Reset()
func (*RegexMatcher_GoogleRE2) String ¶
func (x *RegexMatcher_GoogleRE2) String() string
type RegexMatcher_GoogleRe2 ¶
type RegexMatcher_GoogleRe2 struct { // Google's RE2 regex engine. GoogleRe2 *RegexMatcher_GoogleRE2 `protobuf:"bytes,1,opt,name=google_re2,json=googleRe2,proto3,oneof"` }
type RouteAction ¶
type RouteAction struct { Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` ClusterNotFoundResponseCode int64 `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
RouteAction match route should do
func (*RouteAction) Descriptor
deprecated
func (*RouteAction) Descriptor() ([]byte, []int)
Deprecated: Use RouteAction.ProtoReflect.Descriptor instead.
func (*RouteAction) GetCluster ¶
func (x *RouteAction) GetCluster() string
func (*RouteAction) GetClusterNotFoundResponseCode ¶
func (x *RouteAction) GetClusterNotFoundResponseCode() int64
func (*RouteAction) ProtoMessage ¶
func (*RouteAction) ProtoMessage()
func (*RouteAction) ProtoReflect ¶
func (x *RouteAction) ProtoReflect() protoreflect.Message
func (*RouteAction) Reset ¶
func (x *RouteAction) Reset()
func (*RouteAction) String ¶
func (x *RouteAction) String() string
type RouteConfiguration ¶
type RouteConfiguration struct { Routes []*Router `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"` Dynamic bool `protobuf:"varint,2,opt,name=dynamic,proto3" json:"dynamic,omitempty"` // contains filtered or unexported fields }
RouteConfiguration todo config route from (Http|Grpc|...)ManagerConfig
func (*RouteConfiguration) Descriptor
deprecated
func (*RouteConfiguration) Descriptor() ([]byte, []int)
Deprecated: Use RouteConfiguration.ProtoReflect.Descriptor instead.
func (*RouteConfiguration) GetDynamic ¶
func (x *RouteConfiguration) GetDynamic() bool
func (*RouteConfiguration) GetRoutes ¶
func (x *RouteConfiguration) GetRoutes() []*Router
func (*RouteConfiguration) ProtoMessage ¶
func (*RouteConfiguration) ProtoMessage()
func (*RouteConfiguration) ProtoReflect ¶
func (x *RouteConfiguration) ProtoReflect() protoreflect.Message
func (*RouteConfiguration) Reset ¶
func (x *RouteConfiguration) Reset()
func (*RouteConfiguration) String ¶
func (x *RouteConfiguration) String() string
type Router ¶
type Router struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Match *RouterMatch `protobuf:"bytes,2,opt,name=match,proto3" json:"match,omitempty"` Route *RouteAction `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"` // contains filtered or unexported fields }
Router router config for RouteConfiguration
func (*Router) Descriptor
deprecated
func (*Router) GetMatch ¶
func (x *Router) GetMatch() *RouterMatch
func (*Router) GetRoute ¶
func (x *Router) GetRoute() *RouteAction
func (*Router) ProtoMessage ¶
func (*Router) ProtoMessage()
func (*Router) ProtoReflect ¶
func (x *Router) ProtoReflect() protoreflect.Message
type RouterMatch ¶
type RouterMatch struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Methods []string `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"` // contains filtered or unexported fields }
RouterMatch
func (*RouterMatch) Descriptor
deprecated
func (*RouterMatch) Descriptor() ([]byte, []int)
Deprecated: Use RouterMatch.ProtoReflect.Descriptor instead.
func (*RouterMatch) GetMethods ¶
func (x *RouterMatch) GetMethods() []string
func (*RouterMatch) GetPath ¶
func (x *RouterMatch) GetPath() string
func (*RouterMatch) GetPrefix ¶
func (x *RouterMatch) GetPrefix() string
func (*RouterMatch) ProtoMessage ¶
func (*RouterMatch) ProtoMessage()
func (*RouterMatch) ProtoReflect ¶
func (x *RouterMatch) ProtoReflect() protoreflect.Message
func (*RouterMatch) Reset ¶
func (x *RouterMatch) Reset()
func (*RouterMatch) String ¶
func (x *RouterMatch) String() string
type ShutdownConfig ¶
type ShutdownConfig struct { Timeout string `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` StepTimeout string `protobuf:"bytes,2,opt,name=step_timeout,json=stepTimeout,proto3" json:"step_timeout,omitempty"` RejectPolicy string `protobuf:"bytes,3,opt,name=reject_policy,json=rejectPolicy,proto3" json:"reject_policy,omitempty"` // contains filtered or unexported fields }
ShutdownConfig how to shutdown server.
func (*ShutdownConfig) Descriptor
deprecated
func (*ShutdownConfig) Descriptor() ([]byte, []int)
Deprecated: Use ShutdownConfig.ProtoReflect.Descriptor instead.
func (*ShutdownConfig) GetRejectPolicy ¶
func (x *ShutdownConfig) GetRejectPolicy() string
func (*ShutdownConfig) GetStepTimeout ¶
func (x *ShutdownConfig) GetStepTimeout() string
func (*ShutdownConfig) GetTimeout ¶
func (x *ShutdownConfig) GetTimeout() string
func (*ShutdownConfig) ProtoMessage ¶
func (*ShutdownConfig) ProtoMessage()
func (*ShutdownConfig) ProtoReflect ¶
func (x *ShutdownConfig) ProtoReflect() protoreflect.Message
func (*ShutdownConfig) Reset ¶
func (x *ShutdownConfig) Reset()
func (*ShutdownConfig) String ¶
func (x *ShutdownConfig) String() string
type SocketAddress ¶
type SocketAddress struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Port int64 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` ResolverName string `protobuf:"bytes,3,opt,name=resolver_name,json=resolverName,proto3" json:"resolver_name,omitempty"` Domains []string `protobuf:"bytes,4,rep,name=domains,proto3" json:"domains,omitempty"` CertsDir string `protobuf:"bytes,5,opt,name=certsDir,proto3" json:"certsDir,omitempty"` // contains filtered or unexported fields }
SocketAddress specify either a logical or physical address and port, which are used to tell server where to bind/listen, connect to upstream and find management servers
func (*SocketAddress) Descriptor
deprecated
func (*SocketAddress) Descriptor() ([]byte, []int)
Deprecated: Use SocketAddress.ProtoReflect.Descriptor instead.
func (*SocketAddress) GetAddress ¶
func (x *SocketAddress) GetAddress() string
func (*SocketAddress) GetCertsDir ¶
func (x *SocketAddress) GetCertsDir() string
func (*SocketAddress) GetDomains ¶
func (x *SocketAddress) GetDomains() []string
func (*SocketAddress) GetPort ¶
func (x *SocketAddress) GetPort() int64
func (*SocketAddress) GetResolverName ¶
func (x *SocketAddress) GetResolverName() string
func (*SocketAddress) ProtoMessage ¶
func (*SocketAddress) ProtoMessage()
func (*SocketAddress) ProtoReflect ¶
func (x *SocketAddress) ProtoReflect() protoreflect.Message
func (*SocketAddress) Reset ¶
func (x *SocketAddress) Reset()
func (*SocketAddress) String ¶
func (x *SocketAddress) String() string
type StaticResources ¶
type StaticResources struct { Listeners []*Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"` Clusters []*Cluster `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"` Adapters []*Adapter `protobuf:"bytes,3,rep,name=adapters,proto3" json:"adapters,omitempty"` ShutdownConfig *ShutdownConfig `protobuf:"bytes,4,opt,name=shutdown_config,json=shutdownConfig,proto3" json:"shutdown_config,omitempty"` PprofConf *PprofConf `protobuf:"bytes,5,opt,name=pprof_conf,json=pprofConf,proto3" json:"pprof_conf,omitempty"` // contains filtered or unexported fields }
StaticResources
func (*StaticResources) Descriptor
deprecated
func (*StaticResources) Descriptor() ([]byte, []int)
Deprecated: Use StaticResources.ProtoReflect.Descriptor instead.
func (*StaticResources) GetAdapters ¶
func (x *StaticResources) GetAdapters() []*Adapter
func (*StaticResources) GetClusters ¶
func (x *StaticResources) GetClusters() []*Cluster
func (*StaticResources) GetListeners ¶
func (x *StaticResources) GetListeners() []*Listener
func (*StaticResources) GetPprofConf ¶
func (x *StaticResources) GetPprofConf() *PprofConf
func (*StaticResources) GetShutdownConfig ¶
func (x *StaticResources) GetShutdownConfig() *ShutdownConfig
func (*StaticResources) ProtoMessage ¶
func (*StaticResources) ProtoMessage()
func (*StaticResources) ProtoReflect ¶
func (x *StaticResources) ProtoReflect() protoreflect.Message
func (*StaticResources) Reset ¶
func (x *StaticResources) Reset()
func (*StaticResources) String ¶
func (x *StaticResources) String() string
type StringMatcher ¶
type StringMatcher struct { // Types that are assignable to MatchPattern: // *StringMatcher_Exact // *StringMatcher_Prefix // *StringMatcher_Suffix // *StringMatcher_SafeRegex // *StringMatcher_Contains MatchPattern isStringMatcher_MatchPattern `protobuf_oneof:"match_pattern"` // If true, indicates the exact/prefix/suffix/contains matching should be case insensitive. This // has no effect for the safe_regex match. // For example, the matcher *data* will match both input string *Data* and *data* if set to true. IgnoreCase bool `protobuf:"varint,6,opt,name=ignore_case,json=ignoreCase,proto3" json:"ignore_case,omitempty"` // contains filtered or unexported fields }
func (*StringMatcher) Descriptor
deprecated
func (*StringMatcher) Descriptor() ([]byte, []int)
Deprecated: Use StringMatcher.ProtoReflect.Descriptor instead.
func (*StringMatcher) GetContains ¶
func (x *StringMatcher) GetContains() string
func (*StringMatcher) GetExact ¶
func (x *StringMatcher) GetExact() string
func (*StringMatcher) GetIgnoreCase ¶
func (x *StringMatcher) GetIgnoreCase() bool
func (*StringMatcher) GetMatchPattern ¶
func (m *StringMatcher) GetMatchPattern() isStringMatcher_MatchPattern
func (*StringMatcher) GetPrefix ¶
func (x *StringMatcher) GetPrefix() string
func (*StringMatcher) GetSafeRegex ¶
func (x *StringMatcher) GetSafeRegex() *RegexMatcher
func (*StringMatcher) GetSuffix ¶
func (x *StringMatcher) GetSuffix() string
func (*StringMatcher) ProtoMessage ¶
func (*StringMatcher) ProtoMessage()
func (*StringMatcher) ProtoReflect ¶
func (x *StringMatcher) ProtoReflect() protoreflect.Message
func (*StringMatcher) Reset ¶
func (x *StringMatcher) Reset()
func (*StringMatcher) String ¶
func (x *StringMatcher) String() string
type StringMatcher_Contains ¶
type StringMatcher_Contains struct { // The input string must have the substring specified here. // Note: empty contains match is not allowed, please use regex instead. // // Examples: // // * *abc* matches the value *xyz.abc.def* Contains string `protobuf:"bytes,7,opt,name=contains,proto3,oneof"` }
type StringMatcher_Exact ¶
type StringMatcher_Exact struct { // The input string must match exactly the string specified here. // // Examples: // // * *abc* only matches the value *abc*. Exact string `protobuf:"bytes,1,opt,name=exact,proto3,oneof"` }
type StringMatcher_Prefix ¶
type StringMatcher_Prefix struct { // The input string must have the prefix specified here. // Note: empty prefix is not allowed, please use regex instead. // // Examples: // // * *abc* matches the value *abc.xyz* Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof"` }
type StringMatcher_SafeRegex ¶
type StringMatcher_SafeRegex struct { // The input string must match the regular expression specified here. SafeRegex *RegexMatcher `protobuf:"bytes,5,opt,name=safe_regex,json=safeRegex,proto3,oneof"` }
type StringMatcher_Suffix ¶
type StringMatcher_Suffix struct { // The input string must have the suffix specified here. // Note: empty prefix is not allowed, please use regex instead. // // Examples: // // * *abc* matches the value *xyz.abc* Suffix string `protobuf:"bytes,3,opt,name=suffix,proto3,oneof"` }