database

package

v1.1.1 Latest Latest Go to latest Published: Mar 19, 2026 License: MIT Imports: 7 Imported by: 0

Details

Package database provides a portable database API with cross-cutting concerns.

This section is empty.

This section is empty.

This section is empty.

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

Database is the portable database type wrapping a driver.

func NewDatabase(d driver.Database, opts ...Option) *Database

NewDatabase creates a new portable Database.

func (db *Database) BatchGetItems(ctx context.Context, table string, keys []map[string]any) ([]map[string]any, error)

func (db *Database) BatchPutItems(ctx context.Context, table string, items []map[string]any) error

func (db *Database) CreateTable(ctx context.Context, config driver.TableConfig) error

func (db *Database) DeleteItem(ctx context.Context, table string, key map[string]any) error

func (db *Database) DeleteTable(ctx context.Context, name string) error

func (db *Database) DescribeTable(ctx context.Context, name string) (*driver.TableConfig, error)

func (db *Database) GetItem(ctx context.Context, table string, key map[string]any) (map[string]any, error)

func (db *Database) ListTables(ctx context.Context) ([]string, error)

func (db *Database) PutItem(ctx context.Context, table string, item map[string]any) error

func (db *Database) Query(ctx context.Context, input driver.QueryInput) (*driver.QueryResult, error)

func (db *Database) Scan(ctx context.Context, input driver.ScanInput) (*driver.QueryResult, error)

type Option func(*Database)

Option configures a portable Database.

func WithErrorInjection(i *inject.Injector) Option

func WithLatency(dur time.Duration) Option

func WithMetrics(m *metrics.Collector) Option

func WithRateLimiter(l *ratelimit.Limiter) Option

func WithRecorder(r *recorder.Recorder) Option

Path	Synopsis
driver Package driver defines the interface for database service implementations.	Package driver defines the interface for database service implementations.