destination

package
v0.1.12 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AddrSet) Descriptor 

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

func (*AddrSet) GetAddrs 

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

func (*AddrSet) ProtoMessage 

func (*AddrSet) ProtoMessage()

func (*AddrSet) Reset 

func (m *AddrSet) Reset()

func (*AddrSet) String 

func (m *AddrSet) String() string

func (*AddrSet) XXX_DiscardUnknown added in v0.1.2 

func (m *AddrSet) XXX_DiscardUnknown()

func (*AddrSet) XXX_Marshal added in v0.1.2 

func (m *AddrSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddrSet) XXX_Merge added in v0.1.2 

func (dst *AddrSet) XXX_Merge(src proto.Message)

func (*AddrSet) XXX_Size added in v0.1.2 

func (m *AddrSet) XXX_Size() int

func (*AddrSet) XXX_Unmarshal added in v0.1.2 

func (m *AddrSet) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AuthorityOverride) Descriptor added in v0.1.12 

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

func (*AuthorityOverride) GetAuthorityOverride added in v0.1.12 

func (m *AuthorityOverride) GetAuthorityOverride() string

func (*AuthorityOverride) ProtoMessage added in v0.1.12 

func (*AuthorityOverride) ProtoMessage()

func (*AuthorityOverride) Reset added in v0.1.12 

func (m *AuthorityOverride) Reset()

func (*AuthorityOverride) String added in v0.1.12 

func (m *AuthorityOverride) String() string

func (*AuthorityOverride) XXX_DiscardUnknown added in v0.1.12 

func (m *AuthorityOverride) XXX_DiscardUnknown()

func (*AuthorityOverride) XXX_Marshal added in v0.1.12 

func (m *AuthorityOverride) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthorityOverride) XXX_Merge added in v0.1.12 

func (dst *AuthorityOverride) XXX_Merge(src proto.Message)

func (*AuthorityOverride) XXX_Size added in v0.1.12 

func (m *AuthorityOverride) XXX_Size() int

func (*AuthorityOverride) XXX_Unmarshal added in v0.1.12 

func (m *AuthorityOverride) XXX_Unmarshal(b []byte) error

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.ClientConn) DestinationClient

type DestinationProfile added in v0.1.2 

type DestinationProfile struct {
	// 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DestinationProfile) Descriptor added in v0.1.2 

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

func (*DestinationProfile) GetDstOverrides added in v0.1.9 

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

func (*DestinationProfile) GetRetryBudget added in v0.1.5 

func (m *DestinationProfile) GetRetryBudget() *RetryBudget

func (*DestinationProfile) GetRoutes added in v0.1.2 

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

func (*DestinationProfile) ProtoMessage added in v0.1.2 

func (*DestinationProfile) ProtoMessage()

func (*DestinationProfile) Reset added in v0.1.2 

func (m *DestinationProfile) Reset()

func (*DestinationProfile) String added in v0.1.2 

func (m *DestinationProfile) String() string

func (*DestinationProfile) XXX_DiscardUnknown added in v0.1.2 

func (m *DestinationProfile) XXX_DiscardUnknown()

func (*DestinationProfile) XXX_Marshal added in v0.1.2 

func (m *DestinationProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DestinationProfile) XXX_Merge added in v0.1.2 

func (dst *DestinationProfile) XXX_Merge(src proto.Message)

func (*DestinationProfile) XXX_Size added in v0.1.2 

func (m *DestinationProfile) XXX_Size() int

func (*DestinationProfile) XXX_Unmarshal added in v0.1.2 

func (m *DestinationProfile) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDestination) Descriptor 

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

func (*GetDestination) GetContextToken added in v0.1.7 

func (m *GetDestination) GetContextToken() string

func (*GetDestination) GetPath 

func (m *GetDestination) GetPath() string

func (*GetDestination) GetScheme 

func (m *GetDestination) GetScheme() string

func (*GetDestination) ProtoMessage 

func (*GetDestination) ProtoMessage()

func (*GetDestination) Reset 

func (m *GetDestination) Reset()

func (*GetDestination) String 

func (m *GetDestination) String() string

func (*GetDestination) XXX_DiscardUnknown added in v0.1.2 

func (m *GetDestination) XXX_DiscardUnknown()

