aggsigdb

Documentation

Index

• Variables
• type MemDB
  • func NewMemDB() *MemDB
  • func (db *MemDB) Await(ctx context.Context, duty core.Duty, pubKey core.PubKey) (core.SignedData, error)
  • func (db *MemDB) Run(ctx context.Context)
  • func (db *MemDB) Store(ctx context.Context, duty core.Duty, pubKey core.PubKey, data core.SignedData) error
• type Stub
  • func (Stub) Await(context.Context, core.Duty, core.PubKey) (core.SignedData, error)
  • func (Stub) Store(context.Context, core.Duty, core.PubKey, core.SignedData) error

Variables

var ErrStopped = errors.New("database stopped")

Types

type MemDB

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

MemDB is a basic memory implementation of core.AggSigDB.

func NewMemDB

func NewMemDB() *MemDB

NewMemDB creates a basic memory based AggSigDB.

func (*MemDB) Await

func (db *MemDB) Await(ctx context.Context, duty core.Duty, pubKey core.PubKey) (core.SignedData, error)

Await implements core.AggSigDB, see its godoc.

func (*MemDB) Run

func (db *MemDB) Run(ctx context.Context)

Run blocks and runs the database process until the context is cancelled.

func (*MemDB) Store

func (db *MemDB) Store(ctx context.Context, duty core.Duty, pubKey core.PubKey, data core.SignedData) error

Store implements core.AggSigDB, see its godoc.

type Stub

type Stub struct{}

Stub implements core.AggSigDB without any logic.

func (Stub) Await

func (Stub) Await(context.Context, core.Duty, core.PubKey) (core.SignedData, error)

func (Stub) Store

func (Stub) Store(context.Context, core.Duty, core.PubKey, core.SignedData) error