api

package
v1.0.0-alpha.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 18, 2019 License: Apache-2.0 Imports: 9 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source
var JobStatus_name = map[int32]string{
	0:  "COMPLETED",
	1:  "CANCELLED",
	2:  "FAILED",
	3:  "TIMEOUT",
	4:  "PENDING",
	10: "UNKNOWN",
}
View Source
var JobStatus_value = map[string]int32{
	"COMPLETED": 0,
	"CANCELLED": 1,
	"FAILED":    2,
	"TIMEOUT":   3,
	"PENDING":   4,
	"UNKNOWN":   10,
}
View Source
var TailAction_name = map[int32]string{
	0: "Start",
	1: "ReadToEndAndClose",
}
View Source
var TailAction_value = map[string]int32{
	"Start":             0,
	"ReadToEndAndClose": 1,
}

Functions

func RegisterWorkloadManagerServer

func RegisterWorkloadManagerServer(s *grpc.Server, srv WorkloadManagerServer)

Types

type CancelJobRequest

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:"-"`
}

func (*CancelJobRequest) Descriptor

func (*CancelJobRequest) Descriptor() ([]byte, []int)

func (*CancelJobRequest) GetJobId

func (m *CancelJobRequest) GetJobId() int64

func (*CancelJobRequest) ProtoMessage

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) Reset

func (m *CancelJobRequest) Reset()

func (*CancelJobRequest) String

func (m *CancelJobRequest) String() string

func (*CancelJobRequest) XXX_DiscardUnknown

func (m *CancelJobRequest) XXX_DiscardUnknown()

func (*CancelJobRequest) XXX_Marshal

func (m *CancelJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelJobRequest) XXX_Merge

func (m *CancelJobRequest) XXX_Merge(src proto.Message)

func (*CancelJobRequest) XXX_Size

func (m *CancelJobRequest) XXX_Size() int

func (*CancelJobRequest) XXX_Unmarshal

func (m *CancelJobRequest) XXX_Unmarshal(b []byte) error

type CancelJobResponse

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

func (*CancelJobResponse) Descriptor

func (*CancelJobResponse) Descriptor() ([]byte, []int)

func (*CancelJobResponse) ProtoMessage

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) Reset

func (m *CancelJobResponse) Reset()

func (*CancelJobResponse) String

func (m *CancelJobResponse) String() string

func (*CancelJobResponse) XXX_DiscardUnknown

func (m *CancelJobResponse) XXX_DiscardUnknown()

func (*CancelJobResponse) XXX_Marshal

func (m *CancelJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelJobResponse) XXX_Merge

func (m *CancelJobResponse) XXX_Merge(src proto.Message)

func (*CancelJobResponse) XXX_Size

func (m *CancelJobResponse) XXX_Size() int

func (*CancelJobResponse) XXX_Unmarshal

func (m *CancelJobResponse) XXX_Unmarshal(b []byte) error

type Chunk

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:"-"`
}

Chunk is an arbitrary amount of bytes.

func (*Chunk) Descriptor

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) GetContent

func (m *Chunk) GetContent() []byte

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) String

func (m *Chunk) String() string

func (*Chunk) XXX_DiscardUnknown

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal

func (m *Chunk) XXX_Unmarshal(b []byte) error

type Feature

type Feature struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Quantity             int64    `protobuf:"varint,3,opt,name=quantity,proto3" json:"quantity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Feature) Descriptor

func (*Feature) Descriptor() ([]byte, []int)

func (*Feature) GetName

func (m *Feature) GetName() string

func (*Feature) GetQuantity

func (m *Feature) GetQuantity() int64

func (*Feature) GetVersion

func (m *Feature) GetVersion() string

func (*Feature) ProtoMessage

func (*Feature) ProtoMessage()

func (*Feature) Reset

func (m *Feature) Reset()

func (*Feature) String

func (m *Feature) String() string

func (*Feature) XXX_DiscardUnknown

func (m *Feature) XXX_DiscardUnknown()

func (*Feature) XXX_Marshal

func (m *Feature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Feature) XXX_Merge

func (m *Feature) XXX_Merge(src proto.Message)

func (*Feature) XXX_Size

func (m *Feature) XXX_Size() int

func (*Feature) XXX_Unmarshal

func (m *Feature) XXX_Unmarshal(b []byte) error

type JobInfo

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:"-"`
}