func (*GetDestination) XXX_Marshal added in v0.1.2 

func (m *GetDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDestination) XXX_Merge added in v0.1.2 

func (dst *GetDestination) XXX_Merge(src proto.Message)

func (*GetDestination) XXX_Size added in v0.1.2 

func (m *GetDestination) XXX_Size() int

func (*GetDestination) XXX_Unmarshal added in v0.1.2 

func (m *GetDestination) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*HttpStatusRange) Descriptor added in v0.1.2 

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

func (*HttpStatusRange) GetMax added in v0.1.2 

func (m *HttpStatusRange) GetMax() uint32

func (*HttpStatusRange) GetMin added in v0.1.2 

func (m *HttpStatusRange) GetMin() uint32

func (*HttpStatusRange) ProtoMessage added in v0.1.2 

func (*HttpStatusRange) ProtoMessage()

func (*HttpStatusRange) Reset added in v0.1.2 

func (m *HttpStatusRange) Reset()

func (*HttpStatusRange) String added in v0.1.2 

func (m *HttpStatusRange) String() string

func (*HttpStatusRange) XXX_DiscardUnknown added in v0.1.2 

func (m *HttpStatusRange) XXX_DiscardUnknown()

func (*HttpStatusRange) XXX_Marshal added in v0.1.2 

func (m *HttpStatusRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpStatusRange) XXX_Merge added in v0.1.2 

func (dst *HttpStatusRange) XXX_Merge(src proto.Message)

func (*HttpStatusRange) XXX_Size added in v0.1.2 

func (m *HttpStatusRange) XXX_Size() int

func (*HttpStatusRange) XXX_Unmarshal added in v0.1.2 

func (m *HttpStatusRange) XXX_Unmarshal(b []byte) error

type NoEndpoints 

type NoEndpoints struct {
	Exists               bool     `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NoEndpoints) Descriptor 

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

func (*NoEndpoints) GetExists 

func (m *NoEndpoints) GetExists() bool

func (*NoEndpoints) ProtoMessage 

func (*NoEndpoints) ProtoMessage()

func (*NoEndpoints) Reset 

func (m *NoEndpoints) Reset()

func (*NoEndpoints) String 

func (m *NoEndpoints) String() string

func (*NoEndpoints) XXX_DiscardUnknown added in v0.1.2 

func (m *NoEndpoints) XXX_DiscardUnknown()

func (*NoEndpoints) XXX_Marshal added in v0.1.2 

func (m *NoEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NoEndpoints) XXX_Merge added in v0.1.2 

func (dst *NoEndpoints) XXX_Merge(src proto.Message)

func (*NoEndpoints) XXX_Size added in v0.1.2 

func (m *NoEndpoints) XXX_Size() int

func (*NoEndpoints) XXX_Unmarshal added in v0.1.2 

func (m *NoEndpoints) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PathMatch) Descriptor added in v0.1.2 

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

func (*PathMatch) GetRegex added in v0.1.2 

func (m *PathMatch) GetRegex() string

func (*PathMatch) ProtoMessage added in v0.1.2 

func (*PathMatch) ProtoMessage()

func (*PathMatch) Reset added in v0.1.2 

func (m *PathMatch) Reset()

func (*PathMatch) String added in v0.1.2 

func (m *PathMatch) String() string

func (*PathMatch) XXX_DiscardUnknown added in v0.1.2 

func (m *PathMatch) XXX_DiscardUnknown()

func (*PathMatch) XXX_Marshal added in v0.1.2 

func (m *PathMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PathMatch) XXX_Merge added in v0.1.2 

func (dst *PathMatch) XXX_Merge(src proto.Message)

func (*PathMatch) XXX_Size added in v0.1.2 

func (m *PathMatch) XXX_Size() int

func (*PathMatch) XXX_Unmarshal added in v0.1.2 

func (m *PathMatch) XXX_Unmarshal(b []byte) error

type ProtocolHint 

type ProtocolHint struct {
	// Types that are valid to be assigned to Protocol:
	//	*ProtocolHint_H2_
	Protocol             isProtocolHint_Protocol `protobuf_oneof:"protocol"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 

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

func (*ProtocolHint) GetH2 

func (m *ProtocolHint) GetH2() *ProtocolHint_H2

func (*ProtocolHint) GetProtocol 

func (m *ProtocolHint) GetProtocol() isProtocolHint_Protocol

func (*ProtocolHint) ProtoMessage 

func (*ProtocolHint) ProtoMessage()

func (*ProtocolHint) Reset 

func (m *ProtocolHint) Reset()

func (*ProtocolHint) String 

func (m *ProtocolHint) String() string

func (*ProtocolHint) XXX_DiscardUnknown added in v0.1.2 

func (m *ProtocolHint) XXX_DiscardUnknown()

func (*ProtocolHint) XXX_Marshal added in v0.1.2 

func (m *ProtocolHint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtocolHint) XXX_Merge added in v0.1.2 

func (dst *ProtocolHint) XXX_Merge(src proto.Message)

func (*ProtocolHint) XXX_OneofFuncs 

func (*ProtocolHint) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ProtocolHint) XXX_Size added in v0.1.2 

