blockstream

Documentation

Index

• type Server
  • func NewBufferedServer(server *grpc.Server, size int) *Server
  • func NewServer(server *grpc.Server) *Server
  • func (s *Server) Blocks(r *pbbstream.BlockRequest, stream pbbstream.BlockStream_BlocksServer) error
  • func (s *Server) Close()
  • func (s *Server) GetHeadInfo(ctx context.Context, req *pbheadinfo.HeadInfoRequest) (*pbheadinfo.HeadInfoResponse, error)
  • func (s *Server) PushBlock(blk *bstream.Block) error
  • func (s *Server) Ready() bool
  • func (s *Server) Serve(listener net.Listener) error
  • func (s *Server) SetHeadInfo(num uint64, id string, blkTime time.Time, libNum uint64)
• type Source
  • func NewSource(ctx context.Context, endpointURL string, burst int64, h bstream.Handler, ...) *Source
  • func (s *Source) Run()
  • func (s *Source) SetName(name string)
  • func (s *Source) SetParallelPreproc(f bstream.PreprocessFunc, threads int)
• type SourceOption
  • func WithName(name string) SourceOption
  • func WithNumGator(blockNum uint64, exclusive bool) SourceOption
  • func WithParallelPreproc(f bstream.PreprocessFunc, threads int) SourceOption
  • func WithTimeThresholdGator(threshold time.Duration) SourceOption

Types

type Server

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

func NewBufferedServer

func NewBufferedServer(server *grpc.Server, size int) *Server

func NewServer

func NewServer(server *grpc.Server) *Server

func (*Server) Blocks

func (s *Server) Blocks(r *pbbstream.BlockRequest, stream pbbstream.BlockStream_BlocksServer) error

func (*Server) Close

func (s *Server) Close()

func (*Server) GetHeadInfo

func (s *Server) GetHeadInfo(ctx context.Context, req *pbheadinfo.HeadInfoRequest) (*pbheadinfo.HeadInfoResponse, error)

func (*Server) PushBlock

func (s *Server) PushBlock(blk *bstream.Block) error

func (*Server) Ready

func (s *Server) Ready() bool

func (*Server) Serve

func (s *Server) Serve(listener net.Listener) error

func (*Server) SetHeadInfo

func (s *Server) SetHeadInfo(num uint64, id string, blkTime time.Time, libNum uint64)

type Source

type Source struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func NewSource

func NewSource(
	ctx context.Context,
	endpointURL string,
	burst int64,
	h bstream.Handler,
	options ...SourceOption,
) *Source

func (*Source) Run

func (s *Source) Run()

func (*Source) SetName

func (s *Source) SetName(name string)

func (*Source) SetParallelPreproc

func (s *Source) SetParallelPreproc(f bstream.PreprocessFunc, threads int)

type SourceOption

type SourceOption = func(s *Source)

func WithName

func WithName(name string) SourceOption

func WithNumGator

func WithNumGator(blockNum uint64, exclusive bool) SourceOption

func WithParallelPreproc

func WithParallelPreproc(f bstream.PreprocessFunc, threads int) SourceOption

func WithTimeThresholdGator

func WithTimeThresholdGator(threshold time.Duration) SourceOption