JobInfo represents compete information about a single job.

func (*JobInfo) Descriptor

func (*JobInfo) Descriptor() ([]byte, []int)

func (*JobInfo) GetArrayId

func (m *JobInfo) GetArrayId() string

func (*JobInfo) GetBatchHost

func (m *JobInfo) GetBatchHost() string

func (*JobInfo) GetExitCode

func (m *JobInfo) GetExitCode() string

func (*JobInfo) GetId

func (m *JobInfo) GetId() string

func (*JobInfo) GetName

func (m *JobInfo) GetName() string

func (*JobInfo) GetNodeList

func (m *JobInfo) GetNodeList() string

func (*JobInfo) GetNumNodes

func (m *JobInfo) GetNumNodes() string

func (*JobInfo) GetPartition

func (m *JobInfo) GetPartition() string

func (*JobInfo) GetRunTime

func (m *JobInfo) GetRunTime() *duration.Duration

func (*JobInfo) GetStartTime

func (m *JobInfo) GetStartTime() *timestamp.Timestamp

func (*JobInfo) GetStatus

func (m *JobInfo) GetStatus() JobStatus

func (*JobInfo) GetStdErr

func (m *JobInfo) GetStdErr() string

func (*JobInfo) GetStdOut

func (m *JobInfo) GetStdOut() string

func (*JobInfo) GetSubmitTime

func (m *JobInfo) GetSubmitTime() *timestamp.Timestamp

func (*JobInfo) GetTimeLimit

func (m *JobInfo) GetTimeLimit() *duration.Duration

func (*JobInfo) GetUserId

func (m *JobInfo) GetUserId() string

func (*JobInfo) GetWorkingDir

func (m *JobInfo) GetWorkingDir() string

func (*JobInfo) ProtoMessage

func (*JobInfo) ProtoMessage()

func (*JobInfo) Reset

func (m *JobInfo) Reset()

func (*JobInfo) String

func (m *JobInfo) String() string

func (*JobInfo) XXX_DiscardUnknown

func (m *JobInfo) XXX_DiscardUnknown()

func (*JobInfo) XXX_Marshal

func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfo) XXX_Merge

func (m *JobInfo) XXX_Merge(src proto.Message)

func (*JobInfo) XXX_Size

func (m *JobInfo) XXX_Size() int

func (*JobInfo) XXX_Unmarshal

func (m *JobInfo) XXX_Unmarshal(b []byte) error

type JobInfoRequest

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:"-"`
}

func (*JobInfoRequest) Descriptor

func (*JobInfoRequest) Descriptor() ([]byte, []int)

func (*JobInfoRequest) GetJobId

func (m *JobInfoRequest) GetJobId() int64

func (*JobInfoRequest) ProtoMessage

func (*JobInfoRequest) ProtoMessage()

func (*JobInfoRequest) Reset

func (m *JobInfoRequest) Reset()

func (*JobInfoRequest) String

func (m *JobInfoRequest) String() string

func (*JobInfoRequest) XXX_DiscardUnknown

func (m *JobInfoRequest) XXX_DiscardUnknown()

func (*JobInfoRequest) XXX_Marshal

func (m *JobInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfoRequest) XXX_Merge

func (m *JobInfoRequest) XXX_Merge(src proto.Message)

func (*JobInfoRequest) XXX_Size

func (m *JobInfoRequest) XXX_Size() int

func (*JobInfoRequest) XXX_Unmarshal

func (m *JobInfoRequest) XXX_Unmarshal(b []byte) error

type JobInfoResponse

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:"-"`
}

func (*JobInfoResponse) Descriptor

func (*JobInfoResponse) Descriptor() ([]byte, []int)

func (*JobInfoResponse) GetInfo

func (m *JobInfoResponse) GetInfo() []*JobInfo

func (*JobInfoResponse) ProtoMessage

func (*JobInfoResponse) ProtoMessage()

func (*JobInfoResponse) Reset

func (m *JobInfoResponse) Reset()

func (*JobInfoResponse) String

func (m *JobInfoResponse) String() string

func (*JobInfoResponse) XXX_DiscardUnknown

func (m *JobInfoResponse) XXX_DiscardUnknown()

func (*JobInfoResponse) XXX_Marshal