func (m *ProtocolHint) XXX_Size() int

func (*ProtocolHint) XXX_Unmarshal added in v0.1.2 

func (m *ProtocolHint) XXX_Unmarshal(b []byte) error

type ProtocolHint_H2 

type ProtocolHint_H2 struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtocolHint_H2) Descriptor 

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

func (*ProtocolHint_H2) ProtoMessage 

func (*ProtocolHint_H2) ProtoMessage()

func (*ProtocolHint_H2) Reset 

func (m *ProtocolHint_H2) Reset()

func (*ProtocolHint_H2) String 

func (m *ProtocolHint_H2) String() string

func (*ProtocolHint_H2) XXX_DiscardUnknown added in v0.1.2 

func (m *ProtocolHint_H2) XXX_DiscardUnknown()

func (*ProtocolHint_H2) XXX_Marshal added in v0.1.2 

func (m *ProtocolHint_H2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtocolHint_H2) XXX_Merge added in v0.1.2 

func (dst *ProtocolHint_H2) XXX_Merge(src proto.Message)

func (*ProtocolHint_H2) XXX_Size added in v0.1.2 

func (m *ProtocolHint_H2) XXX_Size() int

func (*ProtocolHint_H2) XXX_Unmarshal added in v0.1.2 

func (m *ProtocolHint_H2) XXX_Unmarshal(b []byte) error

type ProtocolHint_H2_ 

type ProtocolHint_H2_ struct {
	H2 *ProtocolHint_H2 `protobuf:"bytes,1,opt,name=h2,proto3,oneof"`
}

type RequestMatch added in v0.1.2 

type RequestMatch struct {
	// Types that are valid to be assigned to Match:
	//	*RequestMatch_All
	//	*RequestMatch_Any
	//	*RequestMatch_Not
	//	*RequestMatch_Path
	//	*RequestMatch_Method
	Match                isRequestMatch_Match `protobuf_oneof:"match"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RequestMatch) Descriptor added in v0.1.2 

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

func (*RequestMatch) GetAll added in v0.1.2 

func (m *RequestMatch) GetAll() *RequestMatch_Seq

func (*RequestMatch) GetAny added in v0.1.2 

func (m *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 (m *RequestMatch) GetMethod() *http_types.HttpMethod

func (*RequestMatch) GetNot added in v0.1.2 

func (m *RequestMatch) GetNot() *RequestMatch

func (*RequestMatch) GetPath added in v0.1.2 

func (m *RequestMatch) GetPath() *PathMatch

func (*RequestMatch) ProtoMessage added in v0.1.2 

func (*RequestMatch) ProtoMessage()

func (*RequestMatch) Reset added in v0.1.2 

func (m *RequestMatch) Reset()

func (*RequestMatch) String added in v0.1.2 

func (m *RequestMatch) String() string

func (*RequestMatch) XXX_DiscardUnknown added in v0.1.2 

func (m *RequestMatch) XXX_DiscardUnknown()

func (*RequestMatch) XXX_Marshal added in v0.1.2 

func (m *RequestMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMatch) XXX_Merge added in v0.1.2 

func (dst *RequestMatch) XXX_Merge(src proto.Message)

func (*RequestMatch) XXX_OneofFuncs added in v0.1.2 

func (*RequestMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*RequestMatch) XXX_Size added in v0.1.2 

func (m *RequestMatch) XXX_Size() int

func (*RequestMatch) XXX_Unmarshal added in v0.1.2 

func (m *RequestMatch) XXX_Unmarshal(b []byte) error

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"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RequestMatch_Seq) Descriptor added in v0.1.2 

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

func (*RequestMatch_Seq) GetMatches added in v0.1.2 

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

func (*RequestMatch_Seq) ProtoMessage added in v0.1.2 

func (*RequestMatch_Seq) ProtoMessage()

func (*RequestMatch_Seq) Reset added in v0.1.2 

func (m *RequestMatch_Seq) Reset()

func (*RequestMatch_Seq) String added in v0.1.2 

func (m *RequestMatch_Seq) String() string

func (*RequestMatch_Seq) XXX_DiscardUnknown added in v0.1.2 

func (m *RequestMatch_Seq) XXX_DiscardUnknown()

func (*RequestMatch_Seq) XXX_Marshal added in v0.1.2 

func (m *RequestMatch_Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMatch_Seq) XXX_Merge added in v0.1.2 

func (dst *RequestMatch_Seq) XXX_Merge(src proto.Message)

func (*RequestMatch_Seq) XXX_Size added in v0.1.2 

func (m *RequestMatch_Seq) XXX_Size() int

func (*RequestMatch_Seq) XXX_Unmarshal added in v0.1.2 

func (m *RequestMatch_Seq) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseClass) Descriptor added in v0.1.2 

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

func (*ResponseClass) GetCondition added in v0.1.2 

func (m *ResponseClass) GetCondition() *ResponseMatch

func (*ResponseClass) GetIsFailure added in v0.1.2 

func (m *ResponseClass) GetIsFailure() bool

func (*ResponseClass) ProtoMessage added in v0.1.2 

func (*ResponseClass) ProtoMessage()

func (*ResponseClass) Reset added in v0.1.2 

func (m *ResponseClass) Reset()

func (*ResponseClass) String added in v0.1.2 

func (m *ResponseClass) String() string

func (*ResponseClass) XXX_DiscardUnknown added in v0.1.2 

func (m *ResponseClass) XXX_DiscardUnknown()

func (*ResponseClass) XXX_Marshal added in v0.1.2 

func (m *ResponseClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseClass) XXX_Merge added in v0.1.2 

func (dst *ResponseClass) XXX_Merge(src proto.Message)

func (*ResponseClass) XXX_Size added in v0.1.2 

func (m *ResponseClass) XXX_Size() int

func (*ResponseClass) XXX_Unmarshal added in v0.1.2 

func (m *ResponseClass) XXX_Unmarshal(b []byte) error

type ResponseMatch added in v0.1.2 

type ResponseMatch struct {
	// Types that are valid to be assigned to Match:
	//	*ResponseMatch_All
	//	*ResponseMatch_Any
	//	*ResponseMatch_Not
	//	*ResponseMatch_Status
	Match                isResponseMatch_Match `protobuf_oneof:"match"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ResponseMatch) Descriptor added in v0.1.2 

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

func (*ResponseMatch) GetAll added in v0.1.2 

func (m *ResponseMatch) GetAll() *ResponseMatch_Seq

func (*ResponseMatch) GetAny added in v0.1.2 

func (m *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 (m *ResponseMatch) GetNot() *ResponseMatch

func (*ResponseMatch) GetStatus added in v0.1.2 

func (m *ResponseMatch) GetStatus() *HttpStatusRange

func (*ResponseMatch) ProtoMessage added in v0.1.2 

func (*ResponseMatch) ProtoMessage()

func (*ResponseMatch) Reset added in v0.1.2 

func (m *ResponseMatch) Reset()

func (*ResponseMatch) String added in v0.1.2 

func (m *ResponseMatch) String() string

func (*ResponseMatch) XXX_DiscardUnknown added in v0.1.2 

func (m *ResponseMatch) XXX_DiscardUnknown()

func (*ResponseMatch) XXX_Marshal added in v0.1.2 

func (m *ResponseMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseMatch) XXX_Merge added in v0.1.2 

func (dst *ResponseMatch) XXX_Merge(src proto.Message)

func (*ResponseMatch) XXX_OneofFuncs added in v0.1.2 

func (*ResponseMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ResponseMatch) XXX_Size added in v0.1.2 

func (m *ResponseMatch) XXX_Size() int

func (*ResponseMatch) XXX_Unmarshal added in v0.1.2 

func (m *ResponseMatch) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ResponseMatch_Seq) Descriptor added in v0.1.2 

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

