response

Documentation

Index

• type Stream
  • func New(respFunc substreams.ResponseFunc) *Stream
  • func (s *Stream) BlockScopedData(in *pbsubstreamsrpc.BlockScopedData) error
  • func (s *Stream) RPCFailedProgressResponse(reason string, logs []string, logsTruncated bool) error
  • func (s *Stream) SendModulesStats(stats []*pbsubstreamsrpc.ModuleStats, stages []*pbsubstreamsrpc.Stage, ...) error

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) RPCFailedProgressResponse

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

func (*Stream) SendModulesStats

func (s *Stream) SendModulesStats(stats []*pbsubstreamsrpc.ModuleStats, stages []*pbsubstreamsrpc.Stage, jobs []*pbsubstreamsrpc.Job, bytesRead, bytesWritten uint64) error