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: May 21, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var JobStatus_name = map[int32]string{
	0: "COMPLETED",
	1: "CANCELLED",
	2: "FAILED",
	3: "UNKNOWN",
}
View Source 
var JobStatus_value = map[string]int32{
	"COMPLETED": 0,
	"CANCELLED": 1,
	"FAILED":    2,
	"UNKNOWN":   3,
}
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 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_UNKNOWN   JobStatus = 3
)

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitJobRequest) Descriptor 

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

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) CancelJob(ctx context.Context, req *CancelJobRequest) (*CancelJobResponse, error)

func (*UnimplementedWorkloadManagerServer) JobInfo 

func (*UnimplementedWorkloadManagerServer) JobInfo(ctx context.Context, req *JobInfoRequest) (*JobInfoResponse, error)

func (*UnimplementedWorkloadManagerServer) JobSteps 

func (*UnimplementedWorkloadManagerServer) JobSteps(ctx context.Context, req *JobStepsRequest) (*JobStepsResponse, error)

func (*UnimplementedWorkloadManagerServer) OpenFile 

func (*UnimplementedWorkloadManagerServer) OpenFile(req *OpenFileRequest, srv WorkloadManager_OpenFileServer) error

func (*UnimplementedWorkloadManagerServer) SubmitJob 

func (*UnimplementedWorkloadManagerServer) SubmitJob(ctx context.Context, req *SubmitJobRequest) (*SubmitJobResponse, error)

func (*UnimplementedWorkloadManagerServer) TailFile 

func (*UnimplementedWorkloadManagerServer) TailFile(srv WorkloadManager_TailFileServer) error

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)
}

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
}

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.