types

type AbstractionConfig struct {
	Bot BotConfig `key:"bot" json:"bot"`
	Pod PodConfig `key:"pod" json:"pod"`
	VM  VMConfig  `key:"vm" json:"vm"`
}

type AgentJoinOptions struct {
	GatewayURL                string
	JoinToken                 string
	JoinTokenFile             string
	DevMode                   bool
	ExecutorOverride          string
	TransportOverride         string
	WorkerImage               string
	CacheDir                  string
	MaxCPU                    string
	MaxMemory                 string
	MaxGPUs                   uint
	GPUIDs                    string
	NetworkSlots              uint
	ContainerStartConcurrency uint
	Stdout                    io.Writer
	Stderr                    io.Writer
}

type App struct {
	Id          uint     `db:"id" json:"id" serializer:"id,source:external_id"`
	ExternalId  string   `db:"external_id" json:"external_id,omitempty" serializer:"external_id"`
	Name        string   `db:"name" json:"name" serializer:"name"`
	Description string   `db:"description" json:"description" serializer:"description"`
	WorkspaceId uint     `db:"workspace_id" json:"workspace_id"` // Foreign key to Workspace
	CreatedAt   Time     `db:"created_at" json:"created_at" serializer:"created_at"`
	UpdatedAt   Time     `db:"updated_at" json:"updated_at" serializer:"updated_at"`
	DeletedAt   NullTime `db:"deleted_at" json:"deleted_at" serializer:"deleted_at"`
}

type AppActivityBucket struct {
	Time   time.Time `json:"time"`
	Total  int       `json:"total"`
	Failed int       `json:"failed"`
}

type AppConfig struct {
	ClusterName    string               `key:"clusterName" json:"cluster_name"`
	DebugMode      bool                 `key:"debugMode" json:"debug_mode"`
	PrettyLogs     bool                 `key:"prettyLogs" json:"pretty_logs"`
	Database       DatabaseConfig       `key:"database" json:"database"`
	Events         EventsConfig         `key:"events" json:"events"`
	GatewayService GatewayServiceConfig `key:"gateway" json:"gateway_service"`
	FileService    FileServiceConfig    `key:"fileService" json:"file_service"`
	ImageService   ImageServiceConfig   `key:"imageService" json:"image_service"`
	Storage        StorageConfig        `key:"storage" json:"storage"`
	Worker         WorkerConfig         `key:"worker" json:"worker"`
	Scheduling     SchedulingConfig     `key:"scheduling" json:"scheduling"`
	Providers      ProviderConfig       `key:"providers" json:"providers"`
	Tailscale      TailscaleConfig      `key:"tailscale" json:"tailscale"`
	Monitoring     MonitoringConfig     `key:"monitoring" json:"monitoring"`
	ManagedCompute ManagedComputeConfig `key:"managedCompute" json:"managed_compute"`
	Abstractions   AbstractionConfig    `key:"abstractions" json:"abstractions"`
	Cache          cache.Config         `key:"cache" json:"cache"`
	// ManagedEndpoints configures the platform-owned inference endpoints
	// (GitOps-driven stubs filled onto spare GPU capacity, served under /v1).
	ManagedEndpoints ManagedEndpointsConfig `key:"managedEndpoints" json:"managed_endpoints"`
}

type AppFilter struct {
	Name   string `query:"name"`
	Cursor string `query:"cursor"`
	Limit  uint32 `query:"limit"`

	// Scoping computed server-side from live state. Untagged on purpose so the
	// query binder can never set them from the request.
	IncludeExternalIds []string
	ExcludeExternalIds []string
}

type AppState string

type AppStateCounts struct {
	All     int `json:"all" serializer:"all"`
	Running int `json:"running" serializer:"running"`
	Idle    int `json:"idle" serializer:"idle"`
	Stopped int `json:"stopped" serializer:"stopped"`
}

type Autoscaler struct {
	Type              AutoscalerType `json:"type"`
	MaxContainers     uint           `json:"max_containers"`
	TasksPerContainer uint           `json:"tasks_per_container"`
	MinContainers     uint           `json:"min_containers"`
}

type AutoscalerType string

type AvailableHost struct {
	Hostname    string
	ContainerId string
}

type BackendRoute struct {
	RouteID     string `json:"route_id"`
	WorkspaceID string `json:"workspace_id"`
	PoolName    string `json:"pool_name"`
	MachineID   string `json:"machine_id"`
	WorkerID    string `json:"worker_id"`
	ContainerID string `json:"container_id"`
	Kind        string `json:"kind"`
	Port        int32  `json:"port"`
	Protocol    string `json:"protocol"`
	Transport   string `json:"transport"`
	LocalTarget string `json:"local_target"`
	ProxyTarget string `json:"proxy_target"`
	State       string `json:"state"`
	Error       string `json:"error"`
	UpdatedAt   int64  `json:"updated_at"`
}

type BaseFilter struct {
	Limit  uint32 `query:"limit"`
	Offset int    `query:"offset"`
}

type BotConfig struct {
	SystemPrompt              string `key:"systemPrompt" json:"system_prompt"`
	StepIntervalS             uint   `key:"stepIntervalS" json:"step_interval_s"`
	SessionInactivityTimeoutS uint   `key:"sessionInactivityTimeoutS" json:"session_inactivity_timeout_s"`
}

type BuildAptConfig struct {
	// Mirror replaces http://archive.ubuntu.com/ubuntu and
	// http://security.ubuntu.com/ubuntu in the base image's sources for the
	// duration of each RUN step, e.g. http://mirrors.edge.kernel.org/ubuntu.
	Mirror string `key:"mirror" json:"mirror"`
	// Proxy is set as Acquire::http::Proxy (an apt-cacher-ng, for instance).
	Proxy string `key:"proxy" json:"proxy"`
	// TimeoutS is Acquire::http::Timeout / Acquire::https::Timeout; 0 keeps apt's default.
	TimeoutS int `key:"timeoutS" json:"timeout_s"`
	// Retries is Acquire::Retries; 0 keeps apt's default.
	Retries int `key:"retries" json:"retries"`
}

type BuildOptions struct {
	SourceImage      *string    `json:"source_image"`
	Dockerfile       *string    `json:"dockerfile"`
	BuildCtxObject   *string    `json:"build_context"`
	SourceImageCreds string     `json:"source_image_creds"`
	BuildSecrets     []string   `json:"build_secrets"`
	GitSource        *GitSource `json:"git_source,omitempty"`
}

type BuildRegistryCredentialsConfig struct {
	// Type of credentials: "aws", "gcp", "azure", "basic", "token"
	Type string `key:"type" json:"type"`
	// Credentials is a map of credential key-value pairs
	// For AWS: AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_REGION, AWS_SESSION_TOKEN (optional)
	// For GCP: GCP_ACCESS_TOKEN or GOOGLE_APPLICATION_CREDENTIALS
	// For Azure: AZURE_CLIENT_ID, AZURE_CLIENT_SECRET, AZURE_TENANT_ID
	// For basic auth: USERNAME, PASSWORD
	// For token auth: NGC_API_KEY, GITHUB_TOKEN, DOCKERHUB_TOKEN
	Credentials map[string]string `key:"credentials" json:"credentials"`
}