func (*ResponseMatch_Seq) GetMatches added in v0.1.2 

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

func (*ResponseMatch_Seq) ProtoMessage added in v0.1.2 

func (*ResponseMatch_Seq) ProtoMessage()

func (*ResponseMatch_Seq) Reset added in v0.1.2 

func (m *ResponseMatch_Seq) Reset()

func (*ResponseMatch_Seq) String added in v0.1.2 

func (m *ResponseMatch_Seq) String() string

func (*ResponseMatch_Seq) XXX_DiscardUnknown added in v0.1.2 

func (m *ResponseMatch_Seq) XXX_DiscardUnknown()

func (*ResponseMatch_Seq) XXX_Marshal added in v0.1.2 

func (m *ResponseMatch_Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseMatch_Seq) XXX_Merge added in v0.1.2 

func (dst *ResponseMatch_Seq) XXX_Merge(src proto.Message)

func (*ResponseMatch_Seq) XXX_Size added in v0.1.2 

func (m *ResponseMatch_Seq) XXX_Size() int

func (*ResponseMatch_Seq) XXX_Unmarshal added in v0.1.2 

func (m *ResponseMatch_Seq) XXX_Unmarshal(b []byte) error

type ResponseMatch_Status added in v0.1.2 

type ResponseMatch_Status struct {
	Status *HttpStatusRange `protobuf:"bytes,4,opt,name=status,proto3,oneof"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RetryBudget) Descriptor added in v0.1.5 

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

func (*RetryBudget) GetMinRetriesPerSecond added in v0.1.5 

func (m *RetryBudget) GetMinRetriesPerSecond() uint32

func (*RetryBudget) GetRetryRatio added in v0.1.5 

func (m *RetryBudget) GetRetryRatio() float32

func (*RetryBudget) GetTtl added in v0.1.5 

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

func (*RetryBudget) ProtoMessage added in v0.1.5 

func (*RetryBudget) ProtoMessage()

func (*RetryBudget) Reset added in v0.1.5 

func (m *RetryBudget) Reset()

func (*RetryBudget) String added in v0.1.5 

func (m *RetryBudget) String() string

func (*RetryBudget) XXX_DiscardUnknown added in v0.1.5 

func (m *RetryBudget) XXX_DiscardUnknown()

func (*RetryBudget) XXX_Marshal added in v0.1.5 

func (m *RetryBudget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryBudget) XXX_Merge added in v0.1.5 

func (dst *RetryBudget) XXX_Merge(src proto.Message)

func (*RetryBudget) XXX_Size added in v0.1.5 

func (m *RetryBudget) XXX_Size() int

func (*RetryBudget) XXX_Unmarshal added in v0.1.5 

func (m *RetryBudget) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Route) Descriptor added in v0.1.2 

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

func (*Route) GetCondition added in v0.1.2 

func (m *Route) GetCondition() *RequestMatch

func (*Route) GetIsRetryable added in v0.1.5 

func (m *Route) GetIsRetryable() bool

func (*Route) GetMetricsLabels added in v0.1.3 

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

func (*Route) GetResponseClasses added in v0.1.2 

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

func (*Route) GetTimeout added in v0.1.5 

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

func (*Route) ProtoMessage added in v0.1.2 

func (*Route) ProtoMessage()

func (*Route) Reset added in v0.1.2 

func (m *Route) Reset()

func (*Route) String added in v0.1.2 

func (m *Route) String() string

func (*Route) XXX_DiscardUnknown added in v0.1.2 

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal added in v0.1.2 

func (m *Route) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Route) XXX_Merge added in v0.1.2 

func (dst *Route) XXX_Merge(src proto.Message)

func (*Route) XXX_Size added in v0.1.2 

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal added in v0.1.2 

func (m *Route) XXX_Unmarshal(b []byte) error

type TlsIdentity 

type TlsIdentity struct {
	// Types that are valid to be assigned to Strategy:
	//	*TlsIdentity_DnsLikeIdentity_
	Strategy             isTlsIdentity_Strategy `protobuf_oneof:"strategy"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Which strategy should be used for verifying TLS.

func (*TlsIdentity) Descriptor 

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

func (*TlsIdentity) GetDnsLikeIdentity added in v0.1.7 

func (m *TlsIdentity) GetDnsLikeIdentity() *TlsIdentity_DnsLikeIdentity

func (*TlsIdentity) GetStrategy 

func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy

func (*TlsIdentity) ProtoMessage 

func (*TlsIdentity) ProtoMessage()

func (*TlsIdentity) Reset 

func (m *TlsIdentity) Reset()

func (*TlsIdentity) String 

func (m *TlsIdentity) String() string

func (*TlsIdentity) XXX_DiscardUnknown added in v0.1.2 

func (m *TlsIdentity) XXX_DiscardUnknown()

func (*TlsIdentity) XXX_Marshal added in v0.1.2 

func (m *TlsIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TlsIdentity) XXX_Merge added in v0.1.2 

func (dst *TlsIdentity) XXX_Merge(src proto.Message)

func (*TlsIdentity) XXX_OneofFuncs 

func (*TlsIdentity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TlsIdentity) XXX_Size added in v0.1.2 

func (m *TlsIdentity) XXX_Size() int

func (*TlsIdentity) XXX_Unmarshal added in v0.1.2 

func (m *TlsIdentity) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Verify the certificate based on the Kubernetes pod identity.

func (*TlsIdentity_DnsLikeIdentity) Descriptor added in v0.1.7 

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

func (*TlsIdentity_DnsLikeIdentity) GetName added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) GetName() string

