Documentation
¶
Index ¶
- type Stream
- func (s *Stream) BlockScopedData(in *pbsubstreamsrpc.BlockScopedData) error
- func (s *Stream) BlockScopedDatas(in *pbsubstreamsrpcv4.BlockScopedDatas) error
- func (s *Stream) RPCFailedProgressResponse(reason string, logs []string, logsTruncated bool) error
- func (s *Stream) SendModulesStats(stats []*pbsubstreamsrpc.ModuleStats, stages []*pbsubstreamsrpc.Stage, ...) error
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) BlockScopedDatas ¶ added in v1.18.0
func (s *Stream) BlockScopedDatas(in *pbsubstreamsrpcv4.BlockScopedDatas) error
func (*Stream) RPCFailedProgressResponse ¶
func (*Stream) SendModulesStats ¶ added in v1.1.12
func (s *Stream) SendModulesStats(stats []*pbsubstreamsrpc.ModuleStats, stages []*pbsubstreamsrpc.Stage, jobs []*pbsubstreamsrpc.Job, bytesRead, bytesWritten, blocksProcessed uint64) error
Source Files
Click to show internal directories.
Click to hide internal directories.