storage

Sep 4, 2024

Changes in this version

+ const BlockIndexStoreName

+ const BlockStoreName

+ const CollectionStoreName

+ const EventStoreName

+ const TransactionResultStoreName

+ const TransactionStoreName

Apr 11, 2024

Changes in this version

type DefaultKeyGenerator

+ func (s *DefaultKeyGenerator) ForkedBlock() []byte

type DefaultStore

+ func (s *DefaultStore) ForkedBlockHeight(ctx context.Context) (forkedBlockHeight uint64, err error)

+ func (s *DefaultStore) StoreForkedBlockHeight(ctx context.Context, height uint64) error

type KeyGenerator

+ ForkedBlock func() []byte

May 28, 2024

Changes in this version

type DefaultStore

+ func (s *DefaultStore) FullCollectionByID(ctx context.Context, colID flowgo.Identifier) (col flowgo.Collection, err error)

type Store

+ FullCollectionByID func(ctx context.Context, collectionID flowgo.Identifier) (flowgo.Collection, error)

May 23, 2023

Changes in this version

+ const LedgerStoreName

Apr 10, 2023

Changes in this version

type DefaultStore

+ CurrentHeight uint64

+ func (s *DefaultStore) InsertExecutionSnapshot(ctx context.Context, blockHeight uint64, ...) error

+ func (s *DefaultStore) LedgerByHeight(ctx context.Context, blockHeight uint64) state.StorageSnapshot

+ func (s *DefaultStore) SetBlockHeight(height uint64) error

+ func (s *DefaultStore) Start() error

+ func (s *DefaultStore) Stop()

+ type RollbackProvider interface

+ RollbackToBlockHeight func(height uint64) error

type SnapshotProvider

+ CreateSnapshot func(snapshotName string) error

+ LoadSnapshot func(snapshotName string) error

type Store

+ LedgerByHeight func(ctx context.Context, blockHeight uint64) state.StorageSnapshot

Feb 10, 2023

Changes in this version

+ type SnapshotProvider interface

+ JumpToSnapshot func(snapshotName string, createIfNotExists bool) error

+ Snapshots func() ([]string, error)

+ SupportSnapshotsWithCurrentConfig func() bool

Nov 22, 2022

Changes in this version

+ type DataGetter interface

+ GetBytes func(ctx context.Context, store string, key []byte) ([]byte, error)

+ GetBytesAtVersion func(ctx context.Context, store string, key []byte, version uint64) ([]byte, error)

+ type DataSetter interface

+ SetBytes func(ctx context.Context, store string, key []byte, value []byte) error

+ SetBytesWithVersion func(ctx context.Context, store string, key []byte, value []byte, version uint64) error

+ type DefaultKeyGenerator struct

+ func (s *DefaultKeyGenerator) BlockHeight(blockHeight uint64) []byte

+ func (s *DefaultKeyGenerator) Event(blockHeight uint64, txIndex, eventIndex uint32, eventType flowgo.EventType) []byte

+ func (s *DefaultKeyGenerator) Identifier(id flowgo.Identifier) []byte

+ func (s *DefaultKeyGenerator) LatestBlock() []byte

+ func (s *DefaultKeyGenerator) Storage(key string) string

+ type DefaultStore struct

+ func (s *DefaultStore) BlockByHeight(ctx context.Context, blockHeight uint64) (block *flowgo.Block, err error)

+ func (s *DefaultStore) BlockByID(ctx context.Context, blockID flowgo.Identifier) (block *flowgo.Block, err error)

+ func (s *DefaultStore) CollectionByID(ctx context.Context, colID flowgo.Identifier) (col flowgo.LightCollection, err error)

+ func (s *DefaultStore) CommitBlock(ctx context.Context, block flowgo.Block, collections []*flowgo.LightCollection, ...) error

+ func (s *DefaultStore) EventsByHeight(ctx context.Context, blockHeight uint64, eventType string) (events []flowgo.Event, err error)

+ func (s *DefaultStore) InsertCollection(ctx context.Context, col flowgo.LightCollection) error

+ func (s *DefaultStore) InsertEvents(ctx context.Context, blockHeight uint64, events []flowgo.Event) error

+ func (s *DefaultStore) InsertLedgerDelta(ctx context.Context, blockHeight uint64, delta delta.Delta) error

+ func (s *DefaultStore) InsertTransaction(ctx context.Context, tx flowgo.TransactionBody) error

+ func (s *DefaultStore) InsertTransactionResult(ctx context.Context, txID flowgo.Identifier, ...) error

+ func (s *DefaultStore) LatestBlock(ctx context.Context) (block flowgo.Block, err error)

+ func (s *DefaultStore) LatestBlockHeight(ctx context.Context) (latestBlockHeight uint64, err error)

+ func (s *DefaultStore) LedgerViewByHeight(ctx context.Context, blockHeight uint64) *delta.View

+ func (s *DefaultStore) StoreBlock(ctx context.Context, block *flowgo.Block) error

+ func (s *DefaultStore) TransactionByID(ctx context.Context, txID flowgo.Identifier) (tx flowgo.TransactionBody, err error)

+ func (s *DefaultStore) TransactionResultByID(ctx context.Context, txID flowgo.Identifier) (result types.StorableTransactionResult, err error)

+ type KeyGenerator interface

+ BlockHeight func(height uint64) []byte

+ Event func(blockHeight uint64, txIndex, eventIndex uint32, eventType flowgo.EventType) []byte

+ Identifier func(id flowgo.Identifier) []byte

+ LatestBlock func() []byte

+ Storage func(key string) string

type Store

+ LatestBlockHeight func(ctx context.Context) (uint64, error)

Nov 4, 2020

Changes in this version

+ var ErrNotFound = errors.New("could not find entity")

+ type Store interface

+ BlockByHeight func(height uint64) (*flowgo.Block, error)

+ BlockByID func(blockID flowgo.Identifier) (*flowgo.Block, error)

+ CollectionByID func(flowgo.Identifier) (flowgo.LightCollection, error)

+ CommitBlock func(block flowgo.Block, collections []*flowgo.LightCollection, ...) error

+ EventsByHeight func(blockHeight uint64, eventType string) ([]flowgo.Event, error)

+ LatestBlock func() (flowgo.Block, error)

+ LedgerViewByHeight func(blockHeight uint64) *delta.View

+ StoreBlock func(block *flowgo.Block) error

+ TransactionByID func(flowgo.Identifier) (flowgo.TransactionBody, error)

+ TransactionResultByID func(flowgo.Identifier) (types.StorableTransactionResult, error)