Versions in this module Expand all Collapse all v1 v1.1.3 Jan 20, 2025 v1.1.2 Jan 20, 2025 Changes in this version + func GetReorgError(err error) error + func GetReorgErrorBlockNumber(err error) uint64 + func IsReorgError(err error) bool + func LogComparedBytes(name1 string, name2 string, data1 []byte, data2 []byte, numBytesBefore int, ...) string + func RpcBatchToStateBatch(rpcBatch *types.Batch) *state.Batch + type Cache struct + func NewCache[K comparable, T any](timerProvider TimeProvider, timeOfLiveItems time.Duration) *Cache[K, T] + func (c *Cache[K, T]) Clear() + func (c *Cache[K, T]) Delete(key K) + func (c *Cache[K, T]) DeleteOutdated() + func (c *Cache[K, T]) Get(key K) (T, bool) + func (c *Cache[K, T]) GetOrDefault(key K, defaultValue T) T + func (c *Cache[K, T]) Keys() []K + func (c *Cache[K, T]) Len() int + func (c *Cache[K, T]) RenewEntry(key K, validTime time.Time) + func (c *Cache[K, T]) Set(key K, value T) + func (c *Cache[K, T]) Values() []T + type CriticalErrorHalt struct + EventLog syncinterfaces.EventLogInterface + SleepTime time.Duration + func NewCriticalErrorHalt(eventLog syncinterfaces.EventLogInterface, sleepTime time.Duration) *CriticalErrorHalt + func (g *CriticalErrorHalt) CriticalError(ctx context.Context, err error) + type DefaultTimeProvider struct + func (d DefaultTimeProvider) Now() time.Time + type MockTimerProvider struct + func (m *MockTimerProvider) Now() time.Time + type ReorgError struct + BlockNumber uint64 + Err error + func NewReorgError(blockNumber uint64, err error) *ReorgError + func (e *ReorgError) Error() string + type TimeProvider interface + Now func() time.Time
Go to main page