Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ComputeStartBlock ¶
Types ¶
type ModulesOutputCache ¶
type ModulesOutputCache struct {
OutputCaches map[string]*OutputCache
SaveBlockInterval uint64
}
func NewModuleOutputCache ¶
func NewModuleOutputCache(saveBlockInterval uint64) *ModulesOutputCache
func (*ModulesOutputCache) RegisterModule ¶
func (c *ModulesOutputCache) RegisterModule(ctx context.Context, module *pbsubstreams.Module, hash string, baseCacheStore dstore.Store, requestedStartBlock uint64) (*OutputCache, error)
type OutputCache ¶
type OutputCache struct {
ModuleName string
CurrentBlockRange *block.Range
Store dstore.Store
New bool
// contains filtered or unexported fields
}
func NewOutputCache ¶
func NewOutputCache(moduleName string, store dstore.Store, saveBlockInterval uint64) *OutputCache
func (*OutputCache) Load ¶
func (c *OutputCache) Load(ctx context.Context, atBlock uint64) (err error)
func (*OutputCache) SortedCacheItem ¶
func (c *OutputCache) SortedCacheItem() (out []*CacheItem)
Click to show internal directories.
Click to hide internal directories.