datastore

Documentation

Index

• Variables
• func PayloadKeyKey(key structs.PayloadKey) ds.Key
• type DBInter
• type Datastore
  • func NewDatastore(t TTLStorage, db DBInter) *Datastore
  • func (s *Datastore) GetPayload(ctx context.Context, fork structs.ForkVersion, key structs.PayloadKey) (payload structs.BlockAndTraceExtended, 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, ...) 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
}

func NewDatastore

func NewDatastore(t TTLStorage, db DBInter) *Datastore

func (*Datastore) GetPayload

func (s *Datastore) GetPayload(ctx context.Context, fork structs.ForkVersion, key structs.PayloadKey) (payload structs.BlockAndTraceExtended, 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.BlockAndTraceExtended, 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)
}