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

mdk

package module

Go to main page

Versions in this module

v0

v0.4.0

Jun 18, 2026

Changes in this version

+ func GetLineageEvents() []string

+ func OnRegisterLineageEvent(cb func(string))

+ func RegisterLineageEvent(eventType string)

+ type DependentModule interface

+ Dependencies func() []string

type EventBus

+ Subscribers func() []SubscriptionInfo

+ type MiddlewareProvider interface

+ Middlewares func() []func(http.Handler) http.Handler

+ type SubscriptionInfo struct

+ Handler string

+ Namespace string

+ Type string

type Workflow

+ func (w *Workflow) Validate() error

+ type WorkflowStatus struct

+ EndedAt *time.Time

+ Error string

+ StartedAt time.Time

+ State StepStatus

+ Steps map[string]string

v0.3.0

Jun 6, 2026

Changes in this version

+ const LockOwnerKey

+ var ErrLockAcquisitionTimeout = errors.New("lock acquisition timed out")

+ var ErrLockNotHeld = errors.New("lock not held")

+ func RegisterDialect(name string, provider DialectProvider)

+ func RegisterEventBusProvider(name string, provider BusProvider)

+ func RegisterLocker(name string, provider LockerProvider)

+ func RegisterStateStore(name string, provider StoreProvider)

+ type BusProvider func(url string) (EventBusCloser, error)

+ func GetEventBusProvider(name string) (BusProvider, bool)

+ type DialectProvider func(dsn string) gorm.Dialector

+ func GetDialect(name string) (DialectProvider, bool)

+ type EventBusCloser interface

+ Close func() error

+ type Locker interface

+ Acquire func(ctx context.Context, key string, ttl time.Duration, timeout time.Duration) (bool, error)

+ Close func() error

+ Release func(ctx context.Context, key string) error

+ type LockerProvider func(url string, bucketOrPrefix string) (Locker, error)

+ func GetLocker(name string) (LockerProvider, bool)

+ type ObjectStorage interface

+ Delete func(ctx context.Context, path string) error

+ GetURL func(ctx context.Context, path string) (string, error)

+ Open func(ctx context.Context, path string) (io.ReadCloser, error)

+ Upload func(ctx context.Context, path string, data io.Reader) (string, error)

+ type StateStore interface

+ GetInput func(ctx context.Context, execID string) ([]byte, error)

+ GetState func(ctx context.Context, execID string) (map[string]string, error)

+ GetStepOutput func(ctx context.Context, execID string, stepID string) ([]byte, error)

+ InitializeExecution func(ctx context.Context, execID string, input []byte) error

+ IsEventEmitted func(ctx context.Context, execID string, eventType string) (bool, error)

+ ListExecutions func(ctx context.Context, state string) ([]string, error)

+ RecordEventEmitted func(ctx context.Context, execID string, eventType string) error

+ SaveInput func(ctx context.Context, execID string, input []byte) error

+ SaveState func(ctx context.Context, execID string, stepID string, state string) error

+ SaveStepOutput func(ctx context.Context, execID string, stepID string, output []byte) error

+ SetTTL func(ctx context.Context, execID string, ttl time.Duration) error

+ type StoreProvider func(url string, bucketOrPrefix string) (StateStore, error)

+ func GetStateStore(name string) (StoreProvider, bool)

v0.2.0

Jun 6, 2026

v0.1.0

Jun 5, 2026

Changes in this version

+ const Version

+ var ErrAlreadyRegistered = errors.New("mdk: already registered")

+ var ErrModuleNotFound = errors.New("mdk: module not found")

+ var ErrRunNotFound = errors.New("mdk: run not found")

+ var ErrWorkflowNotFound = errors.New("mdk: workflow not found")

+ func Register(factory Factory)

+ func Registered() map[string]Factory

+ func WithActor(ctx context.Context, actor Actor) context.Context

+ type Actor interface

+ GetID func() string

+ GetMetadata func() map[string]string

+ GetName func() string

+ GetType func() ActorType

+ func ActorFromContext(ctx context.Context) (Actor, bool)

+ type ActorType string

+ const ActorAIAgent

+ const ActorHuman

+ const ActorSystem

+ type BaseActor struct

+ ID string

+ Metadata map[string]string

+ Name string

+ Type ActorType

+ func (b *BaseActor) GetID() string

+ func (b *BaseActor) GetMetadata() map[string]string

+ func (b *BaseActor) GetName() string

+ func (b *BaseActor) GetType() ActorType

+ type Event struct

+ ID string

+ Namespace string

+ OccurredAt time.Time

+ Payload map[string]any

+ TraceID string

+ Type string

+ type EventBus interface

+ Publish func(ctx context.Context, e Event) error

+ Subscribe func(namespace, eventType string, handler EventHandler) (unsubscribe func(), err error)

+ type EventHandler func(ctx context.Context, e Event) error

+ type Factory func() Module

+ type GetPromptResult struct

+ Description string

+ Messages []MCPPromptMessage

+ type HTMLUIProvider interface

+ RenderHTML func(ctx context.Context) (title, html string, err error)

+ type JSONMap map[string]string

+ func (m *JSONMap) Scan(value interface{}) error

+ func (m JSONMap) Value() (driver.Value, error)

+ type LineageData interface

+ GetEndedAt func() *time.Time

+ GetError func() string

+ GetEvents func() []Event

+ GetID func() string

+ GetName func() string

+ GetStartedAt func() time.Time

+ GetState func() string

+ type MCPPrompt struct

+ Arguments []MCPPromptArgument

+ Description string

+ Name string

+ type MCPPromptArgument struct

+ Description string

+ Name string

+ Required bool

+ type MCPPromptMessage struct

+ Content MCPPromptMessageContent

+ Role string

+ type MCPPromptMessageContent struct

+ Text string

+ Type string

+ type MCPResource struct

+ Description string

+ MimeType string

+ Name string

+ URI string

+ type Metadata map[string]interface

+ func (m *Metadata) Scan(val interface{}) error

+ func (m Metadata) Value() (driver.Value, error)

+ type Module interface

+ ID func() string

+ Init func(ctx context.Context, rt Runtime) error

+ Models func() []any

+ Routes func() []Route

+ Shutdown func(ctx context.Context) error

+ type Projector interface

+ ListLineages func() []LineageData

+ QueryLineages func(filter func(LineageData) bool) []LineageData

+ type ProjectorProvider interface

+ Projector func() Projector

+ type PromptProvider interface

+ GetPrompt func(ctx context.Context, name string, arguments map[string]string) (*GetPromptResult, error)

+ ListPrompts func(ctx context.Context) ([]MCPPrompt, error)

+ type ResourceProvider interface

+ ListResources func(ctx context.Context) ([]MCPResource, error)

+ ReadResource func(ctx context.Context, uri string) (string, error)

+ type Route struct

+ Handler http.Handler

+ Method string

+ Pattern string

+ type Runtime interface

+ Bus func() EventBus

+ Config func(key string) any

+ DB func() *gorm.DB

+ Logger func() *slog.Logger

+ Module func(id string) (Module, bool)

+ Workflows func() WorkflowEngine

+ type Saga struct

+ IsCritical bool

+ Uses string

+ type Step struct

+ DependsOn []string

+ ID string

+ MaxRetries int

+ Name string

+ Saga *Saga

+ Uses string

+ type StepContext struct

+ Ctx context.Context

+ Input map[string]any

+ RunID string

+ Runtime Runtime

+ StepID string

+ WorkflowID string

+ type StepHandler func(ctx StepContext) StepResult

+ type StepResult struct

+ Err error

+ Output map[string]any

+ type StepStatus string

+ const StepCompleted

+ const StepFailed

+ const StepPending

+ const StepRetrying

+ const StepRunning

+ const StepSkipped

+ type TokenValidator interface

+ ValidateToken func(ctx context.Context, token string) (Actor, error)

+ type Workflow struct

+ Description string

+ ExposeToAI bool

+ ID string

+ InputSchema map[string]any

+ Name string

+ Steps []Step

+ type WorkflowEngine interface

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

+ Execute func(ctx context.Context, workflowID string, input map[string]any) (runID string, err error)

+ Register func(w Workflow) error

+ RegisterHandler func(name string, handler StepHandler) error

+ Status func(ctx context.Context, runID string) (StepStatus, error)