datasource

Documentation

Index

• Variables
• type Config
  • func (c Config) Valid(_ context.Context) map[string]string
• type DataSource
• type PostgresDataSource
  • func NewPostgresDataSource(ctx context.Context, cfg Config, logger *slog.Logger) (*PostgresDataSource, error)
  • func (p *PostgresDataSource) Close(ctx context.Context) error
  • func (p *PostgresDataSource) FetchData(ctx context.Context, query string) (map[string]any, error)

Variables

var (
	// ErrQueryReturnedNoRows indicates a query expected exactly one row but found none.
	ErrQueryReturnedNoRows = errors.New("query returned no rows")

	// ErrQueryReturnedMultipleRows indicates a query expected exactly one row but found more. Often wraps
	// pgx.ErrTooManyRows or similar driver errors.
	ErrQueryReturnedMultipleRows = errors.New("query returned multiple rows")

	// ErrDataSourceClosed indicates an operation was attempted on a closed data source.
	ErrDataSourceClosed = errors.New("data source is closed")
)

Types

type Config

type Config struct {
	DSN string
}

func (Config) Valid

func (c Config) Valid(_ context.Context) map[string]string

type DataSource

type DataSource interface {
	FetchData(ctx context.Context, query string) (map[string]any, error)
	Close(ctx context.Context) error
}

type PostgresDataSource

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

func NewPostgresDataSource

func NewPostgresDataSource(ctx context.Context, cfg Config, logger *slog.Logger) (*PostgresDataSource, error)

func (*PostgresDataSource) Close

func (p *PostgresDataSource) Close(ctx context.Context) error

func (*PostgresDataSource) FetchData

func (p *PostgresDataSource) FetchData(ctx context.Context, query string) (map[string]any, error)