pb

type JobControllerClient interface {
	// Start starts a job and returns an identifier that can be used to uniquely identify the started job.
	Start(ctx context.Context, in *JobStartRequest, opts ...grpc.CallOption) (*JobIdentifier, error)
	// Stop kills the running job and returns the exit code.
	Stop(ctx context.Context, in *JobIdentifier, opts ...grpc.CallOption) (*JobStatus, error)
	// Status returns the status of a job.
	Status(ctx context.Context, in *JobIdentifier, opts ...grpc.CallOption) (*JobStatus, error)
	// Log streams job logs.
	Log(ctx context.Context, in *JobIdentifier, opts ...grpc.CallOption) (JobController_LogClient, error)
}

type JobControllerServer interface {
	// Start starts a job and returns an identifier that can be used to uniquely identify the started job.
	Start(context.Context, *JobStartRequest) (*JobIdentifier, error)
	// Stop kills the running job and returns the exit code.
	Stop(context.Context, *JobIdentifier) (*JobStatus, error)
	// Status returns the status of a job.
	Status(context.Context, *JobIdentifier) (*JobStatus, error)
	// Log streams job logs.
	Log(*JobIdentifier, JobController_LogServer) error
	// contains filtered or unexported methods
}

type JobController_LogClient interface {
	Recv() (*JobLog, error)
	grpc.ClientStream
}

type JobController_LogServer interface {
	Send(*JobLog) error
	grpc.ServerStream
}

type JobIdentifier struct {

	// ulid uniquely identifies a process started by JobController.
	Ulid string `protobuf:"bytes,1,opt,name=ulid,proto3" json:"ulid,omitempty"`
	// contains filtered or unexported fields
}

type JobLog struct {
	Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

type JobStartRequest struct {

	// Command name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional command arguments.
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// The maximum bandwidth limit, which indicates how many time units the job may consume out of 100000.
	MaxCpuBandwidth *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=max_cpu_bandwidth,json=maxCpuBandwidth,proto3" json:"max_cpu_bandwidth,omitempty"`
	// Memory usage hard limit in bytes.
	MaxMemoryUsage *wrapperspb.UInt64Value `protobuf:"bytes,4,opt,name=max_memory_usage,json=maxMemoryUsage,proto3" json:"max_memory_usage,omitempty"`
	// Max read bytes per second.
	MaxRbps *wrapperspb.UInt64Value `protobuf:"bytes,5,opt,name=max_rbps,json=maxRbps,proto3" json:"max_rbps,omitempty"`
	// Max write bytes per second.
	MaxWbps *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=max_wbps,json=maxWbps,proto3" json:"max_wbps,omitempty"`
	// Max read IO operations per second.
	MaxRiops *wrapperspb.UInt64Value `protobuf:"bytes,7,opt,name=max_riops,json=maxRiops,proto3" json:"max_riops,omitempty"`
	// Max write IO operations per second.
	MaxWiops *wrapperspb.UInt64Value `protobuf:"bytes,8,opt,name=max_wiops,json=maxWiops,proto3" json:"max_wiops,omitempty"`
	// contains filtered or unexported fields
}

type JobStatus struct {

	// Whether the job has been stopped via `Stop` RPC.
	Stopped bool `protobuf:"varint,1,opt,name=stopped,proto3" json:"stopped,omitempty"`
	// Whether the job has been killed.
	Killed bool `protobuf:"varint,2,opt,name=killed,proto3" json:"killed,omitempty"`
	// Exit code of the process, if not set - the process is still running.
	ExitCode *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// CPU user time with microsecond precision.
	UserTime *durationpb.Duration `protobuf:"bytes,4,opt,name=user_time,json=userTime,proto3" json:"user_time,omitempty"`
	// CPU system time with microsecond precision.
	SystemTime *durationpb.Duration `protobuf:"bytes,5,opt,name=system_time,json=systemTime,proto3" json:"system_time,omitempty"`
	// The total amount of memory currently being used by the job cgroup and its descendants in bytes.
	MemoryCurrent uint64 `protobuf:"varint,6,opt,name=memory_current,json=memoryCurrent,proto3" json:"memory_current,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedJobControllerServer struct {
}

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