Documentation ¶
Index ¶
- func NewSQLiteDB(path string) (db.DB, error)
- type SQLiteDB
- func (l *SQLiteDB) Close() error
- func (l *SQLiteDB) GetAssignedBlocksAfterNow(ctx context.Context) ([]db.AssignedBlock, error)
- func (l *SQLiteDB) GetAssignedBlocksBeforeNow(ctx context.Context, epoch uint) ([]db.AssignedBlock, error)
- func (l *SQLiteDB) GetAssignedBlocksWithStatusBeforeNow(ctx context.Context, status db.BlockStatus, offset, limit uint) ([]db.AssignedBlock, error)
- func (l *SQLiteDB) GetLeaderLog(ctx context.Context, epoch uint) (*db.LeaderLog, error)
- func (l *SQLiteDB) GetRegisteredEpochs(ctx context.Context, ordering db.Ordering, limit uint) ([]uint, error)
- func (l *SQLiteDB) Observer() *db.Observer
- func (l *SQLiteDB) UpdateStatusForAssignment(ctx context.Context, epoch, no uint, status db.BlockStatus, ...) error
- func (l *SQLiteDB) WriteLeaderLog(ctx context.Context, leaderLog *db.LeaderLog) error
- func (l *SQLiteDB) WriteMintedBlock(ctx context.Context, block *db.MintedBlock) (*uint, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type SQLiteDB ¶
type SQLiteDB struct {
// contains filtered or unexported fields
}
SQLiteDB is a db.DB making use of sqlite3 database.
func (*SQLiteDB) GetAssignedBlocksAfterNow ¶
func (*SQLiteDB) GetAssignedBlocksBeforeNow ¶
func (*SQLiteDB) GetAssignedBlocksWithStatusBeforeNow ¶
func (l *SQLiteDB) GetAssignedBlocksWithStatusBeforeNow(ctx context.Context, status db.BlockStatus, offset, limit uint) ([]db.AssignedBlock, error)
func (*SQLiteDB) GetLeaderLog ¶
func (*SQLiteDB) GetRegisteredEpochs ¶
func (*SQLiteDB) UpdateStatusForAssignment ¶
func (*SQLiteDB) WriteLeaderLog ¶
func (*SQLiteDB) WriteMintedBlock ¶
Click to show internal directories.
Click to hide internal directories.