taskmaster

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

type Config struct {
	Logger        *zerolog.Logger
	RootNodeID    string
	Nodes         map[string]Node
	Targets       []Target
	OutcomeRouter OutcomeRouter
}

type EmitFunc func(ctx context.Context, msg Message) error

type Locator struct {
	Class     string         `json:"class"`
	Transport string         `json:"transport"`
	Key       string         `json:"key"`
	Address   map[string]any `json:"address,omitempty"`
}

type Message struct {
	ID        string         `json:"id"`
	SessionID string         `json:"session_id"`
	Kind      string         `json:"kind"`
	From      Locator        `json:"from"`
	To        Locator        `json:"to"`
	ParentID  string         `json:"parent_id,omitempty"`
	Content   string         `json:"content"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type Node interface {
	Run(ctx context.Context, msg Message, emit EmitFunc) Outcome
}

type Outcome struct {
	Status   string
	Content  string
	Metadata map[string]any
	Err      error
}

type OutcomeRouter func(msg Message, outcome Outcome) []Message

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

type Target interface {
	Supports(locator Locator) bool
	DispatchMessage(ctx context.Context, msg Message) error
}