Versions in this module Expand all Collapse all v0 v0.5.0 Jul 5, 2018 Changes in this version + func RegisterDestinationServer(s *grpc.Server, srv DestinationServer) + type AddrSet struct + Addrs []*conduit_common.TcpAddress + func (*AddrSet) Descriptor() ([]byte, []int) + func (*AddrSet) ProtoMessage() + func (m *AddrSet) GetAddrs() []*conduit_common.TcpAddress + func (m *AddrSet) Reset() + func (m *AddrSet) String() string + type DestinationClient interface + Get func(ctx context.Context, in *conduit_common.Destination, opts ...grpc.CallOption) (Destination_GetClient, error) + func NewDestinationClient(cc *grpc.ClientConn) DestinationClient + type DestinationServer interface + Get func(*conduit_common.Destination, Destination_GetServer) error + type Destination_GetClient interface + Recv func() (*Update, error) + type Destination_GetServer interface + Send func(*Update) error + type NoEndpoints struct + Exists bool + func (*NoEndpoints) Descriptor() ([]byte, []int) + func (*NoEndpoints) ProtoMessage() + func (m *NoEndpoints) GetExists() bool + func (m *NoEndpoints) Reset() + func (m *NoEndpoints) String() string + type TlsIdentity struct + Strategy isTlsIdentity_Strategy + func (*TlsIdentity) Descriptor() ([]byte, []int) + func (*TlsIdentity) ProtoMessage() + func (*TlsIdentity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *TlsIdentity) GetK8SPodIdentity() *TlsIdentity_K8SPodIdentity + func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy + func (m *TlsIdentity) Reset() + func (m *TlsIdentity) String() string + type TlsIdentity_K8SPodIdentity struct + ControllerNs string + PodIdentity string + func (*TlsIdentity_K8SPodIdentity) Descriptor() ([]byte, []int) + func (*TlsIdentity_K8SPodIdentity) ProtoMessage() + func (m *TlsIdentity_K8SPodIdentity) GetControllerNs() string + func (m *TlsIdentity_K8SPodIdentity) GetPodIdentity() string + func (m *TlsIdentity_K8SPodIdentity) Reset() + func (m *TlsIdentity_K8SPodIdentity) String() string + type TlsIdentity_K8SPodIdentity_ struct + K8SPodIdentity *TlsIdentity_K8SPodIdentity + type Update struct + Update isUpdate_Update + func (*Update) Descriptor() ([]byte, []int) + func (*Update) ProtoMessage() + func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *Update) GetAdd() *WeightedAddrSet + func (m *Update) GetNoEndpoints() *NoEndpoints + func (m *Update) GetRemove() *AddrSet + func (m *Update) GetUpdate() isUpdate_Update + func (m *Update) Reset() + func (m *Update) String() string + type Update_Add struct + Add *WeightedAddrSet + type Update_NoEndpoints struct + NoEndpoints *NoEndpoints + type Update_Remove struct + Remove *AddrSet + type WeightedAddr struct + Addr *conduit_common.TcpAddress + MetricLabels map[string]string + TlsIdentity *TlsIdentity + Weight uint32 + func (*WeightedAddr) Descriptor() ([]byte, []int) + func (*WeightedAddr) ProtoMessage() + func (m *WeightedAddr) GetAddr() *conduit_common.TcpAddress + func (m *WeightedAddr) GetMetricLabels() map[string]string + func (m *WeightedAddr) GetTlsIdentity() *TlsIdentity + func (m *WeightedAddr) GetWeight() uint32 + func (m *WeightedAddr) Reset() + func (m *WeightedAddr) String() string + type WeightedAddrSet struct + Addrs []*WeightedAddr + MetricLabels map[string]string + func (*WeightedAddrSet) Descriptor() ([]byte, []int) + func (*WeightedAddrSet) ProtoMessage() + func (m *WeightedAddrSet) GetAddrs() []*WeightedAddr + func (m *WeightedAddrSet) GetMetricLabels() map[string]string + func (m *WeightedAddrSet) Reset() + func (m *WeightedAddrSet) String() string