destination

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2021 License: Apache-2.0 Imports: 11 Imported by: 102

Documentation

Index

Constants

This section is empty.

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) (Destination_GetClient, 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) (Destination_GetProfileClient, 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"`
	// 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) 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, Destination_GetServer) error
	// Given a destination, return that destination's profile and send an update
	// whenever it changes.
	GetProfile(*GetDestination, Destination_GetProfileServer) 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 interface {
	Recv() (*Update, error)
	grpc.ClientStream
}

type Destination_GetProfileClient added in v0.1.2 

type Destination_GetProfileClient interface {
	Recv() (*DestinationProfile, error)
	grpc.ClientStream
}

type Destination_GetProfileServer added in v0.1.2 

type Destination_GetProfileServer interface {
	Send(*DestinationProfile) error
	grpc.ServerStream
}

type Destination_GetServer 

type Destination_GetServer interface {
	Send(*Update) error
	grpc.ServerStream
}

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 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_
	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) 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_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 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_
	Strategy isTlsIdentity_Strategy `protobuf_oneof:"strategy"`
	// contains filtered or unexported fields
}

Which strategy should be used for verifying TLS.

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) GetStrategy 

func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy

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

type UnimplementedDestinationServer struct {
}

UnimplementedDestinationServer must be embedded to have forward compatible implementations.

func (UnimplementedDestinationServer) Get added in v0.1.13 

func (UnimplementedDestinationServer) Get(*GetDestination, Destination_GetServer) error

func (UnimplementedDestinationServer) GetProfile added in v0.1.13 

func (UnimplementedDestinationServer) GetProfile(*GetDestination, Destination_GetProfileServer) 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"`
	// 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) GetMetricLabels 

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

func (*WeightedAddr) GetProtocolHint 

func (x *WeightedAddr) GetProtocolHint() *ProtocolHint

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"`
	// 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) 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.