Versions in this module Expand all Collapse all v0 v0.1.2 Jul 15, 2026 v0.1.1 Jul 13, 2026 v0.1.0 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
Go to main page