Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Closeable ¶
type Closeable interface {
Close()
}
Closeable represents a driver that holds resources.
type GenericSQLDriver ¶
type GenericSQLDriver struct {
// contains filtered or unexported fields
}
GenericSQLDriver executes database operations using database/sql. Used for MySQL and SQLite.
func NewMySQLDriver ¶
func NewMySQLDriver(name, dsn string) *GenericSQLDriver
NewMySQLDriver creates a MySQL driver for the given named database.
func NewSQLiteDriver ¶
func NewSQLiteDriver(name, dsn string) *GenericSQLDriver
NewSQLiteDriver creates a SQLite driver for the given named database.
func (*GenericSQLDriver) Close ¶
func (d *GenericSQLDriver) Close()
Close cleans up the database connection.
func (*GenericSQLDriver) Name ¶
func (d *GenericSQLDriver) Name() string
type HTTPDriver ¶
type HTTPDriver struct{}
HTTPDriver executes HTTP API calls.
func (*HTTPDriver) Name ¶
func (d *HTTPDriver) Name() string
type KafkaDriver ¶
type KafkaDriver struct{}
KafkaDriver searches Kafka topics for matching messages. Uses direct partition reads — no consumer groups, no side effects.
func (*KafkaDriver) Close ¶
func (d *KafkaDriver) Close()
Close is a no-op — the search driver holds no persistent state.
func (*KafkaDriver) Name ¶
func (d *KafkaDriver) Name() string
type MongoDriver ¶
type MongoDriver struct {
// contains filtered or unexported fields
}
MongoDriver executes operations against a MongoDB instance.
func NewMongoDriver ¶
func NewMongoDriver(name, dsn string) (*MongoDriver, error)
NewMongoDriver creates a MongoDB driver for the given named database.
func (*MongoDriver) Name ¶
func (d *MongoDriver) Name() string
type PostgresDriver ¶
type PostgresDriver struct {
// contains filtered or unexported fields
}
PostgresDriver executes database seeds and queries against a PostgreSQL instance.
func NewPostgresDriver ¶
func NewPostgresDriver(name, dsn string) *PostgresDriver
NewPostgresDriver creates a PostgreSQL driver for the given named database.
func (*PostgresDriver) Close ¶
func (d *PostgresDriver) Close()
Close cleans up the connection pool.
func (*PostgresDriver) Name ¶
func (d *PostgresDriver) Name() string
type RedisDriver ¶
type RedisDriver struct {
// contains filtered or unexported fields
}
RedisDriver executes Redis operations.
func (*RedisDriver) Name ¶
func (d *RedisDriver) Name() string
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry holds all available drivers and can register them with an engine.
func NewRegistry ¶
NewRegistry creates a registry with the default drivers plus database drivers for each configured database.
func (*Registry) RegisterAll ¶
RegisterAll registers all drivers with the given engine.
type ShellDriver ¶
type ShellDriver struct{}
ShellDriver executes shell commands.
func (*ShellDriver) Name ¶
func (d *ShellDriver) Name() string
Source Files