apiv1

type ContainerStats struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Repo             string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	CpuUsageNanos    uint64 `protobuf:"varint,3,opt,name=cpu_usage_nanos,json=cpuUsageNanos,proto3" json:"cpu_usage_nanos,omitempty"`          // cumulative CPU time in nanoseconds
	MemoryBytes      uint64 `protobuf:"varint,4,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`                  // current usage
	MemoryAnonBytes  uint64 `protobuf:"varint,5,opt,name=memory_anon_bytes,json=memoryAnonBytes,proto3" json:"memory_anon_bytes,omitempty"`    // anon-only (cgroup); 0 on Windows
	CpuLimit         uint64 `protobuf:"varint,6,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`                           // configured vCPU count; 0 = unlimited
	MemoryLimitBytes uint64 `protobuf:"varint,7,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"` // configured memory cap; 0 = unlimited
	// Cumulative network bytes (the runner container only — does not include
	// sibling containers spawned via dind). On Linux this is read via
	// netlink against the container's netns and excludes loopback. On
	// Windows it sums BytesReceived/BytesSent across HCS endpoints.
	NetworkRxBytes uint64 `protobuf:"varint,8,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
	NetworkTxBytes uint64 `protobuf:"varint,9,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
	// contains filtered or unexported fields
}

type ContainerStatsBatch struct {
	TimestampUnixNano int64             `protobuf:"varint,1,opt,name=timestamp_unix_nano,json=timestampUnixNano,proto3" json:"timestamp_unix_nano,omitempty"` // server-side wall clock at sample time
	Stats             []*ContainerStats `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

type ControlClient interface {
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	KillJob(ctx context.Context, in *KillJobRequest, opts ...grpc.CallOption) (*KillJobResponse, error)
	GetJobLogs(ctx context.Context, in *GetJobLogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogChunk], error)
	// Cordon stops the daemon from claiming new jobs without initiating
	// shutdown; running jobs continue. Uncordon resumes claiming. Used by
	// `ephemerd drain --wait` to empty the daemon before a restart.
	Cordon(ctx context.Context, in *CordonRequest, opts ...grpc.CallOption) (*CordonResponse, error)
	Uncordon(ctx context.Context, in *UncordonRequest, opts ...grpc.CallOption) (*UncordonResponse, error)
	// Upgrade replaces the running daemon's own binary with a specific
	// published release, then restarts the service into it. The daemon
	// downloads and checksum-verifies the release asset over its own
	// outbound HTTPS (provider-agnostic, no exec/size limit), drains
	// running jobs first, swaps the binary, and restarts. Progress is
	// streamed so the caller can watch state transitions; the final
	// message is UPGRADE_STATE_RESTARTING, sent BEFORE the service
	// restarts, after which the caller polls Status until the reported
	// version matches the target. See docs/arch/upgrade-command.md.
	Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[UpgradeProgress], error)
	// PruneCache reclaims disk inside the RUNNING daemon, through the same
	// cache managers that own the data: BuildKit's own prune for the build
	// cache (deleting its containerd records directly leaves the snapshots
	// pinned by BuildKit's cache DB and frees nothing), dead jobs' scoped
	// build records, and the disk-pressure image collector. This is what
	// `ephemerd cache clear buildkit|containerd` calls, replacing an
	// offline `rm -rf` of the data directory that required stopping the
	// daemon and could not tell in-use data from garbage.
	PruneCache(ctx context.Context, in *PruneCacheRequest, opts ...grpc.CallOption) (*PruneCacheResponse, error)
}

type ControlServer interface {
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	KillJob(context.Context, *KillJobRequest) (*KillJobResponse, error)
	GetJobLogs(*GetJobLogsRequest, grpc.ServerStreamingServer[LogChunk]) error
	// Cordon stops the daemon from claiming new jobs without initiating
	// shutdown; running jobs continue. Uncordon resumes claiming. Used by
	// `ephemerd drain --wait` to empty the daemon before a restart.
	Cordon(context.Context, *CordonRequest) (*CordonResponse, error)
	Uncordon(context.Context, *UncordonRequest) (*UncordonResponse, error)
	// Upgrade replaces the running daemon's own binary with a specific
	// published release, then restarts the service into it. The daemon
	// downloads and checksum-verifies the release asset over its own
	// outbound HTTPS (provider-agnostic, no exec/size limit), drains
	// running jobs first, swaps the binary, and restarts. Progress is
	// streamed so the caller can watch state transitions; the final
	// message is UPGRADE_STATE_RESTARTING, sent BEFORE the service
	// restarts, after which the caller polls Status until the reported
	// version matches the target. See docs/arch/upgrade-command.md.
	Upgrade(*UpgradeRequest, grpc.ServerStreamingServer[UpgradeProgress]) error
	// PruneCache reclaims disk inside the RUNNING daemon, through the same
	// cache managers that own the data: BuildKit's own prune for the build
	// cache (deleting its containerd records directly leaves the snapshots
	// pinned by BuildKit's cache DB and frees nothing), dead jobs' scoped
	// build records, and the disk-pressure image collector. This is what
	// `ephemerd cache clear buildkit|containerd` calls, replacing an
	// offline `rm -rf` of the data directory that required stopping the
	// daemon and could not tell in-use data from garbage.
	PruneCache(context.Context, *PruneCacheRequest) (*PruneCacheResponse, error)
	// contains filtered or unexported methods
}

type Control_GetJobLogsClient = grpc.ServerStreamingClient[LogChunk]

type Control_GetJobLogsServer = grpc.ServerStreamingServer[LogChunk]

type Control_UpgradeClient = grpc.ServerStreamingClient[UpgradeProgress]

type Control_UpgradeServer = grpc.ServerStreamingServer[UpgradeProgress]

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

type CordonResponse struct {
	ActiveJobs int32 `protobuf:"varint,1,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"` // jobs still running at the time of the cordon
	// contains filtered or unexported fields
}

type CreateJobRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image     string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	JitConfig string `protobuf:"bytes,3,opt,name=jit_config,json=jitConfig,proto3" json:"jit_config,omitempty"`
	// provider is the forge name (e.g. "github", "gitea"); together with
	// repo it scopes dind's per-repo image cache.
	Provider string `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"`
	// repo is the forge-native repo path (e.g. "owner/repo").
	Repo string `protobuf:"bytes,5,opt,name=repo,proto3" json:"repo,omitempty"`
	// contains filtered or unexported fields
}

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

type DestroyJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

type DispatchClient interface {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error)
	WaitJob(ctx context.Context, in *WaitJobRequest, opts ...grpc.CallOption) (*WaitJobResponse, error)
	DestroyJob(ctx context.Context, in *DestroyJobRequest, opts ...grpc.CallOption) (*DestroyJobResponse, error)
	StreamContainerStats(ctx context.Context, in *StreamContainerStatsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ContainerStatsBatch], error)
}

type DispatchServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
	WaitJob(context.Context, *WaitJobRequest) (*WaitJobResponse, error)
	DestroyJob(context.Context, *DestroyJobRequest) (*DestroyJobResponse, error)
	StreamContainerStats(*StreamContainerStatsRequest, grpc.ServerStreamingServer[ContainerStatsBatch]) error
	// contains filtered or unexported methods
}

type Dispatch_StreamContainerStatsClient = grpc.ServerStreamingClient[ContainerStatsBatch]

type Dispatch_StreamContainerStatsServer = grpc.ServerStreamingServer[ContainerStatsBatch]

type GetJobLogsRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Follow bool  `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Repo      string `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	Image     string `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	RunnerId  int64  `protobuf:"varint,5,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Status    string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	Pid       uint32 `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"`
	StartedAt string `protobuf:"bytes,8,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` // RFC3339
	Uptime    string `protobuf:"bytes,9,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

type KillJobRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type LogChunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type PruneCacheRequest struct {

	// targets names the caches to prune ("buildkit", "containerd"). Empty
	// prunes every daemon-managed cache.
	Targets []string `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// all drops even cache that the configured retention policy would keep
	// (BuildKit's reserved floor). Off by default: the point of the cache is
	// to stay warm, and a full drop trades disk for network on the next job.
	All bool `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"`
	// contains filtered or unexported fields
}

