init

db.go

@@ -0,0 +1,24 @@
+package outbox
+
+import (
+	"context"
+	"database/sql"
+	_ "embed"
+	"errors"
+)
+
+var (
+	ErrMigrate = errors.New("error creating outbox table")
+)
+
+//go:embed init_db.sql
+var initStatement string
+
+func initDB(ctx context.Context, db *sql.DB) error {
+	_, err := db.ExecContext(ctx, initStatement)
+	if err != nil {
+		return errors.Join(ErrMigrate, err)
+	}
+
+	return nil
+}