Documentation
¶
Index ¶
- type ErrSendBlock
- type Option
- type Service
- func (s *Service) BaseStateStore() dstore.Store
- func (s *Service) BlockType() string
- func (s *Service) Blocks(request *pbsubstreams.Request, streamSrv pbsubstreams.Stream_BlocksServer) error
- func (s *Service) Register(firehoseServer *firehoseServer.Server, streamFactory *firehose.StreamFactory, ...)
- func (s *Service) WasmExtensions() []wasm.WASMExtensioner
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 WithCacheEnabled ¶ added in v0.0.19
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 New ¶
func New(stateStore dstore.Store, blockType string, grpcClientFactory substreams.GrpcClientFactory, parallelSubRequests int, blockRangeSizeSubRequests int, opts ...Option) *Service
func (*Service) BaseStateStore ¶
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)
func (*Service) WasmExtensions ¶
func (s *Service) WasmExtensions() []wasm.WASMExtensioner
Source Files
Click to show internal directories.
Click to hide internal directories.