outbound

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2023 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 (x *Backend_BalanceP2C) GetPeakEwma() *Backend_BalanceP2C_PeakEwma

func (*Backend_BalanceP2C) ProtoMessage 

func (*Backend_BalanceP2C) ProtoMessage()

func (*Backend_BalanceP2C) ProtoReflect 

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

func (*Backend_BalanceP2C) Reset 

func (x *Backend_BalanceP2C) Reset()

func (*Backend_BalanceP2C) String 

func (x *Backend_BalanceP2C) String() string

type Backend_BalanceP2C_PeakEwma 

type Backend_BalanceP2C_PeakEwma struct {

	// Initial latency value used when no latencies have been
	// recorded for an endpoint.
	DefaultRtt *duration.Duration `protobuf:"bytes,1,opt,name=default_rtt,json=defaultRtt,proto3" json:"default_rtt,omitempty"`
	// The duration of the moving window over which latency is observed.
	Decay *duration.Duration `protobuf:"bytes,2,opt,name=decay,proto3" json:"decay,omitempty"`
	// contains filtered or unexported fields
}

Parameters configuring peak EWMA load estimation.

func (*Backend_BalanceP2C_PeakEwma) Descriptor deprecated 

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

Deprecated: Use Backend_BalanceP2C_PeakEwma.ProtoReflect.Descriptor instead.

func (*Backend_BalanceP2C_PeakEwma) GetDecay 

func (x *Backend_BalanceP2C_PeakEwma) GetDecay() *duration.Duration

func (*Backend_BalanceP2C_PeakEwma) GetDefaultRtt 

func (x *Backend_BalanceP2C_PeakEwma) GetDefaultRtt() *duration.Duration

func (*Backend_BalanceP2C_PeakEwma) ProtoMessage 

func (*Backend_BalanceP2C_PeakEwma) ProtoMessage()

func (*Backend_BalanceP2C_PeakEwma) ProtoReflect 

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

func (*Backend_BalanceP2C_PeakEwma) Reset 

func (x *Backend_BalanceP2C_PeakEwma) Reset()

func (*Backend_BalanceP2C_PeakEwma) String 

func (x *Backend_BalanceP2C_PeakEwma) String() string

type Backend_BalanceP2C_PeakEwma_ 

type Backend_BalanceP2C_PeakEwma_ struct {
	// This load balancer uses peak EWMA (exponentially weighted moving
	// average) load estimates.
	PeakEwma *Backend_BalanceP2C_PeakEwma `protobuf:"bytes,2,opt,name=peak_ewma,json=peakEwma,proto3,oneof"`
}

type Backend_Balancer 

type Backend_Balancer struct {
	// A backend that comprises a load balanced service.
	Balancer *Backend_BalanceP2C `protobuf:"bytes,3,opt,name=balancer,proto3,oneof"`
}

type Backend_EndpointDiscovery 

type Backend_EndpointDiscovery struct {

	// Types that are 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 (x *Backend_EndpointDiscovery) GetDst() *Backend_EndpointDiscovery_DestinationGet

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 (x *Backend_EndpointDiscovery) ProtoReflect() protoreflect.Message

func (*Backend_EndpointDiscovery) Reset 

func (x *Backend_EndpointDiscovery) Reset()

func (*Backend_EndpointDiscovery) String 

func (x *Backend_EndpointDiscovery) String() string

type Backend_EndpointDiscovery_DestinationGet 

type Backend_EndpointDiscovery_DestinationGet struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Backend_EndpointDiscovery_DestinationGet) Descriptor deprecated 

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

Deprecated: Use Backend_EndpointDiscovery_DestinationGet.ProtoReflect.Descriptor instead.

func (*Backend_EndpointDiscovery_DestinationGet) GetPath 

func (x *Backend_EndpointDiscovery_DestinationGet) GetPath() string