func (m *JobInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfoResponse) XXX_Merge

func (m *JobInfoResponse) XXX_Merge(src proto.Message)

func (*JobInfoResponse) XXX_Size

func (m *JobInfoResponse) XXX_Size() int

func (*JobInfoResponse) XXX_Unmarshal

func (m *JobInfoResponse) XXX_Unmarshal(b []byte) error

type JobStatus

type JobStatus int32
const (
	JobStatus_COMPLETED JobStatus = 0
	JobStatus_CANCELLED JobStatus = 1
	JobStatus_FAILED    JobStatus = 2
	JobStatus_TIMEOUT   JobStatus = 3
	JobStatus_PENDING   JobStatus = 4
	JobStatus_UNKNOWN   JobStatus = 10
)

func (JobStatus) EnumDescriptor

func (JobStatus) EnumDescriptor() ([]byte, []int)

func (JobStatus) String

func (x JobStatus) String() string

type JobStepInfo

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:"-"`
}

JobStepInfo represents information about a single job step.

func (*JobStepInfo) Descriptor

func (*JobStepInfo) Descriptor() ([]byte, []int)

func (*JobStepInfo) GetEndTime

func (m *JobStepInfo) GetEndTime() *timestamp.Timestamp

func (*JobStepInfo) GetExitCode

func (m *JobStepInfo) GetExitCode() int32

func (*JobStepInfo) GetId

func (m *JobStepInfo) GetId() string

func (*JobStepInfo) GetName

func (m *JobStepInfo) GetName() string

func (*JobStepInfo) GetStartTime

func (m *JobStepInfo) GetStartTime() *timestamp.Timestamp

func (*JobStepInfo) GetStatus

func (m *JobStepInfo) GetStatus() JobStatus

func (*JobStepInfo) ProtoMessage

func (*JobStepInfo) ProtoMessage()

func (*JobStepInfo) Reset

func (m *JobStepInfo) Reset()

func (*JobStepInfo) String

func (m *JobStepInfo) String() string

func (*JobStepInfo) XXX_DiscardUnknown

func (m *JobStepInfo) XXX_DiscardUnknown()

func (*JobStepInfo) XXX_Marshal

func (m *JobStepInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStepInfo) XXX_Merge

func (m *JobStepInfo) XXX_Merge(src proto.Message)

func (*JobStepInfo) XXX_Size

func (m *JobStepInfo) XXX_Size() int

func (*JobStepInfo) XXX_Unmarshal

func (m *JobStepInfo) XXX_Unmarshal(b []byte) error

type JobStepsRequest

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:"-"`
}

func (*JobStepsRequest) Descriptor

func (*JobStepsRequest) Descriptor() ([]byte, []int)

func (*JobStepsRequest) GetJobId

func (m *JobStepsRequest) GetJobId() int64

func (*JobStepsRequest) ProtoMessage

func (*JobStepsRequest) ProtoMessage()

func (*JobStepsRequest) Reset

func (m *JobStepsRequest) Reset()

func (*JobStepsRequest) String

func (m *JobStepsRequest) String() string

func (*JobStepsRequest) XXX_DiscardUnknown

func (m *JobStepsRequest) XXX_DiscardUnknown()

func (*JobStepsRequest) XXX_Marshal

func (m *JobStepsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStepsRequest) XXX_Merge

func (m *JobStepsRequest) XXX_Merge(src proto.Message)

func (*JobStepsRequest) XXX_Size

func (m *JobStepsRequest) XXX_Size() int

func (*JobStepsRequest) XXX_Unmarshal

func (m *JobStepsRequest) XXX_Unmarshal(b []byte) error

type JobStepsResponse

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:"-"`
}

func (*JobStepsResponse) Descriptor

func (*JobStepsResponse) Descriptor() ([]byte, []int)

func (*JobStepsResponse) GetJobSteps

func (m *JobStepsResponse) GetJobSteps() []*JobStepInfo

func (*JobStepsResponse) ProtoMessage

func (*JobStepsResponse) ProtoMessage()

func (*JobStepsResponse) Reset

func (m *JobStepsResponse) Reset()

func (*JobStepsResponse) String

func (m *JobStepsResponse) String() string

func (*JobStepsResponse) XXX_DiscardUnknown

func (m *JobStepsResponse) XXX_DiscardUnknown()

func (*JobStepsResponse) XXX_Marshal

func (m *JobStepsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStepsResponse) XXX_Merge

func (m *JobStepsResponse) XXX_Merge(src proto.Message)

func (*JobStepsResponse) XXX_Size

func (m *JobStepsResponse) XXX_Size() int

func (*JobStepsResponse) XXX_Unmarshal

func (m *JobStepsResponse) XXX_Unmarshal(b []byte) error

type OpenFileRequest

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:"-"`
}

