badger

Documentation

Index

• func RegistrationKey(pk types.PublicKey) ds.Key
• func RegistrationTimeKey(pk types.PublicKey) ds.Key
• type DB
• type Datastore
  • func NewDatastore(t DB, ttl time.Duration) *Datastore
  • func (s *Datastore) GetRegistration(ctx context.Context, pk types.PublicKey) (svr types.SignedValidatorRegistration, err error)
  • func (s *Datastore) PopulateAllRegistrations(ctx context.Context, out chan structs.ValidatorCacheEntry) error
  • func (s *Datastore) PutNewerRegistration(ctx context.Context, pk types.PublicKey, ...) error

Functions

func RegistrationKey

func RegistrationKey(pk types.PublicKey) ds.Key

func RegistrationTimeKey

func RegistrationTimeKey(pk types.PublicKey) ds.Key

Types

type DB

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

type Datastore

type Datastore struct {
	DB

	TTL time.Duration
	// contains filtered or unexported fields
}

func NewDatastore

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

func (*Datastore) GetRegistration

func (s *Datastore) GetRegistration(ctx context.Context, pk types.PublicKey) (svr types.SignedValidatorRegistration, err error)

func (*Datastore) PopulateAllRegistrations

func (s *Datastore) PopulateAllRegistrations(ctx context.Context, out chan structs.ValidatorCacheEntry) error

func (*Datastore) PutNewerRegistration

func (s *Datastore) PutNewerRegistration(ctx context.Context, pk types.PublicKey, registration types.SignedValidatorRegistration) error