substreams

Documentation

Index

• func ReadManifest(path string, params []string) (*pbsubstreams.Package, error)
• type Config
• type Stream
  • func Run(cfg *Config) (*Stream, error)
  • func (s *Stream) Close() error
  • func (s *Stream) Recv() (*pbursa.Block, error)

Functions

func ReadManifest

func ReadManifest(path string, params []string) (*pbsubstreams.Package, error)

Types

type Config

type Config struct {
	Endpoint string
	APIToken string

	Package          *pbsubstreams.Package
	OutputModuleName string

	Cursor string

	DevelopmentMode bool
	BlockBufferSize int
	FinalBlocksOnly bool
}

type Stream

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

func Run

func Run(cfg *Config) (*Stream, error)

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) Recv

func (s *Stream) Recv() (*pbursa.Block, error)