Documentation
¶
Overview ¶
Package grpc is a generated protocol buffer package.
It is generated from these files:
peer.protos
It has these top-level messages:
Empty GossipTable Peer PeersInfo
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterGossipServer ¶
func RegisterGossipServer(s *grpc1.Server, srv GossipServer)
Types ¶
type Empty ¶
type Empty struct {
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type GossipClient ¶
type GossipClient interface {
PushGossip(ctx context.Context, in *GossipTable, opts ...grpc1.CallOption) (*Empty, error)
Ping(ctx context.Context, in *Empty, opts ...grpc1.CallOption) (*Empty, error)
GetGossipTable(ctx context.Context, in *Empty, opts ...grpc1.CallOption) (*GossipTable, error)
PullGossip(ctx context.Context, in *Empty, opts ...grpc1.CallOption) (*GossipTable, error)
}
func NewGossipClient ¶
func NewGossipClient(cc *grpc1.ClientConn) GossipClient
type GossipServer ¶
type GossipTable ¶
type GossipTable struct {
MyID string `protobuf:"bytes,1,opt,name=myID" json:"myID,omitempty"`
Peer []*Peer `protobuf:"bytes,2,rep,name=Peer" json:"Peer,omitempty"`
}
func (*GossipTable) Descriptor ¶
func (*GossipTable) Descriptor() ([]byte, []int)
func (*GossipTable) GetMyID ¶
func (m *GossipTable) GetMyID() string
func (*GossipTable) GetPeer ¶
func (m *GossipTable) GetPeer() []*Peer
func (*GossipTable) ProtoMessage ¶
func (*GossipTable) ProtoMessage()
func (*GossipTable) Reset ¶
func (m *GossipTable) Reset()
func (*GossipTable) String ¶
func (m *GossipTable) String() string
type Peer ¶
type Peer struct {
IpAddress string `protobuf:"bytes,1,opt,name=ipAddress" json:"ipAddress,omitempty"`
PeerID string `protobuf:"bytes,2,opt,name=peerID" json:"peerID,omitempty"`
Counter int64 `protobuf:"varint,3,opt,name=counter" json:"counter,omitempty"`
}
func (*Peer) Descriptor ¶
func (*Peer) GetCounter ¶
func (*Peer) GetIpAddress ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
type PeersInfo ¶
type PeersInfo struct {
}
func (*PeersInfo) Descriptor ¶
func (*PeersInfo) ProtoMessage ¶
func (*PeersInfo) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.