dryrunstore

Documentation

Index

• type Store
  • func New(ctx context.Context, subgraphDef *subgraph.Definition, logger *zap.Logger, ...) *Store
  • func (s *Store) BatchSave(ctx context.Context, block *pbcodec.Block, ...) (err error)
  • func (s *Store) CleanDataAtBlock(ctx context.Context, blockNum uint64) error
  • func (s *Store) CleanUpFork(ctx context.Context, newHeadBlock uint64) error
  • func (s *Store) Close() error
  • func (s *Store) Load(ctx context.Context, id string, out entity.Interface, blockNum uint64) error
  • func (s *Store) LoadAllDistinct(ctx context.Context, model entity.Interface, blockNum uint64) ([]entity.Interface, error)
  • func (s *Store) LoadCursor(ctx context.Context) (string, error)
  • func (s *Store) OpenOutputFiles() error

Types

type Store

type Store struct {
	Cache map[string]map[string]entity.Interface
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, subgraphDef *subgraph.Definition, logger *zap.Logger, endBlock uint64, outputPath string) *Store

func (*Store) BatchSave

func (s *Store) BatchSave(ctx context.Context, block *pbcodec.Block, updates map[string]map[string]entity.Interface, cursor string) (err error)

func (*Store) CleanDataAtBlock

func (s *Store) CleanDataAtBlock(ctx context.Context, blockNum uint64) error

func (*Store) CleanUpFork

func (s *Store) CleanUpFork(ctx context.Context, newHeadBlock uint64) error

func (*Store) Close

func (s *Store) Close() error

func (*Store) Load

func (s *Store) Load(ctx context.Context, id string, out entity.Interface, blockNum uint64) error

func (*Store) LoadAllDistinct

func (s *Store) LoadAllDistinct(ctx context.Context, model entity.Interface, blockNum uint64) ([]entity.Interface, error)

func (*Store) LoadCursor

func (s *Store) LoadCursor(ctx context.Context) (string, error)

func (*Store) OpenOutputFiles

func (s *Store) OpenOutputFiles() error