type CORSConfig struct {
	AllowedOrigins []string `key:"allowOrigins" json:"allow_origins"`
	AllowedMethods []string `key:"allowMethods" json:"allow_methods"`
	AllowedHeaders []string `key:"allowHeaders" json:"allow_headers"`
}

type CPUShareMultiplier float64

type CPUTier string

type CPUTierPolicy struct {
	Enabled        bool    `json:"enabled"`
	DefaultCPUTier CPUTier `json:"default_cpu_tier"`
}

type CRIUConfig struct {
	Mode   CRIUConfigMode   `key:"mode" json:"mode"`
	Nvidia NvidiaCRIUConfig `key:"nvidia" json:"nvidia"`
}

type CRIUConfigMode string

type CacheContentKind string

type CacheRequiredContentItem struct {
	Hash               string           `json:"hash"`
	RoutingKey         string           `json:"routing_key"`
	SizeBytes          int64            `json:"size_bytes,omitempty"`
	ExpectedHash       string           `json:"expected_hash,omitempty"`
	ImageID            string           `json:"image_id,omitempty"`
	Source             string           `json:"source,omitempty"`
	SourceBucket       string           `json:"source_bucket,omitempty"`
	Kind               CacheContentKind `json:"kind,omitempty"`
	CheckpointID       string           `json:"checkpoint_id,omitempty"`
	Accelerator        string           `json:"accelerator,omitempty"`
	DiskName           string           `json:"disk_name,omitempty"`
	SnapshotGeneration int64            `json:"snapshot_generation,omitempty"`
	// Retired withdraws the checkpoint named by CheckpointID from what the
	// stub requires: it has been restored, and will not be again. It carries
	// no hash, so a reader that predates it skips it.
	Retired bool `json:"retired,omitempty"`
}

type CapacityUpdateType int

type Catalog struct {
	Name          string `json:"name,omitempty" yaml:"name"`
	Description   string `json:"description,omitempty" yaml:"description"`
	ContextLength uint32 `json:"context_length,omitempty" yaml:"context_length"`
}

type Charge struct {
	ID          string        `json:"id"`
	Status      ChargeStatus  `json:"status"`
	WorkspaceID string        `json:"workspace_id"` // the caller, never the platform workspace
	TokenID     string        `json:"token_id,omitempty"`
	AppID       string        `json:"app_id"`
	Version     uint          `json:"version"`
	Route       EndpointRoute `json:"route,omitempty"`
	Pricing     Pricing       `json:"pricing"`
	Work        Work          `json:"work"`
	Cost        Cost          `json:"cost"`
	// Provider attribution: set when a workspace-contributed machine served
	// the work; ProviderShareMicroUSD is its cut of Cost.MicroUSD.
	ProviderWorkspaceID   string `json:"provider_workspace_id,omitempty"`
	ProviderShareMicroUSD int64  `json:"provider_share_micro_usd,omitempty"`
	// Diagnostics of the serving attempt (not billing inputs).
	ReplicaID      string    `json:"replica_id,omitempty"`
	ContainerID    string    `json:"container_id,omitempty"`
	MachineID      string    `json:"machine_id,omitempty"`
	GPU            string    `json:"gpu,omitempty"`
	ConfigRevision uint64    `json:"config_revision,omitempty"`
	StatusCode     int       `json:"status_code,omitempty"`
	Stream         bool      `json:"stream,omitempty"`
	DurationMs     int64     `json:"duration_ms,omitempty"`
	TTFTMs         int64     `json:"ttft_ms,omitempty"`
	QueueWaitMs    int64     `json:"queue_wait_ms,omitempty"`
	Error          string    `json:"error,omitempty"`
	AcceptedAt     time.Time `json:"accepted_at"`
	SettledAt      time.Time `json:"settled_at,omitempty"`
}

type ChargeStatus string

type Checkpoint struct {
	Id                uint     `db:"id" json:"id" serializer:"id,source:external_id" go2proto:"ignore"`
	CheckpointId      string   `db:"checkpoint_id" json:"checkpoint_id" serializer:"checkpoint_id"`
	ExternalId        string   `db:"external_id" json:"external_id,omitempty" serializer:"external_id"`
	SourceContainerId string   `db:"source_container_id" json:"source_container_id" serializer:"source_container_id"`
	ContainerIp       string   `db:"container_ip" json:"container_ip" serializer:"container_ip"`
	Status            string   `db:"status" json:"status" serializer:"status"`
	RemoteKey         string   `db:"remote_key" json:"remote_key" serializer:"remote_key"`
	WorkspaceId       uint     `db:"workspace_id" json:"workspace_id" go2proto:"ignore"` // Foreign key to Workspace
	StubId            uint     `db:"stub_id" json:"stub_id" go2proto:"ignore"`           // Foreign key to Stub
	StubType          string   `db:"stub_type" json:"stub_type" serializer:"stub_type"`
	AppId             uint     `db:"app_id" json:"app_id,omitempty" go2proto:"ignore"` // Foreign key to App
	ExposedPorts      []uint32 `db:"exposed_ports" json:"exposed_ports" serializer:"exposed_ports"`
	CreatedAt         Time     `db:"created_at" json:"created_at" serializer:"created_at"`
	LastRestoredAt    Time     `db:"last_restored_at" json:"last_restored_at" serializer:"last_restored_at"`
	DeletedAt         NullTime `db:"deleted_at" json:"deleted_at" serializer:"deleted_at"`
	CacheHash         string   `db:"cache_hash" json:"cache_hash" serializer:"cache_hash"`
	CacheSizeBytes    int64    `db:"cache_size_bytes" json:"cache_size_bytes" serializer:"cache_size_bytes"`
	OriginKey         string   `db:"origin_key" json:"origin_key" serializer:"origin_key"`
	Locality          string   `db:"locality" json:"locality" serializer:"locality"`
	Accelerator       string   `db:"accelerator" json:"accelerator" serializer:"accelerator"`
	Runtime           string   `db:"runtime" json:"runtime" serializer:"runtime"`
	// Internal placement metadata, carried separately by worker RPCs.
	CompatibilityKey string `db:"compatibility_key" json:"compatibility_key,omitempty" go2proto:"ignore"`
}

type CheckpointStatus string

type CheckpointTrigger struct {
	Type            string `json:"type,omitempty"`
	HttpPath        string `json:"http_path,omitempty"`
	HttpPort        uint32 `json:"http_port,omitempty"`
	TimeoutSeconds  uint32 `json:"timeout_seconds,omitempty"`
	IntervalSeconds uint32 `json:"interval_seconds,omitempty"`
}

type ClipVersion uint32

type ComputeCapacitySource string

type ComputeDemand struct {
	PoolName       string
	Selector       string
	GPUs           []string
	Nodes          uint32
	OfferID        string
	CPUMillicores  int64
	MemoryMB       int64
	TTL            time.Duration
	MaxSpendMicros int64
	Providers      []string
	Regions        []string
	MinReliability float64
}

type ComputeOffer struct {
	ID                string
	Provider          string // aggregator/vendor (e.g. "shadeform"), used for pool filtering
	Cloud             string // underlying cloud the vendor sources from (e.g. "imwt")
	InstanceType      string
	Region            string
	GPU               string
	GPUCount          uint32
	NodeCount         uint32
	CPUMillicores     int64
	MemoryMB          int64
	StorageMB         int64
	HourlyCostMicros  int64
	Reliability       float64
	Available         uint32
	DisplayName       string
	Category          string
	RegionDisplayName string
	Latitude          float64
	Longitude         float64
	Labels            map[string]string
	Raw               []byte
}

