cache

Documentation

Overview

Package cache contains critical caches necessary for the runtime of the slasher service, being able to keep attestation spans by epoch for the validators active in the beacon chain.

Index

• type EpochSpansCache
  • func NewEpochSpansCache(size int, onEvicted func(key interface{}, value interface{})) (*EpochSpansCache, error)
  • func (c *EpochSpansCache) Clear()
  • func (c *EpochSpansCache) Delete(epoch uint64) bool
  • func (c *EpochSpansCache) Get(epoch uint64) (map[uint64]types.Span, bool)
  • func (c *EpochSpansCache) Has(epoch uint64) bool
  • func (c *EpochSpansCache) Set(epoch uint64, epochSpans map[uint64]types.Span)
• type PublicKeyCache
  • func NewPublicKeyCache(size int, onEvicted func(key interface{}, value interface{})) (*PublicKeyCache, error)
  • func (c *PublicKeyCache) Clear()
  • func (c *PublicKeyCache) Delete(validatorIdx uint64) bool
  • func (c *PublicKeyCache) Get(validatorIdx uint64) ([]byte, bool)
  • func (c *PublicKeyCache) Has(validatorIdx uint64) bool
  • func (c *PublicKeyCache) Set(validatorIdx uint64, publicKey []byte)

Types

type EpochSpansCache

type EpochSpansCache struct {
	// contains filtered or unexported fields
}

EpochSpansCache is used to store the spans needed on a per-epoch basis for slashing detection.

func NewEpochSpansCache

func NewEpochSpansCache(size int, onEvicted func(key interface{}, value interface{})) (*EpochSpansCache, error)

NewEpochSpansCache initializes the map and underlying cache.

func (*EpochSpansCache) Clear

func (c *EpochSpansCache) Clear()

Clear removes all keys from the SpanCache.

func (*EpochSpansCache) Delete

func (c *EpochSpansCache) Delete(epoch uint64) bool

Delete removes an epoch from the cache and returns if it existed or not. Performs the onEviction function before removal.

func (*EpochSpansCache) Get

func (c *EpochSpansCache) Get(epoch uint64) (map[uint64]types.Span, bool)

Get returns an ok bool and the cached value for the requested epoch key, if any.

func (*EpochSpansCache) Has

func (c *EpochSpansCache) Has(epoch uint64) bool

Has returns true if the key exists in the cache.

func (*EpochSpansCache) Set

func (c *EpochSpansCache) Set(epoch uint64, epochSpans map[uint64]types.Span)

Set the response in the cache.

type PublicKeyCache

type PublicKeyCache struct {
	// contains filtered or unexported fields
}

PublicKeyCache is used to store the public keys needed for signature verification.

func NewPublicKeyCache

func NewPublicKeyCache(size int, onEvicted func(key interface{}, value interface{})) (*PublicKeyCache, error)

NewPublicKeyCache initializes the cache.

func (*PublicKeyCache) Clear

func (c *PublicKeyCache) Clear()

Clear removes all keys from the ValidatorCache.

func (*PublicKeyCache) Delete

func (c *PublicKeyCache) Delete(validatorIdx uint64) bool

Delete removes a validator id from the cache and returns if it existed or not. Performs the onEviction function before removal.

func (*PublicKeyCache) Get

func (c *PublicKeyCache) Get(validatorIdx uint64) ([]byte, bool)

Get returns an ok bool and the cached value for the requested validator id key, if any.

func (*PublicKeyCache) Has

func (c *PublicKeyCache) Has(validatorIdx uint64) bool

Has returns true if the key exists in the cache.

func (*PublicKeyCache) Set

func (c *PublicKeyCache) Set(validatorIdx uint64, publicKey []byte)

Set the response in the cache.