response

package

v1.1.11 Latest Latest Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

type Stream
- func New(respFunc substreams.ResponseFunc) *Stream

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Stream ¶

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

func New ¶

func New(respFunc substreams.ResponseFunc) *Stream

func (*Stream) BlockScopedData ¶

func (s *Stream) BlockScopedData(in *pbsubstreamsrpc.BlockScopedData) error

func (*Stream) InitialProgressMessages ¶

func (s *Stream) InitialProgressMessages(in map[string]block.Ranges) error

func (*Stream) RPCFailedProgressResponse ¶

func (s *Stream) RPCFailedProgressResponse(moduleName, reason string, logs []string, logsTruncated bool) error

func (*Stream) RPCProcessedBytes ¶

func (s *Stream) RPCProcessedBytes(
	moduleName string,
	bytesReadDelta uint64,
	bytesWrittenDelta uint64,
	totalBytesRead uint64,
	totalBytesWritten uint64,
	nanoSeconds uint64,
) error

func (*Stream) RPCRangeProgressResponse ¶

func (s *Stream) RPCRangeProgressResponse(moduleNames []string, start, end uint64) error

Source Files ¶

View all Source files

stream.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL