destination

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 12 Imported by: 75

Documentation

Index

Constants

View Source 
const (
	Destination_Get_FullMethodName        = "/io.linkerd.proxy.destination.Destination/Get"
	Destination_GetProfile_FullMethodName = "/io.linkerd.proxy.destination.Destination/GetProfile"
)

Variables

View Source 
var Destination_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.linkerd.proxy.destination.Destination",
	HandlerType: (*DestinationServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Get",
			Handler:       _Destination_Get_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetProfile",
			Handler:       _Destination_GetProfile_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "destination.proto",
}

Destination_ServiceDesc is the grpc.ServiceDesc for Destination service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_destination_proto protoreflect.FileDescriptor

Functions

func RegisterDestinationServer 

func RegisterDestinationServer(s grpc.ServiceRegistrar, srv DestinationServer)

Types

type AddrSet 

type AddrSet struct {
	Addrs []*net.TcpAddress `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*AddrSet) Descriptor deprecated 

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

Deprecated: Use AddrSet.ProtoReflect.Descriptor instead.

func (*AddrSet) GetAddrs 

func (x *AddrSet) GetAddrs() []*net.TcpAddress

func (*AddrSet) ProtoMessage 

func (*AddrSet) ProtoMessage()

func (*AddrSet) ProtoReflect added in v0.1.13 

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

func (*AddrSet) Reset 

func (x *AddrSet) Reset()

func (*AddrSet) String 

func (x *AddrSet) String() string

type AuthorityOverride added in v0.1.12 

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

func (*AuthorityOverride) Descriptor deprecated added in v0.1.12 

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

Deprecated: Use AuthorityOverride.ProtoReflect.Descriptor instead.

func (*AuthorityOverride) GetAuthorityOverride added in v0.1.12 

func (x *AuthorityOverride) GetAuthorityOverride() string

func (*AuthorityOverride) ProtoMessage added in v0.1.12 

func (*AuthorityOverride) ProtoMessage()

func (*AuthorityOverride) ProtoReflect added in v0.1.13 

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

func (*AuthorityOverride) Reset added in v0.1.12 

func (x *AuthorityOverride) Reset()

func (*AuthorityOverride) String added in v0.1.12 

func (x *AuthorityOverride) String() string

type DestinationClient 

type DestinationClient interface {
	// Given a destination, return all addresses in that destination as a long-
	// running stream of updates.
	Get(ctx context.Context, in *GetDestination, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Update], error)
	// Given a destination, return that destination's profile and send an update
	// whenever it changes.
	GetProfile(ctx context.Context, in *GetDestination, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DestinationProfile], error)
}

DestinationClient is the client API for Destination 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 NewDestinationClient 

func NewDestinationClient(cc grpc.ClientConnInterface) DestinationClient

type DestinationProfile added in v0.1.2 

type DestinationProfile struct {

	// The fully-qualified service name, if one exists.
	//
	// When resolving (especially by IP), this field provides the fully-qualified
	// name of the resolved service, if one exists. This field does NOT include
	// any port information. E.g. a lookup for 10.2.3.4:8080 might have a name
	// like `foo.bar.svc.cluster.local`.
	//
	// Implementations MAY provide names for non-service IP-lookups (e.g., pod or
	// node dns names), but this is not required.
	//
	// If the lookup does not refer to a known named entity, this field MUST be
	// left empty.
	FullyQualifiedName string `protobuf:"bytes,5,opt,name=fully_qualified_name,json=fullyQualifiedName,proto3" json:"fully_qualified_name,omitempty"`
	// Indicates that connections on this service address should be handled as
	// opaque TCP streams. HTTP routes returned on for such services will be
	// ignored.
	OpaqueProtocol bool `protobuf:"varint,4,opt,name=opaque_protocol,json=opaqueProtocol,proto3" json:"opaque_protocol,omitempty"`
	// A list of routes, each with a RequestMatch.  If a request matches
	// more than one route, the first match wins.
	Routes []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// The retry budget controls how much additional load the proxy can generate
	// as retries. Failured requests on retryable routes will not be retried if
	// there is no available budget.
	RetryBudget *RetryBudget `protobuf:"bytes,2,opt,name=retry_budget,json=retryBudget,proto3" json:"retry_budget,omitempty"`
	// If this list is non-empty, requests to this destination should instead be
	// split between the destinations in this list.  Each destination should
	// receive a portion of the requests proportional to its weight.  If this
	// list is empty, requests should be sent to this destination as normal.
	DstOverrides []*WeightedDst `protobuf:"bytes,3,rep,name=dst_overrides,json=dstOverrides,proto3" json:"dst_overrides,omitempty"`
	// If this field is set, it indicates that the target is a known endpoint (and
	// not a service address). The values of `fully_qualified_name` and
	// `dst_overrides` will be ignored for the purposes of service discovery--
	// traffic split and load balancing will be skipped and the single endpoint
	// are used.
	//
	// No endpoint should be set If the target is unknown.
	Endpoint *WeightedAddr `protobuf:"bytes,6,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// A reference to the metadata for this destination, usually a service. May be
	// omitted if the destination is not a service.
	ParentRef *meta.Metadata `protobuf:"bytes,7,opt,name=parent_ref,json=parentRef,proto3" json:"parent_ref,omitempty"`
	// A reference to the metadata for a ServiceProfile resource. This is omitted
	// when no ServiceProfile resource exists.
	ProfileRef *meta.Metadata `protobuf:"bytes,8,opt,name=profile_ref,json=profileRef,proto3" json:"profile_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*DestinationProfile) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use DestinationProfile.ProtoReflect.Descriptor instead.

func (*DestinationProfile) GetDstOverrides added in v0.1.9 

func (x *DestinationProfile) GetDstOverrides() []*WeightedDst

func (*DestinationProfile) GetEndpoint added in v0.1.15 

func (x *DestinationProfile) GetEndpoint() *WeightedAddr

func (*DestinationProfile) GetFullyQualifiedName added in v0.1.14 

func (x *DestinationProfile) GetFullyQualifiedName() string

func (*DestinationProfile) GetOpaqueProtocol added in v0.1.14 

func (x *DestinationProfile) GetOpaqueProtocol() bool

func (*DestinationProfile) GetParentRef added in v0.15.0 

func (x *DestinationProfile) GetParentRef() *meta.Metadata

func (*DestinationProfile) GetProfileRef added in v0.15.0 

func (x *DestinationProfile) GetProfileRef() *meta.Metadata

func (*DestinationProfile) GetRetryBudget added in v0.1.5 

func (x *DestinationProfile) GetRetryBudget() *RetryBudget

func (*DestinationProfile) GetRoutes added in v0.1.2 

func (x *DestinationProfile) GetRoutes() []*Route

func (*DestinationProfile) ProtoMessage added in v0.1.2 

func (*DestinationProfile) ProtoMessage()

func (*DestinationProfile) ProtoReflect added in v0.1.13 

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

func (*DestinationProfile) Reset added in v0.1.2 

func (x *DestinationProfile) Reset()

func (*DestinationProfile) String added in v0.1.2 

func (x *DestinationProfile) String() string

type DestinationServer 

type DestinationServer interface {
	// Given a destination, return all addresses in that destination as a long-
	// running stream of updates.
	Get(*GetDestination, grpc.ServerStreamingServer[Update]) error
	// Given a destination, return that destination's profile and send an update
	// whenever it changes.
	GetProfile(*GetDestination, grpc.ServerStreamingServer[DestinationProfile]) error
	// contains filtered or unexported methods
}

DestinationServer is the server API for Destination service. All implementations must embed UnimplementedDestinationServer for forward compatibility.

type Destination_GetClient 

type Destination_GetClient = grpc.ServerStreamingClient[Update]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Destination_GetProfileClient added in v0.1.2 

type Destination_GetProfileClient = grpc.ServerStreamingClient[DestinationProfile]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Destination_GetProfileServer added in v0.1.2 

type Destination_GetProfileServer = grpc.ServerStreamingServer[DestinationProfile]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Destination_GetServer 

type Destination_GetServer = grpc.ServerStreamingServer[Update]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GetDestination 

type GetDestination struct {
	Scheme string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// An opaque value that is set at injection-time and sent with destintion
	// lookups.
	//
	// If, for instance, the token encodes a namespace or some locality
	// information, the service may alter its results to take this locality into
	// account.
	ContextToken string `protobuf:"bytes,3,opt,name=context_token,json=contextToken,proto3" json:"context_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDestination) Descriptor deprecated 

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

Deprecated: Use GetDestination.ProtoReflect.Descriptor instead.

func (*GetDestination) GetContextToken added in v0.1.7 

func (x *GetDestination) GetContextToken() string

func (*GetDestination) GetPath 

func (x *GetDestination) GetPath() string

func (*GetDestination) GetScheme 

func (x *GetDestination) GetScheme() string

func (*GetDestination) ProtoMessage 

func (*GetDestination) ProtoMessage()

func (*GetDestination) ProtoReflect added in v0.1.13 

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

func (*GetDestination) Reset 

func (x *GetDestination) Reset()

func (*GetDestination) String 

func (x *GetDestination) String() string

type Http2ClientParams added in v0.13.1 

type Http2ClientParams struct {

	// Overrides the default client flow control settings.
	FlowControl *Http2ClientParams_FlowControl `protobuf:"bytes,1,opt,name=flow_control,json=flowControl,proto3" json:"flow_control,omitempty"`
	// Enables keep-alive timeouts.
	KeepAlive *Http2ClientParams_KeepAlive `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3" json:"keep_alive,omitempty"`
	// Configures Hyper internals.
	Internals *Http2ClientParams_Internals `protobuf:"bytes,3,opt,name=internals,proto3" json:"internals,omitempty"`
	// contains filtered or unexported fields
}

Configures the parameters used to initialize an HTTP/2 connection.

func (*Http2ClientParams) Descriptor deprecated added in v0.13.1 

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

Deprecated: Use Http2ClientParams.ProtoReflect.Descriptor instead.

func (*Http2ClientParams) GetFlowControl added in v0.13.1 

func (x *Http2ClientParams) GetFlowControl() *Http2ClientParams_FlowControl

func (*Http2ClientParams) GetInternals added in v0.13.1 

func (x *Http2ClientParams) GetInternals() *Http2ClientParams_Internals

func (*Http2ClientParams) GetKeepAlive added in v0.13.1 

func (x *Http2ClientParams) GetKeepAlive() *Http2ClientParams_KeepAlive

func (*Http2ClientParams) ProtoMessage added in v0.13.1 

func (*Http2ClientParams) ProtoMessage()

func (*Http2ClientParams) ProtoReflect added in v0.13.1 

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

func (*Http2ClientParams) Reset added in v0.13.1 

func (x *Http2ClientParams) Reset()

func (*Http2ClientParams) String added in v0.13.1 

func (x *Http2ClientParams) String() string

type Http2ClientParams_FlowControl added in v0.13.1 

type Http2ClientParams_FlowControl struct {

	// Configures the maximum connection-level flow control window size.
	InitialConnectionWindowSize uint32 `` /* 147-byte string literal not displayed */
	// Configures the maximum stream-level flow control window size.
	InitialStreamWindowSize uint32 `` /* 135-byte string literal not displayed */
	// Enables Hyper's adaptive flow control, ignoring other window settings.
	AdaptiveFlowControl bool `protobuf:"varint,3,opt,name=adaptive_flow_control,json=adaptiveFlowControl,proto3" json:"adaptive_flow_control,omitempty"`
	// contains filtered or unexported fields
}

func (*Http2ClientParams_FlowControl) Descriptor deprecated added in v0.13.1 

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

Deprecated: Use Http2ClientParams_FlowControl.ProtoReflect.Descriptor instead.

func (*Http2ClientParams_FlowControl) GetAdaptiveFlowControl added in v0.13.1 

func (x *Http2ClientParams_FlowControl) GetAdaptiveFlowControl() bool

func (*Http2ClientParams_FlowControl) GetInitialConnectionWindowSize added in v0.13.1 

func (x *Http2ClientParams_FlowControl) GetInitialConnectionWindowSize() uint32

func (*Http2ClientParams_FlowControl) GetInitialStreamWindowSize added in v0.13.1 

func (x *Http2ClientParams_FlowControl) GetInitialStreamWindowSize() uint32

func (*Http2ClientParams_FlowControl) ProtoMessage added in v0.13.1 

func (*Http2ClientParams_FlowControl) ProtoMessage()

func (*Http2ClientParams_FlowControl) ProtoReflect added in v0.13.1 

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

func (*Http2ClientParams_FlowControl) Reset added in v0.13.1 

func (x *Http2ClientParams_FlowControl) Reset()

func (*Http2ClientParams_FlowControl) String added in v0.13.1 

func (x *Http2ClientParams_FlowControl) String() string

type Http2ClientParams_Internals added in v0.13.1 

type Http2ClientParams_Internals struct {
	MaxConcurrentResetStreams uint32 `` /* 141-byte string literal not displayed */
	MaxFrameSize              uint32 `protobuf:"varint,2,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`
	MaxSendBufSize            uint32 `protobuf:"varint,3,opt,name=max_send_buf_size,json=maxSendBufSize,proto3" json:"max_send_buf_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Http2ClientParams_Internals) Descriptor deprecated added in v0.13.1 

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

Deprecated: Use Http2ClientParams_Internals.ProtoReflect.Descriptor instead.

func (*Http2ClientParams_Internals) GetMaxConcurrentResetStreams added in v0.13.1 

func (x *Http2ClientParams_Internals) GetMaxConcurrentResetStreams() uint32

func (*Http2ClientParams_Internals) GetMaxFrameSize added in v0.13.1 

func (x *Http2ClientParams_Internals) GetMaxFrameSize() uint32

func (*Http2ClientParams_Internals) GetMaxSendBufSize added in v0.13.1 

func (x *Http2ClientParams_Internals) GetMaxSendBufSize() uint32

func (*Http2ClientParams_Internals) ProtoMessage added in v0.13.1 

func (*Http2ClientParams_Internals) ProtoMessage()

func (*Http2ClientParams_Internals) ProtoReflect added in v0.13.1 

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

func (*Http2ClientParams_Internals) Reset added in v0.13.1 

func (x *Http2ClientParams_Internals) Reset()

func (*Http2ClientParams_Internals) String added in v0.13.1 

func (x *Http2ClientParams_Internals) String() string

type Http2ClientParams_KeepAlive added in v0.13.1 

type Http2ClientParams_KeepAlive struct {

	// The time between pings.
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// The time to wait for a ping response before considering the connection
	// dead.
	Timeout *duration.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Whether to send pings when there is no other traffic.
	WhileIdle bool `protobuf:"varint,3,opt,name=while_idle,json=whileIdle,proto3" json:"while_idle,omitempty"`
	// contains filtered or unexported fields
}

func (*Http2ClientParams_KeepAlive) Descriptor deprecated added in v0.13.1 

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

Deprecated: Use Http2ClientParams_KeepAlive.ProtoReflect.Descriptor instead.

func (*Http2ClientParams_KeepAlive) GetInterval added in v0.13.1 

func (x *Http2ClientParams_KeepAlive) GetInterval() *duration.Duration

func (*Http2ClientParams_KeepAlive) GetTimeout added in v0.13.1 

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

func (*Http2ClientParams_KeepAlive) GetWhileIdle added in v0.13.1 

func (x *Http2ClientParams_KeepAlive) GetWhileIdle() bool

func (*Http2ClientParams_KeepAlive) ProtoMessage added in v0.13.1 

func (*Http2ClientParams_KeepAlive) ProtoMessage()

func (*Http2ClientParams_KeepAlive) ProtoReflect added in v0.13.1 

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

func (*Http2ClientParams_KeepAlive) Reset added in v0.13.1 

func (x *Http2ClientParams_KeepAlive) Reset()

func (*Http2ClientParams_KeepAlive) String added in v0.13.1 

func (x *Http2ClientParams_KeepAlive) String() string

type HttpStatusRange added in v0.1.2 

type HttpStatusRange struct {

	// Minimum matching http status code (inclusive), if specified.
	Min uint32 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	// Maximum matching http status code (inclusive), if specified.
	Max uint32 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

If either a minimum or maximum is not specified, the range is considered to be over a discrete value.

func (*HttpStatusRange) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use HttpStatusRange.ProtoReflect.Descriptor instead.

func (*HttpStatusRange) GetMax added in v0.1.2 

func (x *HttpStatusRange) GetMax() uint32

func (*HttpStatusRange) GetMin added in v0.1.2 

func (x *HttpStatusRange) GetMin() uint32

func (*HttpStatusRange) ProtoMessage added in v0.1.2 

func (*HttpStatusRange) ProtoMessage()

func (*HttpStatusRange) ProtoReflect added in v0.1.13 

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

func (*HttpStatusRange) Reset added in v0.1.2 

func (x *HttpStatusRange) Reset()

func (*HttpStatusRange) String added in v0.1.2 

func (x *HttpStatusRange) String() string

type NoEndpoints 

type NoEndpoints struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*NoEndpoints) Descriptor deprecated 

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

Deprecated: Use NoEndpoints.ProtoReflect.Descriptor instead.

func (*NoEndpoints) GetExists 

func (x *NoEndpoints) GetExists() bool

func (*NoEndpoints) ProtoMessage 

func (*NoEndpoints) ProtoMessage()

func (*NoEndpoints) ProtoReflect added in v0.1.13 

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

func (*NoEndpoints) Reset 

func (x *NoEndpoints) Reset()

func (*NoEndpoints) String 

func (x *NoEndpoints) String() string

type PathMatch added in v0.1.2 

type PathMatch struct {

	// Match if the request path matches this regex.
	Regex string `protobuf:"bytes,1,opt,name=regex,proto3" json:"regex,omitempty"`
	// contains filtered or unexported fields
}

func (*PathMatch) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use PathMatch.ProtoReflect.Descriptor instead.

func (*PathMatch) GetRegex added in v0.1.2 

func (x *PathMatch) GetRegex() string

func (*PathMatch) ProtoMessage added in v0.1.2 

func (*PathMatch) ProtoMessage()

func (*PathMatch) ProtoReflect added in v0.1.13 

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

func (*PathMatch) Reset added in v0.1.2 

func (x *PathMatch) Reset()

func (*PathMatch) String added in v0.1.2 

func (x *PathMatch) String() string

type ProtocolHint 

type ProtocolHint struct {

	// Types that are assignable to Protocol:
	//
	//	*ProtocolHint_H2_
	//	*ProtocolHint_Opaque_
	Protocol isProtocolHint_Protocol `protobuf_oneof:"protocol"`
	// When set, indicates that the target supports receiving opaque traffic
	// wrapped with the Linkerd connection header on the specified port.
	OpaqueTransport *ProtocolHint_OpaqueTransport `protobuf:"bytes,2,opt,name=opaque_transport,json=opaqueTransport,proto3" json:"opaque_transport,omitempty"`
	// contains filtered or unexported fields
}

A hint of what protocol the service knows. The default value is for the `hint` field to be not be set, essentially meaning "unknown".

func (*ProtocolHint) Descriptor deprecated 

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

Deprecated: Use ProtocolHint.ProtoReflect.Descriptor instead.

func (*ProtocolHint) GetH2 

func (x *ProtocolHint) GetH2() *ProtocolHint_H2

func (*ProtocolHint) GetOpaque added in v0.8.0 

func (x *ProtocolHint) GetOpaque() *ProtocolHint_Opaque

func (*ProtocolHint) GetOpaqueTransport added in v0.1.16 

func (x *ProtocolHint) GetOpaqueTransport() *ProtocolHint_OpaqueTransport

func (*ProtocolHint) GetProtocol 

func (m *ProtocolHint) GetProtocol() isProtocolHint_Protocol

func (*ProtocolHint) ProtoMessage 

func (*ProtocolHint) ProtoMessage()

func (*ProtocolHint) ProtoReflect added in v0.1.13 

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

func (*ProtocolHint) Reset 

func (x *ProtocolHint) Reset()

func (*ProtocolHint) String 

func (x *ProtocolHint) String() string

type ProtocolHint_H2 

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

func (*ProtocolHint_H2) Descriptor deprecated 

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

Deprecated: Use ProtocolHint_H2.ProtoReflect.Descriptor instead.

func (*ProtocolHint_H2) ProtoMessage 

func (*ProtocolHint_H2) ProtoMessage()

func (*ProtocolHint_H2) ProtoReflect added in v0.1.13 

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

func (*ProtocolHint_H2) Reset 

func (x *ProtocolHint_H2) Reset()

func (*ProtocolHint_H2) String 

func (x *ProtocolHint_H2) String() string

type ProtocolHint_H2_ 

type ProtocolHint_H2_ struct {
	// Hints that the service understands HTTP2 and the proxy's internal
	// http2-upgrade mechanism.
	H2 *ProtocolHint_H2 `protobuf:"bytes,1,opt,name=h2,proto3,oneof"`
}

type ProtocolHint_Opaque added in v0.8.0 

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

func (*ProtocolHint_Opaque) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ProtocolHint_Opaque.ProtoReflect.Descriptor instead.

func (*ProtocolHint_Opaque) ProtoMessage added in v0.8.0 

func (*ProtocolHint_Opaque) ProtoMessage()

func (*ProtocolHint_Opaque) ProtoReflect added in v0.8.0 

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

func (*ProtocolHint_Opaque) Reset added in v0.8.0 

func (x *ProtocolHint_Opaque) Reset()

func (*ProtocolHint_Opaque) String added in v0.8.0 

func (x *ProtocolHint_Opaque) String() string

type ProtocolHint_OpaqueTransport added in v0.1.16 

type ProtocolHint_OpaqueTransport struct {

	// The target proxy's inbound port.
	InboundPort uint32 `protobuf:"varint,1,opt,name=inbound_port,json=inboundPort,proto3" json:"inbound_port,omitempty"`
	// contains filtered or unexported fields
}

func (*ProtocolHint_OpaqueTransport) Descriptor deprecated added in v0.1.16 

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

Deprecated: Use ProtocolHint_OpaqueTransport.ProtoReflect.Descriptor instead.

func (*ProtocolHint_OpaqueTransport) GetInboundPort added in v0.1.16 

func (x *ProtocolHint_OpaqueTransport) GetInboundPort() uint32

func (*ProtocolHint_OpaqueTransport) ProtoMessage added in v0.1.16 

func (*ProtocolHint_OpaqueTransport) ProtoMessage()

func (*ProtocolHint_OpaqueTransport) ProtoReflect added in v0.1.16 

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

func (*ProtocolHint_OpaqueTransport) Reset added in v0.1.16 

func (x *ProtocolHint_OpaqueTransport) Reset()

func (*ProtocolHint_OpaqueTransport) String added in v0.1.16 

func (x *ProtocolHint_OpaqueTransport) String() string

type ProtocolHint_Opaque_ added in v0.8.0 

type ProtocolHint_Opaque_ struct {
	// Hints that the destination will handle this connection as an opaque TCP
	// stream, and (if `opaque_transport` is set) that the proxy should not send
	// a `SessionProtocol` as part of its transport header.
	Opaque *ProtocolHint_Opaque `protobuf:"bytes,3,opt,name=opaque,proto3,oneof"`
}

type RequestMatch added in v0.1.2 

type RequestMatch struct {

	// Types that are assignable to Match:
	//
	//	*RequestMatch_All
	//	*RequestMatch_Any
	//	*RequestMatch_Not
	//	*RequestMatch_Path
	//	*RequestMatch_Method
	Match isRequestMatch_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*RequestMatch) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use RequestMatch.ProtoReflect.Descriptor instead.

func (*RequestMatch) GetAll added in v0.1.2 

func (x *RequestMatch) GetAll() *RequestMatch_Seq

func (*RequestMatch) GetAny added in v0.1.2 

func (x *RequestMatch) GetAny() *RequestMatch_Seq

func (*RequestMatch) GetMatch added in v0.1.2 

func (m *RequestMatch) GetMatch() isRequestMatch_Match

func (*RequestMatch) GetMethod added in v0.1.2 

func (x *RequestMatch) GetMethod() *http_types.HttpMethod

func (*RequestMatch) GetNot added in v0.1.2 

func (x *RequestMatch) GetNot() *RequestMatch

func (*RequestMatch) GetPath added in v0.1.2 

func (x *RequestMatch) GetPath() *PathMatch

func (*RequestMatch) ProtoMessage added in v0.1.2 

func (*RequestMatch) ProtoMessage()

func (*RequestMatch) ProtoReflect added in v0.1.13 

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

func (*RequestMatch) Reset added in v0.1.2 

func (x *RequestMatch) Reset()

func (*RequestMatch) String added in v0.1.2 

func (x *RequestMatch) String() string

type RequestMatch_All added in v0.1.2 

type RequestMatch_All struct {
	All *RequestMatch_Seq `protobuf:"bytes,1,opt,name=all,proto3,oneof"`
}

type RequestMatch_Any added in v0.1.2 

type RequestMatch_Any struct {
	Any *RequestMatch_Seq `protobuf:"bytes,2,opt,name=any,proto3,oneof"`
}

type RequestMatch_Method added in v0.1.2 

type RequestMatch_Method struct {
	Method *http_types.HttpMethod `protobuf:"bytes,5,opt,name=method,proto3,oneof"` // TODO: match on arbitrary header
}

type RequestMatch_Not added in v0.1.2 

type RequestMatch_Not struct {
	Not *RequestMatch `protobuf:"bytes,3,opt,name=not,proto3,oneof"`
}

type RequestMatch_Path added in v0.1.2 

type RequestMatch_Path struct {
	Path *PathMatch `protobuf:"bytes,4,opt,name=path,proto3,oneof"`
}

type RequestMatch_Seq added in v0.1.2 

type RequestMatch_Seq struct {
	Matches []*RequestMatch `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestMatch_Seq) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use RequestMatch_Seq.ProtoReflect.Descriptor instead.

func (*RequestMatch_Seq) GetMatches added in v0.1.2 

func (x *RequestMatch_Seq) GetMatches() []*RequestMatch

func (*RequestMatch_Seq) ProtoMessage added in v0.1.2 

func (*RequestMatch_Seq) ProtoMessage()

func (*RequestMatch_Seq) ProtoReflect added in v0.1.13 

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

func (*RequestMatch_Seq) Reset added in v0.1.2 

func (x *RequestMatch_Seq) Reset()

func (*RequestMatch_Seq) String added in v0.1.2 

func (x *RequestMatch_Seq) String() string

type ResponseClass added in v0.1.2 

type ResponseClass struct {

	// This class contains responses which match this condition.
	Condition *ResponseMatch `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	// If responses in this class should be considered failures.  This defaults
	// to false (success).
	IsFailure bool `protobuf:"varint,2,opt,name=is_failure,json=isFailure,proto3" json:"is_failure,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseClass) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ResponseClass.ProtoReflect.Descriptor instead.

func (*ResponseClass) GetCondition added in v0.1.2 

func (x *ResponseClass) GetCondition() *ResponseMatch

func (*ResponseClass) GetIsFailure added in v0.1.2 

func (x *ResponseClass) GetIsFailure() bool

func (*ResponseClass) ProtoMessage added in v0.1.2 

func (*ResponseClass) ProtoMessage()

func (*ResponseClass) ProtoReflect added in v0.1.13 

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

func (*ResponseClass) Reset added in v0.1.2 

func (x *ResponseClass) Reset()

func (*ResponseClass) String added in v0.1.2 

func (x *ResponseClass) String() string

type ResponseMatch added in v0.1.2 

type ResponseMatch struct {

	// Types that are assignable to Match:
	//
	//	*ResponseMatch_All
	//	*ResponseMatch_Any
	//	*ResponseMatch_Not
	//	*ResponseMatch_Status
	Match isResponseMatch_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*ResponseMatch) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ResponseMatch.ProtoReflect.Descriptor instead.

func (*ResponseMatch) GetAll added in v0.1.2 

func (x *ResponseMatch) GetAll() *ResponseMatch_Seq

func (*ResponseMatch) GetAny added in v0.1.2 

func (x *ResponseMatch) GetAny() *ResponseMatch_Seq

func (*ResponseMatch) GetMatch added in v0.1.2 

func (m *ResponseMatch) GetMatch() isResponseMatch_Match

func (*ResponseMatch) GetNot added in v0.1.2 

func (x *ResponseMatch) GetNot() *ResponseMatch

func (*ResponseMatch) GetStatus added in v0.1.2 

func (x *ResponseMatch) GetStatus() *HttpStatusRange

func (*ResponseMatch) ProtoMessage added in v0.1.2 

func (*ResponseMatch) ProtoMessage()

func (*ResponseMatch) ProtoReflect added in v0.1.13 

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

func (*ResponseMatch) Reset added in v0.1.2 

func (x *ResponseMatch) Reset()

func (*ResponseMatch) String added in v0.1.2 

func (x *ResponseMatch) String() string

type ResponseMatch_All added in v0.1.2 

type ResponseMatch_All struct {
	All *ResponseMatch_Seq `protobuf:"bytes,1,opt,name=all,proto3,oneof"`
}

type ResponseMatch_Any added in v0.1.2 

type ResponseMatch_Any struct {
	Any *ResponseMatch_Seq `protobuf:"bytes,2,opt,name=any,proto3,oneof"`
}

type ResponseMatch_Not added in v0.1.2 

type ResponseMatch_Not struct {
	Not *ResponseMatch `protobuf:"bytes,3,opt,name=not,proto3,oneof"`
}

type ResponseMatch_Seq added in v0.1.2 

type ResponseMatch_Seq struct {
	Matches []*ResponseMatch `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseMatch_Seq) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ResponseMatch_Seq.ProtoReflect.Descriptor instead.

func (*ResponseMatch_Seq) GetMatches added in v0.1.2 

func (x *ResponseMatch_Seq) GetMatches() []*ResponseMatch

func (*ResponseMatch_Seq) ProtoMessage added in v0.1.2 

func (*ResponseMatch_Seq) ProtoMessage()

func (*ResponseMatch_Seq) ProtoReflect added in v0.1.13 

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

func (*ResponseMatch_Seq) Reset added in v0.1.2 

func (x *ResponseMatch_Seq) Reset()

func (*ResponseMatch_Seq) String added in v0.1.2 

func (x *ResponseMatch_Seq) String() string

type ResponseMatch_Status added in v0.1.2 

type ResponseMatch_Status struct {
	Status *HttpStatusRange `protobuf:"bytes,4,opt,name=status,proto3,oneof"` // TODO: match on arbitrary header or trailer
}

type RetryBudget added in v0.1.5 

type RetryBudget struct {

	// The ratio of additional traffic that may be added by retries.  A
	// retry_ratio of 0.1 means that 1 retry may be attempted for every 10 regular
	// requests.  A retry_ratio of 1.0 means that 1 retry may be attempted for
	// every 1 regular request (in other words, total request load may be doubled
	// as a result of retries).
	RetryRatio float32 `protobuf:"fixed32,1,opt,name=retry_ratio,json=retryRatio,proto3" json:"retry_ratio,omitempty"`
	// The proxy may always attempt this number of retries per second, even if it
	// would violate the retry_ratio.  This is to allow retries to happen even
	// when the request rate is very low.
	MinRetriesPerSecond uint32 `protobuf:"varint,2,opt,name=min_retries_per_second,json=minRetriesPerSecond,proto3" json:"min_retries_per_second,omitempty"`
	// This duration indicates for how long requests should be considered for the
	// purposes of enforcing the retry_ratio.  A higher value considers a larger
	// window and therefore allows burstier retries.
	Ttl *duration.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryBudget) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use RetryBudget.ProtoReflect.Descriptor instead.

func (*RetryBudget) GetMinRetriesPerSecond added in v0.1.5 

func (x *RetryBudget) GetMinRetriesPerSecond() uint32

func (*RetryBudget) GetRetryRatio added in v0.1.5 

func (x *RetryBudget) GetRetryRatio() float32

func (*RetryBudget) GetTtl added in v0.1.5 

func (x *RetryBudget) GetTtl() *duration.Duration

func (*RetryBudget) ProtoMessage added in v0.1.5 

func (*RetryBudget) ProtoMessage()

func (*RetryBudget) ProtoReflect added in v0.1.13 

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

func (*RetryBudget) Reset added in v0.1.5 

func (x *RetryBudget) Reset()

func (*RetryBudget) String added in v0.1.5 

func (x *RetryBudget) String() string

type Route added in v0.1.2 

type Route struct {

	// This route contains requests which match this condition.
	Condition *RequestMatch `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	// A list of response classes for this route.  If a response matches
	// more than one ResponseClass, the first match wins.  If a response does not
	// match any ResponseClasses, it is considered to be a successful response.
	ResponseClasses []*ResponseClass `protobuf:"bytes,2,rep,name=response_classes,json=responseClasses,proto3" json:"response_classes,omitempty"`
	// Metric labels to attach to requests and responses that match this route.
	MetricsLabels map[string]string `` /* 188-byte string literal not displayed */
	// If a route is retryable, any failed requests on that route may be retried
	// by the proxy.
	IsRetryable bool `protobuf:"varint,4,opt,name=is_retryable,json=isRetryable,proto3" json:"is_retryable,omitempty"`
	// After this time has elapsed since receiving the initial request, any
	// outstanding request will be cancelled, a timeout error response will be
	// returned, and no more retries will be attempted.
	Timeout *duration.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Route) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetCondition added in v0.1.2 

func (x *Route) GetCondition() *RequestMatch

func (*Route) GetIsRetryable added in v0.1.5 

func (x *Route) GetIsRetryable() bool

func (*Route) GetMetricsLabels added in v0.1.3 

func (x *Route) GetMetricsLabels() map[string]string

func (*Route) GetResponseClasses added in v0.1.2 

func (x *Route) GetResponseClasses() []*ResponseClass

func (*Route) GetTimeout added in v0.1.5 

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

func (*Route) ProtoMessage added in v0.1.2 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect added in v0.1.13 

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

func (*Route) Reset added in v0.1.2 

func (x *Route) Reset()

func (*Route) String added in v0.1.2 

func (x *Route) String() string

type TlsIdentity 

type TlsIdentity struct {

	// Types that are assignable to Strategy:
	//
	//	*TlsIdentity_DnsLikeIdentity_
	//	*TlsIdentity_UriLikeIdentity_
	Strategy isTlsIdentity_Strategy `protobuf_oneof:"strategy"`
	// The server name of the endpoint. This is the value that needs to be included
	// by clients in the ClientHello SNI extension of the TLS handshake when they
	// initiate TLS connections to servers.
	ServerName *TlsIdentity_DnsLikeIdentity `protobuf:"bytes,4,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TlsIdentity) Descriptor deprecated 

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

Deprecated: Use TlsIdentity.ProtoReflect.Descriptor instead.

func (*TlsIdentity) GetDnsLikeIdentity added in v0.1.7 

func (x *TlsIdentity) GetDnsLikeIdentity() *TlsIdentity_DnsLikeIdentity

func (*TlsIdentity) GetServerName added in v0.13.0 

func (x *TlsIdentity) GetServerName() *TlsIdentity_DnsLikeIdentity

func (*TlsIdentity) GetStrategy 

func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy

func (*TlsIdentity) GetUriLikeIdentity added in v0.13.0 

func (x *TlsIdentity) GetUriLikeIdentity() *TlsIdentity_UriLikeIdentity

func (*TlsIdentity) ProtoMessage 

func (*TlsIdentity) ProtoMessage()

func (*TlsIdentity) ProtoReflect added in v0.1.13 

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

func (*TlsIdentity) Reset 

func (x *TlsIdentity) Reset()

func (*TlsIdentity) String 

func (x *TlsIdentity) String() string

type TlsIdentity_DnsLikeIdentity added in v0.1.7 

type TlsIdentity_DnsLikeIdentity struct {

	// A DNS-like name that encodes workload coordinates.
	//
	// For example:
	//
	//	{name}.{namespace}.{type}.identity.{control-namespace}.{trust-domain...}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Verify the certificate based on the Kubernetes pod identity.

func (*TlsIdentity_DnsLikeIdentity) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use TlsIdentity_DnsLikeIdentity.ProtoReflect.Descriptor instead.

func (*TlsIdentity_DnsLikeIdentity) GetName added in v0.1.7 

func (x *TlsIdentity_DnsLikeIdentity) GetName() string

func (*TlsIdentity_DnsLikeIdentity) ProtoMessage added in v0.1.7 

func (*TlsIdentity_DnsLikeIdentity) ProtoMessage()

func (*TlsIdentity_DnsLikeIdentity) ProtoReflect added in v0.1.13 

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

func (*TlsIdentity_DnsLikeIdentity) Reset added in v0.1.7 

func (x *TlsIdentity_DnsLikeIdentity) Reset()

func (*TlsIdentity_DnsLikeIdentity) String added in v0.1.7 

func (x *TlsIdentity_DnsLikeIdentity) String() string

type TlsIdentity_DnsLikeIdentity_ added in v0.1.7 

type TlsIdentity_DnsLikeIdentity_ struct {
	DnsLikeIdentity *TlsIdentity_DnsLikeIdentity `protobuf:"bytes,1,opt,name=dns_like_identity,json=dnsLikeIdentity,proto3,oneof"`
}

type TlsIdentity_UriLikeIdentity added in v0.13.0 

type TlsIdentity_UriLikeIdentity struct {

	// A URI name that encodes workload identity.
	//
	// For example:
	//
	//	spiffe://trust-domain/workload-dentifier
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

Verify the certificate based on an URI identity.

func (*TlsIdentity_UriLikeIdentity) Descriptor deprecated added in v0.13.0 

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

Deprecated: Use TlsIdentity_UriLikeIdentity.ProtoReflect.Descriptor instead.

func (*TlsIdentity_UriLikeIdentity) GetUri added in v0.13.0 

func (x *TlsIdentity_UriLikeIdentity) GetUri() string

func (*TlsIdentity_UriLikeIdentity) ProtoMessage added in v0.13.0 

func (*TlsIdentity_UriLikeIdentity) ProtoMessage()

func (*TlsIdentity_UriLikeIdentity) ProtoReflect added in v0.13.0 

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

func (*TlsIdentity_UriLikeIdentity) Reset added in v0.13.0 

func (x *TlsIdentity_UriLikeIdentity) Reset()

func (*TlsIdentity_UriLikeIdentity) String added in v0.13.0 

func (x *TlsIdentity_UriLikeIdentity) String() string

type TlsIdentity_UriLikeIdentity_ added in v0.13.0 

type TlsIdentity_UriLikeIdentity_ struct {
	UriLikeIdentity *TlsIdentity_UriLikeIdentity `protobuf:"bytes,3,opt,name=uri_like_identity,json=uriLikeIdentity,proto3,oneof"`
}

type UnimplementedDestinationServer added in v0.1.13 

type UnimplementedDestinationServer struct{}

UnimplementedDestinationServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDestinationServer) Get added in v0.1.13 

func (UnimplementedDestinationServer) Get(*GetDestination, grpc.ServerStreamingServer[Update]) error

func (UnimplementedDestinationServer) GetProfile added in v0.1.13 

func (UnimplementedDestinationServer) GetProfile(*GetDestination, grpc.ServerStreamingServer[DestinationProfile]) error

type UnsafeDestinationServer added in v0.2.0 

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

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

type Update 

type Update struct {

	// Types that are assignable to Update:
	//
	//	*Update_Add
	//	*Update_Remove
	//	*Update_NoEndpoints
	Update isUpdate_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

func (*Update) Descriptor deprecated 

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetAdd 

func (x *Update) GetAdd() *WeightedAddrSet

func (*Update) GetNoEndpoints 

func (x *Update) GetNoEndpoints() *NoEndpoints

func (*Update) GetRemove 

func (x *Update) GetRemove() *AddrSet

func (*Update) GetUpdate 

func (m *Update) GetUpdate() isUpdate_Update

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect added in v0.1.13 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

type Update_Add 

type Update_Add struct {
	// A new set of endpoints are available for the service. The set might be
	// empty.
	Add *WeightedAddrSet `protobuf:"bytes,1,opt,name=add,proto3,oneof"`
}

type Update_NoEndpoints 

type Update_NoEndpoints struct {
	// `no_endpoints{exists: false}` indicates that the service does not exist
	// and the client MAY try an alternate service discovery method (e.g. DNS).
	//
	// `no_endpoints(exists: true)` indicates that the service does exist and
	// the client MUST NOT fall back to an alternate service discovery method.
	NoEndpoints *NoEndpoints `protobuf:"bytes,3,opt,name=no_endpoints,json=noEndpoints,proto3,oneof"`
}

type Update_Remove 

type Update_Remove struct {
	// Some endpoints have been removed from the service.
	Remove *AddrSet `protobuf:"bytes,2,opt,name=remove,proto3,oneof"`
}

type WeightedAddr 

type WeightedAddr struct {
	Addr              *net.TcpAddress    `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Weight            uint32             `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"`
	MetricLabels      map[string]string  `` /* 185-byte string literal not displayed */
	TlsIdentity       *TlsIdentity       `protobuf:"bytes,5,opt,name=tls_identity,json=tlsIdentity,proto3" json:"tls_identity,omitempty"`
	ProtocolHint      *ProtocolHint      `protobuf:"bytes,6,opt,name=protocol_hint,json=protocolHint,proto3" json:"protocol_hint,omitempty"`
	AuthorityOverride *AuthorityOverride `protobuf:"bytes,7,opt,name=authority_override,json=authorityOverride,proto3" json:"authority_override,omitempty"`
	// The HTTP/2 parameters to use when connecting to the destination, if HTTP/2
	// is used. These parameters are used by proxies when the application traffic
	// is HTTP/2 or when the H2 ProtocolHint is used to transport HTTP/1
	// connections over HTTP/2.
	Http2 *Http2ClientParams `protobuf:"bytes,8,opt,name=http2,proto3" json:"http2,omitempty"`
	// A reference to the metadata for this endpoint, usually a Pod. This may be
	// omitted when the resource type is unknown.
	ResourceRef *meta.Metadata `protobuf:"bytes,9,opt,name=resource_ref,json=resourceRef,proto3" json:"resource_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WeightedAddr) Descriptor deprecated 

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

Deprecated: Use WeightedAddr.ProtoReflect.Descriptor instead.

func (*WeightedAddr) GetAddr 

func (x *WeightedAddr) GetAddr() *net.TcpAddress

func (*WeightedAddr) GetAuthorityOverride added in v0.1.12 

func (x *WeightedAddr) GetAuthorityOverride() *AuthorityOverride

func (*WeightedAddr) GetHttp2 added in v0.13.1 

func (x *WeightedAddr) GetHttp2() *Http2ClientParams

func (*WeightedAddr) GetMetricLabels 

func (x *WeightedAddr) GetMetricLabels() map[string]string

func (*WeightedAddr) GetProtocolHint 

func (x *WeightedAddr) GetProtocolHint() *ProtocolHint

func (*WeightedAddr) GetResourceRef added in v0.15.0 

func (x *WeightedAddr) GetResourceRef() *meta.Metadata

func (*WeightedAddr) GetTlsIdentity 

func (x *WeightedAddr) GetTlsIdentity() *TlsIdentity

func (*WeightedAddr) GetWeight 

func (x *WeightedAddr) GetWeight() uint32

func (*WeightedAddr) ProtoMessage 

func (*WeightedAddr) ProtoMessage()

func (*WeightedAddr) ProtoReflect added in v0.1.13 

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

func (*WeightedAddr) Reset 

func (x *WeightedAddr) Reset()

func (*WeightedAddr) String 

func (x *WeightedAddr) String() string

type WeightedAddrSet 

type WeightedAddrSet struct {
	Addrs        []*WeightedAddr   `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	MetricLabels map[string]string `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WeightedAddrSet) Descriptor deprecated 

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

Deprecated: Use WeightedAddrSet.ProtoReflect.Descriptor instead.

func (*WeightedAddrSet) GetAddrs 

func (x *WeightedAddrSet) GetAddrs() []*WeightedAddr

func (*WeightedAddrSet) GetMetricLabels 

func (x *WeightedAddrSet) GetMetricLabels() map[string]string

func (*WeightedAddrSet) ProtoMessage 

func (*WeightedAddrSet) ProtoMessage()

func (*WeightedAddrSet) ProtoReflect added in v0.1.13 

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

func (*WeightedAddrSet) Reset 

func (x *WeightedAddrSet) Reset()

func (*WeightedAddrSet) String 

func (x *WeightedAddrSet) String() string

type WeightedDst added in v0.1.9 

type WeightedDst struct {

	// This authority will be used as the `path` in a call to the Destination.Get
	// rpc.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// The proportion of requests to send to this destination.  This value is
	// relative to other weights in the same dst_overrides list.
	Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// A reference to the metadata for a Service resource.
	BackendRef *meta.Metadata `protobuf:"bytes,3,opt,name=backend_ref,json=backendRef,proto3" json:"backend_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WeightedDst) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use WeightedDst.ProtoReflect.Descriptor instead.

func (*WeightedDst) GetAuthority added in v0.1.9 

func (x *WeightedDst) GetAuthority() string

func (*WeightedDst) GetBackendRef added in v0.15.0 

func (x *WeightedDst) GetBackendRef() *meta.Metadata

func (*WeightedDst) GetWeight added in v0.1.9 

func (x *WeightedDst) GetWeight() uint32

func (*WeightedDst) ProtoMessage added in v0.1.9 

func (*WeightedDst) ProtoMessage()

func (*WeightedDst) ProtoReflect added in v0.1.13 

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

func (*WeightedDst) Reset added in v0.1.9 

func (x *WeightedDst) Reset()

func (*WeightedDst) String added in v0.1.9 

func (x *WeightedDst) String() string

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.