func (*OpenFileRequest) Descriptor

func (*OpenFileRequest) Descriptor() ([]byte, []int)

func (*OpenFileRequest) GetPath

func (m *OpenFileRequest) GetPath() string

func (*OpenFileRequest) ProtoMessage

func (*OpenFileRequest) ProtoMessage()

func (*OpenFileRequest) Reset

func (m *OpenFileRequest) Reset()

func (*OpenFileRequest) String

func (m *OpenFileRequest) String() string

func (*OpenFileRequest) XXX_DiscardUnknown

func (m *OpenFileRequest) XXX_DiscardUnknown()

func (*OpenFileRequest) XXX_Marshal

func (m *OpenFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenFileRequest) XXX_Merge

func (m *OpenFileRequest) XXX_Merge(src proto.Message)

func (*OpenFileRequest) XXX_Size

func (m *OpenFileRequest) XXX_Size() int

func (*OpenFileRequest) XXX_Unmarshal

func (m *OpenFileRequest) XXX_Unmarshal(b []byte) error

type PartitionsRequest

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

func (*PartitionsRequest) Descriptor

func (*PartitionsRequest) Descriptor() ([]byte, []int)

func (*PartitionsRequest) ProtoMessage

func (*PartitionsRequest) ProtoMessage()

func (*PartitionsRequest) Reset

func (m *PartitionsRequest) Reset()

func (*PartitionsRequest) String

func (m *PartitionsRequest) String() string

func (*PartitionsRequest) XXX_DiscardUnknown

func (m *PartitionsRequest) XXX_DiscardUnknown()

func (*PartitionsRequest) XXX_Marshal

func (m *PartitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionsRequest) XXX_Merge

func (m *PartitionsRequest) XXX_Merge(src proto.Message)

func (*PartitionsRequest) XXX_Size

func (m *PartitionsRequest) XXX_Size() int

func (*PartitionsRequest) XXX_Unmarshal

func (m *PartitionsRequest) XXX_Unmarshal(b []byte) error

type PartitionsResponse

type PartitionsResponse struct {
	Partition            []string `protobuf:"bytes,1,rep,name=partition,proto3" json:"partition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionsResponse) Descriptor

func (*PartitionsResponse) Descriptor() ([]byte, []int)

func (*PartitionsResponse) GetPartition

func (m *PartitionsResponse) GetPartition() []string

func (*PartitionsResponse) ProtoMessage

func (*PartitionsResponse) ProtoMessage()

func (*PartitionsResponse) Reset

func (m *PartitionsResponse) Reset()

func (*PartitionsResponse) String

func (m *PartitionsResponse) String() string

func (*PartitionsResponse) XXX_DiscardUnknown

func (m *PartitionsResponse) XXX_DiscardUnknown()

func (*PartitionsResponse) XXX_Marshal

func (m *PartitionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionsResponse) XXX_Merge

func (m *PartitionsResponse) XXX_Merge(src proto.Message)

func (*PartitionsResponse) XXX_Size

func (m *PartitionsResponse) XXX_Size() int

func (*PartitionsResponse) XXX_Unmarshal

func (m *PartitionsResponse) XXX_Unmarshal(b []byte) error

type ResourcesRequest

type ResourcesRequest struct {
	// Partition which resources should be returned.
	Partition            string   `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResourcesRequest) Descriptor

func (*ResourcesRequest) Descriptor() ([]byte, []int)

func (*ResourcesRequest) GetPartition

func (m *ResourcesRequest) GetPartition() string

func (*ResourcesRequest) ProtoMessage

func (*ResourcesRequest) ProtoMessage()

func (*ResourcesRequest) Reset

func (m *ResourcesRequest) Reset()

func (*ResourcesRequest) String

func (m *ResourcesRequest) String() string

