state

package

Go to main page

Versions in this module

v0

v0.0.20

Aug 23, 2022

Changes in this version

type Store

+ func (s *Store) ApplyDeltaReverse(deltas []*pbsubstreams.StoreDelta)

v0.0.19

Aug 23, 2022

Changes in this version

type Store

+ func NewStore(name string, saveInterval uint64, moduleInitialBlock uint64, moduleHash string, ...) (*Store, error)

v0.0.17

Jul 29, 2022

v0.0.16

Jul 29, 2022

v0.0.15

Jul 29, 2022

v0.0.14

Jul 29, 2022

Changes in this version

+ type Snapshot struct

+ Path string

+ type Snapshots struct

+ Completes block.Ranges

+ Partials block.Ranges

+ func (s *Snapshots) ContainsPartial(r *block.Range) bool

+ func (s *Snapshots) LastCompletedBlock() uint64

+ func (s *Snapshots) Sort()

type Store

+ func (s *Store) Append(ord uint64, key string, value []byte)

+ func (s *Store) ListSnapshots(ctx context.Context) (out *Snapshots, err error)

v0.0.13

Jun 3, 2022

v0.0.12

Jun 3, 2022

v0.0.11

Jun 3, 2022

Changes in this version

+ const OutputValueTypeBigFloat

+ const OutputValueTypeBigInt

+ const OutputValueTypeFloat64

+ const OutputValueTypeInt64

+ const OutputValueTypeString

+ func FullStateFileName(r *block.Range, moduleStartBlock uint64) string

+ func FullStateFilePrefix(blockNum uint64) string

+ func InfoFileName() string

+ func PartialFileName(r *block.Range) string

+ type BuilderOption func(b *Store)

+ type ConditionalKeySetter interface

+ SetBytesIfNotExists func(ord uint64, key string, value []byte)

+ SetIfNotExists func(ord uint64, key string, value string)

+ type Deleter interface

+ DeletePrefix func(ord uint64, prefix string)

+ type FileInfo struct

+ EndBlock uint64

+ Partial bool

+ StartBlock uint64

+ func ParseFileName(filename string) (*FileInfo, bool)

+ type Info struct

+ LastKVFile string

+ LastKVSavedBlock uint64

+ RangeIntervalSize uint64

+ type MaxBigFloatSetter interface

+ SetMaxBigFloat func(ord uint64, key string, value *big.Float)

+ type MaxBigIntSetter interface

+ SetMaxBigInt func(ord uint64, key string, value *big.Int)

+ type MaxFloat64Setter interface

+ SetMaxFloat64 func(ord uint64, key string, value float64)

+ type MaxInt64Setter interface

+ SetMaxInt64 func(ord uint64, key string, value int64)

+ type Mergeable interface

+ Merge func(other *Store) error

+ type MinBigFloatSetter interface

+ SetMinBigFloat func(ord uint64, key string, value *big.Float)

+ type MinBigIntSetter interface

+ SetMinBigInt func(ord uint64, key string, value *big.Int)

+ type MinFloat64Setter interface

+ SetMinFloat64 func(ord uint64, key string, value float64)

+ type MinInt64Setter interface

+ SetMinInt64 func(ord uint64, key string, value int64)

+ type Reader interface

+ GetAt func(ord uint64, key string) ([]byte, bool)

+ GetFirst func(key string) ([]byte, bool)

+ GetLast func(key string) ([]byte, bool)

+ type Store struct

+ DeletedPrefixes []string

+ Deltas []*pbsubstreams.StoreDelta

+ Initialized bool

+ KV map[string][]byte

+ ModuleHash string

+ ModuleInitialBlock uint64

+ Name string

+ ProcessedBlock uint64

+ SaveInterval uint64

+ Store dstore.Store

+ StoreInitialBlock uint64

+ UpdatePolicy pbsubstreams.Module_KindStore_UpdatePolicy

+ ValueType string

+ func NewBuilder(name string, saveInterval uint64, moduleInitialBlock uint64, moduleHash string, ...) (*Store, error)

+ func (b *Store) ApplyDelta(delta *pbsubstreams.StoreDelta)

+ func (b *Store) CloneStructure(newStoreStartBlock uint64) *Store

+ func (b *Store) Del(ord uint64, key string)

+ func (b *Store) DeletePrefix(ord uint64, prefix string)

+ func (b *Store) DeleteStore(ctx context.Context, exclusiveEndBlock uint64) error

+ func (b *Store) Flush()

+ func (b *Store) GetAt(ord uint64, key string) (out []byte, found bool)

+ func (b *Store) GetFirst(key string) ([]byte, bool)

+ func (b *Store) GetLast(key string) ([]byte, bool)

+ func (b *Store) Info(ctx context.Context) (*Info, error)

+ func (b *Store) LoadFrom(ctx context.Context, blockRange *block.Range) (*Store, error)

+ func (b *Store) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (b *Store) Print()

+ func (b *Store) PrintDelta(delta *pbsubstreams.StoreDelta)

+ func (b *Store) Roll(lastBlock uint64)

+ func (b *Store) Set(ord uint64, key string, value string)

+ func (b *Store) SetBytes(ord uint64, key string, value []byte)

+ func (b *Store) SetBytesIfNotExists(ord uint64, key string, value []byte)

+ func (b *Store) SetIfNotExists(ord uint64, key string, value string)

+ func (b *Store) SetMaxBigFloat(ord uint64, key string, value *big.Float)

+ func (b *Store) SetMaxBigInt(ord uint64, key string, value *big.Int)

+ func (b *Store) SetMaxFloat64(ord uint64, key string, value float64)

+ func (b *Store) SetMaxInt64(ord uint64, key string, value int64)

+ func (b *Store) SetMinBigFloat(ord uint64, key string, value *big.Float)

+ func (b *Store) SetMinBigInt(ord uint64, key string, value *big.Int)

+ func (b *Store) SetMinFloat64(ord uint64, key string, value float64)

+ func (b *Store) SetMinInt64(ord uint64, key string, value int64)

+ func (b *Store) SumBigFloat(ord uint64, key string, value *big.Float)

+ func (b *Store) SumBigInt(ord uint64, key string, value *big.Int)

+ func (b *Store) SumFloat64(ord uint64, key string, value float64)

+ func (b *Store) SumInt64(ord uint64, key string, value int64)

+ func (b *Store) Truncate()

+ func (b *Store) WriteState(ctx context.Context, lastBlock uint64) (err error)

+ func (into *Store) Merge(builder *Store) error

+ func (s *Store) Fetch(ctx context.Context, exclusiveEndBlock uint64) error

+ func (s *Store) IsPartial() bool

+ type SumBigFloatSetter interface

+ SumBigFloat func(ord uint64, key string, value *big.Float)

+ type SumBigIntSetter interface

+ SumBigInt func(ord uint64, key string, value *big.Int)

+ type SumFloat64Setter interface

+ SumFloat64 func(ord uint64, key string, value float64)

+ type SumInt64Setter interface

+ SumInt64 func(ord uint64, key string, value int64)

+ type UpdateKeySetter interface

+ Set func(ord uint64, key string, value string)

+ SetBytes func(ord uint64, key string, value []byte)

v0.0.10-beta

Jun 2, 2022

v0.0.9-beta

Jun 2, 2022

v0.0.8-beta

May 30, 2022

v0.0.7-beta

May 30, 2022

v0.0.6-beta

May 17, 2022

v0.0.5-beta3

May 9, 2022

v0.0.5-beta2

May 4, 2022

v0.0.5-beta

Apr 27, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL