database

Documentation

Overview

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

Index

• type Database
  • func NewDatabase(d driver.Database, opts ...Option) *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 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

Types

type Database

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

Database is the portable database type wrapping a driver.

func NewDatabase

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

NewDatabase creates a new portable Database.

func (*Database) BatchGetItems

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

func (*Database) BatchPutItems

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

func (*Database) CreateTable

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

func (*Database) DeleteItem

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

func (*Database) DeleteTable

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

func (*Database) DescribeTable

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

func (*Database) GetItem

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

func (*Database) ListTables

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

func (*Database) PutItem

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

func (*Database) Query

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

func (*Database) Scan

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

type Option

type Option func(*Database)

Option configures a portable Database.

func WithErrorInjection

func WithErrorInjection(i *inject.Injector) Option

func WithLatency

func WithLatency(dur time.Duration) Option

func WithMetrics

func WithMetrics(m *metrics.Collector) Option

func WithRateLimiter

func WithRateLimiter(l *ratelimit.Limiter) Option

func WithRecorder

func WithRecorder(r *recorder.Recorder) Option