api

type CancelJobRequest struct {
	// ID of a job to be cancelled.
	JobId                int64    `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CancelJobResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Chunk struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JobInfo struct {
	// ID of a job.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of a user who submitted the job.
	UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// Job name.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Job exit code. For slurm workload manager will be in form "int:int".
	ExitCode string `protobuf:"bytes,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Job current status.
	Status JobStatus `protobuf:"varint,5,opt,name=status,proto3,enum=api.JobStatus" json:"status,omitempty"`
	// Job submit time.
	SubmitTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
	// Job start time.
	StartTime *timestamp.Timestamp `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Job running time.
	RunTime *duration.Duration `protobuf:"bytes,8,opt,name=run_time,json=runTime,proto3" json:"run_time,omitempty"`
	// Job time limit.
	TimeLimit *duration.Duration `protobuf:"bytes,9,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
	// Job working directory.
	WorkingDir string `protobuf:"bytes,10,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	// Path to job's standard output file.
	StdOut string `protobuf:"bytes,11,opt,name=std_out,json=stdOut,proto3" json:"std_out,omitempty"`
	// Path to job's standard error file.
	StdErr string `protobuf:"bytes,12,opt,name=std_err,json=stdErr,proto3" json:"std_err,omitempty"`
	// Cluster partition on which job resides.
	Partition string `protobuf:"bytes,13,opt,name=partition,proto3" json:"partition,omitempty"`
	// List of nodes on which job is executed.
	NodeList string `protobuf:"bytes,14,opt,name=node_list,json=nodeList,proto3" json:"node_list,omitempty"`
	// Host from which job was submitted.
	BatchHost string `protobuf:"bytes,15,opt,name=batch_host,json=batchHost,proto3" json:"batch_host,omitempty"`
	// Number of nodes requested by job.
	NumNodes string `protobuf:"bytes,16,opt,name=num_nodes,json=numNodes,proto3" json:"num_nodes,omitempty"`
	// Job array id.
	ArrayId              string   `protobuf:"bytes,17,opt,name=array_id,json=arrayId,proto3" json:"array_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JobInfoRequest struct {
	// ID of a job to fetch info of.
	JobId                int64    `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JobInfoResponse struct {
	// Job information.
	Info                 []*JobInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

type JobStatus int32

type JobStepInfo struct {
	// ID od a job step.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Job step name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Job step exit code.
	ExitCode int32 `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Job step current status.
	Status JobStatus `protobuf:"varint,4,opt,name=status,proto3,enum=api.JobStatus" json:"status,omitempty"`
	// Job step start time.
	StartTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Job step end time.
	EndTime              *timestamp.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

type JobStepsRequest struct {
	// ID of a job to fetch steps of.
	JobId                int64    `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JobStepsResponse struct {
	// Job steps information.
	JobSteps             []*JobStepInfo `protobuf:"bytes,1,rep,name=job_steps,json=jobSteps,proto3" json:"job_steps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type OpenFileRequest struct {
	// Path to file to open.
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SubmitJobRequest struct {
	// Bash script that will be submitted to a workload manager.
	Script               string   `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SubmitJobResponse struct {
	// Job ID to track submitted job.
	JobId                int64    `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type TailAction int32

type TailFileRequest struct {
	Action TailAction `protobuf:"varint,1,opt,name=action,proto3,enum=api.TailAction" json:"action,omitempty"`
	// Path to file to tail.
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UnimplementedWorkloadManagerServer struct {
}

type WorkloadManagerClient interface {
	// SubmitJob submits new job to the workload manager and
	// returns job id that can be used to track job status.
	SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*SubmitJobResponse, error)
	// CancelJob cancels job by job id.
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
	// JobInfo returns complete information about a particular job.
	// In case of JobArray the first job in slice is a root.
	// JobInfoResponse have to contain at least one element
	JobInfo(ctx context.Context, in *JobInfoRequest, opts ...grpc.CallOption) (*JobInfoResponse, error)
	// JobSteps returns information about each individual job step.
	JobSteps(ctx context.Context, in *JobStepsRequest, opts ...grpc.CallOption) (*JobStepsResponse, error)
	// OpenFile opens a file and streams its content back. May be
	// useful for results collecting.
	OpenFile(ctx context.Context, in *OpenFileRequest, opts ...grpc.CallOption) (WorkloadManager_OpenFileClient, error)
	// TailFile opens a file and streams its content back. Unlike
	// OpenFile this call will watch file content changes and stream
	// new chunks continuously.
	TailFile(ctx context.Context, opts ...grpc.CallOption) (WorkloadManager_TailFileClient, error)
}

type WorkloadManagerServer interface {
	// SubmitJob submits new job to the workload manager and
	// returns job id that can be used to track job status.
	SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error)
	// CancelJob cancels job by job id.
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	// JobInfo returns complete information about a particular job.
	// In case of JobArray the first job in slice is a root.
	// JobInfoResponse have to contain at least one element
	JobInfo(context.Context, *JobInfoRequest) (*JobInfoResponse, error)
	// JobSteps returns information about each individual job step.
	JobSteps(context.Context, *JobStepsRequest) (*JobStepsResponse, error)
	// OpenFile opens a file and streams its content back. May be
	// useful for results collecting.
	OpenFile(*OpenFileRequest, WorkloadManager_OpenFileServer) error
	// TailFile opens a file and streams its content back. Unlike
	// OpenFile this call will watch file content changes and stream
	// new chunks continuously.
	TailFile(WorkloadManager_TailFileServer) error
}

type WorkloadManager_OpenFileClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type WorkloadManager_OpenFileServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type WorkloadManager_TailFileClient interface {
	Send(*TailFileRequest) error
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type WorkloadManager_TailFileServer interface {
	Send(*Chunk) error
	Recv() (*TailFileRequest, error)
	grpc.ServerStream
}