util

Documentation

Index

• func ParseJSONRPC(r io.Reader, cb func(dec *json.Decoder) error) error
• func SendS3Bytes(ctx context.Context, hc *http.Client, retryHTTP uint64, ...) error
• type S3Chunker
  • func NewS3Chunker(maxSize, maxChunk uint64, send func([]byte, uint64) error) *S3Chunker
  • func (c *S3Chunker) Append(data func(pos, maxChunk uint64) ([]byte, error)) error
  • func (c *S3Chunker) Final() error

Functions

func ParseJSONRPC

func ParseJSONRPC(r io.Reader, cb func(dec *json.Decoder) error) error

ParseJSONRPC manual parse JSONRPC with a callback on the results. Memory efficient for large result arrays.

func SendS3Bytes

func SendS3Bytes(ctx context.Context, hc *http.Client, retryHTTP uint64, addr, network, chainID, typ, file string, position uint64, body []byte) error

Types

type S3Chunker

type S3Chunker struct {
	// contains filtered or unexported fields
}

func NewS3Chunker

func NewS3Chunker(maxSize, maxChunk uint64, send func([]byte, uint64) error) *S3Chunker

func (*S3Chunker) Append

func (c *S3Chunker) Append(data func(pos, maxChunk uint64) ([]byte, error)) error

func (*S3Chunker) Final

func (c *S3Chunker) Final() error