apiv1

Sep 6, 2026

Changes in this version

+ type SlotPool struct

+ Capacity int32

+ Held int32

+ Pool string

+ func (*SlotPool) Descriptor() ([]byte, []int)

+ func (*SlotPool) ProtoMessage()

+ func (x *SlotPool) GetCapacity() int32

+ func (x *SlotPool) GetHeld() int32

+ func (x *SlotPool) GetPool() string

+ func (x *SlotPool) ProtoReflect() protoreflect.Message

+ func (x *SlotPool) Reset()

+ func (x *SlotPool) String() string

type StatusResponse

+ AbandonedMacosVmCap int32

+ AbandonedMacosVms int32

+ HeldSlots int32

+ SlotCapacity int32

+ SlotPools []*SlotPool

+ func (x *StatusResponse) GetAbandonedMacosVmCap() int32

+ func (x *StatusResponse) GetAbandonedMacosVms() int32

+ func (x *StatusResponse) GetHeldSlots() int32

+ func (x *StatusResponse) GetSlotCapacity() int32

+ func (x *StatusResponse) GetSlotPools() []*SlotPool

Aug 12, 2026

Changes in this version

+ const Control_PruneCache_FullMethodName

type ControlClient

+ PruneCache func(ctx context.Context, in *PruneCacheRequest, opts ...grpc.CallOption) (*PruneCacheResponse, error)

type ControlServer

+ PruneCache func(context.Context, *PruneCacheRequest) (*PruneCacheResponse, error)

+ type PruneCacheRequest struct

+ All bool

+ Targets []string

+ func (*PruneCacheRequest) Descriptor() ([]byte, []int)

+ func (*PruneCacheRequest) ProtoMessage()

+ func (x *PruneCacheRequest) GetAll() bool

+ func (x *PruneCacheRequest) GetTargets() []string

+ func (x *PruneCacheRequest) ProtoReflect() protoreflect.Message

+ func (x *PruneCacheRequest) Reset()

+ func (x *PruneCacheRequest) String() string

+ type PruneCacheResponse struct

+ Results []*PruneCacheResult

+ func (*PruneCacheResponse) Descriptor() ([]byte, []int)

+ func (*PruneCacheResponse) ProtoMessage()

+ func (x *PruneCacheResponse) GetResults() []*PruneCacheResult

+ func (x *PruneCacheResponse) ProtoReflect() protoreflect.Message

+ func (x *PruneCacheResponse) Reset()

+ func (x *PruneCacheResponse) String() string

+ type PruneCacheResult struct

+ BytesFreed int64

+ Error string

+ Name string

+ RecordsRemoved int64

+ func (*PruneCacheResult) Descriptor() ([]byte, []int)

+ func (*PruneCacheResult) ProtoMessage()

+ func (x *PruneCacheResult) GetBytesFreed() int64

+ func (x *PruneCacheResult) GetError() string

+ func (x *PruneCacheResult) GetName() string

+ func (x *PruneCacheResult) GetRecordsRemoved() int64

+ func (x *PruneCacheResult) ProtoReflect() protoreflect.Message

+ func (x *PruneCacheResult) Reset()

+ func (x *PruneCacheResult) String() string

type UnimplementedControlServer

+ func (UnimplementedControlServer) PruneCache(context.Context, *PruneCacheRequest) (*PruneCacheResponse, error)

Aug 8, 2026

Changes in this version

+ const Control_Upgrade_FullMethodName

+ var UpgradeState_name = map[int32]string

+ var UpgradeState_value = map[string]int32

type ControlClient

+ Upgrade func(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[UpgradeProgress], error)

type ControlServer

+ Upgrade func(*UpgradeRequest, grpc.ServerStreamingServer[UpgradeProgress]) error

+ type Control_UpgradeClient = grpc.ServerStreamingClient[UpgradeProgress]

+ type Control_UpgradeServer = grpc.ServerStreamingServer[UpgradeProgress]

type StatusResponse

+ Version string

+ func (x *StatusResponse) GetVersion() string

type UnimplementedControlServer

+ func (UnimplementedControlServer) Upgrade(*UpgradeRequest, grpc.ServerStreamingServer[UpgradeProgress]) error

+ type UpgradeProgress struct

+ ActiveJobs int32

+ BytesDownloaded int64

+ BytesTotal int64

+ CurrentVersion string

+ Message string

+ State UpgradeState

+ TargetVersion string

+ func (*UpgradeProgress) Descriptor() ([]byte, []int)

+ func (*UpgradeProgress) ProtoMessage()

+ func (x *UpgradeProgress) GetActiveJobs() int32

