p2p

May 23, 2019

Changes in this version

+ const P2PPathPrefix

+ func WriteError(resp http.ResponseWriter, err error)

+ type GeneralRequest struct

+ Network string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GeneralRequest) Descriptor() ([]byte, []int)

+ func (*GeneralRequest) ProtoMessage()

+ func (m *GeneralRequest) GetNetwork() string

+ func (m *GeneralRequest) Reset()

+ func (m *GeneralRequest) String() string

+ func (m *GeneralRequest) XXX_DiscardUnknown()

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

+ func (m *GeneralRequest) XXX_Merge(src proto.Message)

+ func (m *GeneralRequest) XXX_Size() int

+ func (m *GeneralRequest) XXX_Unmarshal(b []byte) error

+ type GeneralResponse struct

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GeneralResponse) Descriptor() ([]byte, []int)

+ func (*GeneralResponse) ProtoMessage()

+ func (m *GeneralResponse) GetMessage() string

+ func (m *GeneralResponse) Reset()

+ func (m *GeneralResponse) String() string

+ func (m *GeneralResponse) XXX_DiscardUnknown()

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

+ func (m *GeneralResponse) XXX_Merge(src proto.Message)

+ func (m *GeneralResponse) XXX_Size() int

+ func (m *GeneralResponse) XXX_Unmarshal(b []byte) error

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type P2P interface

+ ConnectedPeers func(context.Context, *GeneralRequest) (*GeneralResponse, error)

+ NumConnectedPeers func(context.Context, *GeneralRequest) (*GeneralResponse, error)

+ SyncNetwork func(context.Context, *GeneralRequest) (*GeneralResponse, error)

+ func NewP2PJSONClient(addr string, client HTTPClient) P2P

+ func NewP2PProtobufClient(addr string, client HTTPClient) P2P

+ type TwirpServer interface

+ ProtocGenTwirpVersion func() string

+ ServiceDescriptor func() ([]byte, int)

+ func NewP2PServer(svc P2P, hooks *twirp.ServerHooks) TwirpServer