store

Documentation

Index

• type PaginatedResult
• type Pagination
  • func (p *Pagination) Validate() error
• type Store
  • func New(connStr string, logMode logger.LogLevel) (*Store, error)
  • func (s *Store) Begin() error
  • func (s *Store) Close() error
  • func (s *Store) Commit() error
  • func (s *Store) Conn() (*sql.DB, error)
  • func (s *Store) DatabaseSize() (int64, error)
  • func (s *Store) Rollback() error
  • func (s *Store) Test() error

Types

type PaginatedResult

type PaginatedResult struct {
	Page       int64       `json:"page"`
	Limit      int64       `json:"limit"`
	TotalCount int64       `json:"total_count"`
	TotalPages int64       `json:"total_pages"`
	Records    interface{} `json:"records"`
}

PaginatedResult represents database records with pagination metadata

type Pagination

type Pagination struct {
	Page  int64 `form:"page"`
	Limit int64 `form:"limit"`
}

Pagination represents the pagination parameters

func (*Pagination) Validate

func (p *Pagination) Validate() error

Validate sanitizes the pagination parameters

type Store

type Store struct {
	Epoch       epochStore
	Miner       minerStore
	Transaction transactionStore
	Event       eventStore
	// contains filtered or unexported fields
}

Store handles database operations

func New

func New(connStr string, logMode logger.LogLevel) (*Store, error)

New creates a store from the connection string

func (*Store) Begin

func (s *Store) Begin() error

Begin starts a database transaction

func (*Store) Close

func (s *Store) Close() error

Close closes the database connection

func (*Store) Commit

func (s *Store) Commit() error

Commit commits the database transaction

func (*Store) Conn

func (s *Store) Conn() (*sql.DB, error)

Conn returns the underlying database connection

func (*Store) DatabaseSize

func (s *Store) DatabaseSize() (int64, error)

DatabaseSize returns the size of the database

func (*Store) Rollback

func (s *Store) Rollback() error

Rollback rolls back the database transaction

func (*Store) Test

func (s *Store) Test() error

Test checks the database connection