scheduler

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

type BroadcastReport struct {
	To     []string          // channel ids attempted
	Errors map[string]string // channel id → error text
}

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

type ChannelRef struct {
	ID     string `json:"id"`     // workspace_im_channels.id
	UserID string `json:"userId"` // the IM-side user to message
}

type Config struct {
	AgentserverBase string
	InternalSecret  string
	ImbridgeBase    string
	ImbridgeSecret  string
	CodexBin        string
	PodID           string
	PID             int
	TickInterval    time.Duration
	LeaseSeconds    int
	Concurrency     int
	Tokens          WorkspaceTokenFetcher // workspace Bearer fetcher; nil disables credential injection
	ModelEnvKey     string                // env var name to set with the token (e.g. "CODEX_API_KEY")
}

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

type LeaseRequest struct {
	Limit        int    `json:"limit"`
	LeaseSeconds int    `json:"leaseSeconds"`
	Owner        string `json:"owner"`
}

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

type ResultRequest struct {
	TaskID          string          `json:"taskId"`
	RunID           string          `json:"runId"`
	Status          string          `json:"status"`
	ExitCode        int             `json:"exitCode"`
	DurationMS      int64           `json:"durationMs"`
	Summary         string          `json:"summary"`
	TranscriptURI   string          `json:"transcriptUri"`
	CostUSD         *float64        `json:"costUsd,omitempty"`
	NumTurns        *int            `json:"numTurns,omitempty"`
	BroadcastTo     []string        `json:"broadcastTo"`
	BroadcastErrors json.RawMessage `json:"broadcastErrors"`
}

type SpawnInput struct {
	Prompt  string
	Env     []string
	Timeout time.Duration
}

type SpawnResult struct {
	ExitCode   int
	Transcript string // full captured stdout (truncated at 256 KiB)
	Summary    string // last non-empty line, truncated to 4 KiB
	CostUSD    *float64
	NumTurns   *int
	TimedOut   bool
	DurationMS int64
}

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

type Task struct {
	ID             string  `json:"id"`
	WorkspaceID    string  `json:"workspaceId"`
	SeriesID       string  `json:"seriesId"`
	Prompt         string  `json:"prompt"`
	Script         *string `json:"script,omitempty"`
	Timezone       string  `json:"timezone"`
	Recurrence     *string `json:"recurrence,omitempty"`
	ProcessAfter   string  `json:"processAfter"`
	TimeoutSeconds int     `json:"timeoutSeconds"`
	RunID          string  `json:"runId,omitempty"` // populated server-side
}

type WorkspaceTokenFetcher interface {
	GetOrCreate(ctx context.Context, workspaceID string) (string, error)
}