Versions in this module Expand all Collapse all v0 v0.1.0 Dec 5, 2017 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 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) 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_Remove struct + Remove *AddrSet + type WeightedAddr struct + Addr *conduit_common.TcpAddress + Weight uint32 + func (*WeightedAddr) Descriptor() ([]byte, []int) + func (*WeightedAddr) ProtoMessage() + func (m *WeightedAddr) GetAddr() *conduit_common.TcpAddress + func (m *WeightedAddr) GetWeight() uint32 + func (m *WeightedAddr) Reset() + func (m *WeightedAddr) String() string + type WeightedAddrSet struct + Addrs []*WeightedAddr + func (*WeightedAddrSet) Descriptor() ([]byte, []int) + func (*WeightedAddrSet) ProtoMessage() + func (m *WeightedAddrSet) GetAddrs() []*WeightedAddr + func (m *WeightedAddrSet) Reset() + func (m *WeightedAddrSet) String() string
Go to main page