+ func (x *UpgradeProgress) GetBytesDownloaded() int64

+ func (x *UpgradeProgress) GetBytesTotal() int64

+ func (x *UpgradeProgress) GetCurrentVersion() string

+ func (x *UpgradeProgress) GetMessage() string

+ func (x *UpgradeProgress) GetState() UpgradeState

+ func (x *UpgradeProgress) GetTargetVersion() string

+ func (x *UpgradeProgress) ProtoReflect() protoreflect.Message

+ func (x *UpgradeProgress) Reset()

+ func (x *UpgradeProgress) String() string

+ type UpgradeRequest struct

+ DrainTimeoutSeconds int32

+ Force bool

+ NoDrain bool

+ TargetVersion string

+ UrlOverride string

+ func (*UpgradeRequest) Descriptor() ([]byte, []int)

+ func (*UpgradeRequest) ProtoMessage()

+ func (x *UpgradeRequest) GetDrainTimeoutSeconds() int32

+ func (x *UpgradeRequest) GetForce() bool

+ func (x *UpgradeRequest) GetNoDrain() bool

+ func (x *UpgradeRequest) GetTargetVersion() string

+ func (x *UpgradeRequest) GetUrlOverride() string

+ func (x *UpgradeRequest) ProtoReflect() protoreflect.Message

+ func (x *UpgradeRequest) Reset()

+ func (x *UpgradeRequest) String() string

+ type UpgradeState int32

+ const UpgradeState_UPGRADE_STATE_DOWNLOADING

+ const UpgradeState_UPGRADE_STATE_DRAINING

+ const UpgradeState_UPGRADE_STATE_FAILED

+ const UpgradeState_UPGRADE_STATE_PREFLIGHT

+ const UpgradeState_UPGRADE_STATE_RESTARTING

+ const UpgradeState_UPGRADE_STATE_STAGING

+ const UpgradeState_UPGRADE_STATE_SWAPPING

+ const UpgradeState_UPGRADE_STATE_UNSPECIFIED

+ const UpgradeState_UPGRADE_STATE_UP_TO_DATE

+ const UpgradeState_UPGRADE_STATE_VERIFYING

+ func (UpgradeState) Descriptor() protoreflect.EnumDescriptor

+ func (UpgradeState) EnumDescriptor() ([]byte, []int)

+ func (UpgradeState) Type() protoreflect.EnumType

+ func (x UpgradeState) Enum() *UpgradeState

+ func (x UpgradeState) Number() protoreflect.EnumNumber

+ func (x UpgradeState) String() string

Aug 7, 2026

Changes in this version

+ const Control_Cordon_FullMethodName

+ const Control_Uncordon_FullMethodName

type ControlClient

+ Cordon func(ctx context.Context, in *CordonRequest, opts ...grpc.CallOption) (*CordonResponse, error)

+ Uncordon func(ctx context.Context, in *UncordonRequest, opts ...grpc.CallOption) (*UncordonResponse, error)

type ControlServer

+ Cordon func(context.Context, *CordonRequest) (*CordonResponse, error)

+ Uncordon func(context.Context, *UncordonRequest) (*UncordonResponse, error)

+ type CordonRequest struct

+ func (*CordonRequest) Descriptor() ([]byte, []int)

+ func (*CordonRequest) ProtoMessage()

+ func (x *CordonRequest) ProtoReflect() protoreflect.Message

+ func (x *CordonRequest) Reset()

+ func (x *CordonRequest) String() string

+ type CordonResponse struct

+ ActiveJobs int32

+ func (*CordonResponse) Descriptor() ([]byte, []int)

+ func (*CordonResponse) ProtoMessage()

+ func (x *CordonResponse) GetActiveJobs() int32

+ func (x *CordonResponse) ProtoReflect() protoreflect.Message

+ func (x *CordonResponse) Reset()

+ func (x *CordonResponse) String() string

+ type UncordonRequest struct

+ func (*UncordonRequest) Descriptor() ([]byte, []int)

+ func (*UncordonRequest) ProtoMessage()

+ func (x *UncordonRequest) ProtoReflect() protoreflect.Message

+ func (x *UncordonRequest) Reset()

+ func (x *UncordonRequest) String() string

+ type UncordonResponse struct

+ ActiveJobs int32

+ func (*UncordonResponse) Descriptor() ([]byte, []int)

+ func (*UncordonResponse) ProtoMessage()

+ func (x *UncordonResponse) GetActiveJobs() int32

+ func (x *UncordonResponse) ProtoReflect() protoreflect.Message

