Versions in this module Expand all Collapse all v0 v0.3.6 Oct 20, 2020 v0.3.5 Oct 19, 2020 v0.3.4 Oct 19, 2020 v0.3.3 Oct 18, 2020 v0.3.2 Oct 16, 2020 v0.3.1 Oct 10, 2020 v0.3.0 Sep 25, 2020 v0.2.10 Sep 8, 2020 v0.2.9 Sep 8, 2020 v0.2.8 Sep 7, 2020 v0.2.7 Sep 4, 2020 v0.2.6 Sep 3, 2020 v0.2.5 Sep 3, 2020 v0.2.4 Aug 24, 2020 v0.2.3 Aug 11, 2020 v0.2.2 Aug 7, 2020 v0.2.1 Jul 15, 2020 v0.2.0 Jul 4, 2020 Changes in this version + type RPCState struct + BlocksByRange Responder + BlocksByRoot Responder + Goodbye Responder + Metadata Responder + Ping Responder + Status Responder + type RequestEntry struct + Cancel func() + From peer.ID + Handler reqresp.RequestResponder + type RequestKey uint64 + type Responder struct + Requests sync.Map + func (r *Responder) AddRequest(req *RequestEntry) RequestKey + func (r *Responder) CloseRequest(key RequestKey) + func (r *Responder) GetRequest(key RequestKey) *RequestEntry + type RpcCmd struct + func (c *RpcCmd) Cmd(route string) (cmd interface{}, err error) + func (c *RpcCmd) Help() string + func (c *RpcCmd) Method(name string, resp *Responder, method *reqresp.RPCMethod) *RpcMethodCmd + func (c *RpcCmd) Routes() []string + type RpcMethodCloseCmd struct + ReqId string + func (c *RpcMethodCloseCmd) Help() string + func (c *RpcMethodCloseCmd) Run(ctx context.Context, args ...string) error + type RpcMethodCmd struct + func (c *RpcMethodCmd) Cmd(route string) (cmd interface{}, err error) + func (c *RpcMethodCmd) Help() string + func (c *RpcMethodCmd) Routes() []string + type RpcMethodData struct + Method *reqresp.RPCMethod + Name string + Responder *Responder + type RpcMethodListenCmd struct + Compression flags.CompressionFlag + Drop bool + Raw bool + Read bool + Timeout time.Duration + func (c *RpcMethodListenCmd) Help() string + func (c *RpcMethodListenCmd) Run(ctx context.Context, args ...string) error + type RpcMethodReqCmd struct + func (c *RpcMethodReqCmd) Cmd(route string) (cmd interface{}, err error) + func (c *RpcMethodReqCmd) Help() string + func (c *RpcMethodReqCmd) Routes() []string + type RpcMethodReqRawCmd struct + Compression flags.CompressionFlag + Data []byte + MaxChunks uint64 + PeerID flags.PeerIDFlag + Raw bool + Timeout time.Duration + func (c *RpcMethodReqRawCmd) Help() string + func (c *RpcMethodReqRawCmd) Run(ctx context.Context, args ...string) error + type RpcMethodRespChunkCmd struct + func (c *RpcMethodRespChunkCmd) Cmd(route string) (cmd interface{}, err error) + func (c *RpcMethodRespChunkCmd) Help() string + func (c *RpcMethodRespChunkCmd) Routes() []string + type RpcMethodRespChunkRawCmd struct + Data []byte + Done bool + ReqId string + ResultCode reqresp.ResponseCode + func (c *RpcMethodRespChunkRawCmd) Help() string + func (c *RpcMethodRespChunkRawCmd) Run(ctx context.Context, args ...string) error + type RpcMethodRespCmd struct + func (c *RpcMethodRespCmd) Cmd(route string) (cmd interface{}, err error) + func (c *RpcMethodRespCmd) Help() string + func (c *RpcMethodRespCmd) Routes() []string + type RpcMethodRespErrorCmd struct + Done bool + ReqId string + ResultCode reqresp.ResponseCode + Text string + func (c *RpcMethodRespErrorCmd) Help() string + func (c *RpcMethodRespErrorCmd) Run(ctx context.Context, args ...string) error
Go to main page