storage

Documentation

Overview

Code generated by options-gen. DO NOT EDIT.

Index

• Variables
• type InsertQueryResultsReq
• type OptOptionsSetter
• type Options
  • func NewOptions(logger *slog.Logger, dbWrite *sql.DB, options ...OptOptionsSetter) Options
  • func (o *Options) Validate() error
• type Service
  • func New(opts Options) (*Service, error)
  • func (s *Service) Conn(ctx context.Context) qrm.DB
  • func (s *Service) DoInTx(ctx context.Context, transactionCallback func(conn qrm.DB) error) error
  • func (s *Service) GetQueryResults(conn qrm.DB, uid config.UserID, id uuid6.UUID) (*model.QueryResults, error)
  • func (s *Service) InsertQueryResults(conn qrm.DB, req InsertQueryResultsReq) error

Variables

var (
	ErrBadRequest         = errors.New("bad request")
	ErrNotFound           = errors.New("not found")
	ErrIntegrityViolation = errors.New("integrity violation")
)

Types

type InsertQueryResultsReq

type InsertQueryResultsReq struct {
	ID        uuid6.UUID
	UserID    config.UserID
	CreatedAt time.Time
	Query     string
	Response  json.RawMessage
}

type OptOptionsSetter

type OptOptionsSetter func(o *Options)

type Options

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

func NewOptions

func NewOptions(
	logger *slog.Logger,
	dbWrite *sql.DB,
	options ...OptOptionsSetter,
) Options

func (*Options) Validate

func (o *Options) Validate() error

type Service

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

func New

func New(opts Options) (*Service, error)

func (*Service) Conn

func (s *Service) Conn(ctx context.Context) qrm.DB

func (*Service) DoInTx

func (s *Service) DoInTx(ctx context.Context, transactionCallback func(conn qrm.DB) error) error

func (*Service) GetQueryResults

func (s *Service) GetQueryResults(conn qrm.DB, uid config.UserID, id uuid6.UUID) (*model.QueryResults, error)

func (*Service) InsertQueryResults

func (s *Service) InsertQueryResults(conn qrm.DB, req InsertQueryResultsReq) error