+ func (x *UncordonResponse) Reset()

+ func (x *UncordonResponse) String() string

type UnimplementedControlServer

+ func (UnimplementedControlServer) Cordon(context.Context, *CordonRequest) (*CordonResponse, error)

+ func (UnimplementedControlServer) Uncordon(context.Context, *UncordonRequest) (*UncordonResponse, error)

Jul 13, 2026

Changes in this version

+ const Control_GetJobLogs_FullMethodName

+ const Control_GetJob_FullMethodName

+ const Control_KillJob_FullMethodName

+ const Control_ListJobs_FullMethodName

+ const Control_Status_FullMethodName

+ const Dispatch_CreateJob_FullMethodName

+ const Dispatch_DestroyJob_FullMethodName

+ const Dispatch_StreamContainerStats_FullMethodName

+ const Dispatch_WaitJob_FullMethodName

+ var Control_ServiceDesc = grpc.ServiceDesc

+ var Dispatch_ServiceDesc = grpc.ServiceDesc

+ var File_api_v1_ephemerd_proto protoreflect.FileDescriptor

+ func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)

+ func RegisterDispatchServer(s grpc.ServiceRegistrar, srv DispatchServer)

+ type ContainerStats struct

+ CpuLimit uint64

+ CpuUsageNanos uint64

+ Id string

+ MemoryAnonBytes uint64

+ MemoryBytes uint64

+ MemoryLimitBytes uint64

+ NetworkRxBytes uint64

+ NetworkTxBytes uint64

+ Repo string

+ func (*ContainerStats) Descriptor() ([]byte, []int)

+ func (*ContainerStats) ProtoMessage()

+ func (x *ContainerStats) GetCpuLimit() uint64

+ func (x *ContainerStats) GetCpuUsageNanos() uint64

+ func (x *ContainerStats) GetId() string

+ func (x *ContainerStats) GetMemoryAnonBytes() uint64

+ func (x *ContainerStats) GetMemoryBytes() uint64

+ func (x *ContainerStats) GetMemoryLimitBytes() uint64

+ func (x *ContainerStats) GetNetworkRxBytes() uint64

+ func (x *ContainerStats) GetNetworkTxBytes() uint64

+ func (x *ContainerStats) GetRepo() string

+ func (x *ContainerStats) ProtoReflect() protoreflect.Message

+ func (x *ContainerStats) Reset()

+ func (x *ContainerStats) String() string

+ type ContainerStatsBatch struct

+ Stats []*ContainerStats

+ TimestampUnixNano int64

+ func (*ContainerStatsBatch) Descriptor() ([]byte, []int)

+ func (*ContainerStatsBatch) ProtoMessage()

+ func (x *ContainerStatsBatch) GetStats() []*ContainerStats

+ func (x *ContainerStatsBatch) GetTimestampUnixNano() int64

+ func (x *ContainerStatsBatch) ProtoReflect() protoreflect.Message

+ func (x *ContainerStatsBatch) Reset()

+ func (x *ContainerStatsBatch) String() string

+ type ControlClient interface

+ GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)

+ GetJobLogs func(ctx context.Context, in *GetJobLogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogChunk], error)

+ KillJob func(ctx context.Context, in *KillJobRequest, opts ...grpc.CallOption) (*KillJobResponse, error)

+ ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)

+ Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

+ func NewControlClient(cc grpc.ClientConnInterface) ControlClient

+ type ControlServer interface

+ GetJob func(context.Context, *GetJobRequest) (*Job, error)

+ GetJobLogs func(*GetJobLogsRequest, grpc.ServerStreamingServer[LogChunk]) error

+ KillJob func(context.Context, *KillJobRequest) (*KillJobResponse, error)

+ ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ Status func(context.Context, *StatusRequest) (*StatusResponse, error)

+ type Control_GetJobLogsClient = grpc.ServerStreamingClient[LogChunk]

+ type Control_GetJobLogsServer = grpc.ServerStreamingServer[LogChunk]

+ type CreateJobRequest struct

+ Id string

+ Image string

+ JitConfig string

+ Provider string

+ Repo string

+ func (*CreateJobRequest) Descriptor() ([]byte, []int)

+ func (*CreateJobRequest) ProtoMessage()

+ func (x *CreateJobRequest) GetId() string

+ func (x *CreateJobRequest) GetImage() string

+ func (x *CreateJobRequest) GetJitConfig() string

+ func (x *CreateJobRequest) GetProvider() string

+ func (x *CreateJobRequest) GetRepo() string

+ func (x *CreateJobRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateJobRequest) Reset()

+ func (x *CreateJobRequest) String() string

+ type CreateJobResponse struct

+ func (*CreateJobResponse) Descriptor() ([]byte, []int)

+ func (*CreateJobResponse) ProtoMessage()

+ func (x *CreateJobResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateJobResponse) Reset()

+ func (x *CreateJobResponse) String() string

+ type DestroyJobRequest struct

+ Id string

+ func (*DestroyJobRequest) Descriptor() ([]byte, []int)

+ func (*DestroyJobRequest) ProtoMessage()

+ func (x *DestroyJobRequest) GetId() string

+ func (x *DestroyJobRequest) ProtoReflect() protoreflect.Message

+ func (x *DestroyJobRequest) Reset()

+ func (x *DestroyJobRequest) String() string

+ type DestroyJobResponse struct

+ func (*DestroyJobResponse) Descriptor() ([]byte, []int)

+ func (*DestroyJobResponse) ProtoMessage()

+ func (x *DestroyJobResponse) ProtoReflect() protoreflect.Message

+ func (x *DestroyJobResponse) Reset()

+ func (x *DestroyJobResponse) String() string

+ type DispatchClient interface

+ CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error)

+ DestroyJob func(ctx context.Context, in *DestroyJobRequest, opts ...grpc.CallOption) (*DestroyJobResponse, error)

+ StreamContainerStats func(ctx context.Context, in *StreamContainerStatsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ContainerStatsBatch], error)

+ WaitJob func(ctx context.Context, in *WaitJobRequest, opts ...grpc.CallOption) (*WaitJobResponse, error)

+ func NewDispatchClient(cc grpc.ClientConnInterface) DispatchClient

+ type DispatchServer interface

+ CreateJob func(context.Context, *CreateJobRequest) (*CreateJobResponse, error)

+ DestroyJob func(context.Context, *DestroyJobRequest) (*DestroyJobResponse, error)

+ StreamContainerStats func(*StreamContainerStatsRequest, grpc.ServerStreamingServer[ContainerStatsBatch]) error

+ WaitJob func(context.Context, *WaitJobRequest) (*WaitJobResponse, error)

+ type Dispatch_StreamContainerStatsClient = grpc.ServerStreamingClient[ContainerStatsBatch]

+ type Dispatch_StreamContainerStatsServer = grpc.ServerStreamingServer[ContainerStatsBatch]

+ type GetJobLogsRequest struct

+ Follow bool

+ Id int64

+ func (*GetJobLogsRequest) Descriptor() ([]byte, []int)

+ func (*GetJobLogsRequest) ProtoMessage()

+ func (x *GetJobLogsRequest) GetFollow() bool

+ func (x *GetJobLogsRequest) GetId() int64

+ func (x *GetJobLogsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetJobLogsRequest) Reset()

+ func (x *GetJobLogsRequest) String() string

+ type GetJobRequest struct

+ Id int64

+ func (*GetJobRequest) Descriptor() ([]byte, []int)

+ func (*GetJobRequest) ProtoMessage()

+ func (x *GetJobRequest) GetId() int64

+ func (x *GetJobRequest) ProtoReflect() protoreflect.Message

+ func (x *GetJobRequest) Reset()

+ func (x *GetJobRequest) String() string

+ type Job struct

+ Id int64

+ Image string

+ Name string

+ Pid uint32

+ Repo string

+ RunnerId int64

+ StartedAt string

+ Status string

+ Uptime string

+ func (*Job) Descriptor() ([]byte, []int)

+ func (*Job) ProtoMessage()

+ func (x *Job) GetId() int64

+ func (x *Job) GetImage() string

+ func (x *Job) GetName() string

+ func (x *Job) GetPid() uint32

+ func (x *Job) GetRepo() string

+ func (x *Job) GetRunnerId() int64

+ func (x *Job) GetStartedAt() string

+ func (x *Job) GetStatus() string

+ func (x *Job) GetUptime() string

+ func (x *Job) ProtoReflect() protoreflect.Message

+ func (x *Job) Reset()

+ func (x *Job) String() string

+ type KillJobRequest struct

+ Id int64

+ func (*KillJobRequest) Descriptor() ([]byte, []int)

+ func (*KillJobRequest) ProtoMessage()

+ func (x *KillJobRequest) GetId() int64

+ func (x *KillJobRequest) ProtoReflect() protoreflect.Message

+ func (x *KillJobRequest) Reset()

+ func (x *KillJobRequest) String() string

+ type KillJobResponse struct

+ func (*KillJobResponse) Descriptor() ([]byte, []int)

+ func (*KillJobResponse) ProtoMessage()

+ func (x *KillJobResponse) ProtoReflect() protoreflect.Message

+ func (x *KillJobResponse) Reset()

+ func (x *KillJobResponse) String() string

+ type ListJobsRequest struct

+ func (*ListJobsRequest) Descriptor() ([]byte, []int)

+ func (*ListJobsRequest) ProtoMessage()

+ func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListJobsRequest) Reset()

+ func (x *ListJobsRequest) String() string

+ type ListJobsResponse struct

+ Jobs []*Job

+ func (*ListJobsResponse) Descriptor() ([]byte, []int)

+ func (*ListJobsResponse) ProtoMessage()

+ func (x *ListJobsResponse) GetJobs() []*Job

+ func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListJobsResponse) Reset()

+ func (x *ListJobsResponse) String() string

+ type LogChunk struct

+ Data []byte

+ func (*LogChunk) Descriptor() ([]byte, []int)

+ func (*LogChunk) ProtoMessage()

+ func (x *LogChunk) GetData() []byte

+ func (x *LogChunk) ProtoReflect() protoreflect.Message

+ func (x *LogChunk) Reset()

+ func (x *LogChunk) String() string

+ type StatusRequest struct

+ func (*StatusRequest) Descriptor() ([]byte, []int)

+ func (*StatusRequest) ProtoMessage()

+ func (x *StatusRequest) ProtoReflect() protoreflect.Message

+ func (x *StatusRequest) Reset()

+ func (x *StatusRequest) String() string

+ type StatusResponse struct

+ ActiveJobs int32

+ Draining bool

+ MaxConcurrent int32

+ Status string

+ Uptime string

+ func (*StatusResponse) Descriptor() ([]byte, []int)

+ func (*StatusResponse) ProtoMessage()

+ func (x *StatusResponse) GetActiveJobs() int32

+ func (x *StatusResponse) GetDraining() bool

+ func (x *StatusResponse) GetMaxConcurrent() int32

+ func (x *StatusResponse) GetStatus() string

+ func (x *StatusResponse) GetUptime() string

+ func (x *StatusResponse) ProtoReflect() protoreflect.Message

+ func (x *StatusResponse) Reset()

+ func (x *StatusResponse) String() string

+ type StreamContainerStatsRequest struct

+ IntervalSeconds uint32

+ func (*StreamContainerStatsRequest) Descriptor() ([]byte, []int)

+ func (*StreamContainerStatsRequest) ProtoMessage()

+ func (x *StreamContainerStatsRequest) GetIntervalSeconds() uint32

+ func (x *StreamContainerStatsRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamContainerStatsRequest) Reset()

+ func (x *StreamContainerStatsRequest) String() string

+ type UnimplementedControlServer struct

+ func (UnimplementedControlServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

+ func (UnimplementedControlServer) GetJobLogs(*GetJobLogsRequest, grpc.ServerStreamingServer[LogChunk]) error

+ func (UnimplementedControlServer) KillJob(context.Context, *KillJobRequest) (*KillJobResponse, error)

+ func (UnimplementedControlServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ func (UnimplementedControlServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

+ type UnimplementedDispatchServer struct

+ func (UnimplementedDispatchServer) CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)

+ func (UnimplementedDispatchServer) DestroyJob(context.Context, *DestroyJobRequest) (*DestroyJobResponse, error)

+ func (UnimplementedDispatchServer) StreamContainerStats(*StreamContainerStatsRequest, grpc.ServerStreamingServer[ContainerStatsBatch]) error

+ func (UnimplementedDispatchServer) WaitJob(context.Context, *WaitJobRequest) (*WaitJobResponse, error)

+ type UnsafeControlServer interface

+ type UnsafeDispatchServer interface

+ type WaitJobRequest struct

+ Id string

+ func (*WaitJobRequest) Descriptor() ([]byte, []int)

+ func (*WaitJobRequest) ProtoMessage()

+ func (x *WaitJobRequest) GetId() string

+ func (x *WaitJobRequest) ProtoReflect() protoreflect.Message

+ func (x *WaitJobRequest) Reset()

+ func (x *WaitJobRequest) String() string

+ type WaitJobResponse struct

+ ExitCode uint32

+ func (*WaitJobResponse) Descriptor() ([]byte, []int)

+ func (*WaitJobResponse) ProtoMessage()

+ func (x *WaitJobResponse) GetExitCode() uint32

+ func (x *WaitJobResponse) ProtoReflect() protoreflect.Message

+ func (x *WaitJobResponse) Reset()

+ func (x *WaitJobResponse) String() string