func (*TlsIdentity_DnsLikeIdentity) ProtoMessage added in v0.1.7 

func (*TlsIdentity_DnsLikeIdentity) ProtoMessage()

func (*TlsIdentity_DnsLikeIdentity) Reset added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) Reset()

func (*TlsIdentity_DnsLikeIdentity) String added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) String() string

func (*TlsIdentity_DnsLikeIdentity) XXX_DiscardUnknown added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) XXX_DiscardUnknown()

func (*TlsIdentity_DnsLikeIdentity) XXX_Marshal added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TlsIdentity_DnsLikeIdentity) XXX_Merge added in v0.1.7 

func (dst *TlsIdentity_DnsLikeIdentity) XXX_Merge(src proto.Message)

func (*TlsIdentity_DnsLikeIdentity) XXX_Size added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) XXX_Size() int

func (*TlsIdentity_DnsLikeIdentity) XXX_Unmarshal added in v0.1.7 

func (m *TlsIdentity_DnsLikeIdentity) XXX_Unmarshal(b []byte) error

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 Update 

type Update struct {
	// Types that are valid to be assigned to Update:
	//	*Update_Add
	//	*Update_Remove
	//	*Update_NoEndpoints
	Update               isUpdate_Update `protobuf_oneof:"update"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Update) Descriptor 

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

func (*Update) GetAdd 

func (m *Update) GetAdd() *WeightedAddrSet

func (*Update) GetNoEndpoints 

func (m *Update) GetNoEndpoints() *NoEndpoints

func (*Update) GetRemove 

func (m *Update) GetRemove() *AddrSet

func (*Update) GetUpdate 

func (m *Update) GetUpdate() isUpdate_Update

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) String 

func (m *Update) String() string

func (*Update) XXX_DiscardUnknown added in v0.1.2 

func (m *Update) XXX_DiscardUnknown()

func (*Update) XXX_Marshal added in v0.1.2 

func (m *Update) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Update) XXX_Merge added in v0.1.2 

func (dst *Update) XXX_Merge(src proto.Message)

func (*Update) XXX_OneofFuncs 

func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Update) XXX_Size added in v0.1.2 

func (m *Update) XXX_Size() int

func (*Update) XXX_Unmarshal added in v0.1.2 

func (m *Update) XXX_Unmarshal(b []byte) error

type Update_Add 

type Update_Add struct {
	Add *WeightedAddrSet `protobuf:"bytes,1,opt,name=add,proto3,oneof"`
}

type Update_NoEndpoints 

type Update_NoEndpoints struct {
	NoEndpoints *NoEndpoints `protobuf:"bytes,3,opt,name=no_endpoints,json=noEndpoints,proto3,oneof"`
}

type Update_Remove 

type Update_Remove struct {
	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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WeightedAddr) Descriptor 

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

func (*WeightedAddr) GetAddr 

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

func (*WeightedAddr) GetAuthorityOverride added in v0.1.12 

func (m *WeightedAddr) GetAuthorityOverride() *AuthorityOverride

func (*WeightedAddr) GetMetricLabels 

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

func (*WeightedAddr) GetProtocolHint 

func (m *WeightedAddr) GetProtocolHint() *ProtocolHint

func (*WeightedAddr) GetTlsIdentity 

func (m *WeightedAddr) GetTlsIdentity() *TlsIdentity

func (*WeightedAddr) GetWeight 

func (m *WeightedAddr) GetWeight() uint32

func (*WeightedAddr) ProtoMessage 

func (*WeightedAddr) ProtoMessage()

func (*WeightedAddr) Reset 

func (m *WeightedAddr) Reset()

func (*WeightedAddr) String 

func (m *WeightedAddr) String() string

func (*WeightedAddr) XXX_DiscardUnknown added in v0.1.2 

func (m *WeightedAddr) XXX_DiscardUnknown()

func (*WeightedAddr) XXX_Marshal added in v0.1.2 

func (m *WeightedAddr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WeightedAddr) XXX_Merge added in v0.1.2 

func (dst *WeightedAddr) XXX_Merge(src proto.Message)

func (*WeightedAddr) XXX_Size added in v0.1.2 

func (m *WeightedAddr) XXX_Size() int

func (*WeightedAddr) XXX_Unmarshal added in v0.1.2 

func (m *WeightedAddr) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WeightedAddrSet) Descriptor 

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

func (*WeightedAddrSet) GetAddrs 

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

func (*WeightedAddrSet) GetMetricLabels 

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

func (*WeightedAddrSet) ProtoMessage 

func (*WeightedAddrSet) ProtoMessage()

func (*WeightedAddrSet) Reset 

func (m *WeightedAddrSet) Reset()

func (*WeightedAddrSet) String 

func (m *WeightedAddrSet) String() string

func (*WeightedAddrSet) XXX_DiscardUnknown added in v0.1.2 

func (m *WeightedAddrSet) XXX_DiscardUnknown()

func (*WeightedAddrSet) XXX_Marshal added in v0.1.2 

func (m *WeightedAddrSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WeightedAddrSet) XXX_Merge added in v0.1.2 

func (dst *WeightedAddrSet) XXX_Merge(src proto.Message)

func (*WeightedAddrSet) XXX_Size added in v0.1.2 

func (m *WeightedAddrSet) XXX_Size() int

func (*WeightedAddrSet) XXX_Unmarshal added in v0.1.2 

func (m *WeightedAddrSet) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WeightedDst) Descriptor added in v0.1.9 

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

func (*WeightedDst) GetAuthority added in v0.1.9 

func (m *WeightedDst) GetAuthority() string

func (*WeightedDst) GetWeight added in v0.1.9 

func (m *WeightedDst) GetWeight() uint32

func (*WeightedDst) ProtoMessage added in v0.1.9 

func (*WeightedDst) ProtoMessage()

func (*WeightedDst) Reset added in v0.1.9 

func (m *WeightedDst) Reset()

func (*WeightedDst) String added in v0.1.9 

func (m *WeightedDst) String() string

func (*WeightedDst) XXX_DiscardUnknown added in v0.1.9 

func (m *WeightedDst) XXX_DiscardUnknown()

func (*WeightedDst) XXX_Marshal added in v0.1.9 

func (m *WeightedDst) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WeightedDst) XXX_Merge added in v0.1.9 

func (dst *WeightedDst) XXX_Merge(src proto.Message)

func (*WeightedDst) XXX_Size added in v0.1.9 

func (m *WeightedDst) XXX_Size() int

func (*WeightedDst) XXX_Unmarshal added in v0.1.9 

func (m *WeightedDst) XXX_Unmarshal(b []byte) error

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.