type ComputeOfferRequest struct {
	GPUs            []string
	Nodes           uint32
	OfferID         string
	Providers       []string
	Regions         []string
	MinReliability  float64
	MaxHourlyMicros int64
}

type ComputePool struct {
	Name           string
	Selector       string
	GPUs           []string
	Nodes          uint32
	OfferID        string
	TTL            time.Duration
	MaxSpendMicros int64
	Providers      []string
	Regions        []string
	MinReliability float64
	Source         ComputeCapacitySource
}

type ComputeReservation struct {
	ID                    string
	PoolName              string
	Name                  string
	Selector              string
	Provider              string
	Cloud                 string
	Region                string
	OfferID               string
	InstanceType          string
	InstanceID            string
	MachineID             string
	GPU                   string
	GPUCount              uint32
	NodeCount             uint32
	CPUMillicores         int64
	MemoryMB              int64
	StorageMB             int64
	HourlyCostMicros      int64
	CommittedMicros       int64
	Source                ComputeCapacitySource
	Status                ComputeReservationStatus
	CreatedAt             time.Time
	ExpiresAt             time.Time
	BillingRenewalAt      time.Time
	BillingCursorAt       time.Time
	LastStatusCheckAt     time.Time
	LastBillingCheckAt    time.Time
	LastReconcileAt       time.Time
	IdleSince             time.Time // First tick with no work on on-demand failover capacity; cleared when work lands, drives scale-down
	LastStatusMessage     string
	LastError             string
	TerminatingReason     string
	RegistrationTokenHash string
	PublicIP              string
	SSHHost               string
	SSHPort               uint32
}

type ComputeReservationRequest struct {
	PoolName          string
	MachineID         string
	Name              string
	Selector          string
	Offer             ComputeOffer
	Count             uint32
	TTL               time.Duration
	MaxSpendMicros    int64
	Source            ComputeCapacitySource
	RegistrationToken string
	BootstrapCommand  string
}

type ComputeReservationStatus string

type ComputeSolveAction struct {
	Type        ComputeSolveActionType
	Offer       ComputeOffer
	Reservation ComputeReservation
	Count       uint32
	CostMicros  int64
	Reason      string
}

type ComputeSolveActionType string

type ComputeSolveInput struct {
	Demand       ComputeDemand
	Offers       []ComputeOffer
	Reservations []ComputeReservation
	Now          time.Time
	MaxOffers    int
}

type ComputeSolvePlan struct {
	Feasible              bool
	Reason                string
	Actions               []ComputeSolveAction
	TotalCapacity         uint32
	ExistingCapacity      uint32
	NewCapacity           uint32
	IncrementalCostMicros int64
	CommittedCostMicros   int64
}

type ComputeVendor interface {
	Name() string
	ListOffers(ctx context.Context, req ComputeOfferRequest) ([]ComputeOffer, error)
	CreateReservation(ctx context.Context, req ComputeReservationRequest) (*ComputeReservation, error)
	GetReservation(ctx context.Context, id string) (*ComputeReservation, error)
	// ExtendReservation pushes a new expiry to any provider-side auto-delete
	// threshold so the provider cannot kill an instance our control plane
	// still considers alive. Vendors without provider-side thresholds no-op.
	ExtendReservation(ctx context.Context, id string, expiresAt time.Time) error
	DeleteReservation(ctx context.Context, id string) error
}

type ConcurrencyLimit struct {
	Id                uint      `db:"id" json:"-" redis:"-"`
	ExternalId        string    `db:"external_id" json:"external_id,omitempty" redis:"external_id"`
	WorkspaceId       uint      `db:"workspace_id" json:"workspace_id,omitempty" redis:"workspace_id"`
	GPULimit          uint32    `db:"gpu_limit" json:"gpu_limit" redis:"gpu_limit"`
	CPUMillicoreLimit uint32    `db:"cpu_millicore_limit" json:"cpu_millicore_limit" redis:"cpu_millicore_limit"`
	CreatedAt         time.Time `db:"created_at" json:"created_at,omitempty" redis:"-"`
	UpdatedAt         time.Time `db:"updated_at" json:"updated_at,omitempty" redis:"-"`
}

type Container struct {
	ContainerId  string          `redis:"container_id" json:"container_id"`
	StubId       string          `redis:"stub_id" json:"stub_id"`
	Status       ContainerStatus `redis:"status" json:"status"`
	ScheduledAt  time.Time       `redis:"scheduled_at" json:"scheduled_at"`
	StartedAt    time.Time       `redis:"started_at" json:"started_at"`
	WorkspaceId  string          `redis:"workspace_id" json:"workspace_id"`
	WorkerId     string          `redis:"worker_id" json:"worker_id"`
	MachineId    string          `redis:"machine_id" json:"machine_id"`
	DeploymentId string          `redis:"deployment_id" json:"deployment_id"`
}

type ContainerAlreadyScheduledError struct {
	Msg string
}

type ContainerCostHookConfig struct {
	Endpoint string `key:"endpoint" json:"endpoint"`
	Token    string `key:"token" json:"token"`
}

type ContainerEvent struct {
	ContainerId string
	Change      int
}

type ContainerEventDefinition struct {
	ID       ContainerEventID `json:"id"`
	Domain   EventDomain      `json:"domain"`
	Label    string           `json:"label"`
	Required bool             `json:"required"`
}

type ContainerEventID string

type ContainerEventOptions struct {
	Source  EventSource
	Message EventMessage
	Reason  string
	TaskID  string
	Attrs   map[string]string
}

type ContainerEventRecord struct {
	SeqNum      uint64            `json:"seq_num"`
	StoredAtNs  uint64            `json:"stored_at_ns,omitempty"`
	CloudEvent  json.RawMessage   `json:"cloud_event"`
	Type        string            `json:"type"`
	EventID     string            `json:"event_id,omitempty"`
	Domain      string            `json:"domain,omitempty"`
	ParentID    string            `json:"parent_id,omitempty"`
	Timestamp   time.Time         `json:"timestamp,omitempty"`
	StartTime   time.Time         `json:"start_time,omitempty"`
	EndTime     time.Time         `json:"end_time,omitempty"`
	DurationMs  int64             `json:"duration_ms,omitempty"`
	Success     *bool             `json:"success,omitempty"`
	Reason      string            `json:"reason,omitempty"`
	Source      string            `json:"source,omitempty"`
	Message     string            `json:"message,omitempty"`
	Attrs       map[string]string `json:"attrs,omitempty"`
	Stream      string            `json:"stream,omitempty"`
	Line        string            `json:"line,omitempty"`
	Data        json.RawMessage   `json:"data,omitempty"`
	ContainerID string            `json:"container_id,omitempty"`
	StubID      string            `json:"stub_id,omitempty"`
	StubType    string            `json:"stub_type,omitempty"`
	TaskID      string            `json:"task_id,omitempty"`
	WorkspaceID string            `json:"workspace_id,omitempty"`
	AppID       string            `json:"app_id,omitempty"`
	MachineID   string            `json:"machine_id,omitempty"`
	WorkerID    string            `json:"worker_id,omitempty"`
	PID         int32             `json:"pid,omitempty"`
	ProcessArgs []string          `json:"process_args,omitempty"`
	ProcessCwd  string            `json:"process_cwd,omitempty"`
	ProcessSeq  uint64            `json:"process_seq,omitempty"`
}

