rpc

package
v0.0.1-beta.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 18, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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 

func RegisterRPCServer(s *grpc.Server, srv RPCServer)

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) Descriptor() ([]byte, []int)

func (*Location) GetCountry 

func (m *Location) GetCountry() string

func (*Location) GetLatitude 

func (m *Location) GetLatitude() float32

func (*Location) GetLongitude 

func (m *Location) GetLongitude() float32

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*PeerInfo) GetAddrInfo 

func (m *PeerInfo) GetAddrInfo() *PeerAddrInfo

func (*PeerInfo) GetLocation 

func (m *PeerInfo) GetLocation() *Location

func (*PeerInfo) ProtoMessage 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset 

func (m *PeerInfo) Reset()

func (*PeerInfo) String 

func (m *PeerInfo) String() string

func (*PeerInfo) XXX_DiscardUnknown 

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal 

func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerInfo) XXX_Merge 

func (m *PeerInfo) XXX_Merge(src proto.Message)

func (*PeerInfo) XXX_Size 

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal 

func (m *PeerInfo) XXX_Unmarshal(b []byte) error

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 New 

func New(m net.Module) *RPC

New creates a new 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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.