sqlstorage

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

type Config struct {
	Path string `json:"path"`
}

type PaginateCmd struct {
	StartAfter map[string]string
	Limit      int
}

type Querier interface {
	Exec(query string, args ...any) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type Result struct {
	fx.Out
	Querier    Querier
	DB         *sql.DB
	Transactor Transactor
}

type RowScanner interface {
	Scan(...interface{}) error
}

type SQLTime time.Time

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

type Transactor interface {
	// WithinTransaction runs a function within a database transaction.
	//
	// Transaction is propagated in the context,
	// so it is important to propagate it to underlying repositories.
	// Function commits if error is nil, and rollbacks if not.
	// It returns the same error.
	WithinTransaction(context.Context, func(ctx context.Context) error) error
}