Documentation ¶
Index ¶
- Variables
- func RegisterRPCServer(s *grpc.Server, srv RPCServer)
- type ConnectPeerReply
- func (*ConnectPeerReply) Descriptor() ([]byte, []int)
- func (*ConnectPeerReply) ProtoMessage()
- func (m *ConnectPeerReply) Reset()
- func (m *ConnectPeerReply) String() string
- func (m *ConnectPeerReply) XXX_DiscardUnknown()
- func (m *ConnectPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectPeerReply) XXX_Merge(src proto.Message)
- func (m *ConnectPeerReply) XXX_Size() int
- func (m *ConnectPeerReply) XXX_Unmarshal(b []byte) error
- type ConnectPeerRequest
- func (*ConnectPeerRequest) Descriptor() ([]byte, []int)
- func (m *ConnectPeerRequest) GetPeerInfo() *PeerAddrInfo
- func (*ConnectPeerRequest) ProtoMessage()
- func (m *ConnectPeerRequest) Reset()
- func (m *ConnectPeerRequest) String() string
- func (m *ConnectPeerRequest) XXX_DiscardUnknown()
- func (m *ConnectPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectPeerRequest) XXX_Merge(src proto.Message)
- func (m *ConnectPeerRequest) XXX_Size() int
- func (m *ConnectPeerRequest) XXX_Unmarshal(b []byte) error
- type Connectedness
- type ConnectednessReply
- func (*ConnectednessReply) Descriptor() ([]byte, []int)
- func (m *ConnectednessReply) GetConnectedness() Connectedness
- func (*ConnectednessReply) ProtoMessage()
- func (m *ConnectednessReply) Reset()
- func (m *ConnectednessReply) String() string
- func (m *ConnectednessReply) XXX_DiscardUnknown()
- func (m *ConnectednessReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectednessReply) XXX_Merge(src proto.Message)
- func (m *ConnectednessReply) XXX_Size() int
- func (m *ConnectednessReply) XXX_Unmarshal(b []byte) error
- type ConnectednessRequest
- func (*ConnectednessRequest) Descriptor() ([]byte, []int)
- func (m *ConnectednessRequest) GetPeerID() string
- func (*ConnectednessRequest) ProtoMessage()
- func (m *ConnectednessRequest) Reset()
- func (m *ConnectednessRequest) String() string
- func (m *ConnectednessRequest) XXX_DiscardUnknown()
- func (m *ConnectednessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectednessRequest) XXX_Merge(src proto.Message)
- func (m *ConnectednessRequest) XXX_Size() int
- func (m *ConnectednessRequest) XXX_Unmarshal(b []byte) error
- type DisconnectPeerReply
- func (*DisconnectPeerReply) Descriptor() ([]byte, []int)
- func (*DisconnectPeerReply) ProtoMessage()
- func (m *DisconnectPeerReply) Reset()
- func (m *DisconnectPeerReply) String() string
- func (m *DisconnectPeerReply) XXX_DiscardUnknown()
- func (m *DisconnectPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DisconnectPeerReply) XXX_Merge(src proto.Message)
- func (m *DisconnectPeerReply) XXX_Size() int
- func (m *DisconnectPeerReply) XXX_Unmarshal(b []byte) error
- type DisconnectPeerRequest
- func (*DisconnectPeerRequest) Descriptor() ([]byte, []int)
- func (m *DisconnectPeerRequest) GetPeerID() string
- func (*DisconnectPeerRequest) ProtoMessage()
- func (m *DisconnectPeerRequest) Reset()
- func (m *DisconnectPeerRequest) String() string
- func (m *DisconnectPeerRequest) XXX_DiscardUnknown()
- func (m *DisconnectPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DisconnectPeerRequest) XXX_Merge(src proto.Message)
- func (m *DisconnectPeerRequest) XXX_Size() int
- func (m *DisconnectPeerRequest) XXX_Unmarshal(b []byte) error
- type FindPeerReply
- func (*FindPeerReply) Descriptor() ([]byte, []int)
- func (m *FindPeerReply) GetPeerInfo() *PeerInfo
- func (*FindPeerReply) ProtoMessage()
- func (m *FindPeerReply) Reset()
- func (m *FindPeerReply) String() string
- func (m *FindPeerReply) XXX_DiscardUnknown()
- func (m *FindPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindPeerReply) XXX_Merge(src proto.Message)
- func (m *FindPeerReply) XXX_Size() int
- func (m *FindPeerReply) XXX_Unmarshal(b []byte) error
- type FindPeerRequest
- func (*FindPeerRequest) Descriptor() ([]byte, []int)
- func (m *FindPeerRequest) GetPeerID() string
- func (*FindPeerRequest) ProtoMessage()
- func (m *FindPeerRequest) Reset()
- func (m *FindPeerRequest) String() string
- func (m *FindPeerRequest) XXX_DiscardUnknown()
- func (m *FindPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindPeerRequest) XXX_Merge(src proto.Message)
- func (m *FindPeerRequest) XXX_Size() int
- func (m *FindPeerRequest) XXX_Unmarshal(b []byte) error
- type ListenAddrReply
- func (*ListenAddrReply) Descriptor() ([]byte, []int)
- func (m *ListenAddrReply) GetAddrInfo() *PeerAddrInfo
- func (*ListenAddrReply) ProtoMessage()
- func (m *ListenAddrReply) Reset()
- func (m *ListenAddrReply) String() string
- func (m *ListenAddrReply) XXX_DiscardUnknown()
- func (m *ListenAddrReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListenAddrReply) XXX_Merge(src proto.Message)
- func (m *ListenAddrReply) XXX_Size() int
- func (m *ListenAddrReply) XXX_Unmarshal(b []byte) error
- type ListenAddrRequest
- func (*ListenAddrRequest) Descriptor() ([]byte, []int)
- func (*ListenAddrRequest) ProtoMessage()
- func (m *ListenAddrRequest) Reset()
- func (m *ListenAddrRequest) String() string
- func (m *ListenAddrRequest) XXX_DiscardUnknown()
- func (m *ListenAddrRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListenAddrRequest) XXX_Merge(src proto.Message)
- func (m *ListenAddrRequest) XXX_Size() int
- func (m *ListenAddrRequest) XXX_Unmarshal(b []byte) error
- type Location
- func (*Location) Descriptor() ([]byte, []int)
- func (m *Location) GetCountry() string
- func (m *Location) GetLatitude() float32
- func (m *Location) GetLongitude() float32
- func (*Location) ProtoMessage()
- func (m *Location) Reset()
- func (m *Location) String() string
- func (m *Location) XXX_DiscardUnknown()
- func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Location) XXX_Merge(src proto.Message)
- func (m *Location) XXX_Size() int
- func (m *Location) XXX_Unmarshal(b []byte) error
- type PeerAddrInfo
- func (*PeerAddrInfo) Descriptor() ([]byte, []int)
- func (m *PeerAddrInfo) GetAddrs() []string
- func (m *PeerAddrInfo) GetID() string
- func (*PeerAddrInfo) ProtoMessage()
- func (m *PeerAddrInfo) Reset()
- func (m *PeerAddrInfo) String() string
- func (m *PeerAddrInfo) XXX_DiscardUnknown()
- func (m *PeerAddrInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerAddrInfo) XXX_Merge(src proto.Message)
- func (m *PeerAddrInfo) XXX_Size() int
- func (m *PeerAddrInfo) XXX_Unmarshal(b []byte) error
- type PeerInfo
- func (*PeerInfo) Descriptor() ([]byte, []int)
- func (m *PeerInfo) GetAddrInfo() *PeerAddrInfo
- func (m *PeerInfo) GetLocation() *Location
- func (*PeerInfo) ProtoMessage()
- func (m *PeerInfo) Reset()
- func (m *PeerInfo) String() string
- func (m *PeerInfo) XXX_DiscardUnknown()
- func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerInfo) XXX_Merge(src proto.Message)
- func (m *PeerInfo) XXX_Size() int
- func (m *PeerInfo) XXX_Unmarshal(b []byte) error
- type PeersReply
- func (*PeersReply) Descriptor() ([]byte, []int)
- func (m *PeersReply) GetPeers() []*PeerInfo
- func (*PeersReply) ProtoMessage()
- func (m *PeersReply) Reset()
- func (m *PeersReply) String() string
- func (m *PeersReply) XXX_DiscardUnknown()
- func (m *PeersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeersReply) XXX_Merge(src proto.Message)
- func (m *PeersReply) XXX_Size() int
- func (m *PeersReply) XXX_Unmarshal(b []byte) error
- type PeersRequest
- func (*PeersRequest) Descriptor() ([]byte, []int)
- func (*PeersRequest) ProtoMessage()
- func (m *PeersRequest) Reset()
- func (m *PeersRequest) String() string
- func (m *PeersRequest) XXX_DiscardUnknown()
- func (m *PeersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeersRequest) XXX_Merge(src proto.Message)
- func (m *PeersRequest) XXX_Size() int
- func (m *PeersRequest) XXX_Unmarshal(b []byte) error
- type RPC
- func (a *RPC) ConnectPeer(ctx context.Context, req *ConnectPeerRequest) (*ConnectPeerReply, error)
- func (a *RPC) Connectedness(ctx context.Context, req *ConnectednessRequest) (*ConnectednessReply, error)
- func (a *RPC) DisconnectPeer(ctx context.Context, req *DisconnectPeerRequest) (*DisconnectPeerReply, error)
- func (a *RPC) FindPeer(ctx context.Context, req *FindPeerRequest) (*FindPeerReply, error)
- func (a *RPC) ListenAddr(ctx context.Context, req *ListenAddrRequest) (*ListenAddrReply, error)
- func (a *RPC) Peers(ctx context.Context, req *PeersRequest) (*PeersReply, error)
- type RPCClient
- type RPCServer
- type UnimplementedRPCServer
- func (*UnimplementedRPCServer) ConnectPeer(ctx context.Context, req *ConnectPeerRequest) (*ConnectPeerReply, error)
- func (*UnimplementedRPCServer) Connectedness(ctx context.Context, req *ConnectednessRequest) (*ConnectednessReply, error)
- func (*UnimplementedRPCServer) DisconnectPeer(ctx context.Context, req *DisconnectPeerRequest) (*DisconnectPeerReply, error)
- func (*UnimplementedRPCServer) FindPeer(ctx context.Context, req *FindPeerRequest) (*FindPeerReply, error)
- func (*UnimplementedRPCServer) ListenAddr(ctx context.Context, req *ListenAddrRequest) (*ListenAddrReply, error)
- func (*UnimplementedRPCServer) Peers(ctx context.Context, req *PeersRequest) (*PeersReply, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var Connectedness_name = map[int32]string{
0: "NotConnected",
1: "Connected",
2: "CanConnect",
3: "CannotConnect",
4: "Unknown",
5: "Error",
}
View Source
var Connectedness_value = map[string]int32{
"NotConnected": 0,
"Connected": 1,
"CanConnect": 2,
"CannotConnect": 3,
"Unknown": 4,
"Error": 5,
}
Functions ¶
func RegisterRPCServer ¶
Types ¶
type ConnectPeerReply ¶
type ConnectPeerReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectPeerReply) Descriptor ¶
func (*ConnectPeerReply) Descriptor() ([]byte, []int)
func (*ConnectPeerReply) ProtoMessage ¶
func (*ConnectPeerReply) ProtoMessage()
func (*ConnectPeerReply) Reset ¶
func (m *ConnectPeerReply) Reset()
func (*ConnectPeerReply) String ¶
func (m *ConnectPeerReply) String() string
func (*ConnectPeerReply) XXX_DiscardUnknown ¶
func (m *ConnectPeerReply) XXX_DiscardUnknown()
func (*ConnectPeerReply) XXX_Marshal ¶
func (m *ConnectPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectPeerReply) XXX_Merge ¶
func (m *ConnectPeerReply) XXX_Merge(src proto.Message)
func (*ConnectPeerReply) XXX_Size ¶
func (m *ConnectPeerReply) XXX_Size() int
func (*ConnectPeerReply) XXX_Unmarshal ¶
func (m *ConnectPeerReply) XXX_Unmarshal(b []byte) error
type ConnectPeerRequest ¶
type ConnectPeerRequest struct { PeerInfo *PeerAddrInfo `protobuf:"bytes,1,opt,name=peerInfo,proto3" json:"peerInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectPeerRequest) Descriptor ¶
func (*ConnectPeerRequest) Descriptor() ([]byte, []int)
func (*ConnectPeerRequest) GetPeerInfo ¶
func (m *ConnectPeerRequest) GetPeerInfo() *PeerAddrInfo
func (*ConnectPeerRequest) ProtoMessage ¶
func (*ConnectPeerRequest) ProtoMessage()
func (*ConnectPeerRequest) Reset ¶
func (m *ConnectPeerRequest) Reset()
func (*ConnectPeerRequest) String ¶
func (m *ConnectPeerRequest) String() string
func (*ConnectPeerRequest) XXX_DiscardUnknown ¶
func (m *ConnectPeerRequest) XXX_DiscardUnknown()
func (*ConnectPeerRequest) XXX_Marshal ¶
func (m *ConnectPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectPeerRequest) XXX_Merge ¶
func (m *ConnectPeerRequest) XXX_Merge(src proto.Message)
func (*ConnectPeerRequest) XXX_Size ¶
func (m *ConnectPeerRequest) XXX_Size() int
func (*ConnectPeerRequest) XXX_Unmarshal ¶
func (m *ConnectPeerRequest) XXX_Unmarshal(b []byte) error
type Connectedness ¶
type Connectedness int32
const ( Connectedness_NotConnected Connectedness = 0 Connectedness_Connected Connectedness = 1 Connectedness_CanConnect Connectedness = 2 Connectedness_CannotConnect Connectedness = 3 Connectedness_Unknown Connectedness = 4 Connectedness_Error Connectedness = 5 )
func (Connectedness) EnumDescriptor ¶
func (Connectedness) EnumDescriptor() ([]byte, []int)
func (Connectedness) String ¶
func (x Connectedness) String() string
type ConnectednessReply ¶
type ConnectednessReply struct { Connectedness Connectedness `protobuf:"varint,1,opt,name=connectedness,proto3,enum=net.rpc.Connectedness" json:"connectedness,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectednessReply) Descriptor ¶
func (*ConnectednessReply) Descriptor() ([]byte, []int)
func (*ConnectednessReply) GetConnectedness ¶
func (m *ConnectednessReply) GetConnectedness() Connectedness
func (*ConnectednessReply) ProtoMessage ¶
func (*ConnectednessReply) ProtoMessage()
func (*ConnectednessReply) Reset ¶
func (m *ConnectednessReply) Reset()
func (*ConnectednessReply) String ¶
func (m *ConnectednessReply) String() string
func (*ConnectednessReply) XXX_DiscardUnknown ¶
func (m *ConnectednessReply) XXX_DiscardUnknown()
func (*ConnectednessReply) XXX_Marshal ¶
func (m *ConnectednessReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectednessReply) XXX_Merge ¶
func (m *ConnectednessReply) XXX_Merge(src proto.Message)
func (*ConnectednessReply) XXX_Size ¶
func (m *ConnectednessReply) XXX_Size() int
func (*ConnectednessReply) XXX_Unmarshal ¶
func (m *ConnectednessReply) XXX_Unmarshal(b []byte) error
type ConnectednessRequest ¶
type ConnectednessRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectednessRequest) Descriptor ¶
func (*ConnectednessRequest) Descriptor() ([]byte, []int)
func (*ConnectednessRequest) GetPeerID ¶
func (m *ConnectednessRequest) GetPeerID() string
func (*ConnectednessRequest) ProtoMessage ¶
func (*ConnectednessRequest) ProtoMessage()
func (*ConnectednessRequest) Reset ¶
func (m *ConnectednessRequest) Reset()
func (*ConnectednessRequest) String ¶
func (m *ConnectednessRequest) String() string
func (*ConnectednessRequest) XXX_DiscardUnknown ¶
func (m *ConnectednessRequest) XXX_DiscardUnknown()
func (*ConnectednessRequest) XXX_Marshal ¶
func (m *ConnectednessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectednessRequest) XXX_Merge ¶
func (m *ConnectednessRequest) XXX_Merge(src proto.Message)
func (*ConnectednessRequest) XXX_Size ¶
func (m *ConnectednessRequest) XXX_Size() int
func (*ConnectednessRequest) XXX_Unmarshal ¶
func (m *ConnectednessRequest) XXX_Unmarshal(b []byte) error
type DisconnectPeerReply ¶
type DisconnectPeerReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DisconnectPeerReply) Descriptor ¶
func (*DisconnectPeerReply) Descriptor() ([]byte, []int)
func (*DisconnectPeerReply) ProtoMessage ¶
func (*DisconnectPeerReply) ProtoMessage()
func (*DisconnectPeerReply) Reset ¶
func (m *DisconnectPeerReply) Reset()
func (*DisconnectPeerReply) String ¶
func (m *DisconnectPeerReply) String() string
func (*DisconnectPeerReply) XXX_DiscardUnknown ¶
func (m *DisconnectPeerReply) XXX_DiscardUnknown()
func (*DisconnectPeerReply) XXX_Marshal ¶
func (m *DisconnectPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectPeerReply) XXX_Merge ¶
func (m *DisconnectPeerReply) XXX_Merge(src proto.Message)
func (*DisconnectPeerReply) XXX_Size ¶
func (m *DisconnectPeerReply) XXX_Size() int
func (*DisconnectPeerReply) XXX_Unmarshal ¶
func (m *DisconnectPeerReply) XXX_Unmarshal(b []byte) error
type DisconnectPeerRequest ¶
type DisconnectPeerRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DisconnectPeerRequest) Descriptor ¶
func (*DisconnectPeerRequest) Descriptor() ([]byte, []int)
func (*DisconnectPeerRequest) GetPeerID ¶
func (m *DisconnectPeerRequest) GetPeerID() string
func (*DisconnectPeerRequest) ProtoMessage ¶
func (*DisconnectPeerRequest) ProtoMessage()
func (*DisconnectPeerRequest) Reset ¶
func (m *DisconnectPeerRequest) Reset()
func (*DisconnectPeerRequest) String ¶
func (m *DisconnectPeerRequest) String() string
func (*DisconnectPeerRequest) XXX_DiscardUnknown ¶
func (m *DisconnectPeerRequest) XXX_DiscardUnknown()
func (*DisconnectPeerRequest) XXX_Marshal ¶
func (m *DisconnectPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectPeerRequest) XXX_Merge ¶
func (m *DisconnectPeerRequest) XXX_Merge(src proto.Message)
func (*DisconnectPeerRequest) XXX_Size ¶
func (m *DisconnectPeerRequest) XXX_Size() int
func (*DisconnectPeerRequest) XXX_Unmarshal ¶
func (m *DisconnectPeerRequest) XXX_Unmarshal(b []byte) error
type FindPeerReply ¶
type FindPeerReply struct { PeerInfo *PeerInfo `protobuf:"bytes,1,opt,name=peerInfo,proto3" json:"peerInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FindPeerReply) Descriptor ¶
func (*FindPeerReply) Descriptor() ([]byte, []int)
func (*FindPeerReply) GetPeerInfo ¶
func (m *FindPeerReply) GetPeerInfo() *PeerInfo
func (*FindPeerReply) ProtoMessage ¶
func (*FindPeerReply) ProtoMessage()
func (*FindPeerReply) Reset ¶
func (m *FindPeerReply) Reset()
func (*FindPeerReply) String ¶
func (m *FindPeerReply) String() string
func (*FindPeerReply) XXX_DiscardUnknown ¶
func (m *FindPeerReply) XXX_DiscardUnknown()
func (*FindPeerReply) XXX_Marshal ¶
func (m *FindPeerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FindPeerReply) XXX_Merge ¶
func (m *FindPeerReply) XXX_Merge(src proto.Message)
func (*FindPeerReply) XXX_Size ¶
func (m *FindPeerReply) XXX_Size() int
func (*FindPeerReply) XXX_Unmarshal ¶
func (m *FindPeerReply) XXX_Unmarshal(b []byte) error
type FindPeerRequest ¶
type FindPeerRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FindPeerRequest) Descriptor ¶
func (*FindPeerRequest) Descriptor() ([]byte, []int)
func (*FindPeerRequest) GetPeerID ¶
func (m *FindPeerRequest) GetPeerID() string
func (*FindPeerRequest) ProtoMessage ¶
func (*FindPeerRequest) ProtoMessage()
func (*FindPeerRequest) Reset ¶
func (m *FindPeerRequest) Reset()
func (*FindPeerRequest) String ¶
func (m *FindPeerRequest) String() string
func (*FindPeerRequest) XXX_DiscardUnknown ¶
func (m *FindPeerRequest) XXX_DiscardUnknown()
func (*FindPeerRequest) XXX_Marshal ¶
func (m *FindPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FindPeerRequest) XXX_Merge ¶
func (m *FindPeerRequest) XXX_Merge(src proto.Message)
func (*FindPeerRequest) XXX_Size ¶
func (m *FindPeerRequest) XXX_Size() int
func (*FindPeerRequest) XXX_Unmarshal ¶
func (m *FindPeerRequest) XXX_Unmarshal(b []byte) error
type ListenAddrReply ¶
type ListenAddrReply struct { AddrInfo *PeerAddrInfo `protobuf:"bytes,1,opt,name=addrInfo,proto3" json:"addrInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListenAddrReply) Descriptor ¶
func (*ListenAddrReply) Descriptor() ([]byte, []int)
func (*ListenAddrReply) GetAddrInfo ¶
func (m *ListenAddrReply) GetAddrInfo() *PeerAddrInfo
func (*ListenAddrReply) ProtoMessage ¶
func (*ListenAddrReply) ProtoMessage()
func (*ListenAddrReply) Reset ¶
func (m *ListenAddrReply) Reset()
func (*ListenAddrReply) String ¶
func (m *ListenAddrReply) String() string
func (*ListenAddrReply) XXX_DiscardUnknown ¶
func (m *ListenAddrReply) XXX_DiscardUnknown()
func (*ListenAddrReply) XXX_Marshal ¶
func (m *ListenAddrReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListenAddrReply) XXX_Merge ¶
func (m *ListenAddrReply) XXX_Merge(src proto.Message)
func (*ListenAddrReply) XXX_Size ¶
func (m *ListenAddrReply) XXX_Size() int
func (*ListenAddrReply) XXX_Unmarshal ¶
func (m *ListenAddrReply) XXX_Unmarshal(b []byte) error
type ListenAddrRequest ¶
type ListenAddrRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListenAddrRequest) Descriptor ¶
func (*ListenAddrRequest) Descriptor() ([]byte, []int)
func (*ListenAddrRequest) ProtoMessage ¶
func (*ListenAddrRequest) ProtoMessage()
func (*ListenAddrRequest) Reset ¶
func (m *ListenAddrRequest) Reset()
func (*ListenAddrRequest) String ¶
func (m *ListenAddrRequest) String() string
func (*ListenAddrRequest) XXX_DiscardUnknown ¶
func (m *ListenAddrRequest) XXX_DiscardUnknown()
func (*ListenAddrRequest) XXX_Marshal ¶
func (m *ListenAddrRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListenAddrRequest) XXX_Merge ¶
func (m *ListenAddrRequest) XXX_Merge(src proto.Message)
func (*ListenAddrRequest) XXX_Size ¶
func (m *ListenAddrRequest) XXX_Size() int
func (*ListenAddrRequest) XXX_Unmarshal ¶
func (m *ListenAddrRequest) XXX_Unmarshal(b []byte) error
type Location ¶
type Location struct { Country string `protobuf:"bytes,1,opt,name=country,proto3" json:"country,omitempty"` Latitude float32 `protobuf:"fixed32,2,opt,name=latitude,proto3" json:"latitude,omitempty"` Longitude float32 `protobuf:"fixed32,3,opt,name=longitude,proto3" json:"longitude,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Location) Descriptor ¶
func (*Location) GetCountry ¶
func (*Location) GetLatitude ¶
func (*Location) GetLongitude ¶
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
func (*Location) XXX_DiscardUnknown ¶
func (m *Location) XXX_DiscardUnknown()
func (*Location) XXX_Marshal ¶
func (*Location) XXX_Unmarshal ¶
type PeerAddrInfo ¶
type PeerAddrInfo struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Addrs []string `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeerAddrInfo) Descriptor ¶
func (*PeerAddrInfo) Descriptor() ([]byte, []int)
func (*PeerAddrInfo) GetAddrs ¶
func (m *PeerAddrInfo) GetAddrs() []string
func (*PeerAddrInfo) GetID ¶
func (m *PeerAddrInfo) GetID() string
func (*PeerAddrInfo) ProtoMessage ¶
func (*PeerAddrInfo) ProtoMessage()
func (*PeerAddrInfo) Reset ¶
func (m *PeerAddrInfo) Reset()
func (*PeerAddrInfo) String ¶
func (m *PeerAddrInfo) String() string
func (*PeerAddrInfo) XXX_DiscardUnknown ¶
func (m *PeerAddrInfo) XXX_DiscardUnknown()
func (*PeerAddrInfo) XXX_Marshal ¶
func (m *PeerAddrInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerAddrInfo) XXX_Merge ¶
func (m *PeerAddrInfo) XXX_Merge(src proto.Message)
func (*PeerAddrInfo) XXX_Size ¶
func (m *PeerAddrInfo) XXX_Size() int
func (*PeerAddrInfo) XXX_Unmarshal ¶
func (m *PeerAddrInfo) XXX_Unmarshal(b []byte) error
type PeerInfo ¶
type PeerInfo struct { AddrInfo *PeerAddrInfo `protobuf:"bytes,1,opt,name=addrInfo,proto3" json:"addrInfo,omitempty"` Location *Location `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeerInfo) Descriptor ¶
func (*PeerInfo) GetAddrInfo ¶
func (m *PeerInfo) GetAddrInfo() *PeerAddrInfo
func (*PeerInfo) GetLocation ¶
func (*PeerInfo) ProtoMessage ¶
func (*PeerInfo) ProtoMessage()
func (*PeerInfo) XXX_DiscardUnknown ¶
func (m *PeerInfo) XXX_DiscardUnknown()
func (*PeerInfo) XXX_Marshal ¶
func (*PeerInfo) XXX_Unmarshal ¶
type PeersReply ¶
type PeersReply struct { Peers []*PeerInfo `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeersReply) Descriptor ¶
func (*PeersReply) Descriptor() ([]byte, []int)
func (*PeersReply) GetPeers ¶
func (m *PeersReply) GetPeers() []*PeerInfo
func (*PeersReply) ProtoMessage ¶
func (*PeersReply) ProtoMessage()
func (*PeersReply) Reset ¶
func (m *PeersReply) Reset()
func (*PeersReply) String ¶
func (m *PeersReply) String() string
func (*PeersReply) XXX_DiscardUnknown ¶
func (m *PeersReply) XXX_DiscardUnknown()
func (*PeersReply) XXX_Marshal ¶
func (m *PeersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeersReply) XXX_Merge ¶
func (m *PeersReply) XXX_Merge(src proto.Message)
func (*PeersReply) XXX_Size ¶
func (m *PeersReply) XXX_Size() int
func (*PeersReply) XXX_Unmarshal ¶
func (m *PeersReply) XXX_Unmarshal(b []byte) error
type PeersRequest ¶
type PeersRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeersRequest) Descriptor ¶
func (*PeersRequest) Descriptor() ([]byte, []int)
func (*PeersRequest) ProtoMessage ¶
func (*PeersRequest) ProtoMessage()
func (*PeersRequest) Reset ¶
func (m *PeersRequest) Reset()
func (*PeersRequest) String ¶
func (m *PeersRequest) String() string
func (*PeersRequest) XXX_DiscardUnknown ¶
func (m *PeersRequest) XXX_DiscardUnknown()
func (*PeersRequest) XXX_Marshal ¶
func (m *PeersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeersRequest) XXX_Merge ¶
func (m *PeersRequest) XXX_Merge(src proto.Message)
func (*PeersRequest) XXX_Size ¶
func (m *PeersRequest) XXX_Size() int
func (*PeersRequest) XXX_Unmarshal ¶
func (m *PeersRequest) XXX_Unmarshal(b []byte) error
type RPC ¶
type RPC struct { UnimplementedRPCServer // contains filtered or unexported fields }
RPC implements the rpc service
func (*RPC) ConnectPeer ¶
func (a *RPC) ConnectPeer(ctx context.Context, req *ConnectPeerRequest) (*ConnectPeerReply, error)
ConnectPeer calls module.ConnectPeer
func (*RPC) Connectedness ¶
func (a *RPC) Connectedness(ctx context.Context, req *ConnectednessRequest) (*ConnectednessReply, error)
Connectedness calls module.Connectedness
func (*RPC) DisconnectPeer ¶
func (a *RPC) DisconnectPeer(ctx context.Context, req *DisconnectPeerRequest) (*DisconnectPeerReply, error)
DisconnectPeer calls module.DisconnectPeer
func (*RPC) FindPeer ¶
func (a *RPC) FindPeer(ctx context.Context, req *FindPeerRequest) (*FindPeerReply, error)
FindPeer calls module.FindPeer
func (*RPC) ListenAddr ¶
func (a *RPC) ListenAddr(ctx context.Context, req *ListenAddrRequest) (*ListenAddrReply, error)
ListenAddr calls module.ListenAddr
func (*RPC) Peers ¶
func (a *RPC) Peers(ctx context.Context, req *PeersRequest) (*PeersReply, error)
Peers calls module.Peers
type RPCClient ¶
type RPCClient interface { ListenAddr(ctx context.Context, in *ListenAddrRequest, opts ...grpc.CallOption) (*ListenAddrReply, error) Peers(ctx context.Context, in *PeersRequest, opts ...grpc.CallOption) (*PeersReply, error) FindPeer(ctx context.Context, in *FindPeerRequest, opts ...grpc.CallOption) (*FindPeerReply, error) ConnectPeer(ctx context.Context, in *ConnectPeerRequest, opts ...grpc.CallOption) (*ConnectPeerReply, error) DisconnectPeer(ctx context.Context, in *DisconnectPeerRequest, opts ...grpc.CallOption) (*DisconnectPeerReply, error) Connectedness(ctx context.Context, in *ConnectednessRequest, opts ...grpc.CallOption) (*ConnectednessReply, error) }
RPCClient is the client API for RPC service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRPCClient ¶
func NewRPCClient(cc *grpc.ClientConn) RPCClient
type RPCServer ¶
type RPCServer interface { ListenAddr(context.Context, *ListenAddrRequest) (*ListenAddrReply, error) Peers(context.Context, *PeersRequest) (*PeersReply, error) FindPeer(context.Context, *FindPeerRequest) (*FindPeerReply, error) ConnectPeer(context.Context, *ConnectPeerRequest) (*ConnectPeerReply, error) DisconnectPeer(context.Context, *DisconnectPeerRequest) (*DisconnectPeerReply, error) Connectedness(context.Context, *ConnectednessRequest) (*ConnectednessReply, error) }
RPCServer is the server API for RPC service.
type UnimplementedRPCServer ¶
type UnimplementedRPCServer struct { }
UnimplementedRPCServer can be embedded to have forward compatible implementations.
func (*UnimplementedRPCServer) ConnectPeer ¶
func (*UnimplementedRPCServer) ConnectPeer(ctx context.Context, req *ConnectPeerRequest) (*ConnectPeerReply, error)
func (*UnimplementedRPCServer) Connectedness ¶
func (*UnimplementedRPCServer) Connectedness(ctx context.Context, req *ConnectednessRequest) (*ConnectednessReply, error)
func (*UnimplementedRPCServer) DisconnectPeer ¶
func (*UnimplementedRPCServer) DisconnectPeer(ctx context.Context, req *DisconnectPeerRequest) (*DisconnectPeerReply, error)
func (*UnimplementedRPCServer) FindPeer ¶
func (*UnimplementedRPCServer) FindPeer(ctx context.Context, req *FindPeerRequest) (*FindPeerReply, error)
func (*UnimplementedRPCServer) ListenAddr ¶
func (*UnimplementedRPCServer) ListenAddr(ctx context.Context, req *ListenAddrRequest) (*ListenAddrReply, error)
func (*UnimplementedRPCServer) Peers ¶
func (*UnimplementedRPCServer) Peers(ctx context.Context, req *PeersRequest) (*PeersReply, error)
Click to show internal directories.
Click to hide internal directories.