badger

Documentation

Index

• Constants
• func DeliveredHashKey(bh types.Hash) ds.Key
• func DeliveredKey(slot structs.Slot) ds.Key
• func DeliveredNumKey(bn uint64) ds.Key
• func DeliveredPubkeyKey(pk types.PublicKey) ds.Key
• func HeaderHashKey(bh types.Hash) ds.Key
• func HeaderKeyContent(slot uint64, blockHash string, builderHash string) ds.Key
• func HeaderNumKey(bn uint64) ds.Key
• type DB
• type DBInter
• type Datastore
  • func NewDatastore(t DB, d DBInter, ttl time.Duration) *Datastore
  • func (s *Datastore) GetBuilderBlockSubmissions(ctx context.Context, w io.Writer, headSlot uint64, ...) error
  • func (s *Datastore) GetDeliveredPayloads(ctx context.Context, w io.Writer, headSlot uint64, ...) error
  • func (s *Datastore) PutBuilderBlockSubmission(ctx context.Context, bid structs.BidTraceWithTimestamp, isMostProfitable bool) (err error)
  • func (s *Datastore) PutDelivered(ctx context.Context, slot structs.Slot, trace structs.DeliveredTrace) error

Constants

const (
	HeaderContentPrefix = "hc"
)

Functions

func DeliveredHashKey

func DeliveredHashKey(bh types.Hash) ds.Key

func DeliveredKey

func DeliveredKey(slot structs.Slot) ds.Key

func DeliveredNumKey

func DeliveredNumKey(bn uint64) ds.Key

func DeliveredPubkeyKey

func DeliveredPubkeyKey(pk types.PublicKey) ds.Key

func HeaderHashKey

func HeaderHashKey(bh types.Hash) ds.Key

func HeaderKeyContent

func HeaderKeyContent(slot uint64, blockHash string, builderHash string) ds.Key

func HeaderNumKey

func HeaderNumKey(bn uint64) ds.Key

Types

type DB

type DB interface {
	Get(context.Context, ds.Key) ([]byte, error)
}

type DBInter

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

type Datastore

type Datastore struct {
	DB
	DBInter

	TTL time.Duration
}

func NewDatastore

func NewDatastore(t DB, d DBInter, ttl time.Duration) *Datastore

func (*Datastore) GetBuilderBlockSubmissions

func (s *Datastore) GetBuilderBlockSubmissions(ctx context.Context, w io.Writer, headSlot uint64, query structs.SubmissionTraceQuery) error

func (*Datastore) GetDeliveredPayloads

func (s *Datastore) GetDeliveredPayloads(ctx context.Context, w io.Writer, headSlot uint64, query structs.PayloadTraceQuery) error

func (*Datastore) PutBuilderBlockSubmission

func (s *Datastore) PutBuilderBlockSubmission(ctx context.Context, bid structs.BidTraceWithTimestamp, isMostProfitable bool) (err error)

func (*Datastore) PutDelivered

func (s *Datastore) PutDelivered(ctx context.Context, slot structs.Slot, trace structs.DeliveredTrace) error