blocks

Documentation

Index

• func BlockDecoder(blk *bstream.Block) (interface{}, error)
• func BlockFromProto(b *pbcodec.Block) (*bstream.Block, error)
• type BlockReader
  • func NewBlockReader(reader io.Reader) (out *BlockReader, err error)
  • func (l *BlockReader) Read() (*bstream.Block, error)
• type Firehose
• type LocalFirehoseFactory
  • func NewLocalFirehoseFactory(store dstore.Store) *LocalFirehoseFactory
  • func (f *LocalFirehoseFactory) StreamBlocks(ctx context.Context, req *pbfirehose.Request) (pbfirehose.Stream_BlocksClient, error)
• type StreamingFastFirehoseFactory
  • func NewStreamingFastFirehoseFactory(apiKey string, endpoint string) (*StreamingFastFirehoseFactory, error)
  • func (f *StreamingFastFirehoseFactory) StreamBlocks(ctx context.Context, req *pbfirehose.Request) (pbfirehose.Stream_BlocksClient, error)

Functions

func BlockDecoder

func BlockDecoder(blk *bstream.Block) (interface{}, error)

func BlockFromProto

func BlockFromProto(b *pbcodec.Block) (*bstream.Block, error)

Types

type BlockReader

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

BlockReader reads the dbin format where each element is assumed to be a `bstream.Block`.

func NewBlockReader

func NewBlockReader(reader io.Reader) (out *BlockReader, err error)

func (*BlockReader) Read

func (l *BlockReader) Read() (*bstream.Block, error)

type Firehose

type Firehose interface {
	StreamBlocks(ctx context.Context, req *pbfirehose.Request) (pbfirehose.Stream_BlocksClient, error)
}

type LocalFirehoseFactory

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

func NewLocalFirehoseFactory

func NewLocalFirehoseFactory(store dstore.Store) *LocalFirehoseFactory

func (*LocalFirehoseFactory) StreamBlocks

func (f *LocalFirehoseFactory) StreamBlocks(ctx context.Context, req *pbfirehose.Request) (pbfirehose.Stream_BlocksClient, error)

type StreamingFastFirehoseFactory

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

func NewStreamingFastFirehoseFactory

func NewStreamingFastFirehoseFactory(apiKey string, endpoint string) (*StreamingFastFirehoseFactory, error)

func (*StreamingFastFirehoseFactory) StreamBlocks

func (f *StreamingFastFirehoseFactory) StreamBlocks(ctx context.Context, req *pbfirehose.Request) (pbfirehose.Stream_BlocksClient, error)