storage

package

v0.21.1 Latest Latest Go to latest Published: Jul 5, 2026 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Package storage implements a set of functions to interact with the database.

This section is empty.

View Source

var ErrDatabaseNotFound = errors.New("database not found")

func Migrate(db *sql.DB) error

Migrate executes database migrations. nolint: errcheck

func NewConnectionPool(dsn string, minConnections, maxConnections int, connectionLifetime time.Duration) (*sql.DB, error)

NewConnectionPool configures the database connection pool.

func Open(opts *config.Options, path string) (*bolt.DB, error)

Open open a bolt database on current directory in given path. It is the caller's responsibility to close it.

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

Storage handles all operations related to the database.

func NewStorage(ds *sql.DB, db *bolt.DB) *Storage

NewStorage returns a new Storage. It is the caller's responsibility to close it.

func (s *Storage) Close() (err error)

Close the bolt database

func (s *Storage) CreatePlayback(pb *entity.Playback) error

CreatePlayback creates a playback callback data.

func (s *Storage) CreateWayback(ctx context.Context, cols []wayback.Collect) error

func (s *Storage) Ping() error

Ping checks if the database connection works.

func (s *Storage) Playback(id uint64) (*entity.Playback, error)

Playback returns playback data of the given id.

func (s *Storage) RemovePlayback(id uint64) error

RemovePlayback removes a playback callback entry by id.