Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

database

package

Go to main page

Versions in this module

v0

v0.7.0

Jul 23, 2026

Changes in this version

+ var ErrOutboxItemNotFound = errors.New("outbox item not found")

type Database

+ Transaction func(ctx context.Context, fn func(Database) error) error

type GormDB

+ func (g *GormDB) AddOutboxItems(ctx context.Context, items []*model.OutboxItem) error

+ func (g *GormDB) GetOutboxItems(ctx context.Context, q *OutboxQuery) ([]*model.OutboxItem, error)

+ func (g *GormDB) SetDeliveredAt(ctx context.Context, id int64, t time.Time) error

+ func (g *GormDB) SetDeliveredByEventID(ctx context.Context, eventID string, t time.Time) error

+ func (g *GormDB) SetPublishedAt(ctx context.Context, id int64, t time.Time) error

+ func (g *GormDB) Transaction(ctx context.Context, fn func(Database) error) error

+ type OutboxQuery struct

+ Limit int

+ OnlyUndelivered bool

+ OnlyUnpublished bool

+ type OutboxStore interface

+ AddOutboxItems func(ctx context.Context, items []*model.OutboxItem) error

+ GetOutboxItems func(ctx context.Context, q *OutboxQuery) ([]*model.OutboxItem, error)

+ SetDeliveredAt func(ctx context.Context, id int64, t time.Time) error

+ SetDeliveredByEventID func(ctx context.Context, eventID string, t time.Time) error

+ SetPublishedAt func(ctx context.Context, id int64, t time.Time) error

v0.6.0

Oct 25, 2025

v0.5.0

Oct 6, 2025

Changes in this version

type GormDB

+ func (g *GormDB) ListItems(ctx context.Context) ([]*model.Item, error)

type InventoryStore

+ ListItems func(ctx context.Context) ([]*model.Item, error)

v0.4.0

Oct 5, 2025

v0.3.0

Oct 5, 2025

v0.2.0

Oct 5, 2025

v0.1.0

Feb 19, 2025

v0.0.1

Feb 19, 2025

Changes in this version

+ const DBName

+ const InMemoryDSN

+ type Database interface

+ type GormDB struct

+ func NewGormDB(d gorm.Dialector, recreateSchema bool) (*GormDB, error)

+ func NewPostgresDB(host, user, password string, port int) (*GormDB, error)

+ func NewSQLiteDB(databaseDSN string, recreateSchema bool) (*GormDB, error)

+ func (g *GormDB) AddOrder(ctx context.Context, o *model.Order) error

+ func (g *GormDB) GetItemByName(ctx context.Context, name string) (*model.Item, error)

+ func (g *GormDB) GetItemBySKU(ctx context.Context, sku string) (*model.Item, error)

+ func (g *GormDB) GetItemsBySKU(ctx context.Context, skus []string) ([]*model.Item, error)

+ func (g *GormDB) GetOrders(ctx context.Context) ([]*model.Order, error)

+ func (g *GormDB) Ping(ctx context.Context) error

+ func (g *GormDB) UpsertItems(ctx context.Context, items []*model.Item) ([]*model.Item, error)

+ type HealthChecker interface

+ Ping func(ctx context.Context) error

+ type InventoryStore interface

+ GetItemByName func(ctx context.Context, name string) (*model.Item, error)

+ GetItemBySKU func(ctx context.Context, sku string) (*model.Item, error)

+ GetItemsBySKU func(ctx context.Context, sku []string) ([]*model.Item, error)

+ UpsertItems func(ctx context.Context, items []*model.Item) ([]*model.Item, error)

+ type OrderStore interface

+ AddOrder func(ctx context.Context, o *model.Order) error

+ GetOrders func(ctx context.Context) ([]*model.Order, error)