Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrSendBlock ¶
type ErrSendBlock struct {
// contains filtered or unexported fields
}
func NewErrSendBlock ¶
func NewErrSendBlock(inner error) ErrSendBlock
func (ErrSendBlock) Error ¶
func (e ErrSendBlock) Error() string
type Option ¶
type Option func(*Service)
func WithPartialMode ¶
func WithPartialMode() Option
func WithPipelineOptions ¶
func WithPipelineOptions(f pipeline.PipelineOptioner) Option
func WithStoresSaveInterval ¶
func WithWASMExtension ¶
func WithWASMExtension(ext wasm.WASMExtensioner) Option
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) Blocks ¶
func (s *Service) Blocks(request *pbsubstreams.Request, streamSrv pbsubstreams.Stream_BlocksServer) error
func (*Service) Register ¶
func (s *Service) Register(firehoseServer *firehoseServer.Server, streamFactory *firehose.StreamFactory, logger *zap.Logger)
Source Files
Click to show internal directories.
Click to hide internal directories.