type ContainerEventsResponse struct {
	ContainerID    string                 `json:"container_id"`
	WorkspaceID    string                 `json:"workspace_id,omitempty"`
	StubID         string                 `json:"stub_id,omitempty"`
	Status         string                 `json:"status,omitempty"`
	StopReason     string                 `json:"stop_reason,omitempty"`
	RootCauseEvent string                 `json:"root_cause_event,omitempty"`
	Summary        map[string]int64       `json:"summary"`
	Events         []ContainerEventRecord `json:"events"`
	Missing        []string               `json:"missing"`
	Streams        []string               `json:"streams,omitempty"`
}

type ContainerExitCode int

type ContainerIpAssignment struct {
	ContainerID string `json:"container_id"`
	IPAddress   string `json:"ip_address"`
}

type ContainerLease struct {
	ContainerId  string
	Err          error
	Status       ContainerStatus
	Started      bool
	Evicting     bool
	DrainSeconds uint32
}

type ContainerLeaseRenewal struct {
	ContainerId    string
	RuntimeStarted bool
}

type ContainerLifecycleDefinition struct {
	ID       ContainerLifecycleID `json:"id"`
	Domain   EventDomain          `json:"domain"`
	ParentID ContainerLifecycleID `json:"parent_id,omitempty"`
	Label    string               `json:"label"`
	Required bool                 `json:"required"`
}

type ContainerLifecycleID string

type ContainerLifecycleOptions struct {
	Source EventSource
	TaskID string
	Attrs  map[string]string
}

type ContainerNetworkPolicy string

type ContainerRequest struct {
	ContainerId              string          `json:"container_id"`
	EntryPoint               []string        `json:"entry_point"`
	Env                      []string        `json:"env"`
	Cpu                      int64           `json:"cpu"`
	Memory                   int64           `json:"memory"`
	Gpu                      string          `json:"gpu"`
	GpuRequest               []string        `json:"gpu_request"`
	GpuCount                 uint32          `json:"gpu_count"`
	ImageId                  string          `json:"image_id"`
	StubId                   string          `json:"stub_id"`
	WorkspaceId              string          `json:"workspace_id"`
	Workspace                Workspace       `json:"workspace"`
	Stub                     StubWithRelated `json:"stub"`
	Timestamp                time.Time       `json:"timestamp"`
	Mounts                   []Mount         `json:"mounts"`
	RetryCount               int             `json:"retry_count"`
	PoolSelector             string          `json:"pool_selector"`
	Preemptable              bool            `json:"preemptable"`
	CheckpointEnabled        bool            `json:"checkpoint_enabled"`
	BuildOptions             BuildOptions    `json:"build_options"`
	Ports                    []uint32        `json:"ports"`
	CostPerMs                float64         `json:"cost_per_ms"`
	AppId                    string          `json:"app_id"`
	Checkpoint               *Checkpoint     `json:"checkpoint"`
	ConfigPath               string          `json:"config_path"`
	ImageCredentials         string          `json:"image_credentials"`
	BuildRegistryCredentials string          `json:"build_registry_credentials"`
	BlockNetwork             bool            `json:"block_network"`
	AllowList                []string        `json:"allow_list"`
	DockerEnabled            bool            `json:"docker_enabled"` // Enable Docker-in-Docker
	RuntimeSecretNames       []string        `json:"runtime_secret_names,omitempty"`
	RuntimeTokenRequired     bool            `json:"runtime_token_required,omitempty"`

	// MachineId pins scheduling to a single agent machine; empty means any
	// machine. The scheduler fills it in after placement on agent pools.
	MachineId         string             `json:"machine_id,omitempty"`
	CheckpointTrigger *CheckpointTrigger `json:"checkpoint_trigger,omitempty"`
	TaskId            string             `json:"task_id,omitempty"`
	DeliveryToken     string             `json:"-" go2proto:"ignore"`
	// Hostname preserved across checkpoint and restore.
	Hostname             string `json:"hostname,omitempty"`
	ProvisioningAttempts int    `json:"provisioning_attempts,omitempty" go2proto:"ignore"`
	// Evictable marks a container that the scheduler may stop to make room for
	// a non-evictable request (managed endpoint replicas).
	Evictable bool `json:"evictable,omitempty"`
	// OpportunisticOnly restricts placement to capacity that is already free:
	// the request never triggers pool scale-up or provisioning.
	OpportunisticOnly bool `json:"opportunistic_only,omitempty"`
	// EvictContainerIds lists evictable containers the worker must stop before
	// starting this one. Set by the scheduler, never by callers.
	EvictContainerIds []string `json:"evict_container_ids,omitempty"`
	// EvictDrainSeconds is how long the worker lets the victims in
	// EvictContainerIds drain after SIGTERM before killing them. Set by the
	// scheduler from the victims' own DrainSeconds.
	EvictDrainSeconds uint32 `json:"evict_drain_seconds,omitempty"`
	// DrainSeconds is the grace this container gets to finish in-flight work
	// when it is evicted. Only meaningful with Evictable.
	DrainSeconds uint32 `json:"drain_seconds,omitempty"`
	// EvictOrder ranks evictable containers on a worker: lower values are
	// evicted first. Ties fall to the most recently started container.
	EvictOrder int32 `json:"evict_order,omitempty"`
	// UseVM asks for a microvm pool: the sandbox boots in its own virtual
	// machine. Only such requests are ever scheduled onto microvm workers, and
	// they never fall back to a container runtime.
	UseVM          bool            `json:"use_vm,omitempty"`
	SecretBindings []SecretBinding `json:"secret_bindings,omitempty"`
	// ReservedCpu is the CPU the request takes from its worker's capacity (see
	// CPUTier.CPUReservation). The scheduler sets it when it places the request
	// and the worker when it accepts it; zero means Cpu.
	ReservedCpu int64 `json:"reserved_cpu,omitempty" go2proto:"ignore"`
	// contains filtered or unexported fields
}

type ContainerRequestStatus string

type ContainerResourceLimitsConfig struct {
	CPUEnforced         bool `key:"cpuEnforced" json:"cpu_enforced"`
	CPUAffinityEnforced bool `key:"cpuAffinityEnforced" json:"cpu_affinity_enforced"`
	MemoryEnforced      bool `key:"memoryEnforced" json:"memory_enforced"`
}

type ContainerResourceUsage struct {
	ContainerID       string `json:"ContainerID"`
	CpuMillicoresUsed int64  `json:"CpuMillicoresUsed"`
	MemoryUsed        int    `json:"MemoryUsed"`
	GpuMemoryUsed     int64  `json:"GpuMemoryUsed"`
	GpuMemoryTotal    int64  `json:"GpuMemoryTotal"`
	GpuType           string `json:"GpuType"`
}

