destination

package
v0.1.15 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2020 License: Apache-2.0 Imports: 12 Imported by: 102

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_destination_proto protoreflect.FileDescriptor

Functions

func RegisterDestinationServer 

func RegisterDestinationServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#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
}

DestinationServer is the server API for Destination service.

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