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

mdktest

package

Go to main page

Versions in this module

v0

v0.4.0

Jun 18, 2026

Changes in this version

+ func SetupSharedTestDB(dbName string) (*gorm.DB, error)

+ func SetupTestDB(dbFile string) (*gorm.DB, error)

type TestEventBus

+ func (teb *TestEventBus) Subscribers() []mdk.SubscriptionInfo

type TestRuntime

+ func NewInMemoryTestRuntime() (*TestRuntime, error)

v0.3.0

Jun 6, 2026

v0.2.0

Jun 6, 2026

v0.1.0

Jun 5, 2026

Changes in this version

+ type ProjectorModule struct

+ ModuleID string

+ Proj mdk.Projector

+ func (pm *ProjectorModule) ID() string

+ func (pm *ProjectorModule) Init(ctx context.Context, rt mdk.Runtime) error

+ func (pm *ProjectorModule) Models() []any

+ func (pm *ProjectorModule) Projector() mdk.Projector

+ func (pm *ProjectorModule) Routes() []mdk.Route

+ func (pm *ProjectorModule) Shutdown(ctx context.Context) error

+ type TestEventBus struct

+ Published []mdk.Event

+ func NewTestEventBus(rt *TestRuntime) *TestEventBus

+ func (teb *TestEventBus) Publish(ctx context.Context, e mdk.Event) error

+ func (teb *TestEventBus) Subscribe(namespace, eventType string, handler mdk.EventHandler) (func(), error)

+ type TestLineageData struct

+ EndedAt *time.Time

+ Error string

+ Events []mdk.Event

+ ID string

+ Name string

+ StartedAt time.Time

+ State string

+ func (tld TestLineageData) GetEndedAt() *time.Time

+ func (tld TestLineageData) GetError() string

+ func (tld TestLineageData) GetEvents() []mdk.Event

+ func (tld TestLineageData) GetID() string

+ func (tld TestLineageData) GetName() string

+ func (tld TestLineageData) GetStartedAt() time.Time

+ func (tld TestLineageData) GetState() string

+ type TestProjector struct

+ Lineages []mdk.LineageData

+ func (tp *TestProjector) ListLineages() []mdk.LineageData

+ func (tp *TestProjector) QueryLineages(filter func(mdk.LineageData) bool) []mdk.LineageData

+ type TestRuntime struct

+ func NewTestRuntime(db *gorm.DB) *TestRuntime

+ func (tr *TestRuntime) Bus() mdk.EventBus

+ func (tr *TestRuntime) Config(key string) any

+ func (tr *TestRuntime) DB() *gorm.DB

+ func (tr *TestRuntime) Logger() *slog.Logger

+ func (tr *TestRuntime) Module(id string) (mdk.Module, bool)

+ func (tr *TestRuntime) SetConfig(key string, val any)

+ func (tr *TestRuntime) SetLogger(l *slog.Logger)

+ func (tr *TestRuntime) SetModule(id string, m mdk.Module)

+ func (tr *TestRuntime) Workflows() mdk.WorkflowEngine

+ type TestWorkflowEngine struct

+ func NewTestWorkflowEngine(rt *TestRuntime) *TestWorkflowEngine

+ func (twe *TestWorkflowEngine) Cancel(ctx context.Context, runID string) error

+ func (twe *TestWorkflowEngine) Execute(ctx context.Context, workflowID string, input map[string]any) (string, error)

+ func (twe *TestWorkflowEngine) ExecuteSync(ctx context.Context, runID, workflowID string, input map[string]any) (map[string]any, error)

+ func (twe *TestWorkflowEngine) Register(w mdk.Workflow) error

+ func (twe *TestWorkflowEngine) RegisterHandler(name string, handler mdk.StepHandler) error

+ func (twe *TestWorkflowEngine) Status(ctx context.Context, runID string) (mdk.StepStatus, error)