Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterOutboundPoliciesServer(s grpc.ServiceRegistrar, srv OutboundPoliciesServer)
- type Backend
- func (*Backend) Descriptor() ([]byte, []int)deprecated
- func (x *Backend) GetBalancer() *Backend_BalanceP2C
- func (x *Backend) GetForward() *destination.WeightedAddr
- func (x *Backend) GetKind() isBackend_Kind
- func (x *Backend) GetMetadata() *meta.Metadata
- func (x *Backend) GetQueue() *Queue
- func (*Backend) ProtoMessage()
- func (x *Backend) ProtoReflect() protoreflect.Message
- func (x *Backend) Reset()
- func (x *Backend) String() string
- type Backend_BalanceP2C
- func (*Backend_BalanceP2C) Descriptor() ([]byte, []int)deprecated
- func (x *Backend_BalanceP2C) GetDiscovery() *Backend_EndpointDiscovery
- func (x *Backend_BalanceP2C) GetLoad() isBackend_BalanceP2C_Load
- func (x *Backend_BalanceP2C) GetPeakEwma() *Backend_BalanceP2C_PeakEwma
- func (*Backend_BalanceP2C) ProtoMessage()
- func (x *Backend_BalanceP2C) ProtoReflect() protoreflect.Message
- func (x *Backend_BalanceP2C) Reset()
- func (x *Backend_BalanceP2C) String() string
- type Backend_BalanceP2C_PeakEwma
- func (*Backend_BalanceP2C_PeakEwma) Descriptor() ([]byte, []int)deprecated
- func (x *Backend_BalanceP2C_PeakEwma) GetDecay() *duration.Duration
- func (x *Backend_BalanceP2C_PeakEwma) GetDefaultRtt() *duration.Duration
- func (*Backend_BalanceP2C_PeakEwma) ProtoMessage()
- func (x *Backend_BalanceP2C_PeakEwma) ProtoReflect() protoreflect.Message
- func (x *Backend_BalanceP2C_PeakEwma) Reset()
- func (x *Backend_BalanceP2C_PeakEwma) String() string
- type Backend_BalanceP2C_PeakEwma_
- type Backend_Balancer
- type Backend_EndpointDiscovery
- func (*Backend_EndpointDiscovery) Descriptor() ([]byte, []int)deprecated
- func (x *Backend_EndpointDiscovery) GetDst() *Backend_EndpointDiscovery_DestinationGet
- func (x *Backend_EndpointDiscovery) GetKind() isBackend_EndpointDiscovery_Kind
- func (*Backend_EndpointDiscovery) ProtoMessage()
- func (x *Backend_EndpointDiscovery) ProtoReflect() protoreflect.Message
- func (x *Backend_EndpointDiscovery) Reset()
- func (x *Backend_EndpointDiscovery) String() string
- type Backend_EndpointDiscovery_DestinationGet
- func (*Backend_EndpointDiscovery_DestinationGet) Descriptor() ([]byte, []int)deprecated
- func (x *Backend_EndpointDiscovery_DestinationGet) GetPath() string
- func (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage()
- func (x *Backend_EndpointDiscovery_DestinationGet) ProtoReflect() protoreflect.Message
- func (x *Backend_EndpointDiscovery_DestinationGet) Reset()
- func (x *Backend_EndpointDiscovery_DestinationGet) String() string
- type Backend_EndpointDiscovery_Dst
- type Backend_Forward
- type ExponentialBackoff
- func (*ExponentialBackoff) Descriptor() ([]byte, []int)deprecated
- func (x *ExponentialBackoff) GetJitterRatio() float32
- func (x *ExponentialBackoff) GetMaxBackoff() *duration.Duration
- func (x *ExponentialBackoff) GetMinBackoff() *duration.Duration
- func (*ExponentialBackoff) ProtoMessage()
- func (x *ExponentialBackoff) ProtoReflect() protoreflect.Message
- func (x *ExponentialBackoff) Reset()
- func (x *ExponentialBackoff) String() string
- type FailureAccrual
- func (*FailureAccrual) Descriptor() ([]byte, []int)deprecated
- func (x *FailureAccrual) GetConsecutiveFailures() *FailureAccrual_ConsecutiveFailures
- func (x *FailureAccrual) GetKind() isFailureAccrual_Kind
- func (*FailureAccrual) ProtoMessage()
- func (x *FailureAccrual) ProtoReflect() protoreflect.Message
- func (x *FailureAccrual) Reset()
- func (x *FailureAccrual) String() string
- type FailureAccrual_ConsecutiveFailures
- func (*FailureAccrual_ConsecutiveFailures) Descriptor() ([]byte, []int)deprecated
- func (x *FailureAccrual_ConsecutiveFailures) GetBackoff() *ExponentialBackoff
- func (x *FailureAccrual_ConsecutiveFailures) GetMaxFailures() uint32
- func (*FailureAccrual_ConsecutiveFailures) ProtoMessage()
- func (x *FailureAccrual_ConsecutiveFailures) ProtoReflect() protoreflect.Message
- func (x *FailureAccrual_ConsecutiveFailures) Reset()
- func (x *FailureAccrual_ConsecutiveFailures) String() string
- type FailureAccrual_ConsecutiveFailures_
- type GrpcRoute
- func (*GrpcRoute) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute) GetHosts() []*http_route.HostMatch
- func (x *GrpcRoute) GetMetadata() *meta.Metadata
- func (x *GrpcRoute) GetRules() []*GrpcRoute_Rule
- func (*GrpcRoute) ProtoMessage()
- func (x *GrpcRoute) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute) Reset()
- func (x *GrpcRoute) String() string
- type GrpcRoute_Distribution
- func (*GrpcRoute_Distribution) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Distribution) GetEmpty() *GrpcRoute_Distribution_Empty
- func (x *GrpcRoute_Distribution) GetFirstAvailable() *GrpcRoute_Distribution_FirstAvailable
- func (x *GrpcRoute_Distribution) GetKind() isGrpcRoute_Distribution_Kind
- func (x *GrpcRoute_Distribution) GetRandomAvailable() *GrpcRoute_Distribution_RandomAvailable
- func (*GrpcRoute_Distribution) ProtoMessage()
- func (x *GrpcRoute_Distribution) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Distribution) Reset()
- func (x *GrpcRoute_Distribution) String() string
- type GrpcRoute_Distribution_Empty
- func (*GrpcRoute_Distribution_Empty) Descriptor() ([]byte, []int)deprecated
- func (*GrpcRoute_Distribution_Empty) ProtoMessage()
- func (x *GrpcRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Distribution_Empty) Reset()
- func (x *GrpcRoute_Distribution_Empty) String() string
- type GrpcRoute_Distribution_Empty_
- type GrpcRoute_Distribution_FirstAvailable
- func (*GrpcRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Distribution_FirstAvailable) GetBackends() []*GrpcRoute_RouteBackend
- func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage()
- func (x *GrpcRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Distribution_FirstAvailable) Reset()
- func (x *GrpcRoute_Distribution_FirstAvailable) String() string
- type GrpcRoute_Distribution_FirstAvailable_
- type GrpcRoute_Distribution_RandomAvailable
- func (*GrpcRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Distribution_RandomAvailable) GetBackends() []*GrpcRoute_WeightedRouteBackend
- func (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage()
- func (x *GrpcRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Distribution_RandomAvailable) Reset()
- func (x *GrpcRoute_Distribution_RandomAvailable) String() string
- type GrpcRoute_Distribution_RandomAvailable_
- type GrpcRoute_Filter
- func (*GrpcRoute_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Filter) GetFailureInjector() *grpc_route.GrpcFailureInjector
- func (x *GrpcRoute_Filter) GetKind() isGrpcRoute_Filter_Kind
- func (x *GrpcRoute_Filter) GetRequestHeaderModifier() *http_route.RequestHeaderModifier
- func (*GrpcRoute_Filter) ProtoMessage()
- func (x *GrpcRoute_Filter) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Filter) Reset()
- func (x *GrpcRoute_Filter) String() string
- type GrpcRoute_Filter_FailureInjector
- type GrpcRoute_Filter_RequestHeaderModifier
- type GrpcRoute_Retry
- func (*GrpcRoute_Retry) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Retry) GetBackoff() *ExponentialBackoff
- func (x *GrpcRoute_Retry) GetConditions() *GrpcRoute_Retry_Conditions
- func (x *GrpcRoute_Retry) GetMaxRequestBytes() uint32
- func (x *GrpcRoute_Retry) GetMaxRetries() uint32
- func (x *GrpcRoute_Retry) GetTimeout() *duration.Duration
- func (*GrpcRoute_Retry) ProtoMessage()
- func (x *GrpcRoute_Retry) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Retry) Reset()
- func (x *GrpcRoute_Retry) String() string
- type GrpcRoute_Retry_Conditions
- func (*GrpcRoute_Retry_Conditions) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Retry_Conditions) GetCancelled() bool
- func (x *GrpcRoute_Retry_Conditions) GetDeadineExceeded() bool
- func (x *GrpcRoute_Retry_Conditions) GetInternal() bool
- func (x *GrpcRoute_Retry_Conditions) GetResourceExhausted() bool
- func (x *GrpcRoute_Retry_Conditions) GetUnavailable() bool
- func (*GrpcRoute_Retry_Conditions) ProtoMessage()
- func (x *GrpcRoute_Retry_Conditions) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Retry_Conditions) Reset()
- func (x *GrpcRoute_Retry_Conditions) String() string
- type GrpcRoute_RouteBackend
- func (*GrpcRoute_RouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_RouteBackend) GetBackend() *Backend
- func (x *GrpcRoute_RouteBackend) GetFilters() []*GrpcRoute_Filter
- func (x *GrpcRoute_RouteBackend) GetRequestTimeout() *duration.Durationdeprecated
- func (*GrpcRoute_RouteBackend) ProtoMessage()
- func (x *GrpcRoute_RouteBackend) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_RouteBackend) Reset()
- func (x *GrpcRoute_RouteBackend) String() string
- type GrpcRoute_Rule
- func (*GrpcRoute_Rule) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_Rule) GetAllowL5DRequestHeaders() bool
- func (x *GrpcRoute_Rule) GetBackends() *GrpcRoute_Distribution
- func (x *GrpcRoute_Rule) GetFilters() []*GrpcRoute_Filter
- func (x *GrpcRoute_Rule) GetMatches() []*grpc_route.GrpcRouteMatch
- func (x *GrpcRoute_Rule) GetRequestTimeout() *duration.Durationdeprecated
- func (x *GrpcRoute_Rule) GetRetry() *GrpcRoute_Retry
- func (x *GrpcRoute_Rule) GetTimeouts() *http_route.Timeouts
- func (*GrpcRoute_Rule) ProtoMessage()
- func (x *GrpcRoute_Rule) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_Rule) Reset()
- func (x *GrpcRoute_Rule) String() string
- type GrpcRoute_WeightedRouteBackend
- func (*GrpcRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcRoute_WeightedRouteBackend) GetBackend() *GrpcRoute_RouteBackend
- func (x *GrpcRoute_WeightedRouteBackend) GetWeight() uint32
- func (*GrpcRoute_WeightedRouteBackend) ProtoMessage()
- func (x *GrpcRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
- func (x *GrpcRoute_WeightedRouteBackend) Reset()
- func (x *GrpcRoute_WeightedRouteBackend) String() string
- type HttpRoute
- func (*HttpRoute) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute) GetHosts() []*http_route.HostMatch
- func (x *HttpRoute) GetMetadata() *meta.Metadata
- func (x *HttpRoute) GetRules() []*HttpRoute_Rule
- func (*HttpRoute) ProtoMessage()
- func (x *HttpRoute) ProtoReflect() protoreflect.Message
- func (x *HttpRoute) Reset()
- func (x *HttpRoute) String() string
- type HttpRoute_Distribution
- func (*HttpRoute_Distribution) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Distribution) GetEmpty() *HttpRoute_Distribution_Empty
- func (x *HttpRoute_Distribution) GetFirstAvailable() *HttpRoute_Distribution_FirstAvailable
- func (x *HttpRoute_Distribution) GetKind() isHttpRoute_Distribution_Kind
- func (x *HttpRoute_Distribution) GetRandomAvailable() *HttpRoute_Distribution_RandomAvailable
- func (*HttpRoute_Distribution) ProtoMessage()
- func (x *HttpRoute_Distribution) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Distribution) Reset()
- func (x *HttpRoute_Distribution) String() string
- type HttpRoute_Distribution_Empty
- func (*HttpRoute_Distribution_Empty) Descriptor() ([]byte, []int)deprecated
- func (*HttpRoute_Distribution_Empty) ProtoMessage()
- func (x *HttpRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Distribution_Empty) Reset()
- func (x *HttpRoute_Distribution_Empty) String() string
- type HttpRoute_Distribution_Empty_
- type HttpRoute_Distribution_FirstAvailable
- func (*HttpRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Distribution_FirstAvailable) GetBackends() []*HttpRoute_RouteBackend
- func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage()
- func (x *HttpRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Distribution_FirstAvailable) Reset()
- func (x *HttpRoute_Distribution_FirstAvailable) String() string
- type HttpRoute_Distribution_FirstAvailable_
- type HttpRoute_Distribution_RandomAvailable
- func (*HttpRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Distribution_RandomAvailable) GetBackends() []*HttpRoute_WeightedRouteBackend
- func (*HttpRoute_Distribution_RandomAvailable) ProtoMessage()
- func (x *HttpRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Distribution_RandomAvailable) Reset()
- func (x *HttpRoute_Distribution_RandomAvailable) String() string
- type HttpRoute_Distribution_RandomAvailable_
- type HttpRoute_Filter
- func (*HttpRoute_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Filter) GetFailureInjector() *http_route.HttpFailureInjector
- func (x *HttpRoute_Filter) GetKind() isHttpRoute_Filter_Kind
- func (x *HttpRoute_Filter) GetRedirect() *http_route.RequestRedirect
- func (x *HttpRoute_Filter) GetRequestHeaderModifier() *http_route.RequestHeaderModifier
- func (x *HttpRoute_Filter) GetResponseHeaderModifier() *http_route.ResponseHeaderModifier
- func (*HttpRoute_Filter) ProtoMessage()
- func (x *HttpRoute_Filter) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Filter) Reset()
- func (x *HttpRoute_Filter) String() string
- type HttpRoute_Filter_FailureInjector
- type HttpRoute_Filter_Redirect
- type HttpRoute_Filter_RequestHeaderModifier
- type HttpRoute_Filter_ResponseHeaderModifier
- type HttpRoute_Retry
- func (*HttpRoute_Retry) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Retry) GetBackoff() *ExponentialBackoff
- func (x *HttpRoute_Retry) GetConditions() *HttpRoute_Retry_Conditions
- func (x *HttpRoute_Retry) GetMaxRequestBytes() uint32
- func (x *HttpRoute_Retry) GetMaxRetries() uint32
- func (x *HttpRoute_Retry) GetTimeout() *duration.Duration
- func (*HttpRoute_Retry) ProtoMessage()
- func (x *HttpRoute_Retry) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Retry) Reset()
- func (x *HttpRoute_Retry) String() string
- type HttpRoute_Retry_Conditions
- func (*HttpRoute_Retry_Conditions) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Retry_Conditions) GetStatusRanges() []*HttpRoute_Retry_Conditions_StatusRange
- func (*HttpRoute_Retry_Conditions) ProtoMessage()
- func (x *HttpRoute_Retry_Conditions) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Retry_Conditions) Reset()
- func (x *HttpRoute_Retry_Conditions) String() string
- type HttpRoute_Retry_Conditions_StatusRange
- func (*HttpRoute_Retry_Conditions_StatusRange) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Retry_Conditions_StatusRange) GetEnd() uint32
- func (x *HttpRoute_Retry_Conditions_StatusRange) GetStart() uint32
- func (*HttpRoute_Retry_Conditions_StatusRange) ProtoMessage()
- func (x *HttpRoute_Retry_Conditions_StatusRange) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Retry_Conditions_StatusRange) Reset()
- func (x *HttpRoute_Retry_Conditions_StatusRange) String() string
- type HttpRoute_RouteBackend
- func (*HttpRoute_RouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_RouteBackend) GetBackend() *Backend
- func (x *HttpRoute_RouteBackend) GetFilters() []*HttpRoute_Filter
- func (x *HttpRoute_RouteBackend) GetRequestTimeout() *duration.Durationdeprecated
- func (*HttpRoute_RouteBackend) ProtoMessage()
- func (x *HttpRoute_RouteBackend) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_RouteBackend) Reset()
- func (x *HttpRoute_RouteBackend) String() string
- type HttpRoute_Rule
- func (*HttpRoute_Rule) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_Rule) GetAllowL5DRequestHeaders() bool
- func (x *HttpRoute_Rule) GetBackends() *HttpRoute_Distribution
- func (x *HttpRoute_Rule) GetFilters() []*HttpRoute_Filter
- func (x *HttpRoute_Rule) GetMatches() []*http_route.HttpRouteMatch
- func (x *HttpRoute_Rule) GetRequestTimeout() *duration.Durationdeprecated
- func (x *HttpRoute_Rule) GetRetry() *HttpRoute_Retry
- func (x *HttpRoute_Rule) GetTimeouts() *http_route.Timeouts
- func (*HttpRoute_Rule) ProtoMessage()
- func (x *HttpRoute_Rule) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_Rule) Reset()
- func (x *HttpRoute_Rule) String() string
- type HttpRoute_WeightedRouteBackend
- func (*HttpRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRoute_WeightedRouteBackend) GetBackend() *HttpRoute_RouteBackend
- func (x *HttpRoute_WeightedRouteBackend) GetWeight() uint32
- func (*HttpRoute_WeightedRouteBackend) ProtoMessage()
- func (x *HttpRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
- func (x *HttpRoute_WeightedRouteBackend) Reset()
- func (x *HttpRoute_WeightedRouteBackend) String() string
- type OpaqueRoute
- func (*OpaqueRoute) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute) GetMetadata() *meta.Metadata
- func (x *OpaqueRoute) GetRules() []*OpaqueRoute_Rule
- func (*OpaqueRoute) ProtoMessage()
- func (x *OpaqueRoute) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute) Reset()
- func (x *OpaqueRoute) String() string
- type OpaqueRoute_Distribution
- func (*OpaqueRoute_Distribution) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_Distribution) GetEmpty() *OpaqueRoute_Distribution_Empty
- func (x *OpaqueRoute_Distribution) GetFirstAvailable() *OpaqueRoute_Distribution_FirstAvailable
- func (x *OpaqueRoute_Distribution) GetKind() isOpaqueRoute_Distribution_Kind
- func (x *OpaqueRoute_Distribution) GetRandomAvailable() *OpaqueRoute_Distribution_RandomAvailable
- func (*OpaqueRoute_Distribution) ProtoMessage()
- func (x *OpaqueRoute_Distribution) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Distribution) Reset()
- func (x *OpaqueRoute_Distribution) String() string
- type OpaqueRoute_Distribution_Empty
- func (*OpaqueRoute_Distribution_Empty) Descriptor() ([]byte, []int)deprecated
- func (*OpaqueRoute_Distribution_Empty) ProtoMessage()
- func (x *OpaqueRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Distribution_Empty) Reset()
- func (x *OpaqueRoute_Distribution_Empty) String() string
- type OpaqueRoute_Distribution_Empty_
- type OpaqueRoute_Distribution_FirstAvailable
- func (*OpaqueRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_Distribution_FirstAvailable) GetBackends() []*OpaqueRoute_RouteBackend
- func (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage()
- func (x *OpaqueRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Distribution_FirstAvailable) Reset()
- func (x *OpaqueRoute_Distribution_FirstAvailable) String() string
- type OpaqueRoute_Distribution_FirstAvailable_
- type OpaqueRoute_Distribution_RandomAvailable
- func (*OpaqueRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_Distribution_RandomAvailable) GetBackends() []*OpaqueRoute_WeightedRouteBackend
- func (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage()
- func (x *OpaqueRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Distribution_RandomAvailable) Reset()
- func (x *OpaqueRoute_Distribution_RandomAvailable) String() string
- type OpaqueRoute_Distribution_RandomAvailable_
- type OpaqueRoute_Filter
- func (*OpaqueRoute_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_Filter) GetForbidden() *opaque_route.Forbidden
- func (x *OpaqueRoute_Filter) GetInvalid() *opaque_route.Invalid
- func (x *OpaqueRoute_Filter) GetKind() isOpaqueRoute_Filter_Kind
- func (*OpaqueRoute_Filter) ProtoMessage()
- func (x *OpaqueRoute_Filter) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Filter) Reset()
- func (x *OpaqueRoute_Filter) String() string
- type OpaqueRoute_Filter_Forbidden
- type OpaqueRoute_Filter_Invalid
- type OpaqueRoute_RouteBackend
- func (*OpaqueRoute_RouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_RouteBackend) GetBackend() *Backend
- func (x *OpaqueRoute_RouteBackend) GetFilters() []*OpaqueRoute_Filter
- func (*OpaqueRoute_RouteBackend) ProtoMessage()
- func (x *OpaqueRoute_RouteBackend) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_RouteBackend) Reset()
- func (x *OpaqueRoute_RouteBackend) String() string
- type OpaqueRoute_Rule
- func (*OpaqueRoute_Rule) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_Rule) GetBackends() *OpaqueRoute_Distribution
- func (x *OpaqueRoute_Rule) GetFilters() []*OpaqueRoute_Filter
- func (*OpaqueRoute_Rule) ProtoMessage()
- func (x *OpaqueRoute_Rule) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_Rule) Reset()
- func (x *OpaqueRoute_Rule) String() string
- type OpaqueRoute_WeightedRouteBackend
- func (*OpaqueRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueRoute_WeightedRouteBackend) GetBackend() *OpaqueRoute_RouteBackend
- func (x *OpaqueRoute_WeightedRouteBackend) GetWeight() uint32
- func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage()
- func (x *OpaqueRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
- func (x *OpaqueRoute_WeightedRouteBackend) Reset()
- func (x *OpaqueRoute_WeightedRouteBackend) String() string
- type OutboundPoliciesClient
- type OutboundPoliciesServer
- type OutboundPolicies_WatchClient
- type OutboundPolicies_WatchServer
- type OutboundPolicy
- func (*OutboundPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *OutboundPolicy) GetMetadata() *meta.Metadata
- func (x *OutboundPolicy) GetProtocol() *ProxyProtocol
- func (*OutboundPolicy) ProtoMessage()
- func (x *OutboundPolicy) ProtoReflect() protoreflect.Message
- func (x *OutboundPolicy) Reset()
- func (x *OutboundPolicy) String() string
- type ProxyProtocol
- func (*ProxyProtocol) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol) GetDetect() *ProxyProtocol_Detect
- func (x *ProxyProtocol) GetGrpc() *ProxyProtocol_Grpc
- func (x *ProxyProtocol) GetHttp1() *ProxyProtocol_Http1
- func (x *ProxyProtocol) GetHttp2() *ProxyProtocol_Http2
- func (x *ProxyProtocol) GetKind() isProxyProtocol_Kind
- func (x *ProxyProtocol) GetOpaque() *ProxyProtocol_Opaque
- func (x *ProxyProtocol) GetTls() *ProxyProtocol_Tls
- func (*ProxyProtocol) ProtoMessage()
- func (x *ProxyProtocol) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol) Reset()
- func (x *ProxyProtocol) String() string
- type ProxyProtocol_Detect
- func (*ProxyProtocol_Detect) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Detect) GetHttp1() *ProxyProtocol_Http1
- func (x *ProxyProtocol_Detect) GetHttp2() *ProxyProtocol_Http2
- func (x *ProxyProtocol_Detect) GetOpaque() *ProxyProtocol_Opaque
- func (x *ProxyProtocol_Detect) GetTimeout() *duration.Duration
- func (*ProxyProtocol_Detect) ProtoMessage()
- func (x *ProxyProtocol_Detect) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Detect) Reset()
- func (x *ProxyProtocol_Detect) String() string
- type ProxyProtocol_Detect_
- type ProxyProtocol_Grpc
- func (*ProxyProtocol_Grpc) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Grpc) GetFailureAccrual() *FailureAccrual
- func (x *ProxyProtocol_Grpc) GetRoutes() []*GrpcRoute
- func (*ProxyProtocol_Grpc) ProtoMessage()
- func (x *ProxyProtocol_Grpc) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Grpc) Reset()
- func (x *ProxyProtocol_Grpc) String() string
- type ProxyProtocol_Grpc_
- type ProxyProtocol_Http1
- func (*ProxyProtocol_Http1) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Http1) GetFailureAccrual() *FailureAccrual
- func (x *ProxyProtocol_Http1) GetRoutes() []*HttpRoute
- func (*ProxyProtocol_Http1) ProtoMessage()
- func (x *ProxyProtocol_Http1) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Http1) Reset()
- func (x *ProxyProtocol_Http1) String() string
- type ProxyProtocol_Http1_
- type ProxyProtocol_Http2
- func (*ProxyProtocol_Http2) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Http2) GetFailureAccrual() *FailureAccrual
- func (x *ProxyProtocol_Http2) GetRoutes() []*HttpRoute
- func (*ProxyProtocol_Http2) ProtoMessage()
- func (x *ProxyProtocol_Http2) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Http2) Reset()
- func (x *ProxyProtocol_Http2) String() string
- type ProxyProtocol_Http2_
- type ProxyProtocol_Opaque
- func (*ProxyProtocol_Opaque) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Opaque) GetRoutes() []*OpaqueRoute
- func (*ProxyProtocol_Opaque) ProtoMessage()
- func (x *ProxyProtocol_Opaque) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Opaque) Reset()
- func (x *ProxyProtocol_Opaque) String() string
- type ProxyProtocol_Opaque_
- type ProxyProtocol_Tls
- func (*ProxyProtocol_Tls) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyProtocol_Tls) GetRoutes() []*TlsRoute
- func (*ProxyProtocol_Tls) ProtoMessage()
- func (x *ProxyProtocol_Tls) ProtoReflect() protoreflect.Message
- func (x *ProxyProtocol_Tls) Reset()
- func (x *ProxyProtocol_Tls) String() string
- type ProxyProtocol_Tls_
- type Queue
- type TlsRoute
- func (*TlsRoute) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute) GetMetadata() *meta.Metadata
- func (x *TlsRoute) GetRules() []*TlsRoute_Rule
- func (x *TlsRoute) GetSnis() []*tls_route.SniMatch
- func (*TlsRoute) ProtoMessage()
- func (x *TlsRoute) ProtoReflect() protoreflect.Message
- func (x *TlsRoute) Reset()
- func (x *TlsRoute) String() string
- type TlsRoute_Distribution
- func (*TlsRoute_Distribution) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_Distribution) GetEmpty() *TlsRoute_Distribution_Empty
- func (x *TlsRoute_Distribution) GetFirstAvailable() *TlsRoute_Distribution_FirstAvailable
- func (x *TlsRoute_Distribution) GetKind() isTlsRoute_Distribution_Kind
- func (x *TlsRoute_Distribution) GetRandomAvailable() *TlsRoute_Distribution_RandomAvailable
- func (*TlsRoute_Distribution) ProtoMessage()
- func (x *TlsRoute_Distribution) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_Distribution) Reset()
- func (x *TlsRoute_Distribution) String() string
- type TlsRoute_Distribution_Empty
- type TlsRoute_Distribution_Empty_
- type TlsRoute_Distribution_FirstAvailable
- func (*TlsRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_Distribution_FirstAvailable) GetBackends() []*TlsRoute_RouteBackend
- func (*TlsRoute_Distribution_FirstAvailable) ProtoMessage()
- func (x *TlsRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_Distribution_FirstAvailable) Reset()
- func (x *TlsRoute_Distribution_FirstAvailable) String() string
- type TlsRoute_Distribution_FirstAvailable_
- type TlsRoute_Distribution_RandomAvailable
- func (*TlsRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_Distribution_RandomAvailable) GetBackends() []*TlsRoute_WeightedRouteBackend
- func (*TlsRoute_Distribution_RandomAvailable) ProtoMessage()
- func (x *TlsRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_Distribution_RandomAvailable) Reset()
- func (x *TlsRoute_Distribution_RandomAvailable) String() string
- type TlsRoute_Distribution_RandomAvailable_
- type TlsRoute_Filter
- func (*TlsRoute_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_Filter) GetForbidden() *opaque_route.Forbidden
- func (x *TlsRoute_Filter) GetInvalid() *opaque_route.Invalid
- func (x *TlsRoute_Filter) GetKind() isTlsRoute_Filter_Kind
- func (*TlsRoute_Filter) ProtoMessage()
- func (x *TlsRoute_Filter) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_Filter) Reset()
- func (x *TlsRoute_Filter) String() string
- type TlsRoute_Filter_Forbidden
- type TlsRoute_Filter_Invalid
- type TlsRoute_RouteBackend
- func (*TlsRoute_RouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_RouteBackend) GetBackend() *Backend
- func (x *TlsRoute_RouteBackend) GetFilters() []*TlsRoute_Filter
- func (*TlsRoute_RouteBackend) ProtoMessage()
- func (x *TlsRoute_RouteBackend) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_RouteBackend) Reset()
- func (x *TlsRoute_RouteBackend) String() string
- type TlsRoute_Rule
- func (*TlsRoute_Rule) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_Rule) GetBackends() *TlsRoute_Distribution
- func (x *TlsRoute_Rule) GetFilters() []*TlsRoute_Filter
- func (*TlsRoute_Rule) ProtoMessage()
- func (x *TlsRoute_Rule) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_Rule) Reset()
- func (x *TlsRoute_Rule) String() string
- type TlsRoute_WeightedRouteBackend
- func (*TlsRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)deprecated
- func (x *TlsRoute_WeightedRouteBackend) GetBackend() *TlsRoute_RouteBackend
- func (x *TlsRoute_WeightedRouteBackend) GetWeight() uint32
- func (*TlsRoute_WeightedRouteBackend) ProtoMessage()
- func (x *TlsRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
- func (x *TlsRoute_WeightedRouteBackend) Reset()
- func (x *TlsRoute_WeightedRouteBackend) String() string
- type TrafficSpec
- func (*TrafficSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TrafficSpec) GetAddr() *net.TcpAddress
- func (x *TrafficSpec) GetAuthority() string
- func (x *TrafficSpec) GetSourceWorkload() string
- func (x *TrafficSpec) GetTarget() isTrafficSpec_Target
- func (*TrafficSpec) ProtoMessage()
- func (x *TrafficSpec) ProtoReflect() protoreflect.Message
- func (x *TrafficSpec) Reset()
- func (x *TrafficSpec) String() string
- type TrafficSpec_Addr
- type TrafficSpec_Authority
- type UnimplementedOutboundPoliciesServer
- type UnsafeOutboundPoliciesServer
Constants ¶
const ( OutboundPolicies_Get_FullMethodName = "/io.linkerd.proxy.outbound.OutboundPolicies/Get" OutboundPolicies_Watch_FullMethodName = "/io.linkerd.proxy.outbound.OutboundPolicies/Watch" )
Variables ¶
var File_outbound_proto protoreflect.FileDescriptor
var OutboundPolicies_ServiceDesc = grpc.ServiceDesc{ ServiceName: "io.linkerd.proxy.outbound.OutboundPolicies", HandlerType: (*OutboundPoliciesServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _OutboundPolicies_Get_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _OutboundPolicies_Watch_Handler, ServerStreams: true, }, }, Metadata: "outbound.proto", }
OutboundPolicies_ServiceDesc is the grpc.ServiceDesc for OutboundPolicies service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterOutboundPoliciesServer ¶
func RegisterOutboundPoliciesServer(s grpc.ServiceRegistrar, srv OutboundPoliciesServer)
Types ¶
type Backend ¶
type Backend struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// Types that are valid to be assigned to Kind:
//
// *Backend_Forward
// *Backend_Balancer
Kind isBackend_Kind `protobuf_oneof:"kind"`
// Describes queue configuration for a backend.
Queue *Queue `protobuf:"bytes,4,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
func (*Backend) Descriptor
deprecated
func (*Backend) GetBalancer ¶
func (x *Backend) GetBalancer() *Backend_BalanceP2C
func (*Backend) GetForward ¶
func (x *Backend) GetForward() *destination.WeightedAddr
func (*Backend) GetMetadata ¶
func (*Backend) ProtoMessage ¶
func (*Backend) ProtoMessage()
func (*Backend) ProtoReflect ¶
func (x *Backend) ProtoReflect() protoreflect.Message
type Backend_BalanceP2C ¶
type Backend_BalanceP2C struct {
Discovery *Backend_EndpointDiscovery `protobuf:"bytes,1,opt,name=discovery,proto3" json:"discovery,omitempty"`
// The load estimation strategy used by this load balancer.
//
// Types that are valid to be assigned to Load:
//
// *Backend_BalanceP2C_PeakEwma_
Load isBackend_BalanceP2C_Load `protobuf_oneof:"load"`
// contains filtered or unexported fields
}
Describes a power-of-two-choices (P2C) load balancer configuration for a backend.
func (*Backend_BalanceP2C) Descriptor
deprecated
func (*Backend_BalanceP2C) Descriptor() ([]byte, []int)
Deprecated: Use Backend_BalanceP2C.ProtoReflect.Descriptor instead.
func (*Backend_BalanceP2C) GetDiscovery ¶
func (x *Backend_BalanceP2C) GetDiscovery() *Backend_EndpointDiscovery
func (*Backend_BalanceP2C) GetLoad ¶
func (x *Backend_BalanceP2C) GetLoad() isBackend_BalanceP2C_Load
func (*Backend_BalanceP2C) GetPeakEwma ¶
func (x *Backend_BalanceP2C) GetPeakEwma() *Backend_BalanceP2C_PeakEwma
func (*Backend_BalanceP2C) ProtoMessage ¶
func (*Backend_BalanceP2C) ProtoMessage()
func (*Backend_BalanceP2C) ProtoReflect ¶
func (x *Backend_BalanceP2C) ProtoReflect() protoreflect.Message
func (*Backend_BalanceP2C) Reset ¶
func (x *Backend_BalanceP2C) Reset()
func (*Backend_BalanceP2C) String ¶
func (x *Backend_BalanceP2C) String() string
type Backend_BalanceP2C_PeakEwma ¶
type Backend_BalanceP2C_PeakEwma struct {
// Initial latency value used when no latencies have been
// recorded for an endpoint.
DefaultRtt *duration.Duration `protobuf:"bytes,1,opt,name=default_rtt,json=defaultRtt,proto3" json:"default_rtt,omitempty"`
// The duration of the moving window over which latency is observed.
Decay *duration.Duration `protobuf:"bytes,2,opt,name=decay,proto3" json:"decay,omitempty"`
// contains filtered or unexported fields
}
Parameters configuring peak EWMA load estimation.
func (*Backend_BalanceP2C_PeakEwma) Descriptor
deprecated
func (*Backend_BalanceP2C_PeakEwma) Descriptor() ([]byte, []int)
Deprecated: Use Backend_BalanceP2C_PeakEwma.ProtoReflect.Descriptor instead.
func (*Backend_BalanceP2C_PeakEwma) GetDecay ¶
func (x *Backend_BalanceP2C_PeakEwma) GetDecay() *duration.Duration
func (*Backend_BalanceP2C_PeakEwma) GetDefaultRtt ¶
func (x *Backend_BalanceP2C_PeakEwma) GetDefaultRtt() *duration.Duration
func (*Backend_BalanceP2C_PeakEwma) ProtoMessage ¶
func (*Backend_BalanceP2C_PeakEwma) ProtoMessage()
func (*Backend_BalanceP2C_PeakEwma) ProtoReflect ¶
func (x *Backend_BalanceP2C_PeakEwma) ProtoReflect() protoreflect.Message
func (*Backend_BalanceP2C_PeakEwma) Reset ¶
func (x *Backend_BalanceP2C_PeakEwma) Reset()
func (*Backend_BalanceP2C_PeakEwma) String ¶
func (x *Backend_BalanceP2C_PeakEwma) String() string
type Backend_BalanceP2C_PeakEwma_ ¶
type Backend_BalanceP2C_PeakEwma_ struct {
// This load balancer uses peak EWMA (exponentially weighted moving
// average) load estimates.
PeakEwma *Backend_BalanceP2C_PeakEwma `protobuf:"bytes,2,opt,name=peak_ewma,json=peakEwma,proto3,oneof"`
}
type Backend_Balancer ¶
type Backend_Balancer struct {
// A backend that comprises a load balanced service.
Balancer *Backend_BalanceP2C `protobuf:"bytes,3,opt,name=balancer,proto3,oneof"`
}
type Backend_EndpointDiscovery ¶
type Backend_EndpointDiscovery struct {
// Types that are valid to be assigned to Kind:
//
// *Backend_EndpointDiscovery_Dst
Kind isBackend_EndpointDiscovery_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
A strategy for discovering endpoints for a service.
func (*Backend_EndpointDiscovery) Descriptor
deprecated
func (*Backend_EndpointDiscovery) Descriptor() ([]byte, []int)
Deprecated: Use Backend_EndpointDiscovery.ProtoReflect.Descriptor instead.
func (*Backend_EndpointDiscovery) GetDst ¶
func (x *Backend_EndpointDiscovery) GetDst() *Backend_EndpointDiscovery_DestinationGet
func (*Backend_EndpointDiscovery) GetKind ¶
func (x *Backend_EndpointDiscovery) GetKind() isBackend_EndpointDiscovery_Kind
func (*Backend_EndpointDiscovery) ProtoMessage ¶
func (*Backend_EndpointDiscovery) ProtoMessage()
func (*Backend_EndpointDiscovery) ProtoReflect ¶
func (x *Backend_EndpointDiscovery) ProtoReflect() protoreflect.Message
func (*Backend_EndpointDiscovery) Reset ¶
func (x *Backend_EndpointDiscovery) Reset()
func (*Backend_EndpointDiscovery) String ¶
func (x *Backend_EndpointDiscovery) String() string
type Backend_EndpointDiscovery_DestinationGet ¶
type Backend_EndpointDiscovery_DestinationGet struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
func (*Backend_EndpointDiscovery_DestinationGet) Descriptor
deprecated
func (*Backend_EndpointDiscovery_DestinationGet) Descriptor() ([]byte, []int)
Deprecated: Use Backend_EndpointDiscovery_DestinationGet.ProtoReflect.Descriptor instead.
func (*Backend_EndpointDiscovery_DestinationGet) GetPath ¶
func (x *Backend_EndpointDiscovery_DestinationGet) GetPath() string
func (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage ¶
func (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage()
func (*Backend_EndpointDiscovery_DestinationGet) ProtoReflect ¶
func (x *Backend_EndpointDiscovery_DestinationGet) ProtoReflect() protoreflect.Message
func (*Backend_EndpointDiscovery_DestinationGet) Reset ¶
func (x *Backend_EndpointDiscovery_DestinationGet) Reset()
func (*Backend_EndpointDiscovery_DestinationGet) String ¶
func (x *Backend_EndpointDiscovery_DestinationGet) String() string
type Backend_EndpointDiscovery_Dst ¶
type Backend_EndpointDiscovery_Dst struct {
// Use the `Destination` service to discover endpoints for this service.
Dst *Backend_EndpointDiscovery_DestinationGet `protobuf:"bytes,1,opt,name=dst,proto3,oneof"`
}
type Backend_Forward ¶
type Backend_Forward struct {
// A backend that consists of a single endpoint.
Forward *destination.WeightedAddr `protobuf:"bytes,2,opt,name=forward,proto3,oneof"`
}
type ExponentialBackoff ¶
type ExponentialBackoff struct {
// The minimum amount of time to wait before resuming an operation.
MinBackoff *duration.Duration `protobuf:"bytes,1,opt,name=min_backoff,json=minBackoff,proto3" json:"min_backoff,omitempty"`
// The maximum amount of time to wait before resuming an operation.
// Must be greater than or equal to min_backoff.
MaxBackoff *duration.Duration `protobuf:"bytes,2,opt,name=max_backoff,json=maxBackoff,proto3" json:"max_backoff,omitempty"`
// The ratio of the base timeout that may be randomly added to a backoff.
// Must be greater than or equal to 0.0.
JitterRatio float32 `protobuf:"fixed32,3,opt,name=jitter_ratio,json=jitterRatio,proto3" json:"jitter_ratio,omitempty"`
// contains filtered or unexported fields
}
func (*ExponentialBackoff) Descriptor
deprecated
func (*ExponentialBackoff) Descriptor() ([]byte, []int)
Deprecated: Use ExponentialBackoff.ProtoReflect.Descriptor instead.
func (*ExponentialBackoff) GetJitterRatio ¶
func (x *ExponentialBackoff) GetJitterRatio() float32
func (*ExponentialBackoff) GetMaxBackoff ¶
func (x *ExponentialBackoff) GetMaxBackoff() *duration.Duration
func (*ExponentialBackoff) GetMinBackoff ¶
func (x *ExponentialBackoff) GetMinBackoff() *duration.Duration
func (*ExponentialBackoff) ProtoMessage ¶
func (*ExponentialBackoff) ProtoMessage()
func (*ExponentialBackoff) ProtoReflect ¶
func (x *ExponentialBackoff) ProtoReflect() protoreflect.Message
func (*ExponentialBackoff) Reset ¶
func (x *ExponentialBackoff) Reset()
func (*ExponentialBackoff) String ¶
func (x *ExponentialBackoff) String() string
type FailureAccrual ¶
type FailureAccrual struct {
// Types that are valid to be assigned to Kind:
//
// *FailureAccrual_ConsecutiveFailures_
Kind isFailureAccrual_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*FailureAccrual) Descriptor
deprecated
func (*FailureAccrual) Descriptor() ([]byte, []int)
Deprecated: Use FailureAccrual.ProtoReflect.Descriptor instead.
func (*FailureAccrual) GetConsecutiveFailures ¶
func (x *FailureAccrual) GetConsecutiveFailures() *FailureAccrual_ConsecutiveFailures
func (*FailureAccrual) GetKind ¶
func (x *FailureAccrual) GetKind() isFailureAccrual_Kind
func (*FailureAccrual) ProtoMessage ¶
func (*FailureAccrual) ProtoMessage()
func (*FailureAccrual) ProtoReflect ¶
func (x *FailureAccrual) ProtoReflect() protoreflect.Message
func (*FailureAccrual) Reset ¶
func (x *FailureAccrual) Reset()
func (*FailureAccrual) String ¶
func (x *FailureAccrual) String() string
type FailureAccrual_ConsecutiveFailures ¶
type FailureAccrual_ConsecutiveFailures struct {
MaxFailures uint32 `protobuf:"varint,1,opt,name=max_failures,json=maxFailures,proto3" json:"max_failures,omitempty"`
Backoff *ExponentialBackoff `protobuf:"bytes,2,opt,name=backoff,proto3" json:"backoff,omitempty"`
// contains filtered or unexported fields
}
func (*FailureAccrual_ConsecutiveFailures) Descriptor
deprecated
func (*FailureAccrual_ConsecutiveFailures) Descriptor() ([]byte, []int)
Deprecated: Use FailureAccrual_ConsecutiveFailures.ProtoReflect.Descriptor instead.
func (*FailureAccrual_ConsecutiveFailures) GetBackoff ¶
func (x *FailureAccrual_ConsecutiveFailures) GetBackoff() *ExponentialBackoff
func (*FailureAccrual_ConsecutiveFailures) GetMaxFailures ¶
func (x *FailureAccrual_ConsecutiveFailures) GetMaxFailures() uint32
func (*FailureAccrual_ConsecutiveFailures) ProtoMessage ¶
func (*FailureAccrual_ConsecutiveFailures) ProtoMessage()
func (*FailureAccrual_ConsecutiveFailures) ProtoReflect ¶
func (x *FailureAccrual_ConsecutiveFailures) ProtoReflect() protoreflect.Message
func (*FailureAccrual_ConsecutiveFailures) Reset ¶
func (x *FailureAccrual_ConsecutiveFailures) Reset()
func (*FailureAccrual_ConsecutiveFailures) String ¶
func (x *FailureAccrual_ConsecutiveFailures) String() string
type FailureAccrual_ConsecutiveFailures_ ¶
type FailureAccrual_ConsecutiveFailures_ struct {
ConsecutiveFailures *FailureAccrual_ConsecutiveFailures `protobuf:"bytes,1,opt,name=consecutive_failures,json=consecutiveFailures,proto3,oneof"`
}
type GrpcRoute ¶
type GrpcRoute struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// If empty, the host value is ignored.
Hosts []*http_route.HostMatch `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
// Must have at least one rule.
Rules []*GrpcRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute) Descriptor
deprecated
func (*GrpcRoute) GetHosts ¶
func (x *GrpcRoute) GetHosts() []*http_route.HostMatch
func (*GrpcRoute) GetMetadata ¶
func (*GrpcRoute) GetRules ¶
func (x *GrpcRoute) GetRules() []*GrpcRoute_Rule
func (*GrpcRoute) ProtoMessage ¶
func (*GrpcRoute) ProtoMessage()
func (*GrpcRoute) ProtoReflect ¶
func (x *GrpcRoute) ProtoReflect() protoreflect.Message
type GrpcRoute_Distribution ¶
type GrpcRoute_Distribution struct {
// Types that are valid to be assigned to Kind:
//
// *GrpcRoute_Distribution_Empty_
// *GrpcRoute_Distribution_FirstAvailable_
// *GrpcRoute_Distribution_RandomAvailable_
Kind isGrpcRoute_Distribution_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution) Descriptor
deprecated
func (*GrpcRoute_Distribution) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Distribution) GetEmpty ¶
func (x *GrpcRoute_Distribution) GetEmpty() *GrpcRoute_Distribution_Empty
func (*GrpcRoute_Distribution) GetFirstAvailable ¶
func (x *GrpcRoute_Distribution) GetFirstAvailable() *GrpcRoute_Distribution_FirstAvailable
func (*GrpcRoute_Distribution) GetKind ¶
func (x *GrpcRoute_Distribution) GetKind() isGrpcRoute_Distribution_Kind
func (*GrpcRoute_Distribution) GetRandomAvailable ¶
func (x *GrpcRoute_Distribution) GetRandomAvailable() *GrpcRoute_Distribution_RandomAvailable
func (*GrpcRoute_Distribution) ProtoMessage ¶
func (*GrpcRoute_Distribution) ProtoMessage()
func (*GrpcRoute_Distribution) ProtoReflect ¶
func (x *GrpcRoute_Distribution) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Distribution) Reset ¶
func (x *GrpcRoute_Distribution) Reset()
func (*GrpcRoute_Distribution) String ¶
func (x *GrpcRoute_Distribution) String() string
type GrpcRoute_Distribution_Empty ¶
type GrpcRoute_Distribution_Empty struct {
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution_Empty) Descriptor
deprecated
func (*GrpcRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Distribution_Empty) ProtoMessage ¶
func (*GrpcRoute_Distribution_Empty) ProtoMessage()
func (*GrpcRoute_Distribution_Empty) ProtoReflect ¶
func (x *GrpcRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Distribution_Empty) Reset ¶
func (x *GrpcRoute_Distribution_Empty) Reset()
func (*GrpcRoute_Distribution_Empty) String ¶
func (x *GrpcRoute_Distribution_Empty) String() string
type GrpcRoute_Distribution_Empty_ ¶
type GrpcRoute_Distribution_Empty_ struct {
Empty *GrpcRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
type GrpcRoute_Distribution_FirstAvailable ¶
type GrpcRoute_Distribution_FirstAvailable struct {
Backends []*GrpcRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution_FirstAvailable) Descriptor
deprecated
func (*GrpcRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Distribution_FirstAvailable) GetBackends ¶
func (x *GrpcRoute_Distribution_FirstAvailable) GetBackends() []*GrpcRoute_RouteBackend
func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage ¶
func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage()
func (*GrpcRoute_Distribution_FirstAvailable) ProtoReflect ¶
func (x *GrpcRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Distribution_FirstAvailable) Reset ¶
func (x *GrpcRoute_Distribution_FirstAvailable) Reset()
func (*GrpcRoute_Distribution_FirstAvailable) String ¶
func (x *GrpcRoute_Distribution_FirstAvailable) String() string
type GrpcRoute_Distribution_FirstAvailable_ ¶
type GrpcRoute_Distribution_FirstAvailable_ struct {
// Use the first available backend in the list.
FirstAvailable *GrpcRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}
type GrpcRoute_Distribution_RandomAvailable ¶
type GrpcRoute_Distribution_RandomAvailable struct {
Backends []*GrpcRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution_RandomAvailable) Descriptor
deprecated
func (*GrpcRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Distribution_RandomAvailable) GetBackends ¶
func (x *GrpcRoute_Distribution_RandomAvailable) GetBackends() []*GrpcRoute_WeightedRouteBackend
func (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage ¶
func (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage()
func (*GrpcRoute_Distribution_RandomAvailable) ProtoReflect ¶
func (x *GrpcRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Distribution_RandomAvailable) Reset ¶
func (x *GrpcRoute_Distribution_RandomAvailable) Reset()
func (*GrpcRoute_Distribution_RandomAvailable) String ¶
func (x *GrpcRoute_Distribution_RandomAvailable) String() string
type GrpcRoute_Distribution_RandomAvailable_ ¶
type GrpcRoute_Distribution_RandomAvailable_ struct {
RandomAvailable *GrpcRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type GrpcRoute_Filter ¶
type GrpcRoute_Filter struct {
// Types that are valid to be assigned to Kind:
//
// *GrpcRoute_Filter_FailureInjector
// *GrpcRoute_Filter_RequestHeaderModifier
Kind isGrpcRoute_Filter_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Filter) Descriptor
deprecated
func (*GrpcRoute_Filter) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Filter.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Filter) GetFailureInjector ¶
func (x *GrpcRoute_Filter) GetFailureInjector() *grpc_route.GrpcFailureInjector
func (*GrpcRoute_Filter) GetKind ¶
func (x *GrpcRoute_Filter) GetKind() isGrpcRoute_Filter_Kind
func (*GrpcRoute_Filter) GetRequestHeaderModifier ¶
func (x *GrpcRoute_Filter) GetRequestHeaderModifier() *http_route.RequestHeaderModifier
func (*GrpcRoute_Filter) ProtoMessage ¶
func (*GrpcRoute_Filter) ProtoMessage()
func (*GrpcRoute_Filter) ProtoReflect ¶
func (x *GrpcRoute_Filter) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Filter) Reset ¶
func (x *GrpcRoute_Filter) Reset()
func (*GrpcRoute_Filter) String ¶
func (x *GrpcRoute_Filter) String() string
type GrpcRoute_Filter_FailureInjector ¶
type GrpcRoute_Filter_FailureInjector struct {
FailureInjector *grpc_route.GrpcFailureInjector `protobuf:"bytes,1,opt,name=failure_injector,json=failureInjector,proto3,oneof"`
}
type GrpcRoute_Filter_RequestHeaderModifier ¶
type GrpcRoute_Filter_RequestHeaderModifier struct {
RequestHeaderModifier *http_route.RequestHeaderModifier `protobuf:"bytes,2,opt,name=request_header_modifier,json=requestHeaderModifier,proto3,oneof"`
}
type GrpcRoute_Retry ¶ added in v0.14.0
type GrpcRoute_Retry struct {
MaxRetries uint32 `protobuf:"varint,1,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
MaxRequestBytes uint32 `protobuf:"varint,2,opt,name=max_request_bytes,json=maxRequestBytes,proto3" json:"max_request_bytes,omitempty"`
// Must be set, even if there are no internal conditions.
Conditions *GrpcRoute_Retry_Conditions `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
Backoff *ExponentialBackoff `protobuf:"bytes,5,opt,name=backoff,proto3" json:"backoff,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Retry) Descriptor
deprecated
added in
v0.14.0
func (*GrpcRoute_Retry) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Retry.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Retry) GetBackoff ¶ added in v0.14.0
func (x *GrpcRoute_Retry) GetBackoff() *ExponentialBackoff
func (*GrpcRoute_Retry) GetConditions ¶ added in v0.14.0
func (x *GrpcRoute_Retry) GetConditions() *GrpcRoute_Retry_Conditions
func (*GrpcRoute_Retry) GetMaxRequestBytes ¶ added in v0.14.0
func (x *GrpcRoute_Retry) GetMaxRequestBytes() uint32
func (*GrpcRoute_Retry) GetMaxRetries ¶ added in v0.14.0
func (x *GrpcRoute_Retry) GetMaxRetries() uint32
func (*GrpcRoute_Retry) GetTimeout ¶ added in v0.14.0
func (x *GrpcRoute_Retry) GetTimeout() *duration.Duration
func (*GrpcRoute_Retry) ProtoMessage ¶ added in v0.14.0
func (*GrpcRoute_Retry) ProtoMessage()
func (*GrpcRoute_Retry) ProtoReflect ¶ added in v0.14.0
func (x *GrpcRoute_Retry) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Retry) Reset ¶ added in v0.14.0
func (x *GrpcRoute_Retry) Reset()
func (*GrpcRoute_Retry) String ¶ added in v0.14.0
func (x *GrpcRoute_Retry) String() string
type GrpcRoute_Retry_Conditions ¶ added in v0.14.0
type GrpcRoute_Retry_Conditions struct {
Cancelled bool `protobuf:"varint,1,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
DeadineExceeded bool `protobuf:"varint,4,opt,name=deadine_exceeded,json=deadineExceeded,proto3" json:"deadine_exceeded,omitempty"`
ResourceExhausted bool `protobuf:"varint,8,opt,name=resource_exhausted,json=resourceExhausted,proto3" json:"resource_exhausted,omitempty"`
Internal bool `protobuf:"varint,13,opt,name=internal,proto3" json:"internal,omitempty"`
// contains filtered or unexported fields
}
Retryable gRPC status codes.
func (*GrpcRoute_Retry_Conditions) Descriptor
deprecated
added in
v0.14.0
func (*GrpcRoute_Retry_Conditions) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Retry_Conditions.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Retry_Conditions) GetCancelled ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) GetCancelled() bool
func (*GrpcRoute_Retry_Conditions) GetDeadineExceeded ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) GetDeadineExceeded() bool
func (*GrpcRoute_Retry_Conditions) GetInternal ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) GetInternal() bool
func (*GrpcRoute_Retry_Conditions) GetResourceExhausted ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) GetResourceExhausted() bool
func (*GrpcRoute_Retry_Conditions) GetUnavailable ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) GetUnavailable() bool
func (*GrpcRoute_Retry_Conditions) ProtoMessage ¶ added in v0.14.0
func (*GrpcRoute_Retry_Conditions) ProtoMessage()
func (*GrpcRoute_Retry_Conditions) ProtoReflect ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Retry_Conditions) Reset ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) Reset()
func (*GrpcRoute_Retry_Conditions) String ¶ added in v0.14.0
func (x *GrpcRoute_Retry_Conditions) String() string
type GrpcRoute_RouteBackend ¶
type GrpcRoute_RouteBackend struct {
Backend *Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Filters []*GrpcRoute_Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
// DEPRECATED: proxies ignore this. Retry timeouts are used instead of this.
//
// Deprecated: Marked as deprecated in outbound.proto.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_RouteBackend) Descriptor
deprecated
func (*GrpcRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (*GrpcRoute_RouteBackend) GetBackend ¶
func (x *GrpcRoute_RouteBackend) GetBackend() *Backend
func (*GrpcRoute_RouteBackend) GetFilters ¶
func (x *GrpcRoute_RouteBackend) GetFilters() []*GrpcRoute_Filter
func (*GrpcRoute_RouteBackend) GetRequestTimeout
deprecated
added in
v0.10.0
func (x *GrpcRoute_RouteBackend) GetRequestTimeout() *duration.Duration
Deprecated: Marked as deprecated in outbound.proto.
func (*GrpcRoute_RouteBackend) ProtoMessage ¶
func (*GrpcRoute_RouteBackend) ProtoMessage()
func (*GrpcRoute_RouteBackend) ProtoReflect ¶
func (x *GrpcRoute_RouteBackend) ProtoReflect() protoreflect.Message
func (*GrpcRoute_RouteBackend) Reset ¶
func (x *GrpcRoute_RouteBackend) Reset()
func (*GrpcRoute_RouteBackend) String ¶
func (x *GrpcRoute_RouteBackend) String() string
type GrpcRoute_Rule ¶
type GrpcRoute_Rule struct {
Matches []*grpc_route.GrpcRouteMatch `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
Filters []*GrpcRoute_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
Backends *GrpcRoute_Distribution `protobuf:"bytes,3,opt,name=backends,proto3" json:"backends,omitempty"`
// DEPRECATED: use `timeouts` instead. Servers should continue to set this
// value to the same value as `timeouts.response`.
//
// Deprecated: Marked as deprecated in outbound.proto.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
Timeouts *http_route.Timeouts `protobuf:"bytes,5,opt,name=timeouts,proto3" json:"timeouts,omitempty"`
Retry *GrpcRoute_Retry `protobuf:"bytes,6,opt,name=retry,proto3" json:"retry,omitempty"`
// If true, the proxy will allow headers to control retry and timeout
// behavior.
AllowL5DRequestHeaders bool `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GrpcRoute_Rule) Descriptor
deprecated
func (*GrpcRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Rule.ProtoReflect.Descriptor instead.
func (*GrpcRoute_Rule) GetAllowL5DRequestHeaders ¶ added in v0.14.0
func (x *GrpcRoute_Rule) GetAllowL5DRequestHeaders() bool
func (*GrpcRoute_Rule) GetBackends ¶
func (x *GrpcRoute_Rule) GetBackends() *GrpcRoute_Distribution
func (*GrpcRoute_Rule) GetFilters ¶
func (x *GrpcRoute_Rule) GetFilters() []*GrpcRoute_Filter
func (*GrpcRoute_Rule) GetMatches ¶
func (x *GrpcRoute_Rule) GetMatches() []*grpc_route.GrpcRouteMatch
func (*GrpcRoute_Rule) GetRequestTimeout
deprecated
added in
v0.10.0
func (x *GrpcRoute_Rule) GetRequestTimeout() *duration.Duration
Deprecated: Marked as deprecated in outbound.proto.
func (*GrpcRoute_Rule) GetRetry ¶ added in v0.14.0
func (x *GrpcRoute_Rule) GetRetry() *GrpcRoute_Retry
func (*GrpcRoute_Rule) GetTimeouts ¶ added in v0.14.0
func (x *GrpcRoute_Rule) GetTimeouts() *http_route.Timeouts
func (*GrpcRoute_Rule) ProtoMessage ¶
func (*GrpcRoute_Rule) ProtoMessage()
func (*GrpcRoute_Rule) ProtoReflect ¶
func (x *GrpcRoute_Rule) ProtoReflect() protoreflect.Message
func (*GrpcRoute_Rule) Reset ¶
func (x *GrpcRoute_Rule) Reset()
func (*GrpcRoute_Rule) String ¶
func (x *GrpcRoute_Rule) String() string
type GrpcRoute_WeightedRouteBackend ¶
type GrpcRoute_WeightedRouteBackend struct {
Backend *GrpcRoute_RouteBackend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_WeightedRouteBackend) Descriptor
deprecated
func (*GrpcRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
func (*GrpcRoute_WeightedRouteBackend) GetBackend ¶
func (x *GrpcRoute_WeightedRouteBackend) GetBackend() *GrpcRoute_RouteBackend
func (*GrpcRoute_WeightedRouteBackend) GetWeight ¶
func (x *GrpcRoute_WeightedRouteBackend) GetWeight() uint32
func (*GrpcRoute_WeightedRouteBackend) ProtoMessage ¶
func (*GrpcRoute_WeightedRouteBackend) ProtoMessage()
func (*GrpcRoute_WeightedRouteBackend) ProtoReflect ¶
func (x *GrpcRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
func (*GrpcRoute_WeightedRouteBackend) Reset ¶
func (x *GrpcRoute_WeightedRouteBackend) Reset()
func (*GrpcRoute_WeightedRouteBackend) String ¶
func (x *GrpcRoute_WeightedRouteBackend) String() string
type HttpRoute ¶
type HttpRoute struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// If empty, the host value is ignored.
Hosts []*http_route.HostMatch `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
// Must have at least one rule.
Rules []*HttpRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
// contains filtered or unexported fields
}
Outbound-specific HTTP route configuration (based on the [Gateway API](https://gateway-api.sigs.k8s.io/v1alpha2/references/spec/#gateway.networking.k8s.io/v1alpha2.HTTPRoute)).
func (*HttpRoute) Descriptor
deprecated
func (*HttpRoute) GetHosts ¶
func (x *HttpRoute) GetHosts() []*http_route.HostMatch
func (*HttpRoute) GetMetadata ¶
func (*HttpRoute) GetRules ¶
func (x *HttpRoute) GetRules() []*HttpRoute_Rule
func (*HttpRoute) ProtoMessage ¶
func (*HttpRoute) ProtoMessage()
func (*HttpRoute) ProtoReflect ¶
func (x *HttpRoute) ProtoReflect() protoreflect.Message
type HttpRoute_Distribution ¶
type HttpRoute_Distribution struct {
// Types that are valid to be assigned to Kind:
//
// *HttpRoute_Distribution_Empty_
// *HttpRoute_Distribution_FirstAvailable_
// *HttpRoute_Distribution_RandomAvailable_
Kind isHttpRoute_Distribution_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution) Descriptor
deprecated
func (*HttpRoute_Distribution) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution.ProtoReflect.Descriptor instead.
func (*HttpRoute_Distribution) GetEmpty ¶
func (x *HttpRoute_Distribution) GetEmpty() *HttpRoute_Distribution_Empty
func (*HttpRoute_Distribution) GetFirstAvailable ¶
func (x *HttpRoute_Distribution) GetFirstAvailable() *HttpRoute_Distribution_FirstAvailable
func (*HttpRoute_Distribution) GetKind ¶
func (x *HttpRoute_Distribution) GetKind() isHttpRoute_Distribution_Kind
func (*HttpRoute_Distribution) GetRandomAvailable ¶
func (x *HttpRoute_Distribution) GetRandomAvailable() *HttpRoute_Distribution_RandomAvailable
func (*HttpRoute_Distribution) ProtoMessage ¶
func (*HttpRoute_Distribution) ProtoMessage()
func (*HttpRoute_Distribution) ProtoReflect ¶
func (x *HttpRoute_Distribution) ProtoReflect() protoreflect.Message
func (*HttpRoute_Distribution) Reset ¶
func (x *HttpRoute_Distribution) Reset()
func (*HttpRoute_Distribution) String ¶
func (x *HttpRoute_Distribution) String() string
type HttpRoute_Distribution_Empty ¶
type HttpRoute_Distribution_Empty struct {
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution_Empty) Descriptor
deprecated
func (*HttpRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
func (*HttpRoute_Distribution_Empty) ProtoMessage ¶
func (*HttpRoute_Distribution_Empty) ProtoMessage()
func (*HttpRoute_Distribution_Empty) ProtoReflect ¶
func (x *HttpRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
func (*HttpRoute_Distribution_Empty) Reset ¶
func (x *HttpRoute_Distribution_Empty) Reset()
func (*HttpRoute_Distribution_Empty) String ¶
func (x *HttpRoute_Distribution_Empty) String() string
type HttpRoute_Distribution_Empty_ ¶
type HttpRoute_Distribution_Empty_ struct {
Empty *HttpRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
type HttpRoute_Distribution_FirstAvailable ¶
type HttpRoute_Distribution_FirstAvailable struct {
Backends []*HttpRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution_FirstAvailable) Descriptor
deprecated
func (*HttpRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
func (*HttpRoute_Distribution_FirstAvailable) GetBackends ¶
func (x *HttpRoute_Distribution_FirstAvailable) GetBackends() []*HttpRoute_RouteBackend
func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage ¶
func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage()
func (*HttpRoute_Distribution_FirstAvailable) ProtoReflect ¶
func (x *HttpRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
func (*HttpRoute_Distribution_FirstAvailable) Reset ¶
func (x *HttpRoute_Distribution_FirstAvailable) Reset()
func (*HttpRoute_Distribution_FirstAvailable) String ¶
func (x *HttpRoute_Distribution_FirstAvailable) String() string
type HttpRoute_Distribution_FirstAvailable_ ¶
type HttpRoute_Distribution_FirstAvailable_ struct {
// Use the first available backend in the list.
FirstAvailable *HttpRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}
type HttpRoute_Distribution_RandomAvailable ¶
type HttpRoute_Distribution_RandomAvailable struct {
Backends []*HttpRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution_RandomAvailable) Descriptor
deprecated
func (*HttpRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
func (*HttpRoute_Distribution_RandomAvailable) GetBackends ¶
func (x *HttpRoute_Distribution_RandomAvailable) GetBackends() []*HttpRoute_WeightedRouteBackend
func (*HttpRoute_Distribution_RandomAvailable) ProtoMessage ¶
func (*HttpRoute_Distribution_RandomAvailable) ProtoMessage()
func (*HttpRoute_Distribution_RandomAvailable) ProtoReflect ¶
func (x *HttpRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
func (*HttpRoute_Distribution_RandomAvailable) Reset ¶
func (x *HttpRoute_Distribution_RandomAvailable) Reset()
func (*HttpRoute_Distribution_RandomAvailable) String ¶
func (x *HttpRoute_Distribution_RandomAvailable) String() string
type HttpRoute_Distribution_RandomAvailable_ ¶
type HttpRoute_Distribution_RandomAvailable_ struct {
RandomAvailable *HttpRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type HttpRoute_Filter ¶
type HttpRoute_Filter struct {
// Types that are valid to be assigned to Kind:
//
// *HttpRoute_Filter_FailureInjector
// *HttpRoute_Filter_RequestHeaderModifier
// *HttpRoute_Filter_Redirect
// *HttpRoute_Filter_ResponseHeaderModifier
Kind isHttpRoute_Filter_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*HttpRoute_Filter) Descriptor
deprecated
func (*HttpRoute_Filter) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Filter.ProtoReflect.Descriptor instead.
func (*HttpRoute_Filter) GetFailureInjector ¶
func (x *HttpRoute_Filter) GetFailureInjector() *http_route.HttpFailureInjector
func (*HttpRoute_Filter) GetKind ¶
func (x *HttpRoute_Filter) GetKind() isHttpRoute_Filter_Kind
func (*HttpRoute_Filter) GetRedirect ¶
func (x *HttpRoute_Filter) GetRedirect() *http_route.RequestRedirect
func (*HttpRoute_Filter) GetRequestHeaderModifier ¶
func (x *HttpRoute_Filter) GetRequestHeaderModifier() *http_route.RequestHeaderModifier
func (*HttpRoute_Filter) GetResponseHeaderModifier ¶ added in v0.11.0
func (x *HttpRoute_Filter) GetResponseHeaderModifier() *http_route.ResponseHeaderModifier
func (*HttpRoute_Filter) ProtoMessage ¶
func (*HttpRoute_Filter) ProtoMessage()
func (*HttpRoute_Filter) ProtoReflect ¶
func (x *HttpRoute_Filter) ProtoReflect() protoreflect.Message
func (*HttpRoute_Filter) Reset ¶
func (x *HttpRoute_Filter) Reset()
func (*HttpRoute_Filter) String ¶
func (x *HttpRoute_Filter) String() string
type HttpRoute_Filter_FailureInjector ¶
type HttpRoute_Filter_FailureInjector struct {
FailureInjector *http_route.HttpFailureInjector `protobuf:"bytes,1,opt,name=failure_injector,json=failureInjector,proto3,oneof"`
}
type HttpRoute_Filter_Redirect ¶
type HttpRoute_Filter_Redirect struct {
Redirect *http_route.RequestRedirect `protobuf:"bytes,3,opt,name=redirect,proto3,oneof"`
}
type HttpRoute_Filter_RequestHeaderModifier ¶
type HttpRoute_Filter_RequestHeaderModifier struct {
RequestHeaderModifier *http_route.RequestHeaderModifier `protobuf:"bytes,2,opt,name=request_header_modifier,json=requestHeaderModifier,proto3,oneof"`
}
type HttpRoute_Filter_ResponseHeaderModifier ¶ added in v0.11.0
type HttpRoute_Filter_ResponseHeaderModifier struct {
ResponseHeaderModifier *http_route.ResponseHeaderModifier `protobuf:"bytes,4,opt,name=response_header_modifier,json=responseHeaderModifier,proto3,oneof"`
}
type HttpRoute_Retry ¶ added in v0.14.0
type HttpRoute_Retry struct {
MaxRetries uint32 `protobuf:"varint,1,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
MaxRequestBytes uint32 `protobuf:"varint,2,opt,name=max_request_bytes,json=maxRequestBytes,proto3" json:"max_request_bytes,omitempty"`
// Must be set, even if there are no internal conditions.
Conditions *HttpRoute_Retry_Conditions `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
Backoff *ExponentialBackoff `protobuf:"bytes,5,opt,name=backoff,proto3" json:"backoff,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Retry) Descriptor
deprecated
added in
v0.14.0
func (*HttpRoute_Retry) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Retry.ProtoReflect.Descriptor instead.
func (*HttpRoute_Retry) GetBackoff ¶ added in v0.14.0
func (x *HttpRoute_Retry) GetBackoff() *ExponentialBackoff
func (*HttpRoute_Retry) GetConditions ¶ added in v0.14.0
func (x *HttpRoute_Retry) GetConditions() *HttpRoute_Retry_Conditions
func (*HttpRoute_Retry) GetMaxRequestBytes ¶ added in v0.14.0
func (x *HttpRoute_Retry) GetMaxRequestBytes() uint32
func (*HttpRoute_Retry) GetMaxRetries ¶ added in v0.14.0
func (x *HttpRoute_Retry) GetMaxRetries() uint32
func (*HttpRoute_Retry) GetTimeout ¶ added in v0.14.0
func (x *HttpRoute_Retry) GetTimeout() *duration.Duration
func (*HttpRoute_Retry) ProtoMessage ¶ added in v0.14.0
func (*HttpRoute_Retry) ProtoMessage()
func (*HttpRoute_Retry) ProtoReflect ¶ added in v0.14.0
func (x *HttpRoute_Retry) ProtoReflect() protoreflect.Message
func (*HttpRoute_Retry) Reset ¶ added in v0.14.0
func (x *HttpRoute_Retry) Reset()
func (*HttpRoute_Retry) String ¶ added in v0.14.0
func (x *HttpRoute_Retry) String() string
type HttpRoute_Retry_Conditions ¶ added in v0.14.0
type HttpRoute_Retry_Conditions struct {
// Specifies the status code ranges that should trigger a retry.
StatusRanges []*HttpRoute_Retry_Conditions_StatusRange `protobuf:"bytes,1,rep,name=status_ranges,json=statusRanges,proto3" json:"status_ranges,omitempty"`
// contains filtered or unexported fields
}
Retryable conditions.
func (*HttpRoute_Retry_Conditions) Descriptor
deprecated
added in
v0.14.0
func (*HttpRoute_Retry_Conditions) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Retry_Conditions.ProtoReflect.Descriptor instead.
func (*HttpRoute_Retry_Conditions) GetStatusRanges ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions) GetStatusRanges() []*HttpRoute_Retry_Conditions_StatusRange
func (*HttpRoute_Retry_Conditions) ProtoMessage ¶ added in v0.14.0
func (*HttpRoute_Retry_Conditions) ProtoMessage()
func (*HttpRoute_Retry_Conditions) ProtoReflect ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions) ProtoReflect() protoreflect.Message
func (*HttpRoute_Retry_Conditions) Reset ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions) Reset()
func (*HttpRoute_Retry_Conditions) String ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions) String() string
type HttpRoute_Retry_Conditions_StatusRange ¶ added in v0.14.0
type HttpRoute_Retry_Conditions_StatusRange struct {
Start uint32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
End uint32 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Retry_Conditions_StatusRange) Descriptor
deprecated
added in
v0.14.0
func (*HttpRoute_Retry_Conditions_StatusRange) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Retry_Conditions_StatusRange.ProtoReflect.Descriptor instead.
func (*HttpRoute_Retry_Conditions_StatusRange) GetEnd ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions_StatusRange) GetEnd() uint32
func (*HttpRoute_Retry_Conditions_StatusRange) GetStart ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions_StatusRange) GetStart() uint32
func (*HttpRoute_Retry_Conditions_StatusRange) ProtoMessage ¶ added in v0.14.0
func (*HttpRoute_Retry_Conditions_StatusRange) ProtoMessage()
func (*HttpRoute_Retry_Conditions_StatusRange) ProtoReflect ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions_StatusRange) ProtoReflect() protoreflect.Message
func (*HttpRoute_Retry_Conditions_StatusRange) Reset ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions_StatusRange) Reset()
func (*HttpRoute_Retry_Conditions_StatusRange) String ¶ added in v0.14.0
func (x *HttpRoute_Retry_Conditions_StatusRange) String() string
type HttpRoute_RouteBackend ¶
type HttpRoute_RouteBackend struct {
Backend *Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Filters []*HttpRoute_Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
// DEPRECATED: proxies ignore this. Use Retry timeouts instead.
//
// Deprecated: Marked as deprecated in outbound.proto.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_RouteBackend) Descriptor
deprecated
func (*HttpRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (*HttpRoute_RouteBackend) GetBackend ¶
func (x *HttpRoute_RouteBackend) GetBackend() *Backend
func (*HttpRoute_RouteBackend) GetFilters ¶
func (x *HttpRoute_RouteBackend) GetFilters() []*HttpRoute_Filter
func (*HttpRoute_RouteBackend) GetRequestTimeout
deprecated
added in
v0.10.0
func (x *HttpRoute_RouteBackend) GetRequestTimeout() *duration.Duration
Deprecated: Marked as deprecated in outbound.proto.
func (*HttpRoute_RouteBackend) ProtoMessage ¶
func (*HttpRoute_RouteBackend) ProtoMessage()
func (*HttpRoute_RouteBackend) ProtoReflect ¶
func (x *HttpRoute_RouteBackend) ProtoReflect() protoreflect.Message
func (*HttpRoute_RouteBackend) Reset ¶
func (x *HttpRoute_RouteBackend) Reset()
func (*HttpRoute_RouteBackend) String ¶
func (x *HttpRoute_RouteBackend) String() string
type HttpRoute_Rule ¶
type HttpRoute_Rule struct {
Matches []*http_route.HttpRouteMatch `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
Filters []*HttpRoute_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
Backends *HttpRoute_Distribution `protobuf:"bytes,3,opt,name=backends,proto3" json:"backends,omitempty"`
// DEPRECATED: use `timeouts` instead. Servers should continue to set this
// value to the same value as `timeouts.response`.
//
// Deprecated: Marked as deprecated in outbound.proto.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
Timeouts *http_route.Timeouts `protobuf:"bytes,5,opt,name=timeouts,proto3" json:"timeouts,omitempty"`
Retry *HttpRoute_Retry `protobuf:"bytes,6,opt,name=retry,proto3" json:"retry,omitempty"`
// If true, the proxy will allow headers to control retry and timeout
// behavior.
AllowL5DRequestHeaders bool `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*HttpRoute_Rule) Descriptor
deprecated
func (*HttpRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Rule.ProtoReflect.Descriptor instead.
func (*HttpRoute_Rule) GetAllowL5DRequestHeaders ¶ added in v0.14.0
func (x *HttpRoute_Rule) GetAllowL5DRequestHeaders() bool
func (*HttpRoute_Rule) GetBackends ¶
func (x *HttpRoute_Rule) GetBackends() *HttpRoute_Distribution
func (*HttpRoute_Rule) GetFilters ¶
func (x *HttpRoute_Rule) GetFilters() []*HttpRoute_Filter
func (*HttpRoute_Rule) GetMatches ¶
func (x *HttpRoute_Rule) GetMatches() []*http_route.HttpRouteMatch
func (*HttpRoute_Rule) GetRequestTimeout
deprecated
added in
v0.10.0
func (x *HttpRoute_Rule) GetRequestTimeout() *duration.Duration
Deprecated: Marked as deprecated in outbound.proto.
func (*HttpRoute_Rule) GetRetry ¶ added in v0.14.0
func (x *HttpRoute_Rule) GetRetry() *HttpRoute_Retry
func (*HttpRoute_Rule) GetTimeouts ¶ added in v0.14.0
func (x *HttpRoute_Rule) GetTimeouts() *http_route.Timeouts
func (*HttpRoute_Rule) ProtoMessage ¶
func (*HttpRoute_Rule) ProtoMessage()
func (*HttpRoute_Rule) ProtoReflect ¶
func (x *HttpRoute_Rule) ProtoReflect() protoreflect.Message
func (*HttpRoute_Rule) Reset ¶
func (x *HttpRoute_Rule) Reset()
func (*HttpRoute_Rule) String ¶
func (x *HttpRoute_Rule) String() string
type HttpRoute_WeightedRouteBackend ¶
type HttpRoute_WeightedRouteBackend struct {
Backend *HttpRoute_RouteBackend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_WeightedRouteBackend) Descriptor
deprecated
func (*HttpRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
func (*HttpRoute_WeightedRouteBackend) GetBackend ¶
func (x *HttpRoute_WeightedRouteBackend) GetBackend() *HttpRoute_RouteBackend
func (*HttpRoute_WeightedRouteBackend) GetWeight ¶
func (x *HttpRoute_WeightedRouteBackend) GetWeight() uint32
func (*HttpRoute_WeightedRouteBackend) ProtoMessage ¶
func (*HttpRoute_WeightedRouteBackend) ProtoMessage()
func (*HttpRoute_WeightedRouteBackend) ProtoReflect ¶
func (x *HttpRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
func (*HttpRoute_WeightedRouteBackend) Reset ¶
func (x *HttpRoute_WeightedRouteBackend) Reset()
func (*HttpRoute_WeightedRouteBackend) String ¶
func (x *HttpRoute_WeightedRouteBackend) String() string
type OpaqueRoute ¶
type OpaqueRoute struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// Must have at least one rule.
Rules []*OpaqueRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute) Descriptor
deprecated
func (*OpaqueRoute) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute.ProtoReflect.Descriptor instead.
func (*OpaqueRoute) GetMetadata ¶
func (x *OpaqueRoute) GetMetadata() *meta.Metadata
func (*OpaqueRoute) GetRules ¶
func (x *OpaqueRoute) GetRules() []*OpaqueRoute_Rule
func (*OpaqueRoute) ProtoMessage ¶
func (*OpaqueRoute) ProtoMessage()
func (*OpaqueRoute) ProtoReflect ¶
func (x *OpaqueRoute) ProtoReflect() protoreflect.Message
func (*OpaqueRoute) Reset ¶
func (x *OpaqueRoute) Reset()
func (*OpaqueRoute) String ¶
func (x *OpaqueRoute) String() string
type OpaqueRoute_Distribution ¶
type OpaqueRoute_Distribution struct {
// Types that are valid to be assigned to Kind:
//
// *OpaqueRoute_Distribution_Empty_
// *OpaqueRoute_Distribution_FirstAvailable_
// *OpaqueRoute_Distribution_RandomAvailable_
Kind isOpaqueRoute_Distribution_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution) Descriptor
deprecated
func (*OpaqueRoute_Distribution) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Distribution) GetEmpty ¶
func (x *OpaqueRoute_Distribution) GetEmpty() *OpaqueRoute_Distribution_Empty
func (*OpaqueRoute_Distribution) GetFirstAvailable ¶
func (x *OpaqueRoute_Distribution) GetFirstAvailable() *OpaqueRoute_Distribution_FirstAvailable
func (*OpaqueRoute_Distribution) GetKind ¶
func (x *OpaqueRoute_Distribution) GetKind() isOpaqueRoute_Distribution_Kind
func (*OpaqueRoute_Distribution) GetRandomAvailable ¶
func (x *OpaqueRoute_Distribution) GetRandomAvailable() *OpaqueRoute_Distribution_RandomAvailable
func (*OpaqueRoute_Distribution) ProtoMessage ¶
func (*OpaqueRoute_Distribution) ProtoMessage()
func (*OpaqueRoute_Distribution) ProtoReflect ¶
func (x *OpaqueRoute_Distribution) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Distribution) Reset ¶
func (x *OpaqueRoute_Distribution) Reset()
func (*OpaqueRoute_Distribution) String ¶
func (x *OpaqueRoute_Distribution) String() string
type OpaqueRoute_Distribution_Empty ¶
type OpaqueRoute_Distribution_Empty struct {
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution_Empty) Descriptor
deprecated
func (*OpaqueRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Distribution_Empty) ProtoMessage ¶
func (*OpaqueRoute_Distribution_Empty) ProtoMessage()
func (*OpaqueRoute_Distribution_Empty) ProtoReflect ¶
func (x *OpaqueRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Distribution_Empty) Reset ¶
func (x *OpaqueRoute_Distribution_Empty) Reset()
func (*OpaqueRoute_Distribution_Empty) String ¶
func (x *OpaqueRoute_Distribution_Empty) String() string
type OpaqueRoute_Distribution_Empty_ ¶
type OpaqueRoute_Distribution_Empty_ struct {
Empty *OpaqueRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
type OpaqueRoute_Distribution_FirstAvailable ¶
type OpaqueRoute_Distribution_FirstAvailable struct {
Backends []*OpaqueRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution_FirstAvailable) Descriptor
deprecated
func (*OpaqueRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Distribution_FirstAvailable) GetBackends ¶
func (x *OpaqueRoute_Distribution_FirstAvailable) GetBackends() []*OpaqueRoute_RouteBackend
func (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage ¶
func (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage()
func (*OpaqueRoute_Distribution_FirstAvailable) ProtoReflect ¶
func (x *OpaqueRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Distribution_FirstAvailable) Reset ¶
func (x *OpaqueRoute_Distribution_FirstAvailable) Reset()
func (*OpaqueRoute_Distribution_FirstAvailable) String ¶
func (x *OpaqueRoute_Distribution_FirstAvailable) String() string
type OpaqueRoute_Distribution_FirstAvailable_ ¶
type OpaqueRoute_Distribution_FirstAvailable_ struct {
// Use the first available backend in the list.
FirstAvailable *OpaqueRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}
type OpaqueRoute_Distribution_RandomAvailable ¶
type OpaqueRoute_Distribution_RandomAvailable struct {
Backends []*OpaqueRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution_RandomAvailable) Descriptor
deprecated
func (*OpaqueRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Distribution_RandomAvailable) GetBackends ¶
func (x *OpaqueRoute_Distribution_RandomAvailable) GetBackends() []*OpaqueRoute_WeightedRouteBackend
func (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage ¶
func (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage()
func (*OpaqueRoute_Distribution_RandomAvailable) ProtoReflect ¶
func (x *OpaqueRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Distribution_RandomAvailable) Reset ¶
func (x *OpaqueRoute_Distribution_RandomAvailable) Reset()
func (*OpaqueRoute_Distribution_RandomAvailable) String ¶
func (x *OpaqueRoute_Distribution_RandomAvailable) String() string
type OpaqueRoute_Distribution_RandomAvailable_ ¶
type OpaqueRoute_Distribution_RandomAvailable_ struct {
RandomAvailable *OpaqueRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type OpaqueRoute_Filter ¶ added in v0.15.0
type OpaqueRoute_Filter struct {
// Types that are valid to be assigned to Kind:
//
// *OpaqueRoute_Filter_Invalid
// *OpaqueRoute_Filter_Forbidden
Kind isOpaqueRoute_Filter_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Filter) Descriptor
deprecated
added in
v0.15.0
func (*OpaqueRoute_Filter) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Filter.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Filter) GetForbidden ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) GetForbidden() *opaque_route.Forbidden
func (*OpaqueRoute_Filter) GetInvalid ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) GetInvalid() *opaque_route.Invalid
func (*OpaqueRoute_Filter) GetKind ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) GetKind() isOpaqueRoute_Filter_Kind
func (*OpaqueRoute_Filter) ProtoMessage ¶ added in v0.15.0
func (*OpaqueRoute_Filter) ProtoMessage()
func (*OpaqueRoute_Filter) ProtoReflect ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Filter) Reset ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) Reset()
func (*OpaqueRoute_Filter) String ¶ added in v0.15.0
func (x *OpaqueRoute_Filter) String() string
type OpaqueRoute_Filter_Forbidden ¶ added in v0.15.0
type OpaqueRoute_Filter_Forbidden struct {
Forbidden *opaque_route.Forbidden `protobuf:"bytes,2,opt,name=forbidden,proto3,oneof"`
}
type OpaqueRoute_Filter_Invalid ¶ added in v0.15.0
type OpaqueRoute_Filter_Invalid struct {
Invalid *opaque_route.Invalid `protobuf:"bytes,1,opt,name=invalid,proto3,oneof"`
}
type OpaqueRoute_RouteBackend ¶
type OpaqueRoute_RouteBackend struct {
Backend *Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Filters []*OpaqueRoute_Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_RouteBackend) Descriptor
deprecated
func (*OpaqueRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_RouteBackend) GetBackend ¶
func (x *OpaqueRoute_RouteBackend) GetBackend() *Backend
func (*OpaqueRoute_RouteBackend) GetFilters ¶ added in v0.15.0
func (x *OpaqueRoute_RouteBackend) GetFilters() []*OpaqueRoute_Filter
func (*OpaqueRoute_RouteBackend) ProtoMessage ¶
func (*OpaqueRoute_RouteBackend) ProtoMessage()
func (*OpaqueRoute_RouteBackend) ProtoReflect ¶
func (x *OpaqueRoute_RouteBackend) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_RouteBackend) Reset ¶
func (x *OpaqueRoute_RouteBackend) Reset()
func (*OpaqueRoute_RouteBackend) String ¶
func (x *OpaqueRoute_RouteBackend) String() string
type OpaqueRoute_Rule ¶
type OpaqueRoute_Rule struct {
Backends *OpaqueRoute_Distribution `protobuf:"bytes,1,opt,name=backends,proto3" json:"backends,omitempty"`
Filters []*OpaqueRoute_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Rule) Descriptor
deprecated
func (*OpaqueRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Rule.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_Rule) GetBackends ¶
func (x *OpaqueRoute_Rule) GetBackends() *OpaqueRoute_Distribution
func (*OpaqueRoute_Rule) GetFilters ¶ added in v0.15.0
func (x *OpaqueRoute_Rule) GetFilters() []*OpaqueRoute_Filter
func (*OpaqueRoute_Rule) ProtoMessage ¶
func (*OpaqueRoute_Rule) ProtoMessage()
func (*OpaqueRoute_Rule) ProtoReflect ¶
func (x *OpaqueRoute_Rule) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_Rule) Reset ¶
func (x *OpaqueRoute_Rule) Reset()
func (*OpaqueRoute_Rule) String ¶
func (x *OpaqueRoute_Rule) String() string
type OpaqueRoute_WeightedRouteBackend ¶
type OpaqueRoute_WeightedRouteBackend struct {
Backend *OpaqueRoute_RouteBackend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_WeightedRouteBackend) Descriptor
deprecated
func (*OpaqueRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
func (*OpaqueRoute_WeightedRouteBackend) GetBackend ¶
func (x *OpaqueRoute_WeightedRouteBackend) GetBackend() *OpaqueRoute_RouteBackend
func (*OpaqueRoute_WeightedRouteBackend) GetWeight ¶
func (x *OpaqueRoute_WeightedRouteBackend) GetWeight() uint32
func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage ¶
func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage()
func (*OpaqueRoute_WeightedRouteBackend) ProtoReflect ¶
func (x *OpaqueRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
func (*OpaqueRoute_WeightedRouteBackend) Reset ¶
func (x *OpaqueRoute_WeightedRouteBackend) Reset()
func (*OpaqueRoute_WeightedRouteBackend) String ¶
func (x *OpaqueRoute_WeightedRouteBackend) String() string
type OutboundPoliciesClient ¶
type OutboundPoliciesClient interface {
Get(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (*OutboundPolicy, error)
Watch(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (grpc.ServerStreamingClient[OutboundPolicy], error)
}
OutboundPoliciesClient is the client API for OutboundPolicies service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewOutboundPoliciesClient ¶
func NewOutboundPoliciesClient(cc grpc.ClientConnInterface) OutboundPoliciesClient
type OutboundPoliciesServer ¶
type OutboundPoliciesServer interface {
Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)
Watch(*TrafficSpec, grpc.ServerStreamingServer[OutboundPolicy]) error
// contains filtered or unexported methods
}
OutboundPoliciesServer is the server API for OutboundPolicies service. All implementations must embed UnimplementedOutboundPoliciesServer for forward compatibility.
type OutboundPolicies_WatchClient ¶
type OutboundPolicies_WatchClient = grpc.ServerStreamingClient[OutboundPolicy]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type OutboundPolicies_WatchServer ¶
type OutboundPolicies_WatchServer = grpc.ServerStreamingServer[OutboundPolicy]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type OutboundPolicy ¶
type OutboundPolicy struct {
// Indicates the protocol to use for this target. This will be set to Opaque
// if the target has been marked as opaque and will be Discover otherwise.
Protocol *ProxyProtocol `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
// Describes the resource for which outbound policy has been discovered.
Metadata *meta.Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
Outbound policy for a given traffic spec.
func (*OutboundPolicy) Descriptor
deprecated
func (*OutboundPolicy) Descriptor() ([]byte, []int)
Deprecated: Use OutboundPolicy.ProtoReflect.Descriptor instead.
func (*OutboundPolicy) GetMetadata ¶
func (x *OutboundPolicy) GetMetadata() *meta.Metadata
func (*OutboundPolicy) GetProtocol ¶
func (x *OutboundPolicy) GetProtocol() *ProxyProtocol
func (*OutboundPolicy) ProtoMessage ¶
func (*OutboundPolicy) ProtoMessage()
func (*OutboundPolicy) ProtoReflect ¶
func (x *OutboundPolicy) ProtoReflect() protoreflect.Message
func (*OutboundPolicy) Reset ¶
func (x *OutboundPolicy) Reset()
func (*OutboundPolicy) String ¶
func (x *OutboundPolicy) String() string
type ProxyProtocol ¶
type ProxyProtocol struct {
// Types that are valid to be assigned to Kind:
//
// *ProxyProtocol_Detect_
// *ProxyProtocol_Opaque_
// *ProxyProtocol_Http1_
// *ProxyProtocol_Http2_
// *ProxyProtocol_Grpc_
// *ProxyProtocol_Tls_
Kind isProxyProtocol_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*ProxyProtocol) Descriptor
deprecated
func (*ProxyProtocol) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol.ProtoReflect.Descriptor instead.
func (*ProxyProtocol) GetDetect ¶
func (x *ProxyProtocol) GetDetect() *ProxyProtocol_Detect
func (*ProxyProtocol) GetGrpc ¶
func (x *ProxyProtocol) GetGrpc() *ProxyProtocol_Grpc
func (*ProxyProtocol) GetHttp1 ¶
func (x *ProxyProtocol) GetHttp1() *ProxyProtocol_Http1
func (*ProxyProtocol) GetHttp2 ¶
func (x *ProxyProtocol) GetHttp2() *ProxyProtocol_Http2
func (*ProxyProtocol) GetKind ¶
func (x *ProxyProtocol) GetKind() isProxyProtocol_Kind
func (*ProxyProtocol) GetOpaque ¶
func (x *ProxyProtocol) GetOpaque() *ProxyProtocol_Opaque
func (*ProxyProtocol) GetTls ¶ added in v0.15.0
func (x *ProxyProtocol) GetTls() *ProxyProtocol_Tls
func (*ProxyProtocol) ProtoMessage ¶
func (*ProxyProtocol) ProtoMessage()
func (*ProxyProtocol) ProtoReflect ¶
func (x *ProxyProtocol) ProtoReflect() protoreflect.Message
func (*ProxyProtocol) Reset ¶
func (x *ProxyProtocol) Reset()
func (*ProxyProtocol) String ¶
func (x *ProxyProtocol) String() string
type ProxyProtocol_Detect ¶
type ProxyProtocol_Detect struct {
// Protocol detection timeout.
Timeout *duration.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
Opaque *ProxyProtocol_Opaque `protobuf:"bytes,2,opt,name=opaque,proto3" json:"opaque,omitempty"`
// HTTP/1 policy configuration.
Http1 *ProxyProtocol_Http1 `protobuf:"bytes,3,opt,name=http1,proto3" json:"http1,omitempty"`
// HTTP/2 policy configuration.
Http2 *ProxyProtocol_Http2 `protobuf:"bytes,4,opt,name=http2,proto3" json:"http2,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Detect) Descriptor
deprecated
func (*ProxyProtocol_Detect) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Detect.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Detect) GetHttp1 ¶
func (x *ProxyProtocol_Detect) GetHttp1() *ProxyProtocol_Http1
func (*ProxyProtocol_Detect) GetHttp2 ¶
func (x *ProxyProtocol_Detect) GetHttp2() *ProxyProtocol_Http2
func (*ProxyProtocol_Detect) GetOpaque ¶
func (x *ProxyProtocol_Detect) GetOpaque() *ProxyProtocol_Opaque
func (*ProxyProtocol_Detect) GetTimeout ¶
func (x *ProxyProtocol_Detect) GetTimeout() *duration.Duration
func (*ProxyProtocol_Detect) ProtoMessage ¶
func (*ProxyProtocol_Detect) ProtoMessage()
func (*ProxyProtocol_Detect) ProtoReflect ¶
func (x *ProxyProtocol_Detect) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Detect) Reset ¶
func (x *ProxyProtocol_Detect) Reset()
func (*ProxyProtocol_Detect) String ¶
func (x *ProxyProtocol_Detect) String() string
type ProxyProtocol_Detect_ ¶
type ProxyProtocol_Detect_ struct {
Detect *ProxyProtocol_Detect `protobuf:"bytes,1,opt,name=detect,proto3,oneof"`
}
type ProxyProtocol_Grpc ¶
type ProxyProtocol_Grpc struct {
Routes []*GrpcRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// If empty, circuit breaking is not performed.
FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Grpc) Descriptor
deprecated
func (*ProxyProtocol_Grpc) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Grpc.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Grpc) GetFailureAccrual ¶
func (x *ProxyProtocol_Grpc) GetFailureAccrual() *FailureAccrual
func (*ProxyProtocol_Grpc) GetRoutes ¶
func (x *ProxyProtocol_Grpc) GetRoutes() []*GrpcRoute
func (*ProxyProtocol_Grpc) ProtoMessage ¶
func (*ProxyProtocol_Grpc) ProtoMessage()
func (*ProxyProtocol_Grpc) ProtoReflect ¶
func (x *ProxyProtocol_Grpc) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Grpc) Reset ¶
func (x *ProxyProtocol_Grpc) Reset()
func (*ProxyProtocol_Grpc) String ¶
func (x *ProxyProtocol_Grpc) String() string
type ProxyProtocol_Grpc_ ¶
type ProxyProtocol_Grpc_ struct {
// gRPC policy configuration.
Grpc *ProxyProtocol_Grpc `protobuf:"bytes,5,opt,name=grpc,proto3,oneof"`
}
type ProxyProtocol_Http1 ¶
type ProxyProtocol_Http1 struct {
Routes []*HttpRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// If empty, circuit breaking is not performed.
FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Http1) Descriptor
deprecated
func (*ProxyProtocol_Http1) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Http1.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Http1) GetFailureAccrual ¶
func (x *ProxyProtocol_Http1) GetFailureAccrual() *FailureAccrual
func (*ProxyProtocol_Http1) GetRoutes ¶
func (x *ProxyProtocol_Http1) GetRoutes() []*HttpRoute
func (*ProxyProtocol_Http1) ProtoMessage ¶
func (*ProxyProtocol_Http1) ProtoMessage()
func (*ProxyProtocol_Http1) ProtoReflect ¶
func (x *ProxyProtocol_Http1) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Http1) Reset ¶
func (x *ProxyProtocol_Http1) Reset()
func (*ProxyProtocol_Http1) String ¶
func (x *ProxyProtocol_Http1) String() string
type ProxyProtocol_Http1_ ¶
type ProxyProtocol_Http1_ struct {
// HTTP/1 policy configuration.
Http1 *ProxyProtocol_Http1 `protobuf:"bytes,3,opt,name=http1,proto3,oneof"`
}
type ProxyProtocol_Http2 ¶
type ProxyProtocol_Http2 struct {
Routes []*HttpRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// If empty, circuit breaking is not performed.
FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Http2) Descriptor
deprecated
func (*ProxyProtocol_Http2) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Http2.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Http2) GetFailureAccrual ¶
func (x *ProxyProtocol_Http2) GetFailureAccrual() *FailureAccrual
func (*ProxyProtocol_Http2) GetRoutes ¶
func (x *ProxyProtocol_Http2) GetRoutes() []*HttpRoute
func (*ProxyProtocol_Http2) ProtoMessage ¶
func (*ProxyProtocol_Http2) ProtoMessage()
func (*ProxyProtocol_Http2) ProtoReflect ¶
func (x *ProxyProtocol_Http2) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Http2) Reset ¶
func (x *ProxyProtocol_Http2) Reset()
func (*ProxyProtocol_Http2) String ¶
func (x *ProxyProtocol_Http2) String() string
type ProxyProtocol_Http2_ ¶
type ProxyProtocol_Http2_ struct {
// HTTP/2 policy configuration.
Http2 *ProxyProtocol_Http2 `protobuf:"bytes,4,opt,name=http2,proto3,oneof"`
}
type ProxyProtocol_Opaque ¶
type ProxyProtocol_Opaque struct {
Routes []*OpaqueRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Opaque) Descriptor
deprecated
func (*ProxyProtocol_Opaque) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Opaque.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Opaque) GetRoutes ¶
func (x *ProxyProtocol_Opaque) GetRoutes() []*OpaqueRoute
func (*ProxyProtocol_Opaque) ProtoMessage ¶
func (*ProxyProtocol_Opaque) ProtoMessage()
func (*ProxyProtocol_Opaque) ProtoReflect ¶
func (x *ProxyProtocol_Opaque) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Opaque) Reset ¶
func (x *ProxyProtocol_Opaque) Reset()
func (*ProxyProtocol_Opaque) String ¶
func (x *ProxyProtocol_Opaque) String() string
type ProxyProtocol_Opaque_ ¶
type ProxyProtocol_Opaque_ struct {
Opaque *ProxyProtocol_Opaque `protobuf:"bytes,2,opt,name=opaque,proto3,oneof"`
}
type ProxyProtocol_Tls ¶ added in v0.15.0
type ProxyProtocol_Tls struct {
Routes []*TlsRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// contains filtered or unexported fields
}
func (*ProxyProtocol_Tls) Descriptor
deprecated
added in
v0.15.0
func (*ProxyProtocol_Tls) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol_Tls.ProtoReflect.Descriptor instead.
func (*ProxyProtocol_Tls) GetRoutes ¶ added in v0.15.0
func (x *ProxyProtocol_Tls) GetRoutes() []*TlsRoute
func (*ProxyProtocol_Tls) ProtoMessage ¶ added in v0.15.0
func (*ProxyProtocol_Tls) ProtoMessage()
func (*ProxyProtocol_Tls) ProtoReflect ¶ added in v0.15.0
func (x *ProxyProtocol_Tls) ProtoReflect() protoreflect.Message
func (*ProxyProtocol_Tls) Reset ¶ added in v0.15.0
func (x *ProxyProtocol_Tls) Reset()
func (*ProxyProtocol_Tls) String ¶ added in v0.15.0
func (x *ProxyProtocol_Tls) String() string
type ProxyProtocol_Tls_ ¶ added in v0.15.0
type ProxyProtocol_Tls_ struct {
// TLS policy configuration.
Tls *ProxyProtocol_Tls `protobuf:"bytes,6,opt,name=tls,proto3,oneof"`
}
type Queue ¶
type Queue struct {
// The number of requests that may be held in a queue before backpressure is
// exerted.
Capacity uint32 `protobuf:"varint,1,opt,name=capacity,proto3" json:"capacity,omitempty"`
// A timeout that limits how long a backend may remain unready before any
// requests in its queue are failed.
FailfastTimeout *duration.Duration `protobuf:"bytes,2,opt,name=failfast_timeout,json=failfastTimeout,proto3" json:"failfast_timeout,omitempty"`
// contains filtered or unexported fields
}
func (*Queue) Descriptor
deprecated
func (*Queue) GetCapacity ¶
func (*Queue) GetFailfastTimeout ¶
func (*Queue) ProtoMessage ¶
func (*Queue) ProtoMessage()
func (*Queue) ProtoReflect ¶
func (x *Queue) ProtoReflect() protoreflect.Message
type TlsRoute ¶ added in v0.15.0
type TlsRoute struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// If empty, the SNI value is ignored.
Snis []*tls_route.SniMatch `protobuf:"bytes,2,rep,name=snis,proto3" json:"snis,omitempty"`
// Must have at least one rule.
Rules []*TlsRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute) GetMetadata ¶ added in v0.15.0
func (*TlsRoute) GetRules ¶ added in v0.15.0
func (x *TlsRoute) GetRules() []*TlsRoute_Rule
func (*TlsRoute) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute) ProtoMessage()
func (*TlsRoute) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute) ProtoReflect() protoreflect.Message
type TlsRoute_Distribution ¶ added in v0.15.0
type TlsRoute_Distribution struct {
// Types that are valid to be assigned to Kind:
//
// *TlsRoute_Distribution_Empty_
// *TlsRoute_Distribution_FirstAvailable_
// *TlsRoute_Distribution_RandomAvailable_
Kind isTlsRoute_Distribution_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*TlsRoute_Distribution) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Distribution) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Distribution.ProtoReflect.Descriptor instead.
func (*TlsRoute_Distribution) GetEmpty ¶ added in v0.15.0
func (x *TlsRoute_Distribution) GetEmpty() *TlsRoute_Distribution_Empty
func (*TlsRoute_Distribution) GetFirstAvailable ¶ added in v0.15.0
func (x *TlsRoute_Distribution) GetFirstAvailable() *TlsRoute_Distribution_FirstAvailable
func (*TlsRoute_Distribution) GetKind ¶ added in v0.15.0
func (x *TlsRoute_Distribution) GetKind() isTlsRoute_Distribution_Kind
func (*TlsRoute_Distribution) GetRandomAvailable ¶ added in v0.15.0
func (x *TlsRoute_Distribution) GetRandomAvailable() *TlsRoute_Distribution_RandomAvailable
func (*TlsRoute_Distribution) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Distribution) ProtoMessage()
func (*TlsRoute_Distribution) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Distribution) ProtoReflect() protoreflect.Message
func (*TlsRoute_Distribution) Reset ¶ added in v0.15.0
func (x *TlsRoute_Distribution) Reset()
func (*TlsRoute_Distribution) String ¶ added in v0.15.0
func (x *TlsRoute_Distribution) String() string
type TlsRoute_Distribution_Empty ¶ added in v0.15.0
type TlsRoute_Distribution_Empty struct {
// contains filtered or unexported fields
}
func (*TlsRoute_Distribution_Empty) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
func (*TlsRoute_Distribution_Empty) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Distribution_Empty) ProtoMessage()
func (*TlsRoute_Distribution_Empty) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Distribution_Empty) ProtoReflect() protoreflect.Message
func (*TlsRoute_Distribution_Empty) Reset ¶ added in v0.15.0
func (x *TlsRoute_Distribution_Empty) Reset()
func (*TlsRoute_Distribution_Empty) String ¶ added in v0.15.0
func (x *TlsRoute_Distribution_Empty) String() string
type TlsRoute_Distribution_Empty_ ¶ added in v0.15.0
type TlsRoute_Distribution_Empty_ struct {
Empty *TlsRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
type TlsRoute_Distribution_FirstAvailable ¶ added in v0.15.0
type TlsRoute_Distribution_FirstAvailable struct {
Backends []*TlsRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute_Distribution_FirstAvailable) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Distribution_FirstAvailable) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
func (*TlsRoute_Distribution_FirstAvailable) GetBackends ¶ added in v0.15.0
func (x *TlsRoute_Distribution_FirstAvailable) GetBackends() []*TlsRoute_RouteBackend
func (*TlsRoute_Distribution_FirstAvailable) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Distribution_FirstAvailable) ProtoMessage()
func (*TlsRoute_Distribution_FirstAvailable) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Distribution_FirstAvailable) ProtoReflect() protoreflect.Message
func (*TlsRoute_Distribution_FirstAvailable) Reset ¶ added in v0.15.0
func (x *TlsRoute_Distribution_FirstAvailable) Reset()
func (*TlsRoute_Distribution_FirstAvailable) String ¶ added in v0.15.0
func (x *TlsRoute_Distribution_FirstAvailable) String() string
type TlsRoute_Distribution_FirstAvailable_ ¶ added in v0.15.0
type TlsRoute_Distribution_FirstAvailable_ struct {
// Use the first available backend in the list.
FirstAvailable *TlsRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}
type TlsRoute_Distribution_RandomAvailable ¶ added in v0.15.0
type TlsRoute_Distribution_RandomAvailable struct {
Backends []*TlsRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute_Distribution_RandomAvailable) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
func (*TlsRoute_Distribution_RandomAvailable) GetBackends ¶ added in v0.15.0
func (x *TlsRoute_Distribution_RandomAvailable) GetBackends() []*TlsRoute_WeightedRouteBackend
func (*TlsRoute_Distribution_RandomAvailable) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Distribution_RandomAvailable) ProtoMessage()
func (*TlsRoute_Distribution_RandomAvailable) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Distribution_RandomAvailable) ProtoReflect() protoreflect.Message
func (*TlsRoute_Distribution_RandomAvailable) Reset ¶ added in v0.15.0
func (x *TlsRoute_Distribution_RandomAvailable) Reset()
func (*TlsRoute_Distribution_RandomAvailable) String ¶ added in v0.15.0
func (x *TlsRoute_Distribution_RandomAvailable) String() string
type TlsRoute_Distribution_RandomAvailable_ ¶ added in v0.15.0
type TlsRoute_Distribution_RandomAvailable_ struct {
RandomAvailable *TlsRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type TlsRoute_Filter ¶ added in v0.15.0
type TlsRoute_Filter struct {
// Types that are valid to be assigned to Kind:
//
// *TlsRoute_Filter_Invalid
// *TlsRoute_Filter_Forbidden
Kind isTlsRoute_Filter_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*TlsRoute_Filter) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Filter) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Filter.ProtoReflect.Descriptor instead.
func (*TlsRoute_Filter) GetForbidden ¶ added in v0.15.0
func (x *TlsRoute_Filter) GetForbidden() *opaque_route.Forbidden
func (*TlsRoute_Filter) GetInvalid ¶ added in v0.15.0
func (x *TlsRoute_Filter) GetInvalid() *opaque_route.Invalid
func (*TlsRoute_Filter) GetKind ¶ added in v0.15.0
func (x *TlsRoute_Filter) GetKind() isTlsRoute_Filter_Kind
func (*TlsRoute_Filter) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Filter) ProtoMessage()
func (*TlsRoute_Filter) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Filter) ProtoReflect() protoreflect.Message
func (*TlsRoute_Filter) Reset ¶ added in v0.15.0
func (x *TlsRoute_Filter) Reset()
func (*TlsRoute_Filter) String ¶ added in v0.15.0
func (x *TlsRoute_Filter) String() string
type TlsRoute_Filter_Forbidden ¶ added in v0.15.0
type TlsRoute_Filter_Forbidden struct {
Forbidden *opaque_route.Forbidden `protobuf:"bytes,2,opt,name=forbidden,proto3,oneof"`
}
type TlsRoute_Filter_Invalid ¶ added in v0.15.0
type TlsRoute_Filter_Invalid struct {
Invalid *opaque_route.Invalid `protobuf:"bytes,1,opt,name=invalid,proto3,oneof"`
}
type TlsRoute_RouteBackend ¶ added in v0.15.0
type TlsRoute_RouteBackend struct {
Backend *Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Filters []*TlsRoute_Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute_RouteBackend) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (*TlsRoute_RouteBackend) GetBackend ¶ added in v0.15.0
func (x *TlsRoute_RouteBackend) GetBackend() *Backend
func (*TlsRoute_RouteBackend) GetFilters ¶ added in v0.15.0
func (x *TlsRoute_RouteBackend) GetFilters() []*TlsRoute_Filter
func (*TlsRoute_RouteBackend) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_RouteBackend) ProtoMessage()
func (*TlsRoute_RouteBackend) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_RouteBackend) ProtoReflect() protoreflect.Message
func (*TlsRoute_RouteBackend) Reset ¶ added in v0.15.0
func (x *TlsRoute_RouteBackend) Reset()
func (*TlsRoute_RouteBackend) String ¶ added in v0.15.0
func (x *TlsRoute_RouteBackend) String() string
type TlsRoute_Rule ¶ added in v0.15.0
type TlsRoute_Rule struct {
Backends *TlsRoute_Distribution `protobuf:"bytes,1,opt,name=backends,proto3" json:"backends,omitempty"`
Filters []*TlsRoute_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute_Rule) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_Rule.ProtoReflect.Descriptor instead.
func (*TlsRoute_Rule) GetBackends ¶ added in v0.15.0
func (x *TlsRoute_Rule) GetBackends() *TlsRoute_Distribution
func (*TlsRoute_Rule) GetFilters ¶ added in v0.15.0
func (x *TlsRoute_Rule) GetFilters() []*TlsRoute_Filter
func (*TlsRoute_Rule) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_Rule) ProtoMessage()
func (*TlsRoute_Rule) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_Rule) ProtoReflect() protoreflect.Message
func (*TlsRoute_Rule) Reset ¶ added in v0.15.0
func (x *TlsRoute_Rule) Reset()
func (*TlsRoute_Rule) String ¶ added in v0.15.0
func (x *TlsRoute_Rule) String() string
type TlsRoute_WeightedRouteBackend ¶ added in v0.15.0
type TlsRoute_WeightedRouteBackend struct {
Backend *TlsRoute_RouteBackend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*TlsRoute_WeightedRouteBackend) Descriptor
deprecated
added in
v0.15.0
func (*TlsRoute_WeightedRouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use TlsRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
func (*TlsRoute_WeightedRouteBackend) GetBackend ¶ added in v0.15.0
func (x *TlsRoute_WeightedRouteBackend) GetBackend() *TlsRoute_RouteBackend
func (*TlsRoute_WeightedRouteBackend) GetWeight ¶ added in v0.15.0
func (x *TlsRoute_WeightedRouteBackend) GetWeight() uint32
func (*TlsRoute_WeightedRouteBackend) ProtoMessage ¶ added in v0.15.0
func (*TlsRoute_WeightedRouteBackend) ProtoMessage()
func (*TlsRoute_WeightedRouteBackend) ProtoReflect ¶ added in v0.15.0
func (x *TlsRoute_WeightedRouteBackend) ProtoReflect() protoreflect.Message
func (*TlsRoute_WeightedRouteBackend) Reset ¶ added in v0.15.0
func (x *TlsRoute_WeightedRouteBackend) Reset()
func (*TlsRoute_WeightedRouteBackend) String ¶ added in v0.15.0
func (x *TlsRoute_WeightedRouteBackend) String() string
type TrafficSpec ¶
type TrafficSpec struct {
// Uniquely identifies the source proxy workload (e.g., pod name) to the
// control plane.
SourceWorkload string `protobuf:"bytes,1,opt,name=source_workload,json=sourceWorkload,proto3" json:"source_workload,omitempty"`
// Describes a target address, as observed by the proxy.
//
// Types that are valid to be assigned to Target:
//
// *TrafficSpec_Addr
// *TrafficSpec_Authority
Target isTrafficSpec_Target `protobuf_oneof:"target"`
// contains filtered or unexported fields
}
func (*TrafficSpec) Descriptor
deprecated
func (*TrafficSpec) Descriptor() ([]byte, []int)
Deprecated: Use TrafficSpec.ProtoReflect.Descriptor instead.
func (*TrafficSpec) GetAddr ¶
func (x *TrafficSpec) GetAddr() *net.TcpAddress
func (*TrafficSpec) GetAuthority ¶
func (x *TrafficSpec) GetAuthority() string
func (*TrafficSpec) GetSourceWorkload ¶
func (x *TrafficSpec) GetSourceWorkload() string
func (*TrafficSpec) GetTarget ¶
func (x *TrafficSpec) GetTarget() isTrafficSpec_Target
func (*TrafficSpec) ProtoMessage ¶
func (*TrafficSpec) ProtoMessage()
func (*TrafficSpec) ProtoReflect ¶
func (x *TrafficSpec) ProtoReflect() protoreflect.Message
func (*TrafficSpec) Reset ¶
func (x *TrafficSpec) Reset()
func (*TrafficSpec) String ¶
func (x *TrafficSpec) String() string
type TrafficSpec_Addr ¶
type TrafficSpec_Addr struct {
// Indicates the proxy is connecting to a specific IP:port.
Addr *net.TcpAddress `protobuf:"bytes,2,opt,name=addr,proto3,oneof"`
}
type TrafficSpec_Authority ¶
type TrafficSpec_Authority struct {
// Indicates the proxy is connecting to a named address (like an HTTP
// authority).
Authority string `protobuf:"bytes,3,opt,name=authority,proto3,oneof"`
}
type UnimplementedOutboundPoliciesServer ¶
type UnimplementedOutboundPoliciesServer struct{}
UnimplementedOutboundPoliciesServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedOutboundPoliciesServer) Get ¶
func (UnimplementedOutboundPoliciesServer) Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)
type UnsafeOutboundPoliciesServer ¶
type UnsafeOutboundPoliciesServer interface {
// contains filtered or unexported methods
}
UnsafeOutboundPoliciesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OutboundPoliciesServer will result in compilation errors.