outbound

package
v0.13.1 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	OutboundPolicies_Get_FullMethodName   = "/io.linkerd.proxy.outbound.OutboundPolicies/Get"
	OutboundPolicies_Watch_FullMethodName = "/io.linkerd.proxy.outbound.OutboundPolicies/Watch"
)

Variables

View Source
var File_outbound_proto protoreflect.FileDescriptor
View Source
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 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 deprecated

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

Deprecated: Use Backend.ProtoReflect.Descriptor instead.

func (*Backend) GetBalancer

func (x *Backend) GetBalancer() *Backend_BalanceP2C

func (*Backend) GetForward

func (x *Backend) GetForward() *destination.WeightedAddr

func (*Backend) GetKind

func (m *Backend) GetKind() isBackend_Kind

func (*Backend) GetMetadata

func (x *Backend) GetMetadata() *meta.Metadata

func (*Backend) GetQueue

func (x *Backend) GetQueue() *Queue

func (*Backend) ProtoMessage

func (*Backend) ProtoMessage()

func (*Backend) ProtoReflect

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

func (*Backend) Reset

func (x *Backend) Reset()

func (*Backend) String

func (x *Backend) String() string

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 assignable 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 (m *Backend_BalanceP2C) GetLoad() isBackend_BalanceP2C_Load

