service

Documentation

Index

• type Option
  • func WithCacheSaveInterval(block uint64) Option
  • func WithMaxWasmFuelPerBlockModule(maxFuel uint64) Option
  • func WithPartialMode() Option
  • func WithPipelineOptions(f pipeline.PipelineOptioner) Option
  • func WithRequestStats() Option
  • func WithWASMExtension(ext wasm.WASMExtensioner) Option
• type Service
  • func New(stateStore dstore.Store, blockType string, parallelSubRequests uint64, ...) (s *Service, err error)
  • func TestNewService(runtimeConfig config.RuntimeConfig, linearHandoffBlockNum uint64, ...) *Service
  • func (s *Service) BaseStateStore() dstore.Store
  • func (s *Service) BlockType() string
  • func (s *Service) Blocks(request *pbsubstreams.Request, streamSrv pbsubstreams.Stream_BlocksServer) (grpcError error)
  • func (s *Service) Register(server dgrpcserver.Server, mergedBlocksStore dstore.Store, ...)
  • func (s *Service) TestBlocks(ctx context.Context, isSubRequest bool, request *pbsubstreams.Request, ...) error
• type StreamFactory
  • func (s *StreamFactory) GetHeadBlock() (uint64, error)
  • func (s *StreamFactory) GetRecentFinalBlock() (uint64, error)
  • func (sf *StreamFactory) New(ctx context.Context, h bstream.Handler, startBlockNum int64, ...) (Streamable, error)
• type StreamFactoryFunc
• type Streamable

Types

type Option

type Option func(*Service)

func WithCacheSaveInterval

func WithCacheSaveInterval(block uint64) Option

func WithMaxWasmFuelPerBlockModule

func WithMaxWasmFuelPerBlockModule(maxFuel uint64) Option

func WithPartialMode

func WithPartialMode() Option

func WithPipelineOptions

func WithPipelineOptions(f pipeline.PipelineOptioner) Option

func WithRequestStats

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

func TestNewService

func TestNewService(runtimeConfig config.RuntimeConfig, linearHandoffBlockNum uint64, streamFactoryFunc StreamFactoryFunc) *Service

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

func (s *Service) TestBlocks(ctx context.Context, isSubRequest bool, request *pbsubstreams.Request, respFunc substreams.ResponseFunc) error

type StreamFactory

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

func (*StreamFactory) GetHeadBlock

func (s *StreamFactory) GetHeadBlock() (uint64, error)

func (*StreamFactory) GetRecentFinalBlock

func (s *StreamFactory) GetRecentFinalBlock() (uint64, error)

func (*StreamFactory) New

func (sf *StreamFactory) New(
	ctx context.Context,
	h bstream.Handler,
	startBlockNum int64,
	stopBlockNum uint64,
	cursor string,
	cursorIsTarget bool,
) (Streamable, error)

type StreamFactoryFunc

type StreamFactoryFunc func(ctx context.Context, h bstream.Handler, startBlockNum int64, stopBlockNum uint64, cursor string, cursorIsTarget bool) (Streamable, error)

type Streamable

type Streamable interface {
	Run(ctx context.Context) error
}