Versions in this module Expand all Collapse all v1 v1.1.0 Sep 1, 2022 v1.0.0 Dec 13, 2021 Changes in this version + const InvalidReqCode + const MAX_ERR_SIZE + const ServerErrCode + const SuccessCode + func EncodeChunk(result ResponseCode, r io.Reader, w io.Writer, comp Compression) error + func EncodeHeaderAndPayload(r io.Reader, w io.Writer, comp Compression) error + func EncodeResult(result ResponseCode, w io.Writer) error + func StreamChunk(result ResponseCode, size uint64, r io.Reader, w io.Writer, comp Compression) error + func StreamHeaderAndPayload(size uint64, r io.Reader, w io.Writer, comp Compression) error + type BufLimitReader struct + N int + PerRead bool + func NewBufLimitReader(rd io.Reader, size int, limit int) *BufLimitReader + func (b *BufLimitReader) Read(p []byte) (n int, err error) + func (b *BufLimitReader) ReadByte() (byte, error) + type ChunkedRequestHandler interface + type ChunkedResponseHandler interface + ChunkIndex func() uint64 + ChunkSize func() uint64 + ReadErrMsg func() (string, error) + ReadObj func(dest codec.Deserializable) error + ReadRaw func() ([]byte, error) + ResultCode func() ResponseCode + type Codec interface + Alloc func() SerDes + Decode func(r io.Reader, bytesLen uint64, dest codec.Deserializable) error + Encode func(w io.Writer, input codec.Serializable) error + MaxByteLen func() uint64 + MinByteLen func() uint64 + type Compression interface + Compress func(w io.WriteCloser) io.WriteCloser + Decompress func(r io.Reader) io.Reader + MaxEncodedLen func(msgLen uint64) (uint64, error) + Name func() string + type NewStreamFn func(ctx context.Context, peerId peer.ID, protocolId ...protocol.ID) (network.Stream, error) + func (newStreamFn NewStreamFn) Request(ctx context.Context, peerId peer.ID, protocolId protocol.ID, r io.Reader, ...) error + type OnRequestListener func(ctx context.Context, peerId peer.ID, handler ChunkedRequestHandler) + type OnRequested func() + type OnResponseListener func(chunk ChunkedResponseHandler) error + type RPCMethod struct + DefaultResponseChunkCount uint64 + Protocol protocol.ID + RequestCodec Codec + ResponseChunkCodec Codec + func (m *RPCMethod) MakeStreamHandler(newCtx StreamCtxFn, comp Compression, listener OnRequestListener) network.StreamHandler + func (m *RPCMethod) RunRequest(ctx context.Context, newStreamFn NewStreamFn, peerId peer.ID, comp Compression, ...) error + type ReadRequestFn func(dest interface{}) error + type Request interface + type RequestBytesInput []byte + func (v RequestBytesInput) Reader(_ Codec) (io.Reader, error) + type RequestInput interface + Reader func(c Codec) (io.Reader, error) + type RequestPayloadHandler func(ctx context.Context, peerId peer.ID, requestLen uint64, r io.Reader, ...) + func (handle RequestPayloadHandler) MakeStreamHandler(newCtx StreamCtxFn, comp Compression, ...) network.StreamHandler + type RequestReader interface + InvalidInput func() error + RawRequest func() ([]byte, error) + ReadRequest func(dest codec.Deserializable) error + type RequestResponder interface + StreamResponseChunk func(code ResponseCode, size uint64, r io.Reader) error + WriteErrorChunk func(code ResponseCode, msg string) error + WriteRawResponseChunk func(code ResponseCode, chunk []byte) error + WriteResponseChunk func(code ResponseCode, data codec.Serializable) error + type RequestSSZInput struct + Obj codec.Serializable + func (v RequestSSZInput) Reader(c Codec) (io.Reader, error) + type ResponseChunkHandler func(ctx context.Context, chunkIndex uint64, chunkSize uint64, result ResponseCode, ...) error + func (handleChunk ResponseChunkHandler) MakeResponseHandler(maxChunkCount uint64, maxChunkContentSize uint64, comp Compression) ResponseHandler + type ResponseCode uint8 + type ResponseHandler func(ctx context.Context, r io.Reader, w io.WriteCloser) error + type SSZCodec struct + func NewSSZCodec(alloc func() SerDes, minByteLen uint64, maxByteLen uint64) *SSZCodec + func (c *SSZCodec) Alloc() SerDes + func (c *SSZCodec) Decode(r io.Reader, bytesLen uint64, dest codec.Deserializable) error + func (c *SSZCodec) Encode(w io.Writer, input codec.Serializable) error + func (c *SSZCodec) MaxByteLen() uint64 + func (c *SSZCodec) MinByteLen() uint64 + type SerDes interface + type SnappyCompression struct + func (c SnappyCompression) Compress(w io.WriteCloser) io.WriteCloser + func (c SnappyCompression) Decompress(reader io.Reader) io.Reader + func (c SnappyCompression) MaxEncodedLen(msgLen uint64) (uint64, error) + func (c SnappyCompression) Name() string + type StreamCtxFn func() context.Context + type WriteMsgFn func(msg string) error + type WriteSuccessChunkFn func(data interface{}) error