func (*Backend_BalanceP2C) GetPeakEwma

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 (*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 (*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 assignable 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 (*Backend_EndpointDiscovery) GetKind

func (m *Backend_EndpointDiscovery) GetKind() isBackend_EndpointDiscovery_Kind

func (*Backend_EndpointDiscovery) ProtoMessage

func (*Backend_EndpointDiscovery) ProtoMessage()

func (*Backend_EndpointDiscovery) ProtoReflect

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 (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage

func (*Backend_EndpointDiscovery_DestinationGet) ProtoReflect

func (*Backend_EndpointDiscovery_DestinationGet) Reset

func (*Backend_EndpointDiscovery_DestinationGet) 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 assignable 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 (m *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 (*FailureAccrual_ConsecutiveFailures) GetMaxFailures

func (x *FailureAccrual_ConsecutiveFailures) GetMaxFailures() uint32

func (*FailureAccrual_ConsecutiveFailures) ProtoMessage

func (*FailureAccrual_ConsecutiveFailures) ProtoMessage()

func (*FailureAccrual_ConsecutiveFailures) ProtoReflect

func (*FailureAccrual_ConsecutiveFailures) Reset

func (*FailureAccrual_ConsecutiveFailures) 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) Descriptor() ([]byte, []int)

Deprecated: Use GrpcRoute.ProtoReflect.Descriptor instead.

func (*GrpcRoute) GetHosts

func (x *GrpcRoute) GetHosts() []*http_route.HostMatch

func (*GrpcRoute) GetMetadata

func (x *GrpcRoute) GetMetadata() *meta.Metadata

func (*GrpcRoute) GetRules

func (x *GrpcRoute) GetRules() []*GrpcRoute_Rule

func (*GrpcRoute) ProtoMessage

func (*GrpcRoute) ProtoMessage()

func (*GrpcRoute) ProtoReflect

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

func (*GrpcRoute) Reset

func (x *GrpcRoute) Reset()

func (*GrpcRoute) String

func (x *GrpcRoute) String() string

type GrpcRoute_Distribution

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 deprecated

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

Deprecated: Use GrpcRoute_Distribution.ProtoReflect.Descriptor instead.

func (*GrpcRoute_Distribution) GetEmpty

func (*GrpcRoute_Distribution) GetFirstAvailable

func (*GrpcRoute_Distribution) GetKind

func (m *GrpcRoute_Distribution) GetKind() isGrpcRoute_Distribution_Kind

func (*GrpcRoute_Distribution) GetRandomAvailable

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 (*GrpcRoute_Distribution_Empty) Reset

func (x *GrpcRoute_Distribution_Empty) Reset()

func (*GrpcRoute_Distribution_Empty) 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 (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage

func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage()

func (*GrpcRoute_Distribution_FirstAvailable) ProtoReflect

func (*GrpcRoute_Distribution_FirstAvailable) Reset

func (*GrpcRoute_Distribution_FirstAvailable) 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 (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage

func (*GrpcRoute_Distribution_RandomAvailable) ProtoReflect

func (*GrpcRoute_Distribution_RandomAvailable) Reset

func (*GrpcRoute_Distribution_RandomAvailable) 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 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 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 (m *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_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"`
	// 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 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 added in v0.10.0

func (x *GrpcRoute_RouteBackend) GetRequestTimeout() *duration.Duration

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"`
	// 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 deprecated

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

Deprecated: Use GrpcRoute_Rule.ProtoReflect.Descriptor instead.

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 added in v0.10.0

func (x *GrpcRoute_Rule) GetRequestTimeout() *duration.Duration

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 (*GrpcRoute_WeightedRouteBackend) GetWeight

func (x *GrpcRoute_WeightedRouteBackend) GetWeight() uint32

func (*GrpcRoute_WeightedRouteBackend) ProtoMessage

func (*GrpcRoute_WeightedRouteBackend) ProtoMessage()

func (*GrpcRoute_WeightedRouteBackend) ProtoReflect

func (*GrpcRoute_WeightedRouteBackend) Reset

func (x *GrpcRoute_WeightedRouteBackend) Reset()

func (*GrpcRoute_WeightedRouteBackend) 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) Descriptor() ([]byte, []int)

Deprecated: Use HttpRoute.ProtoReflect.Descriptor instead.

func (*HttpRoute) GetHosts

func (x *HttpRoute) GetHosts() []*http_route.HostMatch

func (*HttpRoute) GetMetadata

func (x *HttpRoute) GetMetadata() *meta.Metadata

func (*HttpRoute) GetRules

func (x *HttpRoute) GetRules() []*HttpRoute_Rule

func (*HttpRoute) ProtoMessage

func (*HttpRoute) ProtoMessage()

func (*HttpRoute) ProtoReflect

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

func (*HttpRoute) Reset

func (x *HttpRoute) Reset()

func (*HttpRoute) String

func (x *HttpRoute) String() string

type HttpRoute_Distribution

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 deprecated

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

Deprecated: Use HttpRoute_Distribution.ProtoReflect.Descriptor instead.

func (*HttpRoute_Distribution) GetEmpty

func (*HttpRoute_Distribution) GetFirstAvailable

func (*HttpRoute_Distribution) GetKind

func (m *HttpRoute_Distribution) GetKind() isHttpRoute_Distribution_Kind

func (*HttpRoute_Distribution) GetRandomAvailable

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 (*HttpRoute_Distribution_Empty) Reset

func (x *HttpRoute_Distribution_Empty) Reset()

func (*HttpRoute_Distribution_Empty) 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 (*HttpRoute_Distribution_FirstAvailable) ProtoMessage

func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage()

func (*HttpRoute_Distribution_FirstAvailable) ProtoReflect

func (*HttpRoute_Distribution_FirstAvailable) Reset

func (*HttpRoute_Distribution_FirstAvailable) 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 (*HttpRoute_Distribution_RandomAvailable) ProtoMessage

func (*HttpRoute_Distribution_RandomAvailable) ProtoReflect

func (*HttpRoute_Distribution_RandomAvailable) Reset

func (*HttpRoute_Distribution_RandomAvailable) 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 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 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 (m *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_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"`
	// 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 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 added in v0.10.0

func (x *HttpRoute_RouteBackend) GetRequestTimeout() *duration.Duration

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"`
	// 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 deprecated

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

Deprecated: Use HttpRoute_Rule.ProtoReflect.Descriptor instead.

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 added in v0.10.0

func (x *HttpRoute_Rule) GetRequestTimeout() *duration.Duration

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 (*HttpRoute_WeightedRouteBackend) GetWeight

func (x *HttpRoute_WeightedRouteBackend) GetWeight() uint32

func (*HttpRoute_WeightedRouteBackend) ProtoMessage

func (*HttpRoute_WeightedRouteBackend) ProtoMessage()

func (*HttpRoute_WeightedRouteBackend) ProtoReflect

func (*HttpRoute_WeightedRouteBackend) Reset

func (x *HttpRoute_WeightedRouteBackend) Reset()

func (*HttpRoute_WeightedRouteBackend) 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 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 deprecated

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

Deprecated: Use OpaqueRoute_Distribution.ProtoReflect.Descriptor instead.

func (*OpaqueRoute_Distribution) GetEmpty

func (*OpaqueRoute_Distribution) GetFirstAvailable

func (*OpaqueRoute_Distribution) GetKind

func (m *OpaqueRoute_Distribution) GetKind() isOpaqueRoute_Distribution_Kind

func (*OpaqueRoute_Distribution) GetRandomAvailable

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 (*OpaqueRoute_Distribution_Empty) Reset

func (x *OpaqueRoute_Distribution_Empty) Reset()

func (*OpaqueRoute_Distribution_Empty) 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 (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage

func (*OpaqueRoute_Distribution_FirstAvailable) ProtoReflect

func (*OpaqueRoute_Distribution_FirstAvailable) Reset

func (*OpaqueRoute_Distribution_FirstAvailable) 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 (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage

func (*OpaqueRoute_Distribution_RandomAvailable) ProtoReflect

func (*OpaqueRoute_Distribution_RandomAvailable) Reset

func (*OpaqueRoute_Distribution_RandomAvailable) 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_RouteBackend

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 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) 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"`
	// 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) 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 (*OpaqueRoute_WeightedRouteBackend) GetWeight

func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage

func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage()

func (*OpaqueRoute_WeightedRouteBackend) ProtoReflect

func (*OpaqueRoute_WeightedRouteBackend) Reset

func (*OpaqueRoute_WeightedRouteBackend) 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) (OutboundPolicies_WatchClient, 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.

type OutboundPoliciesServer

type OutboundPoliciesServer interface {
	Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)
	Watch(*TrafficSpec, OutboundPolicies_WatchServer) 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 interface {
	Recv() (*OutboundPolicy, error)
	grpc.ClientStream
}

type OutboundPolicies_WatchServer

type OutboundPolicies_WatchServer interface {
	Send(*OutboundPolicy) error
	grpc.ServerStream
}

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 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 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 (m *ProxyProtocol) GetKind() isProxyProtocol_Kind

func (*ProxyProtocol) GetOpaque

func (x *ProxyProtocol) GetOpaque() *ProxyProtocol_Opaque

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 (*ProxyProtocol_Detect) GetHttp2

func (*ProxyProtocol_Detect) GetOpaque

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Queue.ProtoReflect.Descriptor instead.

func (*Queue) GetCapacity

func (x *Queue) GetCapacity() uint32

func (*Queue) GetFailfastTimeout

func (x *Queue) GetFailfastTimeout() *duration.Duration

func (*Queue) ProtoMessage

func (*Queue) ProtoMessage()

func (*Queue) ProtoReflect

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

func (*Queue) Reset

func (x *Queue) Reset()

func (*Queue) String

func (x *Queue) 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 assignable 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 (m *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.

func (UnimplementedOutboundPoliciesServer) Get

func (UnimplementedOutboundPoliciesServer) Watch

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL