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)
}

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
	// contains filtered or unexported methods
}

type Control_GetJobLogsClient = grpc.ServerStreamingClient[LogChunk]

type Control_GetJobLogsServer = grpc.ServerStreamingServer[LogChunk]

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 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"`
	// 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 UnimplementedControlServer struct{}

type UnimplementedDispatchServer struct{}

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

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

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
}