const (
OutboundPolicies_Get_FullMethodName = "/io.linkerd.proxy.outbound.OutboundPolicies/Get"
OutboundPolicies_Watch_FullMethodName = "/io.linkerd.proxy.outbound.OutboundPolicies/Watch"
)
var File_outbound_proto protoreflect.FileDescriptor
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)
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", }
func RegisterOutboundPoliciesServer(s grpc.ServiceRegistrar, srv OutboundPoliciesServer)
type Backend struct {
Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// Types that are assignable 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() ([]byte, []int)
Deprecated: Use Backend.ProtoReflect.Descriptor instead.
func (x *Backend) GetBalancer() *Backend_BalanceP2C
func (x *Backend) GetForward() *destination.WeightedAddr
func (m *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
Describes a power-of-two-choices (P2C) load balancer configuration for a backend.
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 assignable to Load:
//
// *Backend_BalanceP2C_PeakEwma_
Load isBackend_BalanceP2C_Load `protobuf_oneof:"load"`
// contains filtered or unexported fields
}
func (*Backend_BalanceP2C) Descriptor() ([]byte, []int)
Deprecated: Use Backend_BalanceP2C.ProtoReflect.Descriptor instead.
func (x *Backend_BalanceP2C) GetDiscovery() *Backend_EndpointDiscovery
func (m *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
Parameters configuring peak EWMA load estimation.
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
}
func (*Backend_BalanceP2C_PeakEwma) Descriptor() ([]byte, []int)
Deprecated: Use Backend_BalanceP2C_PeakEwma.ProtoReflect.Descriptor instead.
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_ 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 struct {
// A backend that comprises a load balanced service.
Balancer *Backend_BalanceP2C `protobuf:"bytes,3,opt,name=balancer,proto3,oneof"`
}
A strategy for discovering endpoints for a service.
type Backend_EndpointDiscovery struct {
// Types that are assignable to Kind:
//
// *Backend_EndpointDiscovery_Dst
Kind isBackend_EndpointDiscovery_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*Backend_EndpointDiscovery) Descriptor() ([]byte, []int)
Deprecated: Use Backend_EndpointDiscovery.ProtoReflect.Descriptor instead.
func (x *Backend_EndpointDiscovery) GetDst() *Backend_EndpointDiscovery_DestinationGet
func (m *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 struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
func (*Backend_EndpointDiscovery_DestinationGet) Descriptor() ([]byte, []int)
Deprecated: Use Backend_EndpointDiscovery_DestinationGet.ProtoReflect.Descriptor instead.
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 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 struct {
// A backend that consists of a single endpoint.
Forward *destination.WeightedAddr `protobuf:"bytes,2,opt,name=forward,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ExponentialBackoff.ProtoReflect.Descriptor instead.
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 struct {
// Types that are assignable to Kind:
//
// *FailureAccrual_ConsecutiveFailures_
Kind isFailureAccrual_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*FailureAccrual) Descriptor() ([]byte, []int)
Deprecated: Use FailureAccrual.ProtoReflect.Descriptor instead.
func (x *FailureAccrual) GetConsecutiveFailures() *FailureAccrual_ConsecutiveFailures
func (m *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 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() ([]byte, []int)
Deprecated: Use FailureAccrual_ConsecutiveFailures.ProtoReflect.Descriptor instead.
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_ struct {
ConsecutiveFailures *FailureAccrual_ConsecutiveFailures `protobuf:"bytes,1,opt,name=consecutive_failures,json=consecutiveFailures,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use GrpcRoute.ProtoReflect.Descriptor instead.
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 struct {
// Types that are assignable 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() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution.ProtoReflect.Descriptor instead.
func (x *GrpcRoute_Distribution) GetEmpty() *GrpcRoute_Distribution_Empty
func (x *GrpcRoute_Distribution) GetFirstAvailable() *GrpcRoute_Distribution_FirstAvailable
func (m *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 struct {
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
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_ struct {
Empty *GrpcRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
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_ 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 struct {
Backends []*GrpcRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
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_ struct {
RandomAvailable *GrpcRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type GrpcRoute_Filter struct {
// Types that are assignable to Kind:
//
// *GrpcRoute_Filter_FailureInjector
// *GrpcRoute_Filter_RequestHeaderModifier
Kind isGrpcRoute_Filter_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Filter) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Filter.ProtoReflect.Descriptor instead.
func (x *GrpcRoute_Filter) GetFailureInjector() *grpc_route.GrpcFailureInjector
func (m *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 struct {
FailureInjector *grpc_route.GrpcFailureInjector `protobuf:"bytes,1,opt,name=failure_injector,json=failureInjector,proto3,oneof"`
}
type GrpcRoute_Filter_RequestHeaderModifier struct {
RequestHeaderModifier *http_route.RequestHeaderModifier `protobuf:"bytes,2,opt,name=request_header_modifier,json=requestHeaderModifier,proto3,oneof"`
}
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"`
// After this time has elapsed since a request is dispatched to this
// backend, any request will be cancelled if no response has been received.
// If the request is not retried, a timeout error response is returned.
//
// If this field is empty, no request timeout is applied.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (x *GrpcRoute_RouteBackend) GetBackend() *Backend
func (x *GrpcRoute_RouteBackend) GetFilters() []*GrpcRoute_Filter
func (x *GrpcRoute_RouteBackend) GetRequestTimeout() *duration.Duration
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 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"`
// After this time has elapsed since receiving the initial request, any
// outstanding request will be cancelled if no response has been received.
// If the request is cancelled, a timeout error response will be returned,
// and no more retries will be attempted
//
// If this field is empty, no request timeout is applied.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*GrpcRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use GrpcRoute_Rule.ProtoReflect.Descriptor instead.
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.Duration
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 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() ([]byte, []int)
Deprecated: Use GrpcRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
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
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)).
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
}
func (*HttpRoute) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute.ProtoReflect.Descriptor instead.
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 struct {
// Types that are assignable 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() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution.ProtoReflect.Descriptor instead.
func (x *HttpRoute_Distribution) GetEmpty() *HttpRoute_Distribution_Empty
func (x *HttpRoute_Distribution) GetFirstAvailable() *HttpRoute_Distribution_FirstAvailable
func (m *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 struct {
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
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_ struct {
Empty *HttpRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
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_ 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 struct {
Backends []*HttpRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
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_ struct {
RandomAvailable *HttpRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type HttpRoute_Filter struct {
// Types that are assignable 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() ([]byte, []int)
Deprecated: Use HttpRoute_Filter.ProtoReflect.Descriptor instead.
func (x *HttpRoute_Filter) GetFailureInjector() *http_route.HttpFailureInjector
func (m *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 struct {
FailureInjector *http_route.HttpFailureInjector `protobuf:"bytes,1,opt,name=failure_injector,json=failureInjector,proto3,oneof"`
}
type HttpRoute_Filter_Redirect struct {
Redirect *http_route.RequestRedirect `protobuf:"bytes,3,opt,name=redirect,proto3,oneof"`
}
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 struct {
ResponseHeaderModifier *http_route.ResponseHeaderModifier `protobuf:"bytes,4,opt,name=response_header_modifier,json=responseHeaderModifier,proto3,oneof"`
}
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"`
// After this time has elapsed since a request is dispatched to this
// backend, any request will be cancelled if no response has been received.
// If the request is not retried, a timeout error response is returned.
//
// If this field is empty, no request timeout is applied.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (x *HttpRoute_RouteBackend) GetBackend() *Backend
func (x *HttpRoute_RouteBackend) GetFilters() []*HttpRoute_Filter
func (x *HttpRoute_RouteBackend) GetRequestTimeout() *duration.Duration
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 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"`
// After this time has elapsed since receiving the initial request, any
// outstanding request will be cancelled if no response has been received.
// If the request is cancelled, a timeout error response will be returned,
// and no more retries will be attempted
//
// If this field is empty, no request timeout is applied.
RequestTimeout *duration.Duration `protobuf:"bytes,4,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*HttpRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use HttpRoute_Rule.ProtoReflect.Descriptor instead.
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.Duration
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 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() ([]byte, []int)
Deprecated: Use HttpRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
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 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() ([]byte, []int)
Deprecated: Use OpaqueRoute.ProtoReflect.Descriptor instead.
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 struct {
// Types that are assignable 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() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution.ProtoReflect.Descriptor instead.
func (x *OpaqueRoute_Distribution) GetEmpty() *OpaqueRoute_Distribution_Empty
func (x *OpaqueRoute_Distribution) GetFirstAvailable() *OpaqueRoute_Distribution_FirstAvailable
func (m *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 struct {
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution_Empty) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_Empty.ProtoReflect.Descriptor instead.
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_ struct {
Empty *OpaqueRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.
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_ 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 struct {
Backends []*OpaqueRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Distribution_RandomAvailable) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.
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_ struct {
RandomAvailable *OpaqueRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}
type OpaqueRoute_RouteBackend struct {
Backend *Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_RouteBackend) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_RouteBackend.ProtoReflect.Descriptor instead.
func (x *OpaqueRoute_RouteBackend) GetBackend() *Backend
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 struct {
Backends *OpaqueRoute_Distribution `protobuf:"bytes,1,opt,name=backends,proto3" json:"backends,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueRoute_Rule) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueRoute_Rule.ProtoReflect.Descriptor instead.
func (x *OpaqueRoute_Rule) GetBackends() *OpaqueRoute_Distribution
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 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() ([]byte, []int)
Deprecated: Use OpaqueRoute_WeightedRouteBackend.ProtoReflect.Descriptor instead.
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
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.
type OutboundPoliciesClient interface {
Get(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (*OutboundPolicy, error)
Watch(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (OutboundPolicies_WatchClient, error)
}
func NewOutboundPoliciesClient(cc grpc.ClientConnInterface) OutboundPoliciesClient
OutboundPoliciesServer is the server API for OutboundPolicies service. All implementations must embed UnimplementedOutboundPoliciesServer for forward compatibility
type OutboundPoliciesServer interface {
Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)
Watch(*TrafficSpec, OutboundPolicies_WatchServer) error
// contains filtered or unexported methods
}
type OutboundPolicies_WatchClient interface {
Recv() (*OutboundPolicy, error)
grpc.ClientStream
}
type OutboundPolicies_WatchServer interface {
Send(*OutboundPolicy) error
grpc.ServerStream
}
Outbound policy for a given traffic spec.
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
}
func (*OutboundPolicy) Descriptor() ([]byte, []int)
Deprecated: Use OutboundPolicy.ProtoReflect.Descriptor instead.
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 struct {
// Types that are assignable to Kind:
//
// *ProxyProtocol_Detect_
// *ProxyProtocol_Opaque_
// *ProxyProtocol_Http1_
// *ProxyProtocol_Http2_
// *ProxyProtocol_Grpc_
Kind isProxyProtocol_Kind `protobuf_oneof:"kind"`
// contains filtered or unexported fields
}
func (*ProxyProtocol) Descriptor() ([]byte, []int)
Deprecated: Use ProxyProtocol.ProtoReflect.Descriptor instead.
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 (m *ProxyProtocol) GetKind() isProxyProtocol_Kind
func (x *ProxyProtocol) GetOpaque() *ProxyProtocol_Opaque
func (*ProxyProtocol) ProtoMessage()
func (x *ProxyProtocol) ProtoReflect() protoreflect.Message
func (x *ProxyProtocol) Reset()
func (x *ProxyProtocol) String() string
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() ([]byte, []int)
Deprecated: Use ProxyProtocol_Detect.ProtoReflect.Descriptor instead.
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_ struct {
Detect *ProxyProtocol_Detect `protobuf:"bytes,1,opt,name=detect,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ProxyProtocol_Grpc.ProtoReflect.Descriptor instead.
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_ struct {
// gRPC policy configuration.
Grpc *ProxyProtocol_Grpc `protobuf:"bytes,5,opt,name=grpc,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ProxyProtocol_Http1.ProtoReflect.Descriptor instead.
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_ struct {
// HTTP/1 policy configuration.
Http1 *ProxyProtocol_Http1 `protobuf:"bytes,3,opt,name=http1,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ProxyProtocol_Http2.ProtoReflect.Descriptor instead.
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_ struct {
// HTTP/2 policy configuration.
Http2 *ProxyProtocol_Http2 `protobuf:"bytes,4,opt,name=http2,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ProxyProtocol_Opaque.ProtoReflect.Descriptor instead.
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_ struct {
Opaque *ProxyProtocol_Opaque `protobuf:"bytes,2,opt,name=opaque,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use Queue.ProtoReflect.Descriptor instead.
func (x *Queue) GetCapacity() uint32
func (x *Queue) GetFailfastTimeout() *duration.Duration
func (*Queue) ProtoMessage()
func (x *Queue) ProtoReflect() protoreflect.Message
func (x *Queue) Reset()
func (x *Queue) String() string
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 assignable to Target:
//
// *TrafficSpec_Addr
// *TrafficSpec_Authority
Target isTrafficSpec_Target `protobuf_oneof:"target"`
// contains filtered or unexported fields
}
func (*TrafficSpec) Descriptor() ([]byte, []int)
Deprecated: Use TrafficSpec.ProtoReflect.Descriptor instead.
func (x *TrafficSpec) GetAddr() *net.TcpAddress
func (x *TrafficSpec) GetAuthority() string
func (x *TrafficSpec) GetSourceWorkload() string
func (m *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 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 struct {
// Indicates the proxy is connecting to a named address (like an HTTP
// authority).
Authority string `protobuf:"bytes,3,opt,name=authority,proto3,oneof"`
}
UnimplementedOutboundPoliciesServer must be embedded to have forward compatible implementations.
type UnimplementedOutboundPoliciesServer struct {
}
func (UnimplementedOutboundPoliciesServer) Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)
func (UnimplementedOutboundPoliciesServer) Watch(*TrafficSpec, OutboundPolicies_WatchServer) error
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.
type UnsafeOutboundPoliciesServer interface {
// contains filtered or unexported methods
}