index

Oct 6, 2021

Changes in this version

+ type MetricsWriter struct

+ func NewMetricsWriter(write *Writer) *MetricsWriter

+ func (w *MetricsWriter) Collections(height uint64, collections []*flow.LightCollection) error

+ func (w *MetricsWriter) Commit(height uint64, commit flow.StateCommitment) error

+ func (w *MetricsWriter) Events(height uint64, events []flow.Event) error

+ func (w *MetricsWriter) First(height uint64) error

+ func (w *MetricsWriter) Guarantees(height uint64, guarantees []*flow.CollectionGuarantee) error

+ func (w *MetricsWriter) Header(height uint64, header *flow.Header) error

+ func (w *MetricsWriter) Height(blockID flow.Identifier, height uint64) error

+ func (w *MetricsWriter) Last(height uint64) error

+ func (w *MetricsWriter) Payloads(height uint64, paths []ledger.Path, payloads []*ledger.Payload) error

+ func (w *MetricsWriter) Results(results []*flow.TransactionResult) error

+ func (w *MetricsWriter) Seals(height uint64, seals []*flow.Seal) error

+ func (w *MetricsWriter) Transactions(height uint64, transactions []*flow.TransactionBody) error

Sep 24, 2021

Changes in this version

+ func WithFlushInterval(interval time.Duration) func(*Config)

type Config

+ FlushInterval time.Duration

Aug 14, 2021

Changes in this version

type Reader

+ func (r *Reader) Collection(collID flow.Identifier) (*flow.LightCollection, error)

+ func (r *Reader) CollectionsByHeight(height uint64) ([]flow.Identifier, error)

+ func (r *Reader) Guarantee(collID flow.Identifier) (*flow.CollectionGuarantee, error)

+ func (r *Reader) HeightForTransaction(txID flow.Identifier) (uint64, error)

+ func (r *Reader) Result(txID flow.Identifier) (*flow.TransactionResult, error)

+ func (r *Reader) Seal(sealID flow.Identifier) (*flow.Seal, error)

+ func (r *Reader) SealsByHeight(height uint64) ([]flow.Identifier, error)

type Writer

+ func (w *Writer) Guarantees(_ uint64, guarantees []*flow.CollectionGuarantee) error

+ func (w *Writer) Results(results []*flow.TransactionResult) error

+ func (w *Writer) Seals(height uint64, seals []*flow.Seal) error

Jul 22, 2021

Changes in this version

+ var DefaultConfig = Config

+ func WithConcurrentTransactions(concurrent uint) func(*Config)

+ type Config struct

+ ConcurrentTransactions uint

+ type Reader struct

+ func NewReader(db *badger.DB, lib dps.ReadLibrary) *Reader

+ func (r *Reader) Commit(height uint64) (flow.StateCommitment, error)

+ func (r *Reader) Events(height uint64, types ...flow.EventType) ([]flow.Event, error)

+ func (r *Reader) First() (uint64, error)

+ func (r *Reader) Header(height uint64) (*flow.Header, error)

+ func (r *Reader) HeightForBlock(blockID flow.Identifier) (uint64, error)

+ func (r *Reader) Last() (uint64, error)

+ func (r *Reader) Transaction(txID flow.Identifier) (*flow.TransactionBody, error)

+ func (r *Reader) TransactionsByHeight(height uint64) ([]flow.Identifier, error)

+ func (r *Reader) Values(height uint64, paths []ledger.Path) ([]ledger.Value, error)

+ type Writer struct

+ func NewWriter(db *badger.DB, lib dps.WriteLibrary, options ...func(*Config)) *Writer

+ func (w *Writer) Close() error

+ func (w *Writer) Collections(height uint64, collections []*flow.LightCollection) error

+ func (w *Writer) Commit(height uint64, commit flow.StateCommitment) error

+ func (w *Writer) Events(height uint64, events []flow.Event) error

+ func (w *Writer) First(height uint64) error

+ func (w *Writer) Header(height uint64, header *flow.Header) error

+ func (w *Writer) Height(blockID flow.Identifier, height uint64) error

+ func (w *Writer) Last(height uint64) error

+ func (w *Writer) Payloads(height uint64, paths []ledger.Path, payloads []*ledger.Payload) error

+ func (w *Writer) Transactions(height uint64, transactions []*flow.TransactionBody) error