blockstream

Documentation

Index

• type Server
  • func NewBufferedServer(server dgrpcserver.Server, size int, opts ...ServerOption) *Server
  • func NewServer(server dgrpcserver.Server, opts ...ServerOption) *Server
  • func NewUnmanagedServer(opts ...ServerOption) *Server
  • func (s *Server) Blocks(r *pbbstream.BlockRequest, stream pbbstream.BlockStream_BlocksServer) error
  • func (s *Server) GetHeadInfo(ctx context.Context, req *pbheadinfo.HeadInfoRequest) (*pbheadinfo.HeadInfoResponse, error)
  • func (s *Server) PushBlock(blk *pbbstream.Block) error
  • func (s *Server) Ready() bool
  • func (s *Server) SetHeadInfo(num uint64, id string, blkTime time.Time, libNum uint64)
• type ServerOption
  • func ServerOptionWithBuffer(size int) ServerOption
  • func ServerOptionWithLogger(logger *zap.Logger) ServerOption
• type Source
  • func NewSource(ctx context.Context, endpointURL string, burst int64, h bstream.Handler, ...) *Source
  • func (s *Source) Run()
  • func (s *Source) SetLogger(logger *zap.Logger)
  • func (s *Source) SetParallelPreproc(f bstream.PreprocessFunc, threads int)
• type SourceOption
  • func WithLogger(logger *zap.Logger) SourceOption
  • func WithNumGator(blockNum uint64, exclusive bool) SourceOption
  • func WithParallelPreproc(f bstream.PreprocessFunc, threads int) SourceOption
  • func WithRequester(requester string) SourceOption
  • func WithTimeThresholdGator(threshold time.Duration) SourceOption

Types

type Server

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

func NewBufferedServer

func NewBufferedServer(server dgrpcserver.Server, size int, opts ...ServerOption) *Server

func NewServer

func NewServer(server dgrpcserver.Server, opts ...ServerOption) *Server

func NewUnmanagedServer

func NewUnmanagedServer(opts ...ServerOption) *Server

NewUnmanagedServer can be used to create a BlockStream server that has no control over the actual gRPC server. Registration of services should be made manually by entity calling `blockstream.NewUnmanagedServer`.

Moreover, management methods like `Close`

func (*Server) Blocks

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

func (*Server) GetHeadInfo

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

func (*Server) PushBlock

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

func (*Server) Ready

func (s *Server) Ready() bool

func (*Server) SetHeadInfo

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

type ServerOption

type ServerOption func(s *Server)

func ServerOptionWithBuffer

func ServerOptionWithBuffer(size int) ServerOption

func ServerOptionWithLogger

func ServerOptionWithLogger(logger *zap.Logger) ServerOption

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

func (s *Source) SetLogger(logger *zap.Logger)

func (*Source) SetParallelPreproc

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

type SourceOption

type SourceOption = func(s *Source)

func WithLogger

func WithLogger(logger *zap.Logger) SourceOption

func WithNumGator

func WithNumGator(blockNum uint64, exclusive bool) SourceOption

func WithParallelPreproc

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

func WithRequester

func WithRequester(requester string) SourceOption

func WithTimeThresholdGator

func WithTimeThresholdGator(threshold time.Duration) SourceOption