destination

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2018 License: Apache-2.0 Imports: 7 Imported by: 102

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

func (*GetDestination) Descriptor 

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

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 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"`
	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) GetResponseClasses added in v0.1.2 

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

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_K8SPodIdentity_
	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) GetK8SPodIdentity 

func (m *TlsIdentity) GetK8SPodIdentity() *TlsIdentity_K8SPodIdentity

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_K8SPodIdentity 

type TlsIdentity_K8SPodIdentity struct {
	// The pod_identity string is of the format:
	// {owner_name}.{owner_type}.{pod_ns}.linkerd-managed.{controller_ns}.svc.cluster.local
	PodIdentity string `protobuf:"bytes,1,opt,name=pod_identity,json=podIdentity,proto3" json:"pod_identity,omitempty"`
	// The Kubernetes namespace of the pod's Linkerd2 control plane.
	ControllerNs         string   `protobuf:"bytes,2,opt,name=controller_ns,json=controllerNs,proto3" json:"controller_ns,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Verify the certificate based on the Kubernetes pod identity.

func (*TlsIdentity_K8SPodIdentity) Descriptor 

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

func (*TlsIdentity_K8SPodIdentity) GetControllerNs 

func (m *TlsIdentity_K8SPodIdentity) GetControllerNs() string

func (*TlsIdentity_K8SPodIdentity) GetPodIdentity 

func (m *TlsIdentity_K8SPodIdentity) GetPodIdentity() string

func (*TlsIdentity_K8SPodIdentity) ProtoMessage 

func (*TlsIdentity_K8SPodIdentity) ProtoMessage()

func (*TlsIdentity_K8SPodIdentity) Reset 

func (m *TlsIdentity_K8SPodIdentity) Reset()

func (*TlsIdentity_K8SPodIdentity) String 

func (m *TlsIdentity_K8SPodIdentity) String() string

func (*TlsIdentity_K8SPodIdentity) XXX_DiscardUnknown added in v0.1.2 

func (m *TlsIdentity_K8SPodIdentity) XXX_DiscardUnknown()

func (*TlsIdentity_K8SPodIdentity) XXX_Marshal added in v0.1.2 

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

func (*TlsIdentity_K8SPodIdentity) XXX_Merge added in v0.1.2 

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

func (*TlsIdentity_K8SPodIdentity) XXX_Size added in v0.1.2 

func (m *TlsIdentity_K8SPodIdentity) XXX_Size() int

func (*TlsIdentity_K8SPodIdentity) XXX_Unmarshal added in v0.1.2 

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

type TlsIdentity_K8SPodIdentity_ 

type TlsIdentity_K8SPodIdentity_ struct {
	K8SPodIdentity *TlsIdentity_K8SPodIdentity `protobuf:"bytes,2,opt,name=k8s_pod_identity,json=k8sPodIdentity,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"`
	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) 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

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.