type PruneCacheResponse struct {
	Results []*PruneCacheResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type PruneCacheResult struct {

	// name is the cache that was pruned, matching `ephemerd cache list`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// bytes_freed is the space reclaimed, where the underlying manager
	// reports it. 0 means "unknown", not necessarily "nothing".
	BytesFreed int64 `protobuf:"varint,2,opt,name=bytes_freed,json=bytesFreed,proto3" json:"bytes_freed,omitempty"`
	// records_removed counts the metadata records dropped (image records,
	// cache entries).
	RecordsRemoved int64 `protobuf:"varint,3,opt,name=records_removed,json=recordsRemoved,proto3" json:"records_removed,omitempty"`
	// error is non-empty when this target failed; other targets still ran.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type StatusResponse struct {
	Status        string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ActiveJobs    int32  `protobuf:"varint,2,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"`
	MaxConcurrent int32  `protobuf:"varint,3,opt,name=max_concurrent,json=maxConcurrent,proto3" json:"max_concurrent,omitempty"`
	Draining      bool   `protobuf:"varint,4,opt,name=draining,proto3" json:"draining,omitempty"`
	Uptime        string `protobuf:"bytes,5,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// version is the running daemon's build version (the value stamped into
	// `ephemerd --version`). Empty on daemons built before this field existed.
	// The upgrade flow polls this after a restart to confirm the new binary
	// came up on the target version.
	Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type StreamContainerStatsRequest struct {
	IntervalSeconds uint32 `protobuf:"varint,1,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"` // 0 -> server default (10s)
	// contains filtered or unexported fields
}

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

type UncordonResponse struct {
	ActiveJobs int32 `protobuf:"varint,1,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedControlServer struct{}

type UnimplementedDispatchServer struct{}

type UnsafeControlServer interface {
	// contains filtered or unexported methods
}

type UnsafeDispatchServer interface {
	// contains filtered or unexported methods
}

type UpgradeProgress struct {
	State           UpgradeState `protobuf:"varint,1,opt,name=state,proto3,enum=ephemerd.v1.UpgradeState" json:"state,omitempty"`
	Message         string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	CurrentVersion  string       `protobuf:"bytes,3,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	TargetVersion   string       `protobuf:"bytes,4,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	ActiveJobs      int32        `protobuf:"varint,5,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"`                // populated during DRAINING
	BytesDownloaded int64        `protobuf:"varint,6,opt,name=bytes_downloaded,json=bytesDownloaded,proto3" json:"bytes_downloaded,omitempty"` // populated during DOWNLOADING
	BytesTotal      int64        `protobuf:"varint,7,opt,name=bytes_total,json=bytesTotal,proto3" json:"bytes_total,omitempty"`                // total asset size if known (else 0)
	// contains filtered or unexported fields
}

type UpgradeRequest struct {

	// target_version is REQUIRED, e.g. "v0.1.7". The daemon never resolves
	// "latest" on its own: on a CI fleet an implicit latest would let one bad
	// release take down every node at once. Must be an explicit release tag.
	TargetVersion string `protobuf:"bytes,1,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// url_override optionally replaces the release base URL
	// (https://github.com/ephpm/ephemerd/releases/download/<tag>). When set,
	// the archive is fetched from <url_override>/<asset> and the checksums from
	// <url_override>/checksums.txt. For testing and air-gapped mirrors.
	UrlOverride string `protobuf:"bytes,2,opt,name=url_override,json=urlOverride,proto3" json:"url_override,omitempty"`
	// drain_timeout_seconds bounds the wait for running jobs to finish before
	// the swap. 0 -> server default. On timeout the upgrade aborts and the node
	// keeps running the OLD binary (it is left uncordoned).
	DrainTimeoutSeconds int32 `protobuf:"varint,3,opt,name=drain_timeout_seconds,json=drainTimeoutSeconds,proto3" json:"drain_timeout_seconds,omitempty"`
	// no_drain skips the cordon/drain step (operator override for an emergency
	// upgrade). Running jobs are interrupted by the restart.
	NoDrain bool `protobuf:"varint,4,opt,name=no_drain,json=noDrain,proto3" json:"no_drain,omitempty"`
	// force re-installs the target even if the daemon already reports it.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

type UpgradeState int32

type WaitJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type WaitJobResponse struct {
	ExitCode uint32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}