type ContainerRunnerEvent struct {
	Type        string            `json:"type"`
	ID          string            `json:"id"`
	Timestamp   string            `json:"timestamp"`
	StartTime   string            `json:"start_time"`
	EndTime     string            `json:"end_time"`
	DurationMs  int64             `json:"duration_ms"`
	Success     *bool             `json:"success"`
	ContainerID string            `json:"container_id"`
	StubID      string            `json:"stub_id"`
	StubType    string            `json:"stub_type"`
	TaskID      string            `json:"task_id"`
	Message     string            `json:"message"`
	Attrs       map[string]string `json:"attrs"`
}

type ContainerRuntime string

type ContainerSchedulingFailureReason string

type ContainerState struct {
	ContainerId string          `redis:"container_id" json:"container_id"`
	StubId      string          `redis:"stub_id" json:"stub_id"`
	Status      ContainerStatus `redis:"status" json:"status"`
	ScheduledAt int64           `redis:"scheduled_at" json:"scheduled_at"`
	WorkspaceId string          `redis:"workspace_id" json:"workspace_id"`
	Gpu         string          `redis:"gpu" json:"gpu"`
	GpuCount    uint32          `redis:"gpu_count" json:"gpu_count"`
	Cpu         int64           `redis:"cpu" json:"cpu"`
	Memory      int64           `redis:"memory" json:"memory"`
	StartedAt   int64           `redis:"started_at" json:"started_at"`
	WorkerId    string          `redis:"worker_id" json:"worker_id"`
	MachineId   string          `redis:"machine_id" json:"machine_id"`
	// Evictable mirrors ContainerRequest.Evictable: the scheduler may stop
	// this container to place a non-evictable request.
	Evictable bool `redis:"evictable" json:"evictable,omitempty"`
	// Evicting is set once the scheduler has picked this container as a
	// victim; its resources are no longer counted as held.
	Evicting     bool   `redis:"evicting" json:"evicting,omitempty"`
	DrainSeconds uint32 `redis:"drain_seconds" json:"drain_seconds,omitempty"`
	EvictOrder   int32  `redis:"evict_order" json:"evict_order,omitempty"`
	// ReservedCpu mirrors ContainerRequest.ReservedCpu for the scheduled request.
	ReservedCpu int64 `redis:"reserved_cpu" json:"reserved_cpu,omitempty" go2proto:"ignore"`
}

type ContainerStatus string

type Cost struct {
	MicroUSD           int64 `json:"micro_usd"`
	PromptMicroUSD     int64 `json:"prompt_micro_usd"` // uncached input
	CompletionMicroUSD int64 `json:"completion_micro_usd"`
	CachedMicroUSD     int64 `json:"cached_micro_usd"`
	RequestMicroUSD    int64 `json:"request_micro_usd"`
}

type CreateDatabaseParams struct {
	Kind       string `json:"kind"`
	Name       string `json:"name"`
	Username   string `json:"username"`
	Password   string `json:"password"`
	Database   string `json:"database"`
	Size       string `json:"size"`
	Pool       string `json:"pool"`
	AlwaysOn   bool   `json:"always_on"`
	SnapshotID string `json:"snapshot_id,omitempty"`
	// ZeroLoss answers each Postgres or Redis commit only once object storage
	// has it, instead of up to a second before.
	ZeroLoss bool `json:"zero_loss,omitempty"`
	// Millicores and megabytes; zero means the product default.
	Cpu    int64 `json:"cpu"`
	Memory int64 `json:"memory"`
}

type CreditGateConfig struct {
	Mode            string        `key:"mode" json:"mode"`
	Endpoint        string        `key:"endpoint" json:"endpoint"`
	AuthToken       string        `key:"authToken" json:"auth_token"`
	Timeout         time.Duration `key:"timeout" json:"timeout"`
	CacheTTL        time.Duration `key:"cacheTTL" json:"cache_ttl"`
	StaleTTL        time.Duration `key:"staleTTL" json:"stale_ttl"`
	FailOpen        *bool         `key:"failOpen" json:"fail_open"`
	EnforceInterval time.Duration `key:"enforceInterval" json:"enforce_interval"`
}

type CreditStatus struct {
	OK             bool   `json:"ok"`
	AvailableCents int64  `json:"available_cents"`
	RequiredCents  int64  `json:"required_cents"`
	Code           string `json:"code,omitempty"`
	Message        string `json:"message,omitempty"`
}

type DatabaseConfig struct {
	Redis    RedisConfig    `key:"redis" json:"redis"`
	Postgres PostgresConfig `key:"postgres" json:"postgres"`
	S2       S2Config       `key:"s2" json:"s2"`
}

type DatabaseReadiness struct {
	DeploymentID string `json:"deployment_id"`
	Ready        bool   `json:"ready"`
	TLSVerified  bool   `json:"tls_verified"`
	Error        string `json:"error,omitempty"`
}

type DatabaseServiceInfo struct {
	Name                         string `json:"name"`
	Kind                         string `json:"kind"`
	DeploymentID                 string `json:"deployment_id"`
	StubID                       string `json:"stub_id"`
	AppID                        string `json:"app_id,omitempty"`
	Version                      uint   `json:"version"`
	Active                       bool   `json:"active"`
	ZeroLoss                     bool   `json:"zero_loss"`
	Host                         string `json:"host"`
	Username                     string `json:"username"`
	Database                     string `json:"database,omitempty"`
	ConnectionString             string `json:"connection_string,omitempty"`
	ConnectionEnvName            string `json:"connection_env_name"`
	ConnectionStringSecret       string `json:"connection_string_secret"`
	UsernameSecret               string `json:"username_secret"`
	PasswordSecret               string `json:"password_secret"`
	DatabaseSecret               string `json:"database_secret,omitempty"`
	PooledConnectionString       string `json:"pooled_connection_string,omitempty"`
	PooledConnectionStringSecret string `json:"pooled_connection_string_secret,omitempty"`
}

type DatabaseServingConfig struct {
	Kind                    string   `json:"kind,omitempty" serializer:"kind,omitempty"`
	Port                    uint32   `json:"port,omitempty" serializer:"port,omitempty"`
	ReadinessProbe          string   `json:"readiness_probe,omitempty" serializer:"readiness_probe,omitempty"`
	ConnectionEnvName       string   `json:"connection_env_name,omitempty" serializer:"connection_env_name,omitempty"`
	ConnectionURL           string   `json:"connection_url,omitempty" serializer:"connection_url,omitempty"`
	CredentialSecretNames   []string `json:"credential_secret_names,omitempty" serializer:"credential_secret_names,omitempty"`
	DurabilityMode          string   `json:"durability_mode,omitempty" serializer:"durability_mode,omitempty"`
	CommitLagMs             uint32   `json:"commit_lag_ms,omitempty" serializer:"commit_lag_ms,omitempty"`
	UsernameSecretName      string   `json:"username_secret_name,omitempty" serializer:"username_secret_name,omitempty"`
	PasswordSecretName      string   `json:"password_secret_name,omitempty" serializer:"password_secret_name,omitempty"`
	DatabaseSecretName      string   `json:"database_secret_name,omitempty" serializer:"database_secret_name,omitempty"`
	ConnectionURLSecretName string   `json:"connection_url_secret_name,omitempty" serializer:"connection_url_secret_name,omitempty"`
}

type DefaultConcurrencyLimitConfig struct {
	CPUMillicores uint32 `key:"cpuMillicores" json:"cpu_millicores"`
	GPUCount      uint32 `key:"gpuCount" json:"gpu_count"`
}

type DeletedWorkerReason string

