api

type Application interface {
	ProjectID() string
	PromptRegistry() *prompt.Registry
	Workflow(string) (graph.Workflow, bool)
	Workflows() []graph.Workflow
	Snapshot(string) (graph.Snapshot, bool)
	Context(context.Context) context.Context
}

type EventFilter struct {
	WorkflowID string
	SessionID  string
	RunID      string
	NodeID     string
}

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

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

type ExecutableWorkflow interface {
	graph.Workflow
	InvokeJSON(context.Context, json.RawMessage, ...runtime.InvokeOption) (json.RawMessage, error)
	ResumeJSON(context.Context, ResumeJSONRequest) (json.RawMessage, error)
}

type ResumeJSONRequest struct {
	Run          runtime.Run     `json:"run"`
	State        json.RawMessage `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 ServeOption func(*serveConfig)

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