func (*ResourcesRequest) XXX_DiscardUnknown

func (m *ResourcesRequest) XXX_DiscardUnknown()

func (*ResourcesRequest) XXX_Marshal

func (m *ResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourcesRequest) XXX_Merge

func (m *ResourcesRequest) XXX_Merge(src proto.Message)

func (*ResourcesRequest) XXX_Size

func (m *ResourcesRequest) XXX_Size() int

func (*ResourcesRequest) XXX_Unmarshal

func (m *ResourcesRequest) XXX_Unmarshal(b []byte) error

type ResourcesResponse

type ResourcesResponse struct {
	// Number of nodes in the partition.
	Nodes int64 `protobuf:"varint,1,opt,name=nodes,proto3" json:"nodes,omitempty"`
	// Number of cpus on each node.
	CpuPerNode int64 `protobuf:"varint,2,opt,name=cpuPerNode,proto3" json:"cpuPerNode,omitempty"`
	// Amount of memory on each node.
	MemPerNode int64 `protobuf:"varint,3,opt,name=memPerNode,proto3" json:"memPerNode,omitempty"`
	// Wall time setting for the partition.
	WallTime int64 `protobuf:"varint,4,opt,name=wallTime,proto3" json:"wallTime,omitempty"`
	// Set of features of the partition.
	Features             []*Feature `protobuf:"bytes,5,rep,name=features,proto3" json:"features,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ResourcesResponse) Descriptor

func (*ResourcesResponse) Descriptor() ([]byte, []int)

func (*ResourcesResponse) GetCpuPerNode

func (m *ResourcesResponse) GetCpuPerNode() int64

func (*ResourcesResponse) GetFeatures

func (m *ResourcesResponse) GetFeatures() []*Feature

func (*ResourcesResponse) GetMemPerNode

func (m *ResourcesResponse) GetMemPerNode() int64

func (*ResourcesResponse) GetNodes

func (m *ResourcesResponse) GetNodes() int64

func (*ResourcesResponse) GetWallTime

func (m *ResourcesResponse) GetWallTime() int64

func (*ResourcesResponse) ProtoMessage

func (*ResourcesResponse) ProtoMessage()

func (*ResourcesResponse) Reset

func (m *ResourcesResponse) Reset()

func (*ResourcesResponse) String

func (m *ResourcesResponse) String() string

func (*ResourcesResponse) XXX_DiscardUnknown

func (m *ResourcesResponse) XXX_DiscardUnknown()

func (*ResourcesResponse) XXX_Marshal

func (m *ResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourcesResponse) XXX_Merge

func (m *ResourcesResponse) XXX_Merge(src proto.Message)

func (*ResourcesResponse) XXX_Size

func (m *ResourcesResponse) XXX_Size() int

func (*ResourcesResponse) XXX_Unmarshal

func (m *ResourcesResponse) XXX_Unmarshal(b []byte) error

type SubmitJobRequest

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"`
	// Partition where job should be submitted.
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// ID of a client who submitted this job.
	ClientId             string   `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitJobRequest) Descriptor

func (*SubmitJobRequest) Descriptor() ([]byte, []int)

func (*SubmitJobRequest) GetClientId

func (m *SubmitJobRequest) GetClientId() string

func (*SubmitJobRequest) GetPartition

func (m *SubmitJobRequest) GetPartition() string

func (*SubmitJobRequest) GetScript

func (m *SubmitJobRequest) GetScript() string

func (*SubmitJobRequest) ProtoMessage

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) Reset

func (m *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String

func (m *SubmitJobRequest) String() string

func (*SubmitJobRequest) XXX_DiscardUnknown

func (m *SubmitJobRequest) XXX_DiscardUnknown()

func (*SubmitJobRequest) XXX_Marshal

func (m *SubmitJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubmitJobRequest) XXX_Merge

func (m *SubmitJobRequest) XXX_Merge(src proto.Message)

func (*SubmitJobRequest) XXX_Size

func (m *SubmitJobRequest) XXX_Size() int

func (*SubmitJobRequest) XXX_Unmarshal

func (m *SubmitJobRequest) XXX_Unmarshal(b []byte) error

type SubmitJobResponse

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:"-"`
}

func (*SubmitJobResponse) Descriptor