func (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage 

func (*Backend_EndpointDiscovery_DestinationGet) ProtoMessage()

func (*Backend_EndpointDiscovery_DestinationGet) ProtoReflect 

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

func (*Backend_EndpointDiscovery_DestinationGet) Reset 

func (x *Backend_EndpointDiscovery_DestinationGet) Reset()

func (*Backend_EndpointDiscovery_DestinationGet) String 

func (x *Backend_EndpointDiscovery_DestinationGet) String() string

type Backend_EndpointDiscovery_Dst 

type Backend_EndpointDiscovery_Dst struct {
	// Use the `Destination` service to discover endpoints for this service.
	Dst *Backend_EndpointDiscovery_DestinationGet `protobuf:"bytes,1,opt,name=dst,proto3,oneof"`
}

type Backend_Forward 

type Backend_Forward struct {
	// A backend that consists of a single endpoint.
	Forward *destination.WeightedAddr `protobuf:"bytes,2,opt,name=forward,proto3,oneof"`
}

type ExponentialBackoff 

type ExponentialBackoff struct {

	// The minimum amount of time to wait before resuming an operation.
	MinBackoff *duration.Duration `protobuf:"bytes,1,opt,name=min_backoff,json=minBackoff,proto3" json:"min_backoff,omitempty"`
	// The maximum amount of time to wait before resuming an operation.
	// Must be greater than or equal to min_backoff.
	MaxBackoff *duration.Duration `protobuf:"bytes,2,opt,name=max_backoff,json=maxBackoff,proto3" json:"max_backoff,omitempty"`
	// The ratio of the base timeout that may be randomly added to a backoff.
	// Must be greater than or equal to 0.0.
	JitterRatio float32 `protobuf:"fixed32,3,opt,name=jitter_ratio,json=jitterRatio,proto3" json:"jitter_ratio,omitempty"`
	// contains filtered or unexported fields
}

func (*ExponentialBackoff) Descriptor deprecated 

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

Deprecated: Use ExponentialBackoff.ProtoReflect.Descriptor instead.

func (*ExponentialBackoff) GetJitterRatio 

func (x *ExponentialBackoff) GetJitterRatio() float32

func (*ExponentialBackoff) GetMaxBackoff 

func (x *ExponentialBackoff) GetMaxBackoff() *duration.Duration

func (*ExponentialBackoff) GetMinBackoff 

func (x *ExponentialBackoff) GetMinBackoff() *duration.Duration

func (*ExponentialBackoff) ProtoMessage 

func (*ExponentialBackoff) ProtoMessage()

func (*ExponentialBackoff) ProtoReflect 

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

func (*ExponentialBackoff) Reset 

func (x *ExponentialBackoff) Reset()

func (*ExponentialBackoff) String 

func (x *ExponentialBackoff) String() string

type FailureAccrual 

type FailureAccrual struct {

	// Types that are 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 (x *FailureAccrual_ConsecutiveFailures) GetBackoff() *ExponentialBackoff

func (*FailureAccrual_ConsecutiveFailures) GetMaxFailures 

func (x *FailureAccrual_ConsecutiveFailures) GetMaxFailures() uint32

func (*FailureAccrual_ConsecutiveFailures) ProtoMessage 

func (*FailureAccrual_ConsecutiveFailures) ProtoMessage()

func (*FailureAccrual_ConsecutiveFailures) ProtoReflect 

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

func (*FailureAccrual_ConsecutiveFailures) Reset 

func (x *FailureAccrual_ConsecutiveFailures) Reset()

func (*FailureAccrual_ConsecutiveFailures) String 

func (x *FailureAccrual_ConsecutiveFailures) String() string

type FailureAccrual_ConsecutiveFailures_ 

type FailureAccrual_ConsecutiveFailures_ struct {
	ConsecutiveFailures *FailureAccrual_ConsecutiveFailures `protobuf:"bytes,1,opt,name=consecutive_failures,json=consecutiveFailures,proto3,oneof"`
}

type GrpcRoute 

type GrpcRoute struct {
	Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// If empty, the host value is ignored.
	Hosts []*http_route.HostMatch `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Must have at least one rule.
	Rules []*GrpcRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcRoute) Descriptor deprecated 

func (*GrpcRoute) 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 (x *GrpcRoute_Distribution) GetEmpty() *GrpcRoute_Distribution_Empty

func (*GrpcRoute_Distribution) GetFirstAvailable 

func (x *GrpcRoute_Distribution) GetFirstAvailable() *GrpcRoute_Distribution_FirstAvailable

func (*GrpcRoute_Distribution) GetKind 

func (m *GrpcRoute_Distribution) GetKind() isGrpcRoute_Distribution_Kind

func (*GrpcRoute_Distribution) GetRandomAvailable 

func (x *GrpcRoute_Distribution) GetRandomAvailable() *GrpcRoute_Distribution_RandomAvailable

func (*GrpcRoute_Distribution) ProtoMessage 

func (*GrpcRoute_Distribution) ProtoMessage()

func (*GrpcRoute_Distribution) ProtoReflect 

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

func (*GrpcRoute_Distribution) Reset 

func (x *GrpcRoute_Distribution) Reset()

func (*GrpcRoute_Distribution) String 

func (x *GrpcRoute_Distribution) String() string

type GrpcRoute_Distribution_Empty 

type GrpcRoute_Distribution_Empty struct {
	// contains filtered or unexported fields
}

func (*GrpcRoute_Distribution_Empty) Descriptor deprecated 

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

Deprecated: Use GrpcRoute_Distribution_Empty.ProtoReflect.Descriptor instead.

func (*GrpcRoute_Distribution_Empty) ProtoMessage 

func (*GrpcRoute_Distribution_Empty) ProtoMessage()

func (*GrpcRoute_Distribution_Empty) ProtoReflect 

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

func (*GrpcRoute_Distribution_Empty) Reset 

func (x *GrpcRoute_Distribution_Empty) Reset()

func (*GrpcRoute_Distribution_Empty) String 

func (x *GrpcRoute_Distribution_Empty) String() string

type GrpcRoute_Distribution_Empty_ 

type GrpcRoute_Distribution_Empty_ struct {
	Empty *GrpcRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}

type GrpcRoute_Distribution_FirstAvailable 

type GrpcRoute_Distribution_FirstAvailable struct {
	Backends []*GrpcRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcRoute_Distribution_FirstAvailable) Descriptor deprecated 

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

Deprecated: Use GrpcRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.

func (*GrpcRoute_Distribution_FirstAvailable) GetBackends 

func (x *GrpcRoute_Distribution_FirstAvailable) GetBackends() []*GrpcRoute_RouteBackend

func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage 

func (*GrpcRoute_Distribution_FirstAvailable) ProtoMessage()

func (*GrpcRoute_Distribution_FirstAvailable) ProtoReflect 

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

func (*GrpcRoute_Distribution_FirstAvailable) Reset 

func (x *GrpcRoute_Distribution_FirstAvailable) Reset()

func (*GrpcRoute_Distribution_FirstAvailable) String 

func (x *GrpcRoute_Distribution_FirstAvailable) String() string

type GrpcRoute_Distribution_FirstAvailable_ 

type GrpcRoute_Distribution_FirstAvailable_ struct {
	// Use the first available backend in the list.
	FirstAvailable *GrpcRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}

type GrpcRoute_Distribution_RandomAvailable 

type GrpcRoute_Distribution_RandomAvailable struct {
	Backends []*GrpcRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcRoute_Distribution_RandomAvailable) Descriptor deprecated 

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

Deprecated: Use GrpcRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.

func (*GrpcRoute_Distribution_RandomAvailable) GetBackends 

func (x *GrpcRoute_Distribution_RandomAvailable) GetBackends() []*GrpcRoute_WeightedRouteBackend

func (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage 

func (*GrpcRoute_Distribution_RandomAvailable) ProtoMessage()

func (*GrpcRoute_Distribution_RandomAvailable) ProtoReflect 

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

func (*GrpcRoute_Distribution_RandomAvailable) Reset 

func (x *GrpcRoute_Distribution_RandomAvailable) Reset()

func (*GrpcRoute_Distribution_RandomAvailable) String 

func (x *GrpcRoute_Distribution_RandomAvailable) String() string

type GrpcRoute_Distribution_RandomAvailable_ 

type GrpcRoute_Distribution_RandomAvailable_ struct {
	RandomAvailable *GrpcRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}

type GrpcRoute_Filter 

type GrpcRoute_Filter struct {

	// Types that are 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 (x *GrpcRoute_WeightedRouteBackend) GetBackend() *GrpcRoute_RouteBackend

func (*GrpcRoute_WeightedRouteBackend) GetWeight 

func (x *GrpcRoute_WeightedRouteBackend) GetWeight() uint32

func (*GrpcRoute_WeightedRouteBackend) ProtoMessage 

func (*GrpcRoute_WeightedRouteBackend) ProtoMessage()

func (*GrpcRoute_WeightedRouteBackend) ProtoReflect 

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

func (*GrpcRoute_WeightedRouteBackend) Reset 

func (x *GrpcRoute_WeightedRouteBackend) Reset()

func (*GrpcRoute_WeightedRouteBackend) String 

func (x *GrpcRoute_WeightedRouteBackend) String() string

type HttpRoute 

type HttpRoute struct {
	Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// If empty, the host value is ignored.
	Hosts []*http_route.HostMatch `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Must have at least one rule.
	Rules []*HttpRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

Outbound-specific HTTP route configuration (based on the [Gateway API]api).

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 (x *HttpRoute_Distribution) GetEmpty() *HttpRoute_Distribution_Empty

func (*HttpRoute_Distribution) GetFirstAvailable 

func (x *HttpRoute_Distribution) GetFirstAvailable() *HttpRoute_Distribution_FirstAvailable

func (*HttpRoute_Distribution) GetKind 

func (m *HttpRoute_Distribution) GetKind() isHttpRoute_Distribution_Kind

func (*HttpRoute_Distribution) GetRandomAvailable 

func (x *HttpRoute_Distribution) GetRandomAvailable() *HttpRoute_Distribution_RandomAvailable

func (*HttpRoute_Distribution) ProtoMessage 

func (*HttpRoute_Distribution) ProtoMessage()

func (*HttpRoute_Distribution) ProtoReflect 

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

func (*HttpRoute_Distribution) Reset 

func (x *HttpRoute_Distribution) Reset()

func (*HttpRoute_Distribution) String 

func (x *HttpRoute_Distribution) String() string

type HttpRoute_Distribution_Empty 

type HttpRoute_Distribution_Empty struct {
	// contains filtered or unexported fields
}

func (*HttpRoute_Distribution_Empty) Descriptor deprecated 

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

Deprecated: Use HttpRoute_Distribution_Empty.ProtoReflect.Descriptor instead.

func (*HttpRoute_Distribution_Empty) ProtoMessage 

func (*HttpRoute_Distribution_Empty) ProtoMessage()

func (*HttpRoute_Distribution_Empty) ProtoReflect 

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

func (*HttpRoute_Distribution_Empty) Reset 

func (x *HttpRoute_Distribution_Empty) Reset()

func (*HttpRoute_Distribution_Empty) String 

func (x *HttpRoute_Distribution_Empty) String() string

type HttpRoute_Distribution_Empty_ 

type HttpRoute_Distribution_Empty_ struct {
	Empty *HttpRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}

type HttpRoute_Distribution_FirstAvailable 

type HttpRoute_Distribution_FirstAvailable struct {
	Backends []*HttpRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpRoute_Distribution_FirstAvailable) Descriptor deprecated 

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

Deprecated: Use HttpRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.

func (*HttpRoute_Distribution_FirstAvailable) GetBackends 

func (x *HttpRoute_Distribution_FirstAvailable) GetBackends() []*HttpRoute_RouteBackend

func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage 

func (*HttpRoute_Distribution_FirstAvailable) ProtoMessage()

func (*HttpRoute_Distribution_FirstAvailable) ProtoReflect 

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

func (*HttpRoute_Distribution_FirstAvailable) Reset 

func (x *HttpRoute_Distribution_FirstAvailable) Reset()

func (*HttpRoute_Distribution_FirstAvailable) String 

func (x *HttpRoute_Distribution_FirstAvailable) String() string

type HttpRoute_Distribution_FirstAvailable_ 

type HttpRoute_Distribution_FirstAvailable_ struct {
	// Use the first available backend in the list.
	FirstAvailable *HttpRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}

type HttpRoute_Distribution_RandomAvailable 

type HttpRoute_Distribution_RandomAvailable struct {
	Backends []*HttpRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpRoute_Distribution_RandomAvailable) Descriptor deprecated 

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

Deprecated: Use HttpRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.

func (*HttpRoute_Distribution_RandomAvailable) GetBackends 

func (x *HttpRoute_Distribution_RandomAvailable) GetBackends() []*HttpRoute_WeightedRouteBackend

func (*HttpRoute_Distribution_RandomAvailable) ProtoMessage 

func (*HttpRoute_Distribution_RandomAvailable) ProtoMessage()

func (*HttpRoute_Distribution_RandomAvailable) ProtoReflect 

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

func (*HttpRoute_Distribution_RandomAvailable) Reset 

func (x *HttpRoute_Distribution_RandomAvailable) Reset()

func (*HttpRoute_Distribution_RandomAvailable) String 

func (x *HttpRoute_Distribution_RandomAvailable) String() string

type HttpRoute_Distribution_RandomAvailable_ 

type HttpRoute_Distribution_RandomAvailable_ struct {
	RandomAvailable *HttpRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}

type HttpRoute_Filter 

type HttpRoute_Filter struct {

	// Types that are 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 (x *HttpRoute_WeightedRouteBackend) GetBackend() *HttpRoute_RouteBackend

func (*HttpRoute_WeightedRouteBackend) GetWeight 

func (x *HttpRoute_WeightedRouteBackend) GetWeight() uint32

func (*HttpRoute_WeightedRouteBackend) ProtoMessage 

func (*HttpRoute_WeightedRouteBackend) ProtoMessage()

func (*HttpRoute_WeightedRouteBackend) ProtoReflect 

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

func (*HttpRoute_WeightedRouteBackend) Reset 

func (x *HttpRoute_WeightedRouteBackend) Reset()

func (*HttpRoute_WeightedRouteBackend) String 

func (x *HttpRoute_WeightedRouteBackend) String() string

type OpaqueRoute 

type OpaqueRoute struct {
	Metadata *meta.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Must have at least one rule.
	Rules []*OpaqueRoute_Rule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*OpaqueRoute) Descriptor deprecated 

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

Deprecated: Use OpaqueRoute.ProtoReflect.Descriptor instead.

func (*OpaqueRoute) GetMetadata 

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

func (*OpaqueRoute) GetRules 

func (x *OpaqueRoute) GetRules() []*OpaqueRoute_Rule

func (*OpaqueRoute) ProtoMessage 

func (*OpaqueRoute) ProtoMessage()

func (*OpaqueRoute) ProtoReflect 

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

func (*OpaqueRoute) Reset 

func (x *OpaqueRoute) Reset()

func (*OpaqueRoute) String 

func (x *OpaqueRoute) String() string

type OpaqueRoute_Distribution 

type OpaqueRoute_Distribution struct {

	// Types that are 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 (x *OpaqueRoute_Distribution) GetEmpty() *OpaqueRoute_Distribution_Empty

func (*OpaqueRoute_Distribution) GetFirstAvailable 

func (x *OpaqueRoute_Distribution) GetFirstAvailable() *OpaqueRoute_Distribution_FirstAvailable

func (*OpaqueRoute_Distribution) GetKind 

func (m *OpaqueRoute_Distribution) GetKind() isOpaqueRoute_Distribution_Kind

func (*OpaqueRoute_Distribution) GetRandomAvailable 

func (x *OpaqueRoute_Distribution) GetRandomAvailable() *OpaqueRoute_Distribution_RandomAvailable

func (*OpaqueRoute_Distribution) ProtoMessage 

func (*OpaqueRoute_Distribution) ProtoMessage()

func (*OpaqueRoute_Distribution) ProtoReflect 

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

func (*OpaqueRoute_Distribution) Reset 

func (x *OpaqueRoute_Distribution) Reset()

func (*OpaqueRoute_Distribution) String 

func (x *OpaqueRoute_Distribution) String() string

type OpaqueRoute_Distribution_Empty 

type OpaqueRoute_Distribution_Empty struct {
	// contains filtered or unexported fields
}

func (*OpaqueRoute_Distribution_Empty) Descriptor deprecated 

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

Deprecated: Use OpaqueRoute_Distribution_Empty.ProtoReflect.Descriptor instead.

func (*OpaqueRoute_Distribution_Empty) ProtoMessage 

func (*OpaqueRoute_Distribution_Empty) ProtoMessage()

func (*OpaqueRoute_Distribution_Empty) ProtoReflect 

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

func (*OpaqueRoute_Distribution_Empty) Reset 

func (x *OpaqueRoute_Distribution_Empty) Reset()

func (*OpaqueRoute_Distribution_Empty) String 

func (x *OpaqueRoute_Distribution_Empty) String() string

type OpaqueRoute_Distribution_Empty_ 

type OpaqueRoute_Distribution_Empty_ struct {
	Empty *OpaqueRoute_Distribution_Empty `protobuf:"bytes,1,opt,name=empty,proto3,oneof"`
}

type OpaqueRoute_Distribution_FirstAvailable 

type OpaqueRoute_Distribution_FirstAvailable struct {
	Backends []*OpaqueRoute_RouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*OpaqueRoute_Distribution_FirstAvailable) Descriptor deprecated 

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

Deprecated: Use OpaqueRoute_Distribution_FirstAvailable.ProtoReflect.Descriptor instead.

func (*OpaqueRoute_Distribution_FirstAvailable) GetBackends 

func (x *OpaqueRoute_Distribution_FirstAvailable) GetBackends() []*OpaqueRoute_RouteBackend

func (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage 

func (*OpaqueRoute_Distribution_FirstAvailable) ProtoMessage()

func (*OpaqueRoute_Distribution_FirstAvailable) ProtoReflect 

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

func (*OpaqueRoute_Distribution_FirstAvailable) Reset 

func (x *OpaqueRoute_Distribution_FirstAvailable) Reset()

func (*OpaqueRoute_Distribution_FirstAvailable) String 

func (x *OpaqueRoute_Distribution_FirstAvailable) String() string

type OpaqueRoute_Distribution_FirstAvailable_ 

type OpaqueRoute_Distribution_FirstAvailable_ struct {
	// Use the first available backend in the list.
	FirstAvailable *OpaqueRoute_Distribution_FirstAvailable `protobuf:"bytes,2,opt,name=first_available,json=firstAvailable,proto3,oneof"`
}

type OpaqueRoute_Distribution_RandomAvailable 

type OpaqueRoute_Distribution_RandomAvailable struct {
	Backends []*OpaqueRoute_WeightedRouteBackend `protobuf:"bytes,1,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*OpaqueRoute_Distribution_RandomAvailable) Descriptor deprecated 

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

Deprecated: Use OpaqueRoute_Distribution_RandomAvailable.ProtoReflect.Descriptor instead.

func (*OpaqueRoute_Distribution_RandomAvailable) GetBackends 

func (x *OpaqueRoute_Distribution_RandomAvailable) GetBackends() []*OpaqueRoute_WeightedRouteBackend

func (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage 

func (*OpaqueRoute_Distribution_RandomAvailable) ProtoMessage()

func (*OpaqueRoute_Distribution_RandomAvailable) ProtoReflect 

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

func (*OpaqueRoute_Distribution_RandomAvailable) Reset 

func (x *OpaqueRoute_Distribution_RandomAvailable) Reset()

func (*OpaqueRoute_Distribution_RandomAvailable) String 

func (x *OpaqueRoute_Distribution_RandomAvailable) String() string

type OpaqueRoute_Distribution_RandomAvailable_ 

type OpaqueRoute_Distribution_RandomAvailable_ struct {
	RandomAvailable *OpaqueRoute_Distribution_RandomAvailable `protobuf:"bytes,3,opt,name=random_available,json=randomAvailable,proto3,oneof"`
}

type OpaqueRoute_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 (x *OpaqueRoute_WeightedRouteBackend) GetBackend() *OpaqueRoute_RouteBackend

func (*OpaqueRoute_WeightedRouteBackend) GetWeight 

func (x *OpaqueRoute_WeightedRouteBackend) GetWeight() uint32

func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage 

func (*OpaqueRoute_WeightedRouteBackend) ProtoMessage()

func (*OpaqueRoute_WeightedRouteBackend) ProtoReflect 

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

func (*OpaqueRoute_WeightedRouteBackend) Reset 

func (x *OpaqueRoute_WeightedRouteBackend) Reset()

func (*OpaqueRoute_WeightedRouteBackend) String 

func (x *OpaqueRoute_WeightedRouteBackend) String() string

type OutboundPoliciesClient 

type OutboundPoliciesClient interface {
	Get(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (*OutboundPolicy, error)
	Watch(ctx context.Context, in *TrafficSpec, opts ...grpc.CallOption) (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.

func NewOutboundPoliciesClient 

func NewOutboundPoliciesClient(cc grpc.ClientConnInterface) OutboundPoliciesClient

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 (x *ProxyProtocol_Detect) GetHttp1() *ProxyProtocol_Http1

func (*ProxyProtocol_Detect) GetHttp2 

func (x *ProxyProtocol_Detect) GetHttp2() *ProxyProtocol_Http2

func (*ProxyProtocol_Detect) GetOpaque 

func (x *ProxyProtocol_Detect) GetOpaque() *ProxyProtocol_Opaque

func (*ProxyProtocol_Detect) GetTimeout 

func (x *ProxyProtocol_Detect) GetTimeout() *duration.Duration

func (*ProxyProtocol_Detect) ProtoMessage 

func (*ProxyProtocol_Detect) ProtoMessage()

func (*ProxyProtocol_Detect) ProtoReflect 

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

func (*ProxyProtocol_Detect) Reset 

func (x *ProxyProtocol_Detect) Reset()

func (*ProxyProtocol_Detect) String 

func (x *ProxyProtocol_Detect) String() string

type ProxyProtocol_Detect_ 

type ProxyProtocol_Detect_ struct {
	Detect *ProxyProtocol_Detect `protobuf:"bytes,1,opt,name=detect,proto3,oneof"`
}

type ProxyProtocol_Grpc 

type ProxyProtocol_Grpc struct {
	Routes []*GrpcRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// If empty, circuit breaking is not performed.
	FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyProtocol_Grpc) Descriptor deprecated 

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

Deprecated: Use ProxyProtocol_Grpc.ProtoReflect.Descriptor instead.

func (*ProxyProtocol_Grpc) GetFailureAccrual 

func (x *ProxyProtocol_Grpc) GetFailureAccrual() *FailureAccrual

func (*ProxyProtocol_Grpc) GetRoutes 

func (x *ProxyProtocol_Grpc) GetRoutes() []*GrpcRoute

func (*ProxyProtocol_Grpc) ProtoMessage 

func (*ProxyProtocol_Grpc) ProtoMessage()

func (*ProxyProtocol_Grpc) ProtoReflect 

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

func (*ProxyProtocol_Grpc) Reset 

func (x *ProxyProtocol_Grpc) Reset()

func (*ProxyProtocol_Grpc) String 

func (x *ProxyProtocol_Grpc) String() string

type ProxyProtocol_Grpc_ 

type ProxyProtocol_Grpc_ struct {
	// gRPC policy configuration.
	Grpc *ProxyProtocol_Grpc `protobuf:"bytes,5,opt,name=grpc,proto3,oneof"`
}

type ProxyProtocol_Http1 

type ProxyProtocol_Http1 struct {
	Routes []*HttpRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// If empty, circuit breaking is not performed.
	FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyProtocol_Http1) Descriptor deprecated 

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

Deprecated: Use ProxyProtocol_Http1.ProtoReflect.Descriptor instead.

func (*ProxyProtocol_Http1) GetFailureAccrual 

func (x *ProxyProtocol_Http1) GetFailureAccrual() *FailureAccrual

func (*ProxyProtocol_Http1) GetRoutes 

func (x *ProxyProtocol_Http1) GetRoutes() []*HttpRoute

func (*ProxyProtocol_Http1) ProtoMessage 

func (*ProxyProtocol_Http1) ProtoMessage()

func (*ProxyProtocol_Http1) ProtoReflect 

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

func (*ProxyProtocol_Http1) Reset 

func (x *ProxyProtocol_Http1) Reset()

func (*ProxyProtocol_Http1) String 

func (x *ProxyProtocol_Http1) String() string

type ProxyProtocol_Http1_ 

type ProxyProtocol_Http1_ struct {
	// HTTP/1 policy configuration.
	Http1 *ProxyProtocol_Http1 `protobuf:"bytes,3,opt,name=http1,proto3,oneof"`
}

type ProxyProtocol_Http2 

type ProxyProtocol_Http2 struct {
	Routes []*HttpRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// If empty, circuit breaking is not performed.
	FailureAccrual *FailureAccrual `protobuf:"bytes,2,opt,name=failure_accrual,json=failureAccrual,proto3" json:"failure_accrual,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyProtocol_Http2) Descriptor deprecated 

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

Deprecated: Use ProxyProtocol_Http2.ProtoReflect.Descriptor instead.

func (*ProxyProtocol_Http2) GetFailureAccrual 

func (x *ProxyProtocol_Http2) GetFailureAccrual() *FailureAccrual

func (*ProxyProtocol_Http2) GetRoutes 

func (x *ProxyProtocol_Http2) GetRoutes() []*HttpRoute

func (*ProxyProtocol_Http2) ProtoMessage 

func (*ProxyProtocol_Http2) ProtoMessage()

func (*ProxyProtocol_Http2) ProtoReflect 

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

func (*ProxyProtocol_Http2) Reset 

func (x *ProxyProtocol_Http2) Reset()

func (*ProxyProtocol_Http2) String 

func (x *ProxyProtocol_Http2) String() string

type ProxyProtocol_Http2_ 

type ProxyProtocol_Http2_ struct {
	// HTTP/2 policy configuration.
	Http2 *ProxyProtocol_Http2 `protobuf:"bytes,4,opt,name=http2,proto3,oneof"`
}

type ProxyProtocol_Opaque 

type ProxyProtocol_Opaque struct {
	Routes []*OpaqueRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyProtocol_Opaque) Descriptor deprecated 

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

Deprecated: Use ProxyProtocol_Opaque.ProtoReflect.Descriptor instead.

func (*ProxyProtocol_Opaque) GetRoutes 

func (x *ProxyProtocol_Opaque) GetRoutes() []*OpaqueRoute

func (*ProxyProtocol_Opaque) ProtoMessage 

func (*ProxyProtocol_Opaque) ProtoMessage()

func (*ProxyProtocol_Opaque) ProtoReflect 

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

func (*ProxyProtocol_Opaque) Reset 

func (x *ProxyProtocol_Opaque) Reset()

func (*ProxyProtocol_Opaque) String 

func (x *ProxyProtocol_Opaque) String() string

type ProxyProtocol_Opaque_ 

type ProxyProtocol_Opaque_ struct {
	Opaque *ProxyProtocol_Opaque `protobuf:"bytes,2,opt,name=opaque,proto3,oneof"`
}

type 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) Get(context.Context, *TrafficSpec) (*OutboundPolicy, error)

func (UnimplementedOutboundPoliciesServer) Watch 

func (UnimplementedOutboundPoliciesServer) Watch(*TrafficSpec, OutboundPolicies_WatchServer) error

type UnsafeOutboundPoliciesServer 

type UnsafeOutboundPoliciesServer interface {
	// contains filtered or unexported methods
}

UnsafeOutboundPoliciesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OutboundPoliciesServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.