runtime

type AsyncResult[S any] struct {
	Result *Result[S]
	Error  error
}

type EventContextOptions struct {
	Enabled bool
}

type EventHandler func(context.Context, trace.Event) error

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

type InterruptRecord struct {
	ID           string            `json:"id"`
	WorkflowID   string            `json:"workflow_id"`
	SessionID    string            `json:"session_id,omitempty"`
	RunID        string            `json:"run_id"`
	Metadata     map[string]string `json:"metadata,omitempty"`
	NodeID       string            `json:"node_id"`
	ResumeNode   string            `json:"resume_node"`
	CheckpointID string            `json:"checkpoint_id"`
	Request      graph.Interrupt   `json:"request"`
	Response     *hitl.Response    `json:"response,omitempty"`
	CreatedAt    time.Time         `json:"created_at"`
	ResolvedAt   time.Time         `json:"resolved_at,omitempty"`
}

type Invocation[S any] struct {
	// contains filtered or unexported fields
}

type InvokeOption func(*invokeConfig)

type Option[S any] func(*Runner[S])

type Result[S any] struct {
	Run         Run                     `json:"run"`
	State       S                       `json:"state"`
	Events      []trace.Event           `json:"events"`
	Checkpoints []checkpoint.Checkpoint `json:"checkpoints"`
}

type ResumeRequest[S any] struct {
	Run          Run           `json:"run"`
	State        S             `json:"state"`
	ResumeNode   string        `json:"resume_node"`
	Response     hitl.Response `json:"response"`
	InterruptID  string        `json:"interrupt_id,omitempty"`
	CheckpointID string        `json:"checkpoint_id,omitempty"`
}

type Run struct {
	ID          string            `json:"id"`
	WorkflowID  string            `json:"workflow_id"`
	SessionID   string            `json:"session_id,omitempty"`
	Status      Status            `json:"status"`
	Metadata    map[string]string `json:"metadata,omitempty"`
	StartedAt   time.Time         `json:"started_at"`
	CompletedAt time.Time         `json:"completed_at,omitempty"`
	Error       string            `json:"error,omitempty"`
}

type Runner[S any] struct {
	// contains filtered or unexported fields
}

type Status string