func (*SubmitJobResponse) Descriptor() ([]byte, []int)

func (*SubmitJobResponse) GetJobId

func (m *SubmitJobResponse) GetJobId() int64

func (*SubmitJobResponse) ProtoMessage

func (*SubmitJobResponse) ProtoMessage()

func (*SubmitJobResponse) Reset

func (m *SubmitJobResponse) Reset()

func (*SubmitJobResponse) String

func (m *SubmitJobResponse) String() string

func (*SubmitJobResponse) XXX_DiscardUnknown

func (m *SubmitJobResponse) XXX_DiscardUnknown()

func (*SubmitJobResponse) XXX_Marshal

func (m *SubmitJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubmitJobResponse) XXX_Merge

func (m *SubmitJobResponse) XXX_Merge(src proto.Message)

func (*SubmitJobResponse) XXX_Size

func (m *SubmitJobResponse) XXX_Size() int

func (*SubmitJobResponse) XXX_Unmarshal

func (m *SubmitJobResponse) XXX_Unmarshal(b []byte) error

type TailAction

type TailAction int32
const (
	TailAction_Start             TailAction = 0
	TailAction_ReadToEndAndClose TailAction = 1
)

func (TailAction) EnumDescriptor

func (TailAction) EnumDescriptor() ([]byte, []int)

func (TailAction) String

func (x TailAction) String() string

type TailFileRequest

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:"-"`
}

func (*TailFileRequest) Descriptor

func (*TailFileRequest) Descriptor() ([]byte, []int)

func (*TailFileRequest) GetAction

func (m *TailFileRequest) GetAction() TailAction

func (*TailFileRequest) GetPath

func (m *TailFileRequest) GetPath() string

func (*TailFileRequest) ProtoMessage

func (*TailFileRequest) ProtoMessage()

func (*TailFileRequest) Reset

func (m *TailFileRequest) Reset()

func (*TailFileRequest) String

func (m *TailFileRequest) String() string

func (*TailFileRequest) XXX_DiscardUnknown

func (m *TailFileRequest) XXX_DiscardUnknown()

func (*TailFileRequest) XXX_Marshal

func (m *TailFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TailFileRequest) XXX_Merge

func (m *TailFileRequest) XXX_Merge(src proto.Message)

func (*TailFileRequest) XXX_Size

func (m *TailFileRequest) XXX_Size() int

func (*TailFileRequest) XXX_Unmarshal

func (m *TailFileRequest) XXX_Unmarshal(b []byte) error

type UnimplementedWorkloadManagerServer

type UnimplementedWorkloadManagerServer struct {
}

UnimplementedWorkloadManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkloadManagerServer) CancelJob

func (*UnimplementedWorkloadManagerServer) JobInfo

func (*UnimplementedWorkloadManagerServer) JobSteps

func (*UnimplementedWorkloadManagerServer) OpenFile

func (*UnimplementedWorkloadManagerServer) Partitions

func (*UnimplementedWorkloadManagerServer) Resources

func (*UnimplementedWorkloadManagerServer) SubmitJob

func (*UnimplementedWorkloadManagerServer) TailFile

type WorkloadManagerClient

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)
	// Resources returns partition resources
	// nodes, cpu, mem, wall-time and available features
	Resources(ctx context.Context, in *ResourcesRequest, opts ...grpc.CallOption) (*ResourcesResponse, error)
	// Partitions returns a list of available partitions.
	Partitions(ctx context.Context, in *PartitionsRequest, opts ...grpc.CallOption) (*PartitionsResponse, error)
}

WorkloadManagerClient is the client API for WorkloadManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkloadManagerClient

func NewWorkloadManagerClient(cc *grpc.ClientConn) WorkloadManagerClient

type WorkloadManagerServer

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
	// Resources returns partition resources
	// nodes, cpu, mem, wall-time and available features
	Resources(context.Context, *ResourcesRequest) (*ResourcesResponse, error)
	// Partitions returns a list of available partitions.
	Partitions(context.Context, *PartitionsRequest) (*PartitionsResponse, error)
}

WorkloadManagerServer is the server API for WorkloadManager service.

type WorkloadManager_OpenFileClient

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

type WorkloadManager_OpenFileServer

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

type WorkloadManager_TailFileClient

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

type WorkloadManager_TailFileServer

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL