rpc

type RPCState struct {
	Goodbye       Responder
	Status        Responder
	Ping          Responder
	Metadata      Responder
	BlocksByRange Responder
	BlocksByRoot  Responder
}

type RequestEntry struct {
	From    peer.ID
	Handler reqresp.RequestResponder
	Cancel  func()
}

type RequestKey uint64

type Responder struct {

	// RequestKey -> RequestEntry
	Requests sync.Map
	// contains filtered or unexported fields
}

type RpcCmd struct {
	*base.Base
	*RPCState
}

type RpcMethodCloseCmd struct {
	*base.Base
	*RpcMethodData
	ReqId string `ask:"<req-id>" help:"the ID of the request to close"`
}

type RpcMethodCmd struct {
	*base.Base
	*RpcMethodData
}

type RpcMethodData struct {
	Name      string
	Responder *Responder
	Method    *reqresp.RPCMethod
}

type RpcMethodListenCmd struct {
	*base.Base
	*RpcMethodData
	Timeout     time.Duration         `` /* 127-byte string literal not displayed */
	Compression flags.CompressionFlag `ask:"--compression" help:"Compression. 'none' to disable, 'snappy' for streaming-snappy"`
	Raw         bool                  `ask:"--raw" help:"Do not decode the request, look at raw bytes"`
	Drop        bool                  `ask:"--drop" help:"Drop the requests, do not queue for a response."`
	Read        bool                  `ask:"--read" help:"Read the contents of the request."`
}

type RpcMethodReqCmd struct {
	*base.Base
	*RpcMethodData
}

type RpcMethodReqRawCmd struct {
	*base.Base
	*RpcMethodData
	Timeout     time.Duration         `ask:"--timeout" help:"Timeout for full request and response. 0 to disable"`
	Compression flags.CompressionFlag `ask:"--compression" help:"Compression. 'none' to disable, 'snappy' for streaming-snappy"`
	MaxChunks   uint64                `ask:"--max-chunks" help:"Max response chunk count, if 0, do not wait for a response at all."`
	Raw         bool                  `ask:"--raw" help:"If chunks should be logged as raw hex-encoded byte strings"`
	PeerID      flags.PeerIDFlag      `ask:"<peer-id>" help:"libp2p Peer-ID to request"`
	Data        []byte                `ask:"<data>" help:"Raw uncompressed hex-encoded request data"`
}

type RpcMethodRespChunkCmd struct {
	*base.Base
	*RpcMethodData
}

type RpcMethodRespChunkRawCmd struct {
	*base.Base
	*RpcMethodData
	Done       bool                 `ask:"--done" help:"After writing this chunk, close the response (no more chunks)."`
	ResultCode reqresp.ResponseCode `ask:"--result-code" help:"Customize the chunk result code. (0 = success, 1 = invalid input, 2 = error, 3+ = undefined)"`
	ReqId      string               `ask:"<req-id>" help:"the ID of the request to respond to"`
	Data       []byte               `ask:"<data>" help:"chunk bytes (uncompressed, hex-encoded)"`
}

type RpcMethodRespCmd struct {
	*base.Base
	*RpcMethodData
}

type RpcMethodRespErrorCmd struct {
	*base.Base
	*RpcMethodData
	Done       bool                 `ask:"--done" help:"After writing this chunk, close the response (no more chunks)."`
	ResultCode reqresp.ResponseCode `ask:"--result-code" help:"Customize the chunk result code. (0 = success, 1 = invalid input, 2 = error, 3+ = undefined)"`
	ReqId      string               `ask:"<req-id>" help:"the ID of the request to respond to"`
	Text       string               `ask:"<text>" help:"error text data"`
}