Documentation ¶
Index ¶
- Variables
- func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
- type Empty
- type ExecutorClient
- type ExecutorServer
- type Executor_ExecStreamClient
- type Executor_ExecStreamServer
- type FileContent
- func (*FileContent) Descriptor() ([]byte, []int)deprecated
- func (x *FileContent) GetContent() []byte
- func (x *FileContent) GetName() string
- func (*FileContent) ProtoMessage()
- func (x *FileContent) ProtoReflect() protoreflect.Message
- func (x *FileContent) Reset()
- func (x *FileContent) String() string
- type FileID
- type FileListType
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetCmd() []*Request_CmdType
- func (x *Request) GetPipeMapping() []*Request_PipeMap
- func (x *Request) GetRequestID() string
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Request_CachedFile
- func (*Request_CachedFile) Descriptor() ([]byte, []int)deprecated
- func (x *Request_CachedFile) GetFileID() string
- func (*Request_CachedFile) ProtoMessage()
- func (x *Request_CachedFile) ProtoReflect() protoreflect.Message
- func (x *Request_CachedFile) Reset()
- func (x *Request_CachedFile) String() string
- type Request_CmdType
- func (*Request_CmdType) Descriptor() ([]byte, []int)deprecated
- func (x *Request_CmdType) GetArgs() []string
- func (x *Request_CmdType) GetCPULimit() uint64
- func (x *Request_CmdType) GetCopyIn() map[string]*Request_File
- func (x *Request_CmdType) GetCopyOut() []string
- func (x *Request_CmdType) GetCopyOutCached() []string
- func (x *Request_CmdType) GetCopyOutDir() string
- func (x *Request_CmdType) GetCopyOutMax() uint64
- func (x *Request_CmdType) GetEnv() []string
- func (x *Request_CmdType) GetFiles() []*Request_File
- func (x *Request_CmdType) GetMemoryLimit() uint64
- func (x *Request_CmdType) GetProcLimit() uint64
- func (x *Request_CmdType) GetRealCPULimit() uint64
- func (x *Request_CmdType) GetStackLimit() uint64
- func (x *Request_CmdType) GetTty() bool
- func (*Request_CmdType) ProtoMessage()
- func (x *Request_CmdType) ProtoReflect() protoreflect.Message
- func (x *Request_CmdType) Reset()
- func (x *Request_CmdType) String() string
- type Request_File
- func (*Request_File) Descriptor() ([]byte, []int)deprecated
- func (x *Request_File) GetCached() *Request_CachedFile
- func (m *Request_File) GetFile() isRequest_File_File
- func (x *Request_File) GetLocal() *Request_LocalFile
- func (x *Request_File) GetMemory() *Request_MemoryFile
- func (x *Request_File) GetPipe() *Request_PipeCollector
- func (x *Request_File) GetStreamIn() *Request_StreamInput
- func (x *Request_File) GetStreamOut() *Request_StreamOutput
- func (*Request_File) ProtoMessage()
- func (x *Request_File) ProtoReflect() protoreflect.Message
- func (x *Request_File) Reset()
- func (x *Request_File) String() string
- type Request_File_Cached
- type Request_File_Local
- type Request_File_Memory
- type Request_File_Pipe
- type Request_File_StreamIn
- type Request_File_StreamOut
- type Request_LocalFile
- type Request_MemoryFile
- func (*Request_MemoryFile) Descriptor() ([]byte, []int)deprecated
- func (x *Request_MemoryFile) GetContent() []byte
- func (*Request_MemoryFile) ProtoMessage()
- func (x *Request_MemoryFile) ProtoReflect() protoreflect.Message
- func (x *Request_MemoryFile) Reset()
- func (x *Request_MemoryFile) String() string
- type Request_PipeCollector
- func (*Request_PipeCollector) Descriptor() ([]byte, []int)deprecated
- func (x *Request_PipeCollector) GetMax() int64
- func (x *Request_PipeCollector) GetName() string
- func (*Request_PipeCollector) ProtoMessage()
- func (x *Request_PipeCollector) ProtoReflect() protoreflect.Message
- func (x *Request_PipeCollector) Reset()
- func (x *Request_PipeCollector) String() string
- type Request_PipeMap
- func (*Request_PipeMap) Descriptor() ([]byte, []int)deprecated
- func (x *Request_PipeMap) GetIn() *Request_PipeMap_PipeIndex
- func (x *Request_PipeMap) GetOut() *Request_PipeMap_PipeIndex
- func (*Request_PipeMap) ProtoMessage()
- func (x *Request_PipeMap) ProtoReflect() protoreflect.Message
- func (x *Request_PipeMap) Reset()
- func (x *Request_PipeMap) String() string
- type Request_PipeMap_PipeIndex
- func (*Request_PipeMap_PipeIndex) Descriptor() ([]byte, []int)deprecated
- func (x *Request_PipeMap_PipeIndex) GetFd() int32
- func (x *Request_PipeMap_PipeIndex) GetIndex() int32
- func (*Request_PipeMap_PipeIndex) ProtoMessage()
- func (x *Request_PipeMap_PipeIndex) ProtoReflect() protoreflect.Message
- func (x *Request_PipeMap_PipeIndex) Reset()
- func (x *Request_PipeMap_PipeIndex) String() string
- type Request_StreamInput
- func (*Request_StreamInput) Descriptor() ([]byte, []int)deprecated
- func (x *Request_StreamInput) GetName() string
- func (x *Request_StreamInput) GetTty() bool
- func (*Request_StreamInput) ProtoMessage()
- func (x *Request_StreamInput) ProtoReflect() protoreflect.Message
- func (x *Request_StreamInput) Reset()
- func (x *Request_StreamInput) String() string
- type Request_StreamOutput
- func (*Request_StreamOutput) Descriptor() ([]byte, []int)deprecated
- func (x *Request_StreamOutput) GetName() string
- func (*Request_StreamOutput) ProtoMessage()
- func (x *Request_StreamOutput) ProtoReflect() protoreflect.Message
- func (x *Request_StreamOutput) Reset()
- func (x *Request_StreamOutput) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetError() string
- func (x *Response) GetRequestID() string
- func (x *Response) GetResults() []*Response_Result
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type Response_Result
- func (*Response_Result) Descriptor() ([]byte, []int)deprecated
- func (x *Response_Result) GetError() string
- func (x *Response_Result) GetExitStatus() int32
- func (x *Response_Result) GetFileIDs() map[string]string
- func (x *Response_Result) GetFiles() map[string][]byte
- func (x *Response_Result) GetMemory() uint64
- func (x *Response_Result) GetRunTime() uint64
- func (x *Response_Result) GetStatus() Response_Result_StatusType
- func (x *Response_Result) GetTime() uint64
- func (*Response_Result) ProtoMessage()
- func (x *Response_Result) ProtoReflect() protoreflect.Message
- func (x *Response_Result) Reset()
- func (x *Response_Result) String() string
- type Response_Result_StatusType
- func (Response_Result_StatusType) Descriptor() protoreflect.EnumDescriptor
- func (x Response_Result_StatusType) Enum() *Response_Result_StatusType
- func (Response_Result_StatusType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Response_Result_StatusType) Number() protoreflect.EnumNumber
- func (x Response_Result_StatusType) String() string
- func (Response_Result_StatusType) Type() protoreflect.EnumType
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetExecInput() *StreamRequest_Input
- func (x *StreamRequest) GetExecRequest() *Request
- func (x *StreamRequest) GetExecResize() *StreamRequest_Resize
- func (m *StreamRequest) GetRequest() isStreamRequest_Request
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamRequest_ExecInput
- type StreamRequest_ExecRequest
- type StreamRequest_ExecResize
- type StreamRequest_Input
- func (*StreamRequest_Input) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest_Input) GetContent() []byte
- func (x *StreamRequest_Input) GetName() string
- func (*StreamRequest_Input) ProtoMessage()
- func (x *StreamRequest_Input) ProtoReflect() protoreflect.Message
- func (x *StreamRequest_Input) Reset()
- func (x *StreamRequest_Input) String() string
- type StreamRequest_Resize
- func (*StreamRequest_Resize) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest_Resize) GetCols() uint32
- func (x *StreamRequest_Resize) GetName() string
- func (x *StreamRequest_Resize) GetRows() uint32
- func (x *StreamRequest_Resize) GetX() uint32
- func (x *StreamRequest_Resize) GetY() uint32
- func (*StreamRequest_Resize) ProtoMessage()
- func (x *StreamRequest_Resize) ProtoReflect() protoreflect.Message
- func (x *StreamRequest_Resize) Reset()
- func (x *StreamRequest_Resize) String() string
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResponse) GetExecOutput() *StreamResponse_Output
- func (x *StreamResponse) GetExecResponse() *Response
- func (m *StreamResponse) GetResponse() isStreamResponse_Response
- func (*StreamResponse) ProtoMessage()
- func (x *StreamResponse) ProtoReflect() protoreflect.Message
- func (x *StreamResponse) Reset()
- func (x *StreamResponse) String() string
- type StreamResponse_ExecOutput
- type StreamResponse_ExecResponse
- type StreamResponse_Output
- func (*StreamResponse_Output) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResponse_Output) GetContent() []byte
- func (x *StreamResponse_Output) GetName() string
- func (*StreamResponse_Output) ProtoMessage()
- func (x *StreamResponse_Output) ProtoReflect() protoreflect.Message
- func (x *StreamResponse_Output) Reset()
- func (x *StreamResponse_Output) String() string
- type UnimplementedExecutorServer
- func (*UnimplementedExecutorServer) Exec(context.Context, *Request) (*Response, error)
- func (*UnimplementedExecutorServer) ExecStream(Executor_ExecStreamServer) error
- func (*UnimplementedExecutorServer) FileAdd(context.Context, *FileContent) (*FileID, error)
- func (*UnimplementedExecutorServer) FileDelete(context.Context, *FileID) (*Empty, error)
- func (*UnimplementedExecutorServer) FileGet(context.Context, *FileID) (*FileContent, error)
- func (*UnimplementedExecutorServer) FileList(context.Context, *Empty) (*FileListType, error)
Constants ¶
This section is empty.
Variables ¶
var ( Response_Result_StatusType_name = map[int32]string{ 0: "Invalid", 1: "Accepted", 2: "WrongAnswer", 3: "PartiallyCorrect", 4: "MemoryLimitExceeded", 5: "TimeLimitExceeded", 6: "OutputLimitExceeded", 7: "FileError", 8: "NonZeroExitStatus", 9: "Signalled", 10: "DangerousSyscall", 11: "JudgementFailed", 12: "InvalidInteraction", 13: "InternalError", } Response_Result_StatusType_value = map[string]int32{ "Invalid": 0, "Accepted": 1, "WrongAnswer": 2, "PartiallyCorrect": 3, "MemoryLimitExceeded": 4, "TimeLimitExceeded": 5, "OutputLimitExceeded": 6, "FileError": 7, "NonZeroExitStatus": 8, "Signalled": 9, "DangerousSyscall": 10, "JudgementFailed": 11, "InvalidInteraction": 12, "InternalError": 13, } )
Enum value maps for Response_Result_StatusType.
var File_judge_proto protoreflect.FileDescriptor
Functions ¶
func RegisterExecutorServer ¶
func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
Types ¶
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type ExecutorClient ¶
type ExecutorClient interface { // Exec defines unary RPC to run a program with resource limitations Exec(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) // ExecStream defines streaming RPC to run a program with real-time input & // output. The first request must be execRequest and the following request // must be execInput. The last response must be execResponse and the others // are execOutput. TTY attribute will create single pty for the program thus // stdout & stderr should have same name ExecStream(ctx context.Context, opts ...grpc.CallOption) (Executor_ExecStreamClient, error) // FileList lists all files avaliable in the file store FileList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*FileListType, error) // FileGet download the file from the file store FileGet(ctx context.Context, in *FileID, opts ...grpc.CallOption) (*FileContent, error) // FileAdd create a file into the file store FileAdd(ctx context.Context, in *FileContent, opts ...grpc.CallOption) (*FileID, error) // FileDelete deletes a file from the file store FileDelete(ctx context.Context, in *FileID, opts ...grpc.CallOption) (*Empty, error) }
ExecutorClient is the client API for Executor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExecutorClient ¶
func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient
type ExecutorServer ¶
type ExecutorServer interface { // Exec defines unary RPC to run a program with resource limitations Exec(context.Context, *Request) (*Response, error) // ExecStream defines streaming RPC to run a program with real-time input & // output. The first request must be execRequest and the following request // must be execInput. The last response must be execResponse and the others // are execOutput. TTY attribute will create single pty for the program thus // stdout & stderr should have same name ExecStream(Executor_ExecStreamServer) error // FileList lists all files avaliable in the file store FileList(context.Context, *Empty) (*FileListType, error) // FileGet download the file from the file store FileGet(context.Context, *FileID) (*FileContent, error) // FileAdd create a file into the file store FileAdd(context.Context, *FileContent) (*FileID, error) // FileDelete deletes a file from the file store FileDelete(context.Context, *FileID) (*Empty, error) }
ExecutorServer is the server API for Executor service.
type Executor_ExecStreamClient ¶ added in v0.5.2
type Executor_ExecStreamClient interface { Send(*StreamRequest) error Recv() (*StreamResponse, error) grpc.ClientStream }
type Executor_ExecStreamServer ¶ added in v0.5.2
type Executor_ExecStreamServer interface { Send(*StreamResponse) error Recv() (*StreamRequest, error) grpc.ServerStream }
type FileContent ¶
type FileContent struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*FileContent) Descriptor
deprecated
func (*FileContent) Descriptor() ([]byte, []int)
Deprecated: Use FileContent.ProtoReflect.Descriptor instead.
func (*FileContent) GetContent ¶
func (x *FileContent) GetContent() []byte
func (*FileContent) GetName ¶
func (x *FileContent) GetName() string
func (*FileContent) ProtoMessage ¶
func (*FileContent) ProtoMessage()
func (*FileContent) ProtoReflect ¶
func (x *FileContent) ProtoReflect() protoreflect.Message
func (*FileContent) Reset ¶
func (x *FileContent) Reset()
func (*FileContent) String ¶
func (x *FileContent) String() string
type FileID ¶
type FileID struct { FileID string `protobuf:"bytes,1,opt,name=fileID,proto3" json:"fileID,omitempty"` // contains filtered or unexported fields }
func (*FileID) Descriptor
deprecated
func (*FileID) ProtoMessage ¶
func (*FileID) ProtoMessage()
func (*FileID) ProtoReflect ¶
func (x *FileID) ProtoReflect() protoreflect.Message
type FileListType ¶
type FileListType struct { FileIDs []string `protobuf:"bytes,1,rep,name=fileIDs,proto3" json:"fileIDs,omitempty"` // contains filtered or unexported fields }
func (*FileListType) Descriptor
deprecated
func (*FileListType) Descriptor() ([]byte, []int)
Deprecated: Use FileListType.ProtoReflect.Descriptor instead.
func (*FileListType) GetFileIDs ¶
func (x *FileListType) GetFileIDs() []string
func (*FileListType) ProtoMessage ¶
func (*FileListType) ProtoMessage()
func (*FileListType) ProtoReflect ¶
func (x *FileListType) ProtoReflect() protoreflect.Message
func (*FileListType) Reset ¶
func (x *FileListType) Reset()
func (*FileListType) String ¶
func (x *FileListType) String() string
type Request ¶
type Request struct { RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"` Cmd []*Request_CmdType `protobuf:"bytes,2,rep,name=cmd,proto3" json:"cmd,omitempty"` PipeMapping []*Request_PipeMap `protobuf:"bytes,3,rep,name=pipeMapping,proto3" json:"pipeMapping,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetCmd ¶
func (x *Request) GetCmd() []*Request_CmdType
func (*Request) GetPipeMapping ¶
func (x *Request) GetPipeMapping() []*Request_PipeMap
func (*Request) GetRequestID ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Request_CachedFile ¶
type Request_CachedFile struct { FileID string `protobuf:"bytes,1,opt,name=fileID,proto3" json:"fileID,omitempty"` // contains filtered or unexported fields }
func (*Request_CachedFile) Descriptor
deprecated
func (*Request_CachedFile) Descriptor() ([]byte, []int)
Deprecated: Use Request_CachedFile.ProtoReflect.Descriptor instead.
func (*Request_CachedFile) GetFileID ¶
func (x *Request_CachedFile) GetFileID() string
func (*Request_CachedFile) ProtoMessage ¶
func (*Request_CachedFile) ProtoMessage()
func (*Request_CachedFile) ProtoReflect ¶
func (x *Request_CachedFile) ProtoReflect() protoreflect.Message
func (*Request_CachedFile) Reset ¶
func (x *Request_CachedFile) Reset()
func (*Request_CachedFile) String ¶
func (x *Request_CachedFile) String() string
type Request_CmdType ¶
type Request_CmdType struct { Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"` Env []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"` Files []*Request_File `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"` Tty bool `protobuf:"varint,13,opt,name=tty,proto3" json:"tty,omitempty"` CPULimit uint64 `protobuf:"varint,4,opt,name=CPULimit,proto3" json:"CPULimit,omitempty"` RealCPULimit uint64 `protobuf:"varint,5,opt,name=realCPULimit,proto3" json:"realCPULimit,omitempty"` MemoryLimit uint64 `protobuf:"varint,6,opt,name=memoryLimit,proto3" json:"memoryLimit,omitempty"` StackLimit uint64 `protobuf:"varint,12,opt,name=stackLimit,proto3" json:"stackLimit,omitempty"` ProcLimit uint64 `protobuf:"varint,7,opt,name=procLimit,proto3" json:"procLimit,omitempty"` CopyIn map[string]*Request_File `` /* 153-byte string literal not displayed */ CopyOut []string `protobuf:"bytes,9,rep,name=copyOut,proto3" json:"copyOut,omitempty"` CopyOutCached []string `protobuf:"bytes,10,rep,name=copyOutCached,proto3" json:"copyOutCached,omitempty"` CopyOutDir string `protobuf:"bytes,11,opt,name=copyOutDir,proto3" json:"copyOutDir,omitempty"` CopyOutMax uint64 `protobuf:"varint,14,opt,name=copyOutMax,proto3" json:"copyOutMax,omitempty"` // contains filtered or unexported fields }
func (*Request_CmdType) Descriptor
deprecated
func (*Request_CmdType) Descriptor() ([]byte, []int)
Deprecated: Use Request_CmdType.ProtoReflect.Descriptor instead.
func (*Request_CmdType) GetArgs ¶
func (x *Request_CmdType) GetArgs() []string
func (*Request_CmdType) GetCPULimit ¶
func (x *Request_CmdType) GetCPULimit() uint64
func (*Request_CmdType) GetCopyIn ¶
func (x *Request_CmdType) GetCopyIn() map[string]*Request_File
func (*Request_CmdType) GetCopyOut ¶
func (x *Request_CmdType) GetCopyOut() []string
func (*Request_CmdType) GetCopyOutCached ¶
func (x *Request_CmdType) GetCopyOutCached() []string
func (*Request_CmdType) GetCopyOutDir ¶
func (x *Request_CmdType) GetCopyOutDir() string
func (*Request_CmdType) GetCopyOutMax ¶ added in v0.6.2
func (x *Request_CmdType) GetCopyOutMax() uint64
func (*Request_CmdType) GetEnv ¶
func (x *Request_CmdType) GetEnv() []string
func (*Request_CmdType) GetFiles ¶
func (x *Request_CmdType) GetFiles() []*Request_File
func (*Request_CmdType) GetMemoryLimit ¶
func (x *Request_CmdType) GetMemoryLimit() uint64
func (*Request_CmdType) GetProcLimit ¶
func (x *Request_CmdType) GetProcLimit() uint64
func (*Request_CmdType) GetRealCPULimit ¶
func (x *Request_CmdType) GetRealCPULimit() uint64
func (*Request_CmdType) GetStackLimit ¶ added in v0.5.7
func (x *Request_CmdType) GetStackLimit() uint64
func (*Request_CmdType) GetTty ¶ added in v0.6.2
func (x *Request_CmdType) GetTty() bool
func (*Request_CmdType) ProtoMessage ¶
func (*Request_CmdType) ProtoMessage()
func (*Request_CmdType) ProtoReflect ¶
func (x *Request_CmdType) ProtoReflect() protoreflect.Message
func (*Request_CmdType) Reset ¶
func (x *Request_CmdType) Reset()
func (*Request_CmdType) String ¶
func (x *Request_CmdType) String() string
type Request_File ¶
type Request_File struct { // Types that are assignable to File: // *Request_File_Local // *Request_File_Memory // *Request_File_Cached // *Request_File_Pipe // *Request_File_StreamIn // *Request_File_StreamOut File isRequest_File_File `protobuf_oneof:"file"` // contains filtered or unexported fields }
func (*Request_File) Descriptor
deprecated
func (*Request_File) Descriptor() ([]byte, []int)
Deprecated: Use Request_File.ProtoReflect.Descriptor instead.
func (*Request_File) GetCached ¶
func (x *Request_File) GetCached() *Request_CachedFile
func (*Request_File) GetFile ¶
func (m *Request_File) GetFile() isRequest_File_File
func (*Request_File) GetLocal ¶
func (x *Request_File) GetLocal() *Request_LocalFile
func (*Request_File) GetMemory ¶
func (x *Request_File) GetMemory() *Request_MemoryFile
func (*Request_File) GetPipe ¶
func (x *Request_File) GetPipe() *Request_PipeCollector
func (*Request_File) GetStreamIn ¶ added in v0.5.2
func (x *Request_File) GetStreamIn() *Request_StreamInput
func (*Request_File) GetStreamOut ¶ added in v0.5.2
func (x *Request_File) GetStreamOut() *Request_StreamOutput
func (*Request_File) ProtoMessage ¶
func (*Request_File) ProtoMessage()
func (*Request_File) ProtoReflect ¶
func (x *Request_File) ProtoReflect() protoreflect.Message
func (*Request_File) Reset ¶
func (x *Request_File) Reset()
func (*Request_File) String ¶
func (x *Request_File) String() string
type Request_File_Cached ¶
type Request_File_Cached struct {
Cached *Request_CachedFile `protobuf:"bytes,3,opt,name=cached,proto3,oneof"`
}
type Request_File_Local ¶
type Request_File_Local struct {
Local *Request_LocalFile `protobuf:"bytes,1,opt,name=local,proto3,oneof"`
}
type Request_File_Memory ¶
type Request_File_Memory struct {
Memory *Request_MemoryFile `protobuf:"bytes,2,opt,name=memory,proto3,oneof"`
}
type Request_File_Pipe ¶
type Request_File_Pipe struct {
Pipe *Request_PipeCollector `protobuf:"bytes,4,opt,name=pipe,proto3,oneof"`
}
type Request_File_StreamIn ¶ added in v0.5.2
type Request_File_StreamIn struct { // streamIn only valid in streaming RPC StreamIn *Request_StreamInput `protobuf:"bytes,5,opt,name=streamIn,proto3,oneof"` }
type Request_File_StreamOut ¶ added in v0.5.2
type Request_File_StreamOut struct { // streamOut only valid in streaming RPC StreamOut *Request_StreamOutput `protobuf:"bytes,6,opt,name=streamOut,proto3,oneof"` }
type Request_LocalFile ¶
type Request_LocalFile struct { Src string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"` // contains filtered or unexported fields }
func (*Request_LocalFile) Descriptor
deprecated
func (*Request_LocalFile) Descriptor() ([]byte, []int)
Deprecated: Use Request_LocalFile.ProtoReflect.Descriptor instead.
func (*Request_LocalFile) GetSrc ¶
func (x *Request_LocalFile) GetSrc() string
func (*Request_LocalFile) ProtoMessage ¶
func (*Request_LocalFile) ProtoMessage()
func (*Request_LocalFile) ProtoReflect ¶
func (x *Request_LocalFile) ProtoReflect() protoreflect.Message
func (*Request_LocalFile) Reset ¶
func (x *Request_LocalFile) Reset()
func (*Request_LocalFile) String ¶
func (x *Request_LocalFile) String() string
type Request_MemoryFile ¶
type Request_MemoryFile struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*Request_MemoryFile) Descriptor
deprecated
func (*Request_MemoryFile) Descriptor() ([]byte, []int)
Deprecated: Use Request_MemoryFile.ProtoReflect.Descriptor instead.
func (*Request_MemoryFile) GetContent ¶
func (x *Request_MemoryFile) GetContent() []byte
func (*Request_MemoryFile) ProtoMessage ¶
func (*Request_MemoryFile) ProtoMessage()
func (*Request_MemoryFile) ProtoReflect ¶
func (x *Request_MemoryFile) ProtoReflect() protoreflect.Message
func (*Request_MemoryFile) Reset ¶
func (x *Request_MemoryFile) Reset()
func (*Request_MemoryFile) String ¶
func (x *Request_MemoryFile) String() string
type Request_PipeCollector ¶
type Request_PipeCollector struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Max int64 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"` // contains filtered or unexported fields }
func (*Request_PipeCollector) Descriptor
deprecated
func (*Request_PipeCollector) Descriptor() ([]byte, []int)
Deprecated: Use Request_PipeCollector.ProtoReflect.Descriptor instead.
func (*Request_PipeCollector) GetMax ¶
func (x *Request_PipeCollector) GetMax() int64
func (*Request_PipeCollector) GetName ¶
func (x *Request_PipeCollector) GetName() string
func (*Request_PipeCollector) ProtoMessage ¶
func (*Request_PipeCollector) ProtoMessage()
func (*Request_PipeCollector) ProtoReflect ¶
func (x *Request_PipeCollector) ProtoReflect() protoreflect.Message
func (*Request_PipeCollector) Reset ¶
func (x *Request_PipeCollector) Reset()
func (*Request_PipeCollector) String ¶
func (x *Request_PipeCollector) String() string
type Request_PipeMap ¶
type Request_PipeMap struct { In *Request_PipeMap_PipeIndex `protobuf:"bytes,1,opt,name=in,proto3" json:"in,omitempty"` Out *Request_PipeMap_PipeIndex `protobuf:"bytes,2,opt,name=out,proto3" json:"out,omitempty"` // contains filtered or unexported fields }
func (*Request_PipeMap) Descriptor
deprecated
func (*Request_PipeMap) Descriptor() ([]byte, []int)
Deprecated: Use Request_PipeMap.ProtoReflect.Descriptor instead.
func (*Request_PipeMap) GetIn ¶
func (x *Request_PipeMap) GetIn() *Request_PipeMap_PipeIndex
func (*Request_PipeMap) GetOut ¶
func (x *Request_PipeMap) GetOut() *Request_PipeMap_PipeIndex
func (*Request_PipeMap) ProtoMessage ¶
func (*Request_PipeMap) ProtoMessage()
func (*Request_PipeMap) ProtoReflect ¶
func (x *Request_PipeMap) ProtoReflect() protoreflect.Message
func (*Request_PipeMap) Reset ¶
func (x *Request_PipeMap) Reset()
func (*Request_PipeMap) String ¶
func (x *Request_PipeMap) String() string
type Request_PipeMap_PipeIndex ¶
type Request_PipeMap_PipeIndex struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Fd int32 `protobuf:"varint,2,opt,name=fd,proto3" json:"fd,omitempty"` // contains filtered or unexported fields }
func (*Request_PipeMap_PipeIndex) Descriptor
deprecated
func (*Request_PipeMap_PipeIndex) Descriptor() ([]byte, []int)
Deprecated: Use Request_PipeMap_PipeIndex.ProtoReflect.Descriptor instead.
func (*Request_PipeMap_PipeIndex) GetFd ¶
func (x *Request_PipeMap_PipeIndex) GetFd() int32
func (*Request_PipeMap_PipeIndex) GetIndex ¶
func (x *Request_PipeMap_PipeIndex) GetIndex() int32
func (*Request_PipeMap_PipeIndex) ProtoMessage ¶
func (*Request_PipeMap_PipeIndex) ProtoMessage()
func (*Request_PipeMap_PipeIndex) ProtoReflect ¶
func (x *Request_PipeMap_PipeIndex) ProtoReflect() protoreflect.Message
func (*Request_PipeMap_PipeIndex) Reset ¶
func (x *Request_PipeMap_PipeIndex) Reset()
func (*Request_PipeMap_PipeIndex) String ¶
func (x *Request_PipeMap_PipeIndex) String() string
type Request_StreamInput ¶ added in v0.5.2
type Request_StreamInput struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Tty bool `protobuf:"varint,2,opt,name=tty,proto3" json:"tty,omitempty"` // contains filtered or unexported fields }
func (*Request_StreamInput) Descriptor
deprecated
added in
v0.5.2
func (*Request_StreamInput) Descriptor() ([]byte, []int)
Deprecated: Use Request_StreamInput.ProtoReflect.Descriptor instead.
func (*Request_StreamInput) GetName ¶ added in v0.5.2
func (x *Request_StreamInput) GetName() string
func (*Request_StreamInput) GetTty ¶ added in v0.5.2
func (x *Request_StreamInput) GetTty() bool
func (*Request_StreamInput) ProtoMessage ¶ added in v0.5.2
func (*Request_StreamInput) ProtoMessage()
func (*Request_StreamInput) ProtoReflect ¶ added in v0.5.2
func (x *Request_StreamInput) ProtoReflect() protoreflect.Message
func (*Request_StreamInput) Reset ¶ added in v0.5.2
func (x *Request_StreamInput) Reset()
func (*Request_StreamInput) String ¶ added in v0.5.2
func (x *Request_StreamInput) String() string
type Request_StreamOutput ¶ added in v0.5.2
type Request_StreamOutput struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Request_StreamOutput) Descriptor
deprecated
added in
v0.5.2
func (*Request_StreamOutput) Descriptor() ([]byte, []int)
Deprecated: Use Request_StreamOutput.ProtoReflect.Descriptor instead.
func (*Request_StreamOutput) GetName ¶ added in v0.5.2
func (x *Request_StreamOutput) GetName() string
func (*Request_StreamOutput) ProtoMessage ¶ added in v0.5.2
func (*Request_StreamOutput) ProtoMessage()
func (*Request_StreamOutput) ProtoReflect ¶ added in v0.5.2
func (x *Request_StreamOutput) ProtoReflect() protoreflect.Message
func (*Request_StreamOutput) Reset ¶ added in v0.5.2
func (x *Request_StreamOutput) Reset()
func (*Request_StreamOutput) String ¶ added in v0.5.2
func (x *Request_StreamOutput) String() string
type Response ¶
type Response struct { RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"` Results []*Response_Result `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetRequestID ¶
func (*Response) GetResults ¶
func (x *Response) GetResults() []*Response_Result
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_Result ¶
type Response_Result struct { Status Response_Result_StatusType `protobuf:"varint,1,opt,name=status,proto3,enum=pb.Response_Result_StatusType" json:"status,omitempty"` ExitStatus int32 `protobuf:"varint,2,opt,name=exitStatus,proto3" json:"exitStatus,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Time uint64 `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"` RunTime uint64 `protobuf:"varint,8,opt,name=runTime,proto3" json:"runTime,omitempty"` Memory uint64 `protobuf:"varint,5,opt,name=memory,proto3" json:"memory,omitempty"` Files map[string][]byte `` /* 151-byte string literal not displayed */ FileIDs map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Response_Result) Descriptor
deprecated
func (*Response_Result) Descriptor() ([]byte, []int)
Deprecated: Use Response_Result.ProtoReflect.Descriptor instead.
func (*Response_Result) GetError ¶
func (x *Response_Result) GetError() string
func (*Response_Result) GetExitStatus ¶
func (x *Response_Result) GetExitStatus() int32
func (*Response_Result) GetFileIDs ¶
func (x *Response_Result) GetFileIDs() map[string]string
func (*Response_Result) GetFiles ¶
func (x *Response_Result) GetFiles() map[string][]byte
func (*Response_Result) GetMemory ¶
func (x *Response_Result) GetMemory() uint64
func (*Response_Result) GetRunTime ¶ added in v0.5.6
func (x *Response_Result) GetRunTime() uint64
func (*Response_Result) GetStatus ¶
func (x *Response_Result) GetStatus() Response_Result_StatusType
func (*Response_Result) GetTime ¶
func (x *Response_Result) GetTime() uint64
func (*Response_Result) ProtoMessage ¶
func (*Response_Result) ProtoMessage()
func (*Response_Result) ProtoReflect ¶
func (x *Response_Result) ProtoReflect() protoreflect.Message
func (*Response_Result) Reset ¶
func (x *Response_Result) Reset()
func (*Response_Result) String ¶
func (x *Response_Result) String() string
type Response_Result_StatusType ¶
type Response_Result_StatusType int32
const ( Response_Result_Invalid Response_Result_StatusType = 0 Response_Result_Accepted Response_Result_StatusType = 1 Response_Result_WrongAnswer Response_Result_StatusType = 2 // Not used Response_Result_PartiallyCorrect Response_Result_StatusType = 3 // Not used Response_Result_MemoryLimitExceeded Response_Result_StatusType = 4 Response_Result_TimeLimitExceeded Response_Result_StatusType = 5 Response_Result_OutputLimitExceeded Response_Result_StatusType = 6 Response_Result_FileError Response_Result_StatusType = 7 Response_Result_NonZeroExitStatus Response_Result_StatusType = 8 Response_Result_Signalled Response_Result_StatusType = 9 Response_Result_DangerousSyscall Response_Result_StatusType = 10 Response_Result_JudgementFailed Response_Result_StatusType = 11 Response_Result_InvalidInteraction Response_Result_StatusType = 12 // Not used Response_Result_InternalError Response_Result_StatusType = 13 )
func (Response_Result_StatusType) Descriptor ¶
func (Response_Result_StatusType) Descriptor() protoreflect.EnumDescriptor
func (Response_Result_StatusType) Enum ¶
func (x Response_Result_StatusType) Enum() *Response_Result_StatusType
func (Response_Result_StatusType) EnumDescriptor
deprecated
func (Response_Result_StatusType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Response_Result_StatusType.Descriptor instead.
func (Response_Result_StatusType) Number ¶
func (x Response_Result_StatusType) Number() protoreflect.EnumNumber
func (Response_Result_StatusType) String ¶
func (x Response_Result_StatusType) String() string
func (Response_Result_StatusType) Type ¶
func (Response_Result_StatusType) Type() protoreflect.EnumType
type StreamRequest ¶ added in v0.5.2
type StreamRequest struct { // Types that are assignable to Request: // *StreamRequest_ExecRequest // *StreamRequest_ExecInput // *StreamRequest_ExecResize Request isStreamRequest_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
func (*StreamRequest) Descriptor
deprecated
added in
v0.5.2
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetExecInput ¶ added in v0.5.2
func (x *StreamRequest) GetExecInput() *StreamRequest_Input
func (*StreamRequest) GetExecRequest ¶ added in v0.5.2
func (x *StreamRequest) GetExecRequest() *Request
func (*StreamRequest) GetExecResize ¶ added in v0.5.2
func (x *StreamRequest) GetExecResize() *StreamRequest_Resize
func (*StreamRequest) GetRequest ¶ added in v0.5.2
func (m *StreamRequest) GetRequest() isStreamRequest_Request
func (*StreamRequest) ProtoMessage ¶ added in v0.5.2
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶ added in v0.5.2
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶ added in v0.5.2
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶ added in v0.5.2
func (x *StreamRequest) String() string
type StreamRequest_ExecInput ¶ added in v0.5.2
type StreamRequest_ExecInput struct {
ExecInput *StreamRequest_Input `protobuf:"bytes,2,opt,name=execInput,proto3,oneof"`
}
type StreamRequest_ExecRequest ¶ added in v0.5.2
type StreamRequest_ExecRequest struct {
ExecRequest *Request `protobuf:"bytes,1,opt,name=execRequest,proto3,oneof"`
}
type StreamRequest_ExecResize ¶ added in v0.5.2
type StreamRequest_ExecResize struct {
ExecResize *StreamRequest_Resize `protobuf:"bytes,3,opt,name=execResize,proto3,oneof"`
}
type StreamRequest_Input ¶ added in v0.5.2
type StreamRequest_Input struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*StreamRequest_Input) Descriptor
deprecated
added in
v0.5.2
func (*StreamRequest_Input) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest_Input.ProtoReflect.Descriptor instead.
func (*StreamRequest_Input) GetContent ¶ added in v0.5.2
func (x *StreamRequest_Input) GetContent() []byte
func (*StreamRequest_Input) GetName ¶ added in v0.5.2
func (x *StreamRequest_Input) GetName() string
func (*StreamRequest_Input) ProtoMessage ¶ added in v0.5.2
func (*StreamRequest_Input) ProtoMessage()
func (*StreamRequest_Input) ProtoReflect ¶ added in v0.5.2
func (x *StreamRequest_Input) ProtoReflect() protoreflect.Message
func (*StreamRequest_Input) Reset ¶ added in v0.5.2
func (x *StreamRequest_Input) Reset()
func (*StreamRequest_Input) String ¶ added in v0.5.2
func (x *StreamRequest_Input) String() string
type StreamRequest_Resize ¶ added in v0.5.2
type StreamRequest_Resize struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Rows uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"` Cols uint32 `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"` X uint32 `protobuf:"varint,4,opt,name=x,proto3" json:"x,omitempty"` Y uint32 `protobuf:"varint,5,opt,name=y,proto3" json:"y,omitempty"` // contains filtered or unexported fields }
func (*StreamRequest_Resize) Descriptor
deprecated
added in
v0.5.2
func (*StreamRequest_Resize) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest_Resize.ProtoReflect.Descriptor instead.
func (*StreamRequest_Resize) GetCols ¶ added in v0.5.2
func (x *StreamRequest_Resize) GetCols() uint32
func (*StreamRequest_Resize) GetName ¶ added in v0.5.2
func (x *StreamRequest_Resize) GetName() string
func (*StreamRequest_Resize) GetRows ¶ added in v0.5.2
func (x *StreamRequest_Resize) GetRows() uint32
func (*StreamRequest_Resize) GetX ¶ added in v0.5.2
func (x *StreamRequest_Resize) GetX() uint32
func (*StreamRequest_Resize) GetY ¶ added in v0.5.2
func (x *StreamRequest_Resize) GetY() uint32
func (*StreamRequest_Resize) ProtoMessage ¶ added in v0.5.2
func (*StreamRequest_Resize) ProtoMessage()
func (*StreamRequest_Resize) ProtoReflect ¶ added in v0.5.2
func (x *StreamRequest_Resize) ProtoReflect() protoreflect.Message
func (*StreamRequest_Resize) Reset ¶ added in v0.5.2
func (x *StreamRequest_Resize) Reset()
func (*StreamRequest_Resize) String ¶ added in v0.5.2
func (x *StreamRequest_Resize) String() string
type StreamResponse ¶ added in v0.5.2
type StreamResponse struct { // Types that are assignable to Response: // *StreamResponse_ExecResponse // *StreamResponse_ExecOutput Response isStreamResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*StreamResponse) Descriptor
deprecated
added in
v0.5.2
func (*StreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.
func (*StreamResponse) GetExecOutput ¶ added in v0.5.2
func (x *StreamResponse) GetExecOutput() *StreamResponse_Output
func (*StreamResponse) GetExecResponse ¶ added in v0.5.2
func (x *StreamResponse) GetExecResponse() *Response
func (*StreamResponse) GetResponse ¶ added in v0.5.2
func (m *StreamResponse) GetResponse() isStreamResponse_Response
func (*StreamResponse) ProtoMessage ¶ added in v0.5.2
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) ProtoReflect ¶ added in v0.5.2
func (x *StreamResponse) ProtoReflect() protoreflect.Message
func (*StreamResponse) Reset ¶ added in v0.5.2
func (x *StreamResponse) Reset()
func (*StreamResponse) String ¶ added in v0.5.2
func (x *StreamResponse) String() string
type StreamResponse_ExecOutput ¶ added in v0.5.2
type StreamResponse_ExecOutput struct {
ExecOutput *StreamResponse_Output `protobuf:"bytes,2,opt,name=execOutput,proto3,oneof"`
}
type StreamResponse_ExecResponse ¶ added in v0.5.2
type StreamResponse_ExecResponse struct {
ExecResponse *Response `protobuf:"bytes,1,opt,name=execResponse,proto3,oneof"`
}
type StreamResponse_Output ¶ added in v0.5.2
type StreamResponse_Output struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*StreamResponse_Output) Descriptor
deprecated
added in
v0.5.2
func (*StreamResponse_Output) Descriptor() ([]byte, []int)
Deprecated: Use StreamResponse_Output.ProtoReflect.Descriptor instead.
func (*StreamResponse_Output) GetContent ¶ added in v0.5.2
func (x *StreamResponse_Output) GetContent() []byte
func (*StreamResponse_Output) GetName ¶ added in v0.5.2
func (x *StreamResponse_Output) GetName() string
func (*StreamResponse_Output) ProtoMessage ¶ added in v0.5.2
func (*StreamResponse_Output) ProtoMessage()
func (*StreamResponse_Output) ProtoReflect ¶ added in v0.5.2
func (x *StreamResponse_Output) ProtoReflect() protoreflect.Message
func (*StreamResponse_Output) Reset ¶ added in v0.5.2
func (x *StreamResponse_Output) Reset()
func (*StreamResponse_Output) String ¶ added in v0.5.2
func (x *StreamResponse_Output) String() string
type UnimplementedExecutorServer ¶
type UnimplementedExecutorServer struct { }
UnimplementedExecutorServer can be embedded to have forward compatible implementations.
func (*UnimplementedExecutorServer) ExecStream ¶ added in v0.5.2
func (*UnimplementedExecutorServer) ExecStream(Executor_ExecStreamServer) error
func (*UnimplementedExecutorServer) FileAdd ¶
func (*UnimplementedExecutorServer) FileAdd(context.Context, *FileContent) (*FileID, error)
func (*UnimplementedExecutorServer) FileDelete ¶
func (*UnimplementedExecutorServer) FileGet ¶
func (*UnimplementedExecutorServer) FileGet(context.Context, *FileID) (*FileContent, error)
func (*UnimplementedExecutorServer) FileList ¶
func (*UnimplementedExecutorServer) FileList(context.Context, *Empty) (*FileListType, error)