type Deployment struct {
	Id          uint     `db:"id" json:"id" serializer:"id,source:external_id"`
	ExternalId  string   `db:"external_id" json:"external_id,omitempty" serializer:"external_id"`
	Name        string   `db:"name" json:"name" serializer:"name"`
	Active      bool     `db:"active" json:"active" serializer:"active"`
	Subdomain   string   `db:"subdomain" json:"subdomain" serializer:"subdomain"`
	WorkspaceId uint     `db:"workspace_id" json:"workspace_id"` // Foreign key to Workspace
	StubId      uint     `db:"stub_id" json:"stub_id"`           // Foreign key to Stub
	StubType    string   `db:"stub_type" json:"stub_type" serializer:"stub_type"`
	Version     uint     `db:"version" json:"version" serializer:"version"`
	CreatedAt   Time     `db:"created_at" json:"created_at" serializer:"created_at"`
	UpdatedAt   Time     `db:"updated_at" json:"updated_at" serializer:"updated_at"`
	DeletedAt   NullTime `db:"deleted_at" json:"deleted_at" serializer:"deleted_at"`
	AppId       uint     `db:"app_id" json:"app_id,omitempty"` // Foreign key to App
}

type DeploymentFilter struct {
	BaseFilter
	StubIds          StringSlice `query:"stub_ids"`
	WorkspaceID      uint        `query:"workspace_id"`
	StubType         StringSlice `query:"stub_type"`
	Name             string      `query:"name"`
	Active           *bool       `query:"active"`
	Version          uint        `query:"version"`
	Cursor           string      `query:"cursor"`
	CreatedAtStart   string      `query:"created_at_start"`
	CreatedAtEnd     string      `query:"created_at_end"`
	Pagination       bool        `query:"pagination"`
	Subdomain        string      `query:"subdomain"`
	SearchQuery      string      `query:"search_query"`
	MinContainersGTE uint        `query:"min_containers"`
	ShowDeleted      bool        `query:"show_deleted"`
	AppId            string      `query:"app_id"`
}

type DeploymentWithRelated struct {
	Deployment
	Workspace   Workspace `db:"workspace" json:"workspace" serializer:"workspace"`
	Stub        Stub      `db:"stub" json:"stub" serializer:"stub"`
	App         App       `db:"app" json:"app" serializer:"app"`
	StubId      string    `serializer:"stub_id,source:stub.id"`
	AppId       string    `serializer:"app_id,source:app.id"`
	WorkspaceId string    `serializer:"workspace_id,source:workspace.id"`
	URL         string    `db:"-" json:"url,omitempty" serializer:"url,omitempty"`
	InvokeURL   string    `db:"-" json:"invoke_url,omitempty" serializer:"invoke_url,omitempty"`
}

type Disk struct {
	Id          uint     `db:"id" json:"id"`
	ExternalId  string   `db:"external_id" json:"external_id"`
	WorkspaceId uint     `db:"workspace_id" json:"workspace_id"`
	Name        string   `db:"name" json:"name"`
	Size        string   `db:"size" json:"size"`
	Filesystem  string   `db:"filesystem" json:"filesystem"`
	Driver      string   `db:"driver" json:"driver"`
	MountPath   string   `db:"mount_path" json:"mount_path"`
	CreatedAt   Time     `db:"created_at" json:"created_at"`
	UpdatedAt   Time     `db:"updated_at" json:"updated_at"`
	DeletedAt   NullTime `db:"deleted_at" json:"deleted_at,omitempty"`
}

type DiskCreateInput struct {
	WorkspaceID uint   `json:"workspace_id"`
	Name        string `json:"name"`
	Size        string `json:"size"`
	Filesystem  string `json:"filesystem"`
	Driver      string `json:"driver"`
	MountPath   string `json:"mount_path"`
}

type DiskSnapshot struct {
	Id                  uint               `db:"id" json:"id,omitempty"`
	ExternalId          string             `db:"external_id" json:"external_id"`
	WorkspaceId         uint               `db:"workspace_id" json:"workspace_id"`
	StubId              uint               `db:"stub_id" json:"stub_id,omitempty"`
	DiskName            string             `db:"disk_name" json:"disk_name"`
	Format              string             `db:"format" json:"format"`
	Status              DiskSnapshotStatus `db:"status" json:"status"`
	Reason              string             `db:"reason" json:"reason,omitempty"`
	ParentSnapshotId    string             `db:"parent_snapshot_id" json:"parent_snapshot_id,omitempty"`
	Generation          int64              `db:"generation" json:"generation"`
	SizeBytes           int64              `db:"size_bytes" json:"size_bytes"`
	Filesystem          string             `db:"filesystem" json:"filesystem"`
	Driver              string             `db:"driver" json:"driver"`
	ManifestKey         string             `db:"manifest_key" json:"manifest_key"`
	ManifestDigest      string             `db:"manifest_digest" json:"manifest_digest"`
	ManifestSizeBytes   int64              `db:"manifest_size_bytes" json:"manifest_size_bytes"`
	ChunkCount          int64              `db:"chunk_count" json:"chunk_count"`
	LogicalSizeBytes    int64              `db:"logical_size_bytes" json:"logical_size_bytes"`
	StoredSizeBytes     int64              `db:"stored_size_bytes" json:"stored_size_bytes"`
	BucketName          string             `db:"bucket_name" json:"bucket_name"`
	ObjectPrefix        string             `db:"object_prefix" json:"object_prefix"`
	SourcePool          string             `db:"source_pool" json:"source_pool,omitempty"`
	SourceWorkerId      string             `db:"source_worker_id" json:"source_worker_id,omitempty"`
	SourceStorageNodeId string             `db:"source_storage_node_id" json:"source_storage_node_id,omitempty"`
	CreatedAt           Time               `db:"created_at" json:"created_at"`
	UpdatedAt           Time               `db:"updated_at" json:"updated_at"`
	CompletedAt         NullTime           `db:"completed_at" json:"completed_at,omitempty"`
	DeletedAt           NullTime           `db:"deleted_at" json:"deleted_at,omitempty"`
	Public              bool               `db:"public" json:"public"`
}

type DiskSnapshotChunk struct {
	Index       int64  `json:"index"`
	OffsetBytes int64  `json:"offset_bytes"`
	SizeBytes   int64  `json:"size_bytes"`
	ObjectKey   string `json:"object_key"`
	Digest      string `json:"digest"`
}

type DiskSnapshotFile struct {
	Path            string              `json:"path"`
	Type            string              `json:"type"`
	Mode            int64               `json:"mode"`
	Uid             int                 `json:"uid,omitempty"`
	Gid             int                 `json:"gid,omitempty"`
	SizeBytes       int64               `json:"size_bytes,omitempty"`
	ModTimeUnixNano int64               `json:"mtime_unix_nano,omitempty"`
	ChangeUnixNano  int64               `json:"ctime_unix_nano,omitempty"`
	DeviceId        uint64              `json:"device_id,omitempty"`
	Inode           uint64              `json:"inode,omitempty"`
	LinkName        string              `json:"link_name,omitempty"`
	Chunks          []DiskSnapshotChunk `json:"chunks,omitempty"`
}

type DiskSnapshotFilter struct {
	WorkspaceId         uint
	WorkspaceExternalId string
	DiskName            string
	Statuses            []DiskSnapshotStatus
	Limit               uint64
}

type DiskSnapshotManifest struct {
	Version          int                `json:"version"`
	Format           string             `json:"format"`
	DiskName         string             `json:"disk_name"`
	Filesystem       string             `json:"filesystem"`
	Generation       int64              `json:"generation"`
	ParentSnapshotId string             `json:"parent_snapshot_id,omitempty"`
	LogicalSizeBytes int64              `json:"logical_size_bytes"`
	StoredSizeBytes  int64              `json:"stored_size_bytes"`
	Files            []DiskSnapshotFile `json:"files,omitempty"`
	CreatedAt        time.Time          `json:"created_at"`
}

type DiskSnapshotStatus string

type DiskWithRelated struct {
	Disk
	Workspace Workspace `db:"workspace" json:"workspace"`
}

type DockerImageRegistryConfig struct {
	Username string `key:"username" json:"username"`
	Password string `key:"password" json:"password"`
}

type DurableDiskMountConfig struct {
	Name       string `json:"name"`
	Size       string `json:"size"`
	Filesystem string `json:"filesystem"`
	Driver     string `json:"driver"`
	// Snapshot used to seed a new disk.
	SourceSnapshotId string `json:"source_snapshot_id,omitempty"`
}

type EgressConfig struct {
	Enabled                    bool `key:"enabled" json:"enabled"`
	TLSPort                    int  `key:"tlsPort" json:"tls_port"`
	HTTPPort                   int  `key:"httpPort" json:"http_port"`
	OtherPort                  int  `key:"otherPort" json:"other_port"`
	MaxConnectionsPerContainer int  `key:"maxConnectionsPerContainer" json:"max_connections_per_container"`
}

type EndpointKind string

type EndpointReplica struct {
	ID                  string          `json:"id"`
	EndpointID          string          `json:"endpoint_id"`
	Version             uint            `json:"version"`
	GPU                 string          `json:"gpu"`
	GPUCount            uint32          `json:"gpu_count"`
	Protected           bool            `json:"protected"` // this replica belongs to the protected minimum
	Locality            string          `json:"locality,omitempty"`
	PoolName            string          `json:"pool_name,omitempty"`
	ContainerID         string          `json:"container_id"`
	WorkerID            string          `json:"worker_id,omitempty"`
	MachineID           string          `json:"machine_id,omitempty"`
	ProviderWorkspaceID string          `json:"provider_workspace_id,omitempty"` // set on contributed machines; earns a revenue share
	Address             string          `json:"address,omitempty"`
	Status              ReplicaStatus   `json:"status"`
	StatusReason        string          `json:"status_reason,omitempty"`
	SecretHash          string          `json:"secret_hash,omitempty"` // SHA-256 of BEAM_REPLICA_SECRET
	HarnessEnabled      bool            `json:"harness_enabled"`
	EngineReady         bool            `json:"engine_ready,omitempty"` // harness readiness; HTTP health must also pass before serving
	Probe               ReplicaProbe    `json:"probe"`                  // snapshotted at start; Port 0 means "ready when running"
	Config              ReplicaConfig   `json:"config"`
	Capacity            ReplicaCapacity `json:"capacity"`
	Capabilities        json.RawMessage `json:"capabilities,omitempty"`
	EngineMetrics       json.RawMessage `json:"engine_metrics,omitempty"`
	StartedAt           time.Time       `json:"started_at"`
	LoadingSince        time.Time       `json:"loading_since,omitempty"`
	ReadyAt             time.Time       `json:"ready_at,omitempty"`
	LastHeartbeat       time.Time       `json:"last_heartbeat"`
	EndedAt             time.Time       `json:"ended_at,omitempty"`
	DrainDeadline       time.Time       `json:"drain_deadline,omitempty"`
}

type EndpointRoute string

type EndpointStatus string

type ErrCheckpointNotFound struct {
	CheckpointId string
}

type ErrContainerNotAssigned struct {
}

type ErrContainerStateNotFound struct {
	ContainerId string
}

type ErrDiskSnapshotNotAvailable struct {
	SnapshotId string
}

type ErrDiskSnapshotNotFound struct {
	SnapshotId string
}

type ErrExceededTaskLimit struct {
	MaxPendingTasks uint
}

type ErrInvalidWorkerStatus struct {
}

type ErrNoSuitableWorkerFound struct {
}

type ErrWorkerNotFound struct {
	WorkerId string
}

type ErrWorkerPoolStateNotFound struct {
	PoolName string
}

type EventActor struct {
	Caller       string `json:"caller,omitempty"`
	AgentSession string `json:"agent_session,omitempty"`
}

type EventCallbackConfig struct {
	URL        string            `key:"url" json:"url"`
	Format     string            `key:"format" json:"format"`
	EventTypes []string          `key:"eventTypes" json:"event_types"`
	Headers    map[string]string `key:"headers" json:"headers"`
	Timeout    time.Duration     `key:"timeout" json:"timeout"`
}

type EventClient interface {
	PushEvent(event cloudevents.Event) error
}

type EventComputeSchema struct {
	Timestamp    time.Time         `json:"timestamp"`
	WorkspaceID  string            `json:"workspace_id,omitempty"`
	PoolName     string            `json:"pool_name,omitempty"`
	MachineID    string            `json:"machine_id,omitempty"`
	WorkerID     string            `json:"worker_id,omitempty"`
	ContainerID  string            `json:"container_id,omitempty"`
	RouteID      string            `json:"route_id,omitempty"`
	Action       string            `json:"action"`
	Status       string            `json:"status,omitempty"`
	Transport    string            `json:"transport,omitempty"`
	Executor     string            `json:"executor,omitempty"`
	Fallback     string            `json:"fallback,omitempty"`
	Source       string            `json:"source,omitempty"`
	Hostname     string            `json:"hostname,omitempty"`
	OS           string            `json:"os,omitempty"`
	Arch         string            `json:"arch,omitempty"`
	CPUCount     uint32            `json:"cpu_count,omitempty"`
	MemoryMB     uint64            `json:"memory_mb,omitempty"`
	GPUCount     uint32            `json:"gpu_count,omitempty"`
	NodeCount    uint32            `json:"node_count,omitempty"`
	MachineCount uint32            `json:"machine_count,omitempty"`
	GPUs         []string          `json:"gpus,omitempty"`
	Schedulable  *bool             `json:"schedulable,omitempty"`
	Message      string            `json:"message,omitempty"`
	Attrs        map[string]string `json:"attrs,omitempty"`
}

type EventContainerEventSchema struct {
	ID          ContainerEventID  `json:"id"`
	Domain      EventDomain       `json:"domain"`
	Timestamp   time.Time         `json:"timestamp"`
	ContainerID string            `json:"container_id,omitempty"`
	StubID      string            `json:"stub_id,omitempty"`
	StubType    string            `json:"stub_type,omitempty"`
	TaskID      string            `json:"task_id,omitempty"`
	WorkspaceID string            `json:"workspace_id,omitempty"`
	AppID       string            `json:"app_id,omitempty"`
	WorkerID    string            `json:"worker_id,omitempty"`
	MachineID   string            `json:"machine_id,omitempty"`
	CPU         int64             `json:"cpu,omitempty"`
	GPUCount    uint32            `json:"gpu_count,omitempty"`
	Reason      string            `json:"reason,omitempty"`
	Source      string            `json:"source,omitempty"`
	Message     string            `json:"message,omitempty"`
	Attrs       map[string]string `json:"attrs,omitempty"`
}

type EventContainerLifecycleSchema struct {
	ID          ContainerLifecycleID `json:"id"`
	Domain      EventDomain          `json:"domain"`
	ParentID    ContainerLifecycleID `json:"parent_id,omitempty"`
	StartTime   time.Time            `json:"start_time"`
	EndTime     time.Time            `json:"end_time,omitempty"`
	DurationMs  int64                `json:"duration_ms,omitempty"`
	ContainerID string               `json:"container_id,omitempty"`
	StubID      string               `json:"stub_id,omitempty"`
	StubType    string               `json:"stub_type,omitempty"`
	TaskID      string               `json:"task_id,omitempty"`
	WorkspaceID string               `json:"workspace_id,omitempty"`
	AppID       string               `json:"app_id,omitempty"`
	WorkerID    string               `json:"worker_id,omitempty"`
	MachineID   string               `json:"machine_id,omitempty"`
	Success     *bool                `json:"success,omitempty"`
	Source      string               `json:"source,omitempty"`
	Attrs       map[string]string    `json:"attrs,omitempty"`
}

type EventContainerLogSchema struct {
	Timestamp   time.Time `json:"timestamp"`
	ContainerID string    `json:"container_id,omitempty"`
	StubID      string    `json:"stub_id,omitempty"`
	StubType    string    `json:"stub_type,omitempty"`
	TaskID      string    `json:"task_id,omitempty"`
	WorkspaceID string    `json:"workspace_id,omitempty"`
	AppID       string    `json:"app_id,omitempty"`
	WorkerID    string    `json:"worker_id,omitempty"`
	MachineID   string    `json:"machine_id,omitempty"`
	Stream      string    `json:"stream,omitempty"`
	Line        string    `json:"line"`
	PID         int32     `json:"pid,omitempty"`
	ProcessArgs []string  `json:"process_args,omitempty"`
	ProcessCwd  string    `json:"process_cwd,omitempty"`
	ProcessSeq  uint64    `json:"process_seq,omitempty"`
}

type EventContainerMetricsData struct {
	SampleIntervalMs   int64   `json:"sample_interval_ms,omitempty"`
	CPUUsed            uint64  `json:"cpu_used"`
	CPUTotal           uint64  `json:"cpu_total"`
	CPUPercent         float32 `json:"cpu_pct"`
	MemoryRSS          uint64  `json:"memory_rss_bytes"`
	MemoryVMS          uint64  `json:"memory_vms_bytes"`
	MemorySwap         uint64  `json:"memory_swap_bytes"`
	MemoryTotal        uint64  `json:"memory_total_bytes"`
	DiskReadBytes      uint64  `json:"disk_read_bytes"`
	DiskWriteBytes     uint64  `json:"disk_write_bytes"`
	NetworkBytesRecv   uint64  `json:"network_recv_bytes"`
	NetworkBytesSent   uint64  `json:"network_sent_bytes"`
	NetworkPacketsRecv uint64  `json:"network_recv_packets"`
	NetworkPacketsSent uint64  `json:"network_sent_packets"`
	GPUMemoryUsed      uint64  `json:"gpu_memory_used_bytes"`
	GPUMemoryTotal     uint64  `json:"gpu_memory_total_bytes"`
	GPUType            string  `json:"gpu_type"`
}

type EventContainerMetricsSchema struct {
	WorkerID         string                    `json:"worker_id"`
	MachineID        string                    `json:"machine_id,omitempty"`
	ContainerID      string                    `json:"container_id"`
	WorkspaceID      string                    `json:"workspace_id"`
	StubID           string                    `json:"stub_id"`
	StubType         string                    `json:"stub_type,omitempty"`
	AppID            string                    `json:"app_id,omitempty"`
	CPU              int64                     `json:"cpu,omitempty"`
	GPUCount         uint32                    `json:"gpu_count,omitempty"`
	ContainerMetrics EventContainerMetricsData `json:"metrics"`
}

type EventDomain string

type EventEndpointRequestStatsSchema struct {
	StubID        string    `json:"stub_id"`
	WorkspaceID   string    `json:"workspace_id"`
	AppID         string    `json:"app_id,omitempty"`
	WindowStart   time.Time `json:"window_start"`
	WindowSeconds int       `json:"window_seconds"`
	Requests      int64     `json:"requests"`
	Status4xx     int64     `json:"status_4xx"`
	Status5xx     int64     `json:"status_5xx"`
	DurationSumMs int64     `json:"duration_sum_ms"`
	DurationMaxMs int64     `json:"duration_max_ms"`
	// LatencyBuckets[i] counts requests with duration <= RequestLatencyBoundsMs[i];
	// the final element counts the rest.
	LatencyBuckets  []int64   `json:"latency_buckets"`
	LatencyBoundsMs []int64   `json:"latency_bounds_ms"`
	Timestamp       time.Time `json:"timestamp"`
}

type EventEndpointRouteSchema struct {
	EndpointID  string `json:"endpoint_id"`
	WorkspaceID string `json:"workspace_id"`
	TokenID     string `json:"token_id,omitempty"`
	RequestID   string `json:"request_id"`
	Route       string `json:"route"`
	Model       string `json:"model"`
	Version     uint   `json:"version"`
	ReplicaID   string `json:"replica_id"`
	ContainerID string `json:"container_id,omitempty"`
	MachineID   string `json:"machine_id,omitempty"`
	GPU         string `json:"gpu"`
	Locality    string `json:"locality,omitempty"`
	// ConfigRevision is the replica's acknowledged live config at the time.
	ConfigRevision uint64 `json:"config_revision,omitempty"`
	// Provider attribution: set when the serving replica ran on a
	// workspace-contributed machine; ProviderShareMicroUSD is that
	// workspace's cut of CostMicroUSD.
	ProviderWorkspaceID   string    `json:"provider_workspace_id,omitempty"`
	ProviderShareMicroUSD int64     `json:"provider_share_micro_usd,omitempty"`
	StatusCode            int       `json:"status_code"`
	Stream                bool      `json:"stream"`
	Retried               bool      `json:"retried"`
	RouteReason           string    `json:"route_reason,omitempty"`
	KVHitSource           string    `json:"kv_hit_source,omitempty"`
	PromptTokens          int64     `json:"prompt_tokens"`
	CompletionTokens      int64     `json:"completion_tokens"`
	CachedTokens          int64     `json:"cached_tokens"`
	Images                int64     `json:"images"`
	CostMicroUSD          int64     `json:"cost_micro_usd"`
	PromptMicroUSD        int64     `json:"prompt_micro_usd"`
	CompletionMicroUSD    int64     `json:"completion_micro_usd"`
	CachedMicroUSD        int64     `json:"cached_micro_usd"`
	RequestMicroUSD       int64     `json:"request_micro_usd"`
	ImageMicroUSD         int64     `json:"image_micro_usd"`
	DurationMs            int64     `json:"duration_ms"`
	TTFTMs                int64     `json:"ttft_ms"`
	QueueWaitMs           int64     `json:"queue_wait_ms"`
	Error                 string    `json:"error,omitempty"`
	Timestamp             time.Time `json:"timestamp"`
}