service

package

v0.0.21 Latest Latest Go to latest Published: Oct 31, 2022 License: Apache-2.0 Imports: 30 Imported by: 8

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

type Option
type Service
- func New(stateStore dstore.Store, blockType string, parallelSubRequests uint64, ...) (s *Service, err error)
type StreamFactory
- func (sf *StreamFactory) New(h bstream.Handler, startBlockNum int64, stopBlockNum uint64, cursor string) (*stream.Stream, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option func(*Service)

func WithOutCacheSaveInterval ¶

func WithOutCacheSaveInterval(block uint64) Option

func WithPartialMode ¶

func WithPartialMode() Option

func WithPipelineOptions ¶

func WithPipelineOptions(f pipeline.PipelineOptioner) Option

func WithRequestStats ¶ added in v0.0.21

func WithRequestStats() Option

func WithStoresSaveInterval ¶

func WithStoresSaveInterval(block uint64) Option

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,
	parallelSubRequests uint64,
	blockRangeSizeSubRequests uint64,
	substreamsClientConfig *client.SubstreamsClientConfig,
	opts ...Option,
) (s *Service, err error)

func (*Service) BaseStateStore ¶

func (s *Service) BaseStateStore() dstore.Store

func (*Service) BlockType ¶

func (s *Service) BlockType() string

func (*Service) Blocks ¶

func (s *Service) Blocks(request *pbsubstreams.Request, streamSrv pbsubstreams.Stream_BlocksServer) (grpcError error)

func (*Service) Register ¶

func (s *Service) Register(
	server dgrpcserver.Server,
	mergedBlocksStore dstore.Store,
	forkedBlocksStore dstore.Store,
	forkableHub *hub.ForkableHub,
	logger *zap.Logger)

func (*Service) WasmExtensions ¶

func (s *Service) WasmExtensions() []wasm.WASMExtensioner

type StreamFactory ¶ added in v0.0.21

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

func (*StreamFactory) New ¶ added in v0.0.21

func (sf *StreamFactory) New(
	h bstream.Handler,
	startBlockNum int64,
	stopBlockNum uint64,
	cursor string,
) (*stream.Stream, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL