Documentation
¶
Overview ¶
Package destination is a generated protocol buffer package.
It is generated from these files:
destination.proto
It has these top-level messages:
GetDestination Update AddrSet WeightedAddrSet WeightedAddr TlsIdentity NoEndpoints ProtocolHint
Index ¶
- func RegisterDestinationServer(s *grpc.Server, srv DestinationServer)
- type AddrSet
- type DestinationClient
- type DestinationServer
- type Destination_GetClient
- type Destination_GetServer
- type GetDestination
- type NoEndpoints
- type ProtocolHint
- func (*ProtocolHint) Descriptor() ([]byte, []int)
- func (m *ProtocolHint) GetH2() *ProtocolHint_H2
- func (m *ProtocolHint) GetProtocol() isProtocolHint_Protocol
- func (*ProtocolHint) ProtoMessage()
- func (m *ProtocolHint) Reset()
- func (m *ProtocolHint) String() string
- func (*ProtocolHint) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type ProtocolHint_H2
- type ProtocolHint_H2_
- type TlsIdentity
- func (*TlsIdentity) Descriptor() ([]byte, []int)
- func (m *TlsIdentity) GetK8SPodIdentity() *TlsIdentity_K8SPodIdentity
- func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy
- func (*TlsIdentity) ProtoMessage()
- func (m *TlsIdentity) Reset()
- func (m *TlsIdentity) String() string
- func (*TlsIdentity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type TlsIdentity_K8SPodIdentity
- func (*TlsIdentity_K8SPodIdentity) Descriptor() ([]byte, []int)
- func (m *TlsIdentity_K8SPodIdentity) GetControllerNs() string
- func (m *TlsIdentity_K8SPodIdentity) GetPodIdentity() string
- func (*TlsIdentity_K8SPodIdentity) ProtoMessage()
- func (m *TlsIdentity_K8SPodIdentity) Reset()
- func (m *TlsIdentity_K8SPodIdentity) String() string
- type TlsIdentity_K8SPodIdentity_
- type Update
- func (*Update) Descriptor() ([]byte, []int)
- func (m *Update) GetAdd() *WeightedAddrSet
- func (m *Update) GetNoEndpoints() *NoEndpoints
- func (m *Update) GetRemove() *AddrSet
- func (m *Update) GetUpdate() isUpdate_Update
- func (*Update) ProtoMessage()
- func (m *Update) Reset()
- func (m *Update) String() string
- func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Update_Add
- type Update_NoEndpoints
- type Update_Remove
- type WeightedAddr
- func (*WeightedAddr) Descriptor() ([]byte, []int)
- func (m *WeightedAddr) GetAddr() *io_linkerd_proxy_net.TcpAddress
- func (m *WeightedAddr) GetMetricLabels() map[string]string
- func (m *WeightedAddr) GetProtocolHint() *ProtocolHint
- func (m *WeightedAddr) GetTlsIdentity() *TlsIdentity
- func (m *WeightedAddr) GetWeight() uint32
- func (*WeightedAddr) ProtoMessage()
- func (m *WeightedAddr) Reset()
- func (m *WeightedAddr) String() string
- type WeightedAddrSet
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 []*io_linkerd_proxy_net.TcpAddress `protobuf:"bytes,1,rep,name=addrs" json:"addrs,omitempty"`
}
func (*AddrSet) Descriptor ¶
func (*AddrSet) GetAddrs ¶
func (m *AddrSet) GetAddrs() []*io_linkerd_proxy_net.TcpAddress
func (*AddrSet) ProtoMessage ¶
func (*AddrSet) ProtoMessage()
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)
}
func NewDestinationClient ¶
func NewDestinationClient(cc *grpc.ClientConn) DestinationClient
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
}
type Destination_GetClient ¶
type Destination_GetClient interface {
Recv() (*Update, error)
grpc.ClientStream
}
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" json:"scheme,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
}
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
type NoEndpoints ¶
type NoEndpoints struct {
Exists bool `protobuf:"varint,1,opt,name=exists" json:"exists,omitempty"`
}
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
type ProtocolHint ¶
type ProtocolHint struct {
// Types that are valid to be assigned to Protocol:
// *ProtocolHint_H2_
Protocol isProtocolHint_Protocol `protobuf_oneof:"protocol"`
}
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_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.
type ProtocolHint_H2 ¶
type ProtocolHint_H2 struct {
}
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
type ProtocolHint_H2_ ¶
type ProtocolHint_H2_ struct {
H2 *ProtocolHint_H2 `protobuf:"bytes,1,opt,name=h2,oneof"`
}
type TlsIdentity ¶
type TlsIdentity struct {
// Types that are valid to be assigned to Strategy:
// *TlsIdentity_K8SPodIdentity_
Strategy isTlsIdentity_Strategy `protobuf_oneof:"strategy"`
}
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_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.
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" 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" json:"controller_ns,omitempty"`
}
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
type TlsIdentity_K8SPodIdentity_ ¶
type TlsIdentity_K8SPodIdentity_ struct {
K8SPodIdentity *TlsIdentity_K8SPodIdentity `protobuf:"bytes,2,opt,name=k8s_pod_identity,json=k8sPodIdentity,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"`
}
func (*Update) Descriptor ¶
func (*Update) GetAdd ¶
func (m *Update) GetAdd() *WeightedAddrSet
func (*Update) GetNoEndpoints ¶
func (m *Update) GetNoEndpoints() *NoEndpoints
func (*Update) ProtoMessage ¶
func (*Update) ProtoMessage()
type Update_Add ¶
type Update_Add struct {
Add *WeightedAddrSet `protobuf:"bytes,1,opt,name=add,oneof"`
}
type Update_NoEndpoints ¶
type Update_NoEndpoints struct {
NoEndpoints *NoEndpoints `protobuf:"bytes,3,opt,name=no_endpoints,json=noEndpoints,oneof"`
}
type Update_Remove ¶
type Update_Remove struct {
Remove *AddrSet `protobuf:"bytes,2,opt,name=remove,oneof"`
}
type WeightedAddr ¶
type WeightedAddr struct {
Addr *io_linkerd_proxy_net.TcpAddress `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
Weight uint32 `protobuf:"varint,3,opt,name=weight" json:"weight,omitempty"`
MetricLabels map[string]string `` /* 164-byte string literal not displayed */
TlsIdentity *TlsIdentity `protobuf:"bytes,5,opt,name=tls_identity,json=tlsIdentity" json:"tls_identity,omitempty"`
ProtocolHint *ProtocolHint `protobuf:"bytes,6,opt,name=protocol_hint,json=protocolHint" json:"protocol_hint,omitempty"`
}
func (*WeightedAddr) Descriptor ¶
func (*WeightedAddr) Descriptor() ([]byte, []int)
func (*WeightedAddr) GetAddr ¶
func (m *WeightedAddr) GetAddr() *io_linkerd_proxy_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
type WeightedAddrSet ¶
type WeightedAddrSet struct {
Addrs []*WeightedAddr `protobuf:"bytes,1,rep,name=addrs" json:"addrs,omitempty"`
MetricLabels map[string]string `` /* 164-byte string literal not displayed */
}
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
Click to show internal directories.
Click to hide internal directories.