session

type DbExecutor interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
}

type DbSession interface {
	session.Session
	DbSessionExecutor
	DbSessionQuerier
	DbSessionSingleQuerier
}

type DbSessionExecutor interface {
	Exec(query string, args ...any) (Result, error)
}

type DbSessionQuerier interface {
	Query(query string, args ...any) (Rows, error)
}

type DbSessionSingleQuerier interface {
	QueryRow(query string, args ...any) Row
}

type DeferredDbSession interface {
	DeferredDbSessionExecutor
	DeferredDbSessionQuerier
	DeferredDbSessionSingleQuerier
}

type DeferredDbSessionExecutor interface {
	Exec(query string, args ...any) (DeferredResult, error)
}

type DeferredDbSessionQuerier interface {
	Query(query string, args ...any) (DeferredRows, error)
}

type DeferredDbSessionSingleQuerier interface {
	QueryRow(query string, args ...any) DeferredRow
}

type DeferredResult interface {
	deferred.Deferred[Result]
}

type DeferredResultImp struct {
	ResultImp
	deferred.DeferredImp[Result]
}

type DeferredRow interface {
	deferred.Deferred[Row]
}

type DeferredRows interface {
	deferred.Deferred[Rows]
}

type EventSourcedQueryEvaluator interface {
	QueryEvaluator
	SetStreamType(string)
}

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

type QueryEvaluator interface {
	Evaluate(s DbSession) (Result, error)
}

type Result interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}

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

type Row interface {
	Err() error
	Scan(dest ...any) error
}

type Rows interface {
	Close() error
	Err() error
	Next() bool
	Scan(dest ...any) error
}

type SessionContext struct {
	context.Context
	DbSession
}