datastore

Documentation

Index

• Variables
• func PayloadKeyKey(key structs.PayloadKey) ds.Key
• type DBInter
• type Datastore
  • func NewDatastore(t TTLStorage, db DBInter, payloadCacheSize int) (*Datastore, error)
  • func (s *Datastore) CacheBlock(ctx context.Context, key structs.PayloadKey, ...) error
  • func (s *Datastore) GetPayload(ctx context.Context, fork structs.ForkVersion, key structs.PayloadKey) (payload structs.BlockBidAndTrace, cache bool, err error)
  • func (s *Datastore) GetSlotRawPayload(ctx context.Context, key structs.PayloadKey) (output [][]byte, err error)
  • func (s *Datastore) PutPayload(ctx context.Context, key structs.PayloadKey, payload structs.BlockBidAndTrace, ...) error
• type TTLStorage

Variables

var ErrNotFound = errors.New("not found")

Functions

func PayloadKeyKey

func PayloadKeyKey(key structs.PayloadKey) ds.Key

Types

type DBInter

type DBInter interface {
	View(func(txn *badger.Txn) error) error
	NewTransaction(bool) *badger.Txn
}

type Datastore

type Datastore struct {
	TTLStorage
	DBInter
	PayloadCache *lru.Cache[structs.PayloadKey, structs.BlockBidAndTrace]
}

func NewDatastore

func NewDatastore(t TTLStorage, db DBInter, payloadCacheSize int) (*Datastore, error)

func (*Datastore) CacheBlock

func (s *Datastore) CacheBlock(ctx context.Context, key structs.PayloadKey, block *structs.CompleteBlockstruct) error

func (*Datastore) GetPayload

func (s *Datastore) GetPayload(ctx context.Context, fork structs.ForkVersion, key structs.PayloadKey) (payload structs.BlockBidAndTrace, cache bool, err error)

func (*Datastore) GetSlotRawPayload

func (s *Datastore) GetSlotRawPayload(ctx context.Context, key structs.PayloadKey) (output [][]byte, err error)

func (*Datastore) PutPayload

func (s *Datastore) PutPayload(ctx context.Context, key structs.PayloadKey, payload structs.BlockBidAndTrace, ttl time.Duration) error

type TTLStorage

type TTLStorage interface {
	PutWithTTL(context.Context, ds.Key, []byte, time.Duration) error
	Get(context.Context, ds.Key) ([]byte, error)
}