server Types

This document shows Go type definitions from the codebase.

Generated types:

ChildJobInfo {#childjobinfo}

Source: server/pulse_types.go:87

type ChildJobInfo struct {
	ID string `json:"id"`
	HandlerName string `json:"handler_name"`
	Source string `json:"source"`
	Status string `json:"status"`
	ProgressPct float64 `json:"progress_pct,omitempty"`
	CostEstimate float64 `json:"cost_estimate,omitempty"`
	CostActual float64 `json:"cost_actual,omitempty"`
	Error string `json:"error,omitempty"`
	CreatedAt string `json:"created_at"`
	StartedAt *string `json:"started_at,omitempty"`
	CompletedAt *string `json:"completed_at,omitempty"`
}

CompleteMessage {#completemessage}

Source: server/types.go:94

type CompleteMessage struct {
	Type string `json:"type"`
	Message string `json:"message"`
}

ConsoleFormatter {#consoleformatter}

Source: server/console_formatter.go:10

type ConsoleFormatter struct {
}

ConsoleLog {#consolelog}

Source: server/debug_handler.go:11

type ConsoleLog struct {
	Timestamp time.Time `json:"timestamp"`
	Level string `json:"level"`
	Message string `json:"message"`
	Stack string `json:"stack,omitempty"`
	URL string `json:"url,omitempty"`
}

CreateScheduledJobRequest {#createscheduledjobrequest}

Source: server/pulse_types.go:14

type CreateScheduledJobRequest struct {
	ATSCode string `json:"ats_code"`
	IntervalSeconds int `json:"interval_seconds"`
	CreatedFromDoc string `json:"created_from_doc,omitempty"`
	Metadata string `json:"metadata,omitempty"`
	Force bool `json:"force,omitempty"`
}

DaemonStatusMessage {#daemonstatusmessage}

Source: server/types.go:119

type DaemonStatusMessage struct {
	Type string `json:"type"`
	Running bool `json:"running"`
	ActiveJobs int `json:"active_jobs"`
	QueuedJobs int `json:"queued_jobs"`
	LoadPercent float64 `json:"load_percent"`
	BudgetDaily float64 `json:"budget_daily"`
	BudgetWeekly float64 `json:"budget_weekly"`
	BudgetMonthly float64 `json:"budget_monthly"`
	BudgetDailyLimit float64 `json:"budget_daily_limit"`
	BudgetWeeklyLimit float64 `json:"budget_weekly_limit"`
	BudgetMonthlyLimit float64 `json:"budget_monthly_limit"`
	ServerState string `json:"server_state"`
	Timestamp int64 `json:"timestamp"`
}

ErrorResponse {#errorresponse}

Source: server/pulse_types.go:50

type ErrorResponse struct {
	Error string `json:"error"`
}

JobChildrenResponse {#jobchildrenresponse}

Source: server/pulse_types.go:102

type JobChildrenResponse struct {
	ParentJobID string `json:"parent_job_id"`
	Children []ChildJobInfo `json:"children"`
}

JobStagesResponse {#jobstagesresponse}

Source: server/pulse_types.go:67

type JobStagesResponse struct {
	JobID string `json:"job_id"`
	Stages []StageInfo `json:"stages"`
}

JobUpdateMessage {#jobupdatemessage}

Source: server/types.go:112

type JobUpdateMessage struct {
	Type string `json:"type"`
	Job *async.Job `json:"job" tstype:"Job | null"`
	Metadata map[string]interface{} `json:"metadata"`
}

LLMStreamMessage {#llmstreammessage}

Source: server/types.go:136

type LLMStreamMessage struct {
	Type string `json:"type"`
	JobID string `json:"job_id"`
	TaskID string `json:"task_id,omitempty"`
	Content string `json:"content"`
	Done bool `json:"done"`
	Model string `json:"model,omitempty"`
	Stage string `json:"stage,omitempty"`
	Error string `json:"error,omitempty"`
}

ListExecutionsResponse {#listexecutionsresponse}

Source: server/pulse_execution_handlers.go:18

type ListExecutionsResponse struct {
	Executions []schedule.Execution `json:"executions" tstype:"Execution[]"`
	Count int `json:"count"`
	Total int `json:"total"`
	HasMore bool `json:"has_more"`
}

ListScheduledJobsResponse {#listscheduledjobsresponse}

Source: server/pulse_types.go:44

type ListScheduledJobsResponse struct {
	Jobs []ScheduledJobResponse `json:"jobs"`
	Count int `json:"count,omitempty"`
}

LogEntry {#logentry}

Source: server/pulse_types.go:73

type LogEntry struct {
	Timestamp string `json:"timestamp"`
	Level string `json:"level"`
	Message string `json:"message"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

ParsedATSCode {#parsedatscode}

Source: server/ats_parser.go:22

type ParsedATSCode struct {
	HandlerName string
	Payload []byte
	SourceURL string
}

PluginHealthMessage {#pluginhealthmessage}

Source: server/types.go:202

type PluginHealthMessage struct {
	Type string `json:"type"`
	Name string `json:"name"`
	Healthy bool `json:"healthy"`
	State string `json:"state"`
	Message string `json:"message"`
	Timestamp int64 `json:"timestamp"`
}

PluginInfo {#plugininfo}

Source: server/handlers.go:598

type PluginInfo struct {
	Name string `json:"name"`
	Version string `json:"version"`
	QNTXVersion string `json:"qntx_version,omitempty"`
	Description string `json:"description"`
	Author string `json:"author,omitempty"`
	License string `json:"license,omitempty"`
	Healthy bool `json:"healthy"`
	Message string `json:"message,omitempty"`
	Details map[string]interface{} `json:"details,omitempty"`
	State string `json:"state"`
	Pausable bool `json:"pausable"`
}

ProgressMessage {#progressmessage}

Source: server/types.go:78

type ProgressMessage struct {
	Type string `json:"type"`
	Current int `json:"current"`
	Total int `json:"total"`
	Message string `json:"message"`
}

ProseEntry {#proseentry}

Source: server/prose_handler.go:16

type ProseEntry struct {
	Name string `json:"name"`
	Path string `json:"path"`
	IsDir bool `json:"isDir"`
	Children []ProseEntry `json:"children,omitempty"`
}

PulseExecutionCompletedMessage {#pulseexecutioncompletedmessage}

Source: server/types.go:168

type PulseExecutionCompletedMessage struct {
	Type string `json:"type"`
	ScheduledJobID string `json:"scheduled_job_id"`
	ExecutionID string `json:"execution_id"`
	ATSCode string `json:"ats_code"`
	AsyncJobID string `json:"async_job_id"`
	ResultSummary string `json:"result_summary"`
	DurationMs int `json:"duration_ms"`
	Timestamp int64 `json:"timestamp"`
}

PulseExecutionFailedMessage {#pulseexecutionfailedmessage}

Source: server/types.go:157

type PulseExecutionFailedMessage struct {
	Type string `json:"type"`
	ScheduledJobID string `json:"scheduled_job_id"`
	ExecutionID string `json:"execution_id"`
	ATSCode string `json:"ats_code"`
	ErrorMessage string `json:"error_message"`
	DurationMs int `json:"duration_ms"`
	Timestamp int64 `json:"timestamp"`
}

PulseExecutionLogStreamMessage {#pulseexecutionlogstreammessage}

Source: server/types.go:180

type PulseExecutionLogStreamMessage struct {
	Type string `json:"type"`
	ScheduledJobID string `json:"scheduled_job_id"`
	ExecutionID string `json:"execution_id"`
	LogChunk string `json:"log_chunk"`
	Timestamp int64 `json:"timestamp"`
}

PulseExecutionStartedMessage {#pulseexecutionstartedmessage}

Source: server/types.go:148

type PulseExecutionStartedMessage struct {
	Type string `json:"type"`
	ScheduledJobID string `json:"scheduled_job_id"`
	ExecutionID string `json:"execution_id"`
	ATSCode string `json:"ats_code"`
	Timestamp int64 `json:"timestamp"`
}

QueryMessage {#querymessage}

Source: server/types.go:58

type QueryMessage struct {
	Type string `json:"type"`
	Query string `json:"query"`
	Line int `json:"line"`
	Cursor int `json:"cursor"`
	Verbosity int `json:"verbosity"`
	GraphLimit int `json:"graph_limit"`
	Filename string `json:"filename"`
	FileType string `json:"fileType"`
	Data string `json:"data"`
	Action string `json:"action"`
	DailyBudget float64 `json:"daily_budget"`
	WeeklyBudget float64 `json:"weekly_budget"`
	MonthlyBudget float64 `json:"monthly_budget"`
	JobID string `json:"job_id"`
	NodeType string `json:"node_type"`
	Hidden bool `json:"hidden"`
}

ScheduledJobResponse {#scheduledjobresponse}

Source: server/pulse_types.go:29

type ScheduledJobResponse struct {
	ID string `json:"id"`
	ATSCode string `json:"ats_code"`
	IntervalSeconds int `json:"interval_seconds,omitempty"`
	NextRunAt string `json:"next_run_at"`
	LastRunAt *string `json:"last_run_at,omitempty"`
	LastExecutionID string `json:"last_execution_id,omitempty"`
	State string `json:"state"`
	CreatedFromDoc string `json:"created_from_doc,omitempty"`
	Metadata string `json:"metadata,omitempty"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

StageInfo {#stageinfo}

Source: server/pulse_types.go:61

type StageInfo struct {
	Stage string `json:"stage"`
	Tasks []TaskInfo `json:"tasks"`
}

StatsMessage {#statsmessage}

Source: server/types.go:86

type StatsMessage struct {
	Type string `json:"type"`
	Contacts int `json:"contacts"`
	Attestations int `json:"attestations"`
	Companies int `json:"companies"`
}

StorageWarningMessage {#storagewarningmessage}

Source: server/types.go:189

type StorageWarningMessage struct {
	Type string `json:"type"`
	Actor string `json:"actor"`
	Context string `json:"context"`
	Current int `json:"current"`
	Limit int `json:"limit"`
	FillPercent float64 `json:"fill_percent"`
	TimeUntilFull string `json:"time_until_full"`
	Timestamp int64 `json:"timestamp"`
}

SystemCapabilitiesMessage {#systemcapabilitiesmessage}

Source: server/types.go:213

type SystemCapabilitiesMessage struct {
	Type string `json:"type"`
	FuzzyBackend string `json:"fuzzy_backend"`
	FuzzyOptimized bool `json:"fuzzy_optimized"`
}

TaskInfo {#taskinfo}

Source: server/pulse_types.go:55

type TaskInfo struct {
	TaskID string `json:"task_id"`
	LogCount int `json:"log_count,omitempty"`
}

TaskLogsResponse {#tasklogsresponse}

Source: server/pulse_types.go:81

type TaskLogsResponse struct {
	TaskID string `json:"task_id"`
	Logs []LogEntry `json:"logs"`
}

UpdateScheduledJobRequest {#updatescheduledjobrequest}

Source: server/pulse_types.go:23

type UpdateScheduledJobRequest struct {
	State *string `json:"state,omitempty"`
	IntervalSeconds *int `json:"interval_seconds,omitempty"`
}

UsageUpdateMessage {#usageupdatemessage}

Source: server/types.go:100

type UsageUpdateMessage struct {
	Type string `json:"type"`
	TotalCost float64 `json:"total_cost"`
	Requests int `json:"requests"`
	Success int `json:"success"`
	Tokens int `json:"tokens"`
	Models int `json:"models"`
	Since string `json:"since"`
	Timestamp int64 `json:"timestamp"`
}