Versions in this module Expand all Collapse all v0 v0.2.0 Mar 13, 2019 v0.1.0 Jul 23, 2018 Changes in this version + var ErrIntOverflowSwarm = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthSwarm = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterSwarmServer(s *google_golang_org_grpc.Server, srv SwarmServer) + type Connection struct + LocalAddress []byte + PeerId []byte + RemoteAddress []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connection) Descriptor() ([]byte, []int) + func (*Connection) ProtoMessage() + func (dst *Connection) XXX_Merge(src proto.Message) + func (m *Connection) GetLocalAddress() []byte + func (m *Connection) GetPeerId() []byte + func (m *Connection) GetRemoteAddress() []byte + func (m *Connection) Marshal() (dAtA []byte, err error) + func (m *Connection) MarshalTo(dAtA []byte) (int, error) + func (m *Connection) Reset() + func (m *Connection) Size() (n int) + func (m *Connection) String() string + func (m *Connection) Unmarshal(dAtA []byte) error + func (m *Connection) XXX_DiscardUnknown() + func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connection) XXX_Size() int + func (m *Connection) XXX_Unmarshal(b []byte) error + type ConnectionsReq struct + PeerId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnectionsReq) Descriptor() ([]byte, []int) + func (*ConnectionsReq) ProtoMessage() + func (dst *ConnectionsReq) XXX_Merge(src proto.Message) + func (m *ConnectionsReq) GetPeerId() []byte + func (m *ConnectionsReq) Marshal() (dAtA []byte, err error) + func (m *ConnectionsReq) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectionsReq) Reset() + func (m *ConnectionsReq) Size() (n int) + func (m *ConnectionsReq) String() string + func (m *ConnectionsReq) Unmarshal(dAtA []byte) error + func (m *ConnectionsReq) XXX_DiscardUnknown() + func (m *ConnectionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnectionsReq) XXX_Size() int + func (m *ConnectionsReq) XXX_Unmarshal(b []byte) error + type LocalPeerReq struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LocalPeerReq) Descriptor() ([]byte, []int) + func (*LocalPeerReq) ProtoMessage() + func (dst *LocalPeerReq) XXX_Merge(src proto.Message) + func (m *LocalPeerReq) Marshal() (dAtA []byte, err error) + func (m *LocalPeerReq) MarshalTo(dAtA []byte) (int, error) + func (m *LocalPeerReq) Reset() + func (m *LocalPeerReq) Size() (n int) + func (m *LocalPeerReq) String() string + func (m *LocalPeerReq) Unmarshal(dAtA []byte) error + func (m *LocalPeerReq) XXX_DiscardUnknown() + func (m *LocalPeerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LocalPeerReq) XXX_Size() int + func (m *LocalPeerReq) XXX_Unmarshal(b []byte) error + type Peer struct + Id []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (dst *Peer) XXX_Merge(src proto.Message) + func (m *Peer) GetId() []byte + func (m *Peer) Marshal() (dAtA []byte, err error) + func (m *Peer) MarshalTo(dAtA []byte) (int, error) + func (m *Peer) Reset() + func (m *Peer) Size() (n int) + func (m *Peer) String() string + func (m *Peer) Unmarshal(dAtA []byte) error + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type PeersReq struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeersReq) Descriptor() ([]byte, []int) + func (*PeersReq) ProtoMessage() + func (dst *PeersReq) XXX_Merge(src proto.Message) + func (m *PeersReq) Marshal() (dAtA []byte, err error) + func (m *PeersReq) MarshalTo(dAtA []byte) (int, error) + func (m *PeersReq) Reset() + func (m *PeersReq) Size() (n int) + func (m *PeersReq) String() string + func (m *PeersReq) Unmarshal(dAtA []byte) error + func (m *PeersReq) XXX_DiscardUnknown() + func (m *PeersReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeersReq) XXX_Size() int + func (m *PeersReq) XXX_Unmarshal(b []byte) error + type SwarmClient interface + Connections func(ctx context.Context, in *ConnectionsReq, ...) (Swarm_ConnectionsClient, error) + LocalPeer func(ctx context.Context, in *LocalPeerReq, ...) (*Peer, error) + Peers func(ctx context.Context, in *PeersReq, opts ...google_golang_org_grpc.CallOption) (Swarm_PeersClient, error) + func NewSwarmClient(cc *google_golang_org_grpc.ClientConn) SwarmClient + type SwarmServer interface + Connections func(*ConnectionsReq, Swarm_ConnectionsServer) error + LocalPeer func(context.Context, *LocalPeerReq) (*Peer, error) + Peers func(*PeersReq, Swarm_PeersServer) error + type Swarm_ConnectionsClient interface + Recv func() (*Connection, error) + type Swarm_ConnectionsServer interface + Send func(*Connection) error + type Swarm_PeersClient interface + Recv func() (*Peer, error) + type Swarm_PeersServer interface + Send func(*Peer) error
Go to main page