Documentation ¶
Index ¶
- Variables
- func RegisterRPCServer(s *grpc.Server, srv RPCServer)
- type ConnectPeerReply
- type ConnectPeerRequest
- func (*ConnectPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectPeerRequest) GetPeerInfo() *PeerAddrInfo
- func (*ConnectPeerRequest) ProtoMessage()
- func (x *ConnectPeerRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectPeerRequest) Reset()
- func (x *ConnectPeerRequest) String() string
- type Connectedness
- func (Connectedness) Descriptor() protoreflect.EnumDescriptor
- func (x Connectedness) Enum() *Connectedness
- func (Connectedness) EnumDescriptor() ([]byte, []int)deprecated
- func (x Connectedness) Number() protoreflect.EnumNumber
- func (x Connectedness) String() string
- func (Connectedness) Type() protoreflect.EnumType
- type ConnectednessReply
- func (*ConnectednessReply) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectednessReply) GetConnectedness() Connectedness
- func (*ConnectednessReply) ProtoMessage()
- func (x *ConnectednessReply) ProtoReflect() protoreflect.Message
- func (x *ConnectednessReply) Reset()
- func (x *ConnectednessReply) String() string
- type ConnectednessRequest
- func (*ConnectednessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectednessRequest) GetPeerID() string
- func (*ConnectednessRequest) ProtoMessage()
- func (x *ConnectednessRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectednessRequest) Reset()
- func (x *ConnectednessRequest) String() string
- type DisconnectPeerReply
- type DisconnectPeerRequest
- func (*DisconnectPeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectPeerRequest) GetPeerID() string
- func (*DisconnectPeerRequest) ProtoMessage()
- func (x *DisconnectPeerRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectPeerRequest) Reset()
- func (x *DisconnectPeerRequest) String() string
- type FindPeerReply
- type FindPeerRequest
- type ListenAddrReply
- type ListenAddrRequest
- type Location
- func (*Location) Descriptor() ([]byte, []int)deprecated
- func (x *Location) GetCountry() string
- func (x *Location) GetLatitude() float32
- func (x *Location) GetLongitude() float32
- func (*Location) ProtoMessage()
- func (x *Location) ProtoReflect() protoreflect.Message
- func (x *Location) Reset()
- func (x *Location) String() string
- type PeerAddrInfo
- func (*PeerAddrInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PeerAddrInfo) GetAddrs() []string
- func (x *PeerAddrInfo) GetID() string
- func (*PeerAddrInfo) ProtoMessage()
- func (x *PeerAddrInfo) ProtoReflect() protoreflect.Message
- func (x *PeerAddrInfo) Reset()
- func (x *PeerAddrInfo) String() string
- type PeerInfo
- type PeersReply
- type PeersRequest
- 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(context.Context, *ConnectPeerRequest) (*ConnectPeerReply, error)
- func (*UnimplementedRPCServer) Connectedness(context.Context, *ConnectednessRequest) (*ConnectednessReply, error)
- func (*UnimplementedRPCServer) DisconnectPeer(context.Context, *DisconnectPeerRequest) (*DisconnectPeerReply, error)
- func (*UnimplementedRPCServer) FindPeer(context.Context, *FindPeerRequest) (*FindPeerReply, error)
- func (*UnimplementedRPCServer) ListenAddr(context.Context, *ListenAddrRequest) (*ListenAddrReply, error)
- func (*UnimplementedRPCServer) Peers(context.Context, *PeersRequest) (*PeersReply, error)
Constants ¶
This section is empty.
Variables ¶
var ( Connectedness_name = map[int32]string{ 0: "NotConnected", 1: "Connected", 2: "CanConnect", 3: "CannotConnect", 4: "Unknown", 5: "Error", } Connectedness_value = map[string]int32{ "NotConnected": 0, "Connected": 1, "CanConnect": 2, "CannotConnect": 3, "Unknown": 4, "Error": 5, } )
Enum value maps for Connectedness.
var File_net_rpc_rpc_proto protoreflect.FileDescriptor
Functions ¶
func RegisterRPCServer ¶
Types ¶
type ConnectPeerReply ¶
type ConnectPeerReply struct {
// contains filtered or unexported fields
}
func (*ConnectPeerReply) Descriptor
deprecated
func (*ConnectPeerReply) Descriptor() ([]byte, []int)
Deprecated: Use ConnectPeerReply.ProtoReflect.Descriptor instead.
func (*ConnectPeerReply) ProtoMessage ¶
func (*ConnectPeerReply) ProtoMessage()
func (*ConnectPeerReply) ProtoReflect ¶
func (x *ConnectPeerReply) ProtoReflect() protoreflect.Message
func (*ConnectPeerReply) Reset ¶
func (x *ConnectPeerReply) Reset()
func (*ConnectPeerReply) String ¶
func (x *ConnectPeerReply) String() string
type ConnectPeerRequest ¶
type ConnectPeerRequest struct { PeerInfo *PeerAddrInfo `protobuf:"bytes,1,opt,name=peerInfo,proto3" json:"peerInfo,omitempty"` // contains filtered or unexported fields }
func (*ConnectPeerRequest) Descriptor
deprecated
func (*ConnectPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectPeerRequest.ProtoReflect.Descriptor instead.
func (*ConnectPeerRequest) GetPeerInfo ¶
func (x *ConnectPeerRequest) GetPeerInfo() *PeerAddrInfo
func (*ConnectPeerRequest) ProtoMessage ¶
func (*ConnectPeerRequest) ProtoMessage()
func (*ConnectPeerRequest) ProtoReflect ¶
func (x *ConnectPeerRequest) ProtoReflect() protoreflect.Message
func (*ConnectPeerRequest) Reset ¶
func (x *ConnectPeerRequest) Reset()
func (*ConnectPeerRequest) String ¶
func (x *ConnectPeerRequest) String() string
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) Descriptor ¶
func (Connectedness) Descriptor() protoreflect.EnumDescriptor
func (Connectedness) Enum ¶
func (x Connectedness) Enum() *Connectedness
func (Connectedness) EnumDescriptor
deprecated
func (Connectedness) EnumDescriptor() ([]byte, []int)
Deprecated: Use Connectedness.Descriptor instead.
func (Connectedness) Number ¶
func (x Connectedness) Number() protoreflect.EnumNumber
func (Connectedness) String ¶
func (x Connectedness) String() string
func (Connectedness) Type ¶
func (Connectedness) Type() protoreflect.EnumType
type ConnectednessReply ¶
type ConnectednessReply struct { Connectedness Connectedness `protobuf:"varint,1,opt,name=connectedness,proto3,enum=net.rpc.Connectedness" json:"connectedness,omitempty"` // contains filtered or unexported fields }
func (*ConnectednessReply) Descriptor
deprecated
func (*ConnectednessReply) Descriptor() ([]byte, []int)
Deprecated: Use ConnectednessReply.ProtoReflect.Descriptor instead.
func (*ConnectednessReply) GetConnectedness ¶
func (x *ConnectednessReply) GetConnectedness() Connectedness
func (*ConnectednessReply) ProtoMessage ¶
func (*ConnectednessReply) ProtoMessage()
func (*ConnectednessReply) ProtoReflect ¶
func (x *ConnectednessReply) ProtoReflect() protoreflect.Message
func (*ConnectednessReply) Reset ¶
func (x *ConnectednessReply) Reset()
func (*ConnectednessReply) String ¶
func (x *ConnectednessReply) String() string
type ConnectednessRequest ¶
type ConnectednessRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` // contains filtered or unexported fields }
func (*ConnectednessRequest) Descriptor
deprecated
func (*ConnectednessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectednessRequest.ProtoReflect.Descriptor instead.
func (*ConnectednessRequest) GetPeerID ¶
func (x *ConnectednessRequest) GetPeerID() string
func (*ConnectednessRequest) ProtoMessage ¶
func (*ConnectednessRequest) ProtoMessage()
func (*ConnectednessRequest) ProtoReflect ¶
func (x *ConnectednessRequest) ProtoReflect() protoreflect.Message
func (*ConnectednessRequest) Reset ¶
func (x *ConnectednessRequest) Reset()
func (*ConnectednessRequest) String ¶
func (x *ConnectednessRequest) String() string
type DisconnectPeerReply ¶
type DisconnectPeerReply struct {
// contains filtered or unexported fields
}
func (*DisconnectPeerReply) Descriptor
deprecated
func (*DisconnectPeerReply) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectPeerReply.ProtoReflect.Descriptor instead.
func (*DisconnectPeerReply) ProtoMessage ¶
func (*DisconnectPeerReply) ProtoMessage()
func (*DisconnectPeerReply) ProtoReflect ¶
func (x *DisconnectPeerReply) ProtoReflect() protoreflect.Message
func (*DisconnectPeerReply) Reset ¶
func (x *DisconnectPeerReply) Reset()
func (*DisconnectPeerReply) String ¶
func (x *DisconnectPeerReply) String() string
type DisconnectPeerRequest ¶
type DisconnectPeerRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` // contains filtered or unexported fields }
func (*DisconnectPeerRequest) Descriptor
deprecated
func (*DisconnectPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectPeerRequest.ProtoReflect.Descriptor instead.
func (*DisconnectPeerRequest) GetPeerID ¶
func (x *DisconnectPeerRequest) GetPeerID() string
func (*DisconnectPeerRequest) ProtoMessage ¶
func (*DisconnectPeerRequest) ProtoMessage()
func (*DisconnectPeerRequest) ProtoReflect ¶
func (x *DisconnectPeerRequest) ProtoReflect() protoreflect.Message
func (*DisconnectPeerRequest) Reset ¶
func (x *DisconnectPeerRequest) Reset()
func (*DisconnectPeerRequest) String ¶
func (x *DisconnectPeerRequest) String() string
type FindPeerReply ¶
type FindPeerReply struct { PeerInfo *PeerInfo `protobuf:"bytes,1,opt,name=peerInfo,proto3" json:"peerInfo,omitempty"` // contains filtered or unexported fields }
func (*FindPeerReply) Descriptor
deprecated
func (*FindPeerReply) Descriptor() ([]byte, []int)
Deprecated: Use FindPeerReply.ProtoReflect.Descriptor instead.
func (*FindPeerReply) GetPeerInfo ¶
func (x *FindPeerReply) GetPeerInfo() *PeerInfo
func (*FindPeerReply) ProtoMessage ¶
func (*FindPeerReply) ProtoMessage()
func (*FindPeerReply) ProtoReflect ¶
func (x *FindPeerReply) ProtoReflect() protoreflect.Message
func (*FindPeerReply) Reset ¶
func (x *FindPeerReply) Reset()
func (*FindPeerReply) String ¶
func (x *FindPeerReply) String() string
type FindPeerRequest ¶
type FindPeerRequest struct { PeerID string `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` // contains filtered or unexported fields }
func (*FindPeerRequest) Descriptor
deprecated
func (*FindPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindPeerRequest.ProtoReflect.Descriptor instead.
func (*FindPeerRequest) GetPeerID ¶
func (x *FindPeerRequest) GetPeerID() string
func (*FindPeerRequest) ProtoMessage ¶
func (*FindPeerRequest) ProtoMessage()
func (*FindPeerRequest) ProtoReflect ¶
func (x *FindPeerRequest) ProtoReflect() protoreflect.Message
func (*FindPeerRequest) Reset ¶
func (x *FindPeerRequest) Reset()
func (*FindPeerRequest) String ¶
func (x *FindPeerRequest) String() string
type ListenAddrReply ¶
type ListenAddrReply struct { AddrInfo *PeerAddrInfo `protobuf:"bytes,1,opt,name=addrInfo,proto3" json:"addrInfo,omitempty"` // contains filtered or unexported fields }
func (*ListenAddrReply) Descriptor
deprecated
func (*ListenAddrReply) Descriptor() ([]byte, []int)
Deprecated: Use ListenAddrReply.ProtoReflect.Descriptor instead.
func (*ListenAddrReply) GetAddrInfo ¶
func (x *ListenAddrReply) GetAddrInfo() *PeerAddrInfo
func (*ListenAddrReply) ProtoMessage ¶
func (*ListenAddrReply) ProtoMessage()
func (*ListenAddrReply) ProtoReflect ¶
func (x *ListenAddrReply) ProtoReflect() protoreflect.Message
func (*ListenAddrReply) Reset ¶
func (x *ListenAddrReply) Reset()
func (*ListenAddrReply) String ¶
func (x *ListenAddrReply) String() string
type ListenAddrRequest ¶
type ListenAddrRequest struct {
// contains filtered or unexported fields
}
func (*ListenAddrRequest) Descriptor
deprecated
func (*ListenAddrRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenAddrRequest.ProtoReflect.Descriptor instead.
func (*ListenAddrRequest) ProtoMessage ¶
func (*ListenAddrRequest) ProtoMessage()
func (*ListenAddrRequest) ProtoReflect ¶
func (x *ListenAddrRequest) ProtoReflect() protoreflect.Message
func (*ListenAddrRequest) Reset ¶
func (x *ListenAddrRequest) Reset()
func (*ListenAddrRequest) String ¶
func (x *ListenAddrRequest) String() string
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"` // contains filtered or unexported fields }
func (*Location) Descriptor
deprecated
func (*Location) GetCountry ¶
func (*Location) GetLatitude ¶
func (*Location) GetLongitude ¶
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
func (*Location) ProtoReflect ¶
func (x *Location) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
func (*PeerAddrInfo) Descriptor
deprecated
func (*PeerAddrInfo) Descriptor() ([]byte, []int)
Deprecated: Use PeerAddrInfo.ProtoReflect.Descriptor instead.
func (*PeerAddrInfo) GetAddrs ¶
func (x *PeerAddrInfo) GetAddrs() []string
func (*PeerAddrInfo) GetID ¶
func (x *PeerAddrInfo) GetID() string
func (*PeerAddrInfo) ProtoMessage ¶
func (*PeerAddrInfo) ProtoMessage()
func (*PeerAddrInfo) ProtoReflect ¶
func (x *PeerAddrInfo) ProtoReflect() protoreflect.Message
func (*PeerAddrInfo) Reset ¶
func (x *PeerAddrInfo) Reset()
func (*PeerAddrInfo) String ¶
func (x *PeerAddrInfo) String() string
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"` // contains filtered or unexported fields }
func (*PeerInfo) Descriptor
deprecated
func (*PeerInfo) GetAddrInfo ¶
func (x *PeerInfo) GetAddrInfo() *PeerAddrInfo
func (*PeerInfo) GetLocation ¶
func (*PeerInfo) ProtoMessage ¶
func (*PeerInfo) ProtoMessage()
func (*PeerInfo) ProtoReflect ¶
func (x *PeerInfo) ProtoReflect() protoreflect.Message
type PeersReply ¶
type PeersReply struct { Peers []*PeerInfo `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` // contains filtered or unexported fields }
func (*PeersReply) Descriptor
deprecated
func (*PeersReply) Descriptor() ([]byte, []int)
Deprecated: Use PeersReply.ProtoReflect.Descriptor instead.
func (*PeersReply) GetPeers ¶
func (x *PeersReply) GetPeers() []*PeerInfo
func (*PeersReply) ProtoMessage ¶
func (*PeersReply) ProtoMessage()
func (*PeersReply) ProtoReflect ¶
func (x *PeersReply) ProtoReflect() protoreflect.Message
func (*PeersReply) Reset ¶
func (x *PeersReply) Reset()
func (*PeersReply) String ¶
func (x *PeersReply) String() string
type PeersRequest ¶
type PeersRequest struct {
// contains filtered or unexported fields
}
func (*PeersRequest) Descriptor
deprecated
func (*PeersRequest) Descriptor() ([]byte, []int)
Deprecated: Use PeersRequest.ProtoReflect.Descriptor instead.
func (*PeersRequest) ProtoMessage ¶
func (*PeersRequest) ProtoMessage()
func (*PeersRequest) ProtoReflect ¶
func (x *PeersRequest) ProtoReflect() protoreflect.Message
func (*PeersRequest) Reset ¶
func (x *PeersRequest) Reset()
func (*PeersRequest) String ¶
func (x *PeersRequest) String() string
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.ClientConnInterface) 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(context.Context, *ConnectPeerRequest) (*ConnectPeerReply, error)
func (*UnimplementedRPCServer) Connectedness ¶
func (*UnimplementedRPCServer) Connectedness(context.Context, *ConnectednessRequest) (*ConnectednessReply, error)
func (*UnimplementedRPCServer) DisconnectPeer ¶
func (*UnimplementedRPCServer) DisconnectPeer(context.Context, *DisconnectPeerRequest) (*DisconnectPeerReply, error)
func (*UnimplementedRPCServer) FindPeer ¶
func (*UnimplementedRPCServer) FindPeer(context.Context, *FindPeerRequest) (*FindPeerReply, error)
func (*UnimplementedRPCServer) ListenAddr ¶
func (*UnimplementedRPCServer) ListenAddr(context.Context, *ListenAddrRequest) (*ListenAddrReply, error)
func (*UnimplementedRPCServer) Peers ¶
func (*UnimplementedRPCServer) Peers(context.Context, *PeersRequest) (*PeersReply, error)