pb

package
v1.8.5 Latest Latest
Warning

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

 Go to latest Published: May 23, 2024 License: MIT Imports: 9 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	Executor_Exec_FullMethodName       = "/pb.Executor/Exec"
	Executor_ExecStream_FullMethodName = "/pb.Executor/ExecStream"
	Executor_FileList_FullMethodName   = "/pb.Executor/FileList"
	Executor_FileGet_FullMethodName    = "/pb.Executor/FileGet"
	Executor_FileAdd_FullMethodName    = "/pb.Executor/FileAdd"
	Executor_FileDelete_FullMethodName = "/pb.Executor/FileDelete"
)

Variables

View Source 
var (
	Response_FileError_ErrorType_name = map[int32]string{
		0: "CopyInOpenFile",
		1: "CopyInCreateFile",
		2: "CopyInCopyContent",
		3: "CopyOutOpen",
		4: "CopyOutNotRegularFile",
		5: "CopyOutSizeExceeded",
		6: "CopyOutCreateFile",
		7: "CopyOutCopyContent",
		8: "CollectSizeExceeded",
		9: "Symlink",
	}
	Response_FileError_ErrorType_value = map[string]int32{
		"CopyInOpenFile":        0,
		"CopyInCreateFile":      1,
		"CopyInCopyContent":     2,
		"CopyOutOpen":           3,
		"CopyOutNotRegularFile": 4,
		"CopyOutSizeExceeded":   5,
		"CopyOutCreateFile":     6,
		"CopyOutCopyContent":    7,
		"CollectSizeExceeded":   8,
		"Symlink":               9,
	}
)

Enum value maps for Response_FileError_ErrorType.

View Source 
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.

View Source 
var Executor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Executor",
	HandlerType: (*ExecutorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exec",
			Handler:    _Executor_Exec_Handler,
		},
		{
			MethodName: "FileList",
			Handler:    _Executor_FileList_Handler,
		},
		{
			MethodName: "FileGet",
			Handler:    _Executor_FileGet_Handler,
		},
		{
			MethodName: "FileAdd",
			Handler:    _Executor_FileAdd_Handler,
		},
		{
			MethodName: "FileDelete",
			Handler:    _Executor_FileDelete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecStream",
			Handler:       _Executor_ExecStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "judge.proto",
}

Executor_ServiceDesc is the grpc.ServiceDesc for Executor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_judge_proto protoreflect.FileDescriptor

Functions

func RegisterExecutorServer 

func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)

Types

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 available in the file store
	FileList(ctx context.Context, in *emptypb.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) (*emptypb.Empty, error)
}

ExecutorClient is the client API for Executor service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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 available in the file store
	FileList(context.Context, *emptypb.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) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ExecutorServer is the server API for Executor service. All implementations must embed UnimplementedExecutorServer for forward compatibility

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) Descriptor() ([]byte, []int)

Deprecated: Use FileID.ProtoReflect.Descriptor instead.

func (*FileID) GetFileID 

func (x *FileID) GetFileID() string

func (*FileID) ProtoMessage 

func (*FileID) ProtoMessage()

func (*FileID) ProtoReflect 

func (x *FileID) ProtoReflect() protoreflect.Message

func (*FileID) Reset 

func (x *FileID) Reset()

func (*FileID) String 

func (x *FileID) String() string

type FileListType 

type FileListType struct {
	FileIDs map[string]string `` /* 155-byte string literal not displayed */
	// 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() map[string]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) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetCmd 

func (x *Request) GetCmd() []*Request_CmdType

func (*Request) GetPipeMapping 

func (x *Request) GetPipeMapping() []*Request_PipeMap

func (*Request) GetRequestID 

func (x *Request) GetRequestID() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

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_CmdCopyOutFile added in v1.2.0 

type Request_CmdCopyOutFile struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Optional bool   `protobuf:"varint,2,opt,name=optional,proto3" json:"optional,omitempty"`
	// contains filtered or unexported fields
}

func (*Request_CmdCopyOutFile) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use Request_CmdCopyOutFile.ProtoReflect.Descriptor instead.

func (*Request_CmdCopyOutFile) GetName added in v1.2.0 

func (x *Request_CmdCopyOutFile) GetName() string

func (*Request_CmdCopyOutFile) GetOptional added in v1.2.0 

func (x *Request_CmdCopyOutFile) GetOptional() bool

func (*Request_CmdCopyOutFile) ProtoMessage added in v1.2.0 

func (*Request_CmdCopyOutFile) ProtoMessage()

func (*Request_CmdCopyOutFile) ProtoReflect added in v1.2.0 

func (x *Request_CmdCopyOutFile) ProtoReflect() protoreflect.Message

func (*Request_CmdCopyOutFile) Reset added in v1.2.0 

func (x *Request_CmdCopyOutFile) Reset()

func (*Request_CmdCopyOutFile) String added in v1.2.0 

func (x *Request_CmdCopyOutFile) 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"`
	CpuTimeLimit      uint64                    `protobuf:"varint,4,opt,name=cpuTimeLimit,proto3" json:"cpuTimeLimit,omitempty"`
	ClockTimeLimit    uint64                    `protobuf:"varint,5,opt,name=clockTimeLimit,proto3" json:"clockTimeLimit,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"`
	CpuRateLimit      uint64                    `protobuf:"varint,15,opt,name=cpuRateLimit,proto3" json:"cpuRateLimit,omitempty"`
	CpuSetLimit       string                    `protobuf:"bytes,17,opt,name=cpuSetLimit,proto3" json:"cpuSetLimit,omitempty"`
	DataSegmentLimit  bool                      `protobuf:"varint,16,opt,name=dataSegmentLimit,proto3" json:"dataSegmentLimit,omitempty"`
	AddressSpaceLimit bool                      `protobuf:"varint,19,opt,name=addressSpaceLimit,proto3" json:"addressSpaceLimit,omitempty"`
	CopyIn            map[string]*Request_File  `` /* 153-byte string literal not displayed */
	Symlinks          map[string]string         `` /* 158-byte string literal not displayed */
	CopyOut           []*Request_CmdCopyOutFile `protobuf:"bytes,9,rep,name=copyOut,proto3" json:"copyOut,omitempty"`
	CopyOutCached     []*Request_CmdCopyOutFile `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) GetAddressSpaceLimit added in v1.7.0 

func (x *Request_CmdType) GetAddressSpaceLimit() bool

func (*Request_CmdType) GetArgs 

func (x *Request_CmdType) GetArgs() []string

func (*Request_CmdType) GetClockTimeLimit added in v1.0.0 

func (x *Request_CmdType) GetClockTimeLimit() uint64

func (*Request_CmdType) GetCopyIn 

func (x *Request_CmdType) GetCopyIn() map[string]*Request_File

func (*Request_CmdType) GetCopyOut 

func (x *Request_CmdType) GetCopyOut() []*Request_CmdCopyOutFile

func (*Request_CmdType) GetCopyOutCached 

func (x *Request_CmdType) GetCopyOutCached() []*Request_CmdCopyOutFile

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) GetCpuRateLimit added in v1.3.5 

func (x *Request_CmdType) GetCpuRateLimit() uint64

func (*Request_CmdType) GetCpuSetLimit added in v1.3.5 

func (x *Request_CmdType) GetCpuSetLimit() string

func (*Request_CmdType) GetCpuTimeLimit added in v1.0.0 

func (x *Request_CmdType) GetCpuTimeLimit() uint64

func (*Request_CmdType) GetDataSegmentLimit added in v1.7.0 

func (x *Request_CmdType) GetDataSegmentLimit() bool

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) GetStackLimit added in v0.5.7 

func (x *Request_CmdType) GetStackLimit() uint64
func (x *Request_CmdType) GetSymlinks() map[string]string

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() *emptypb.Empty

func (*Request_File) GetStreamOut added in v0.5.2 

func (x *Request_File) GetStreamOut() *emptypb.Empty

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 *emptypb.Empty `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 *emptypb.Empty `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"`
	Pipe bool   `protobuf:"varint,3,opt,name=pipe,proto3" json:"pipe,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) GetPipe added in v1.3.1 

func (x *Request_PipeCollector) GetPipe() bool

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"`
	Proxy bool                       `protobuf:"varint,3,opt,name=proxy,proto3" json:"proxy,omitempty"`
	Name  string                     `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Max   uint64                     `protobuf:"varint,5,opt,name=max,proto3" json:"max,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) GetMax added in v1.2.1 

func (x *Request_PipeMap) GetMax() uint64

func (*Request_PipeMap) GetName added in v1.2.1 

func (x *Request_PipeMap) GetName() string

func (*Request_PipeMap) GetOut 

func (x *Request_PipeMap) GetOut() *Request_PipeMap_PipeIndex

func (*Request_PipeMap) GetProxy added in v1.2.1 

func (x *Request_PipeMap) GetProxy() bool

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetError 

func (x *Response) GetError() string

func (*Response) GetRequestID 

func (x *Response) GetRequestID() string

func (*Response) GetResults 

func (x *Response) GetResults() []*Response_Result

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_FileError added in v1.3.2 

type Response_FileError struct {
	Name    string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type    Response_FileError_ErrorType `protobuf:"varint,2,opt,name=type,proto3,enum=pb.Response_FileError_ErrorType" json:"type,omitempty"`
	Message string                       `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response_FileError) Descriptor deprecated added in v1.3.2 

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

Deprecated: Use Response_FileError.ProtoReflect.Descriptor instead.

func (*Response_FileError) GetMessage added in v1.3.2 

func (x *Response_FileError) GetMessage() string

func (*Response_FileError) GetName added in v1.3.2 

func (x *Response_FileError) GetName() string

func (*Response_FileError) GetType added in v1.3.2 

func (x *Response_FileError) GetType() Response_FileError_ErrorType

func (*Response_FileError) ProtoMessage added in v1.3.2 

func (*Response_FileError) ProtoMessage()

func (*Response_FileError) ProtoReflect added in v1.3.2 

func (x *Response_FileError) ProtoReflect() protoreflect.Message

func (*Response_FileError) Reset added in v1.3.2 

func (x *Response_FileError) Reset()

func (*Response_FileError) String added in v1.3.2 

func (x *Response_FileError) String() string

type Response_FileError_ErrorType added in v1.3.2 

type Response_FileError_ErrorType int32
const (
	Response_FileError_CopyInOpenFile        Response_FileError_ErrorType = 0
	Response_FileError_CopyInCreateFile      Response_FileError_ErrorType = 1
	Response_FileError_CopyInCopyContent     Response_FileError_ErrorType = 2
	Response_FileError_CopyOutOpen           Response_FileError_ErrorType = 3
	Response_FileError_CopyOutNotRegularFile Response_FileError_ErrorType = 4
	Response_FileError_CopyOutSizeExceeded   Response_FileError_ErrorType = 5
	Response_FileError_CopyOutCreateFile     Response_FileError_ErrorType = 6
	Response_FileError_CopyOutCopyContent    Response_FileError_ErrorType = 7
	Response_FileError_CollectSizeExceeded   Response_FileError_ErrorType = 8
	Response_FileError_Symlink               Response_FileError_ErrorType = 9
)

func (Response_FileError_ErrorType) Descriptor added in v1.3.2 

func (Response_FileError_ErrorType) Descriptor() protoreflect.EnumDescriptor

func (Response_FileError_ErrorType) Enum added in v1.3.2 

func (x Response_FileError_ErrorType) Enum() *Response_FileError_ErrorType

func (Response_FileError_ErrorType) EnumDescriptor deprecated added in v1.3.2 

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

Deprecated: Use Response_FileError_ErrorType.Descriptor instead.

func (Response_FileError_ErrorType) Number added in v1.3.2 

func (x Response_FileError_ErrorType) Number() protoreflect.EnumNumber

func (Response_FileError_ErrorType) String added in v1.3.2 

func (x Response_FileError_ErrorType) String() string

func (Response_FileError_ErrorType) Type added in v1.3.2 

func (Response_FileError_ErrorType) Type() protoreflect.EnumType

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 */
	FileError  []*Response_FileError      `protobuf:"bytes,9,rep,name=fileError,proto3" json:"fileError,omitempty"`
	// 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) GetFileError added in v1.3.2 

func (x *Response_Result) GetFileError() []*Response_FileError

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 // Not used
	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
	//	*StreamRequest_ExecCancel
	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) GetExecCancel added in v1.8.1 

func (x *StreamRequest) GetExecCancel() *emptypb.Empty

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_ExecCancel added in v1.8.1 

type StreamRequest_ExecCancel struct {
	ExecCancel *emptypb.Empty `protobuf:"bytes,4,opt,name=execCancel,proto3,oneof"`
}

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 {
	Index   uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Fd      uint32 `protobuf:"varint,3,opt,name=fd,proto3" json:"fd,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) GetFd added in v1.8.1 

func (x *StreamRequest_Input) GetFd() uint32

func (*StreamRequest_Input) GetIndex added in v1.8.1 

func (x *StreamRequest_Input) GetIndex() uint32

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 {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Fd    uint32 `protobuf:"varint,6,opt,name=fd,proto3" json:"fd,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) GetFd added in v1.8.1 

func (x *StreamRequest_Resize) GetFd() uint32

func (*StreamRequest_Resize) GetIndex added in v1.8.1 

func (x *StreamRequest_Resize) GetIndex() uint32

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 {
	Index   uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Fd      uint32 `protobuf:"varint,3,opt,name=fd,proto3" json:"fd,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) GetFd added in v1.8.1 

func (x *StreamResponse_Output) GetFd() uint32

func (*StreamResponse_Output) GetIndex added in v1.8.1 

func (x *StreamResponse_Output) GetIndex() uint32

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 must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServer) Exec 

func (UnimplementedExecutorServer) Exec(context.Context, *Request) (*Response, error)

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) FileDelete(context.Context, *FileID) (*emptypb.Empty, error)

func (UnimplementedExecutorServer) FileGet 

func (UnimplementedExecutorServer) FileGet(context.Context, *FileID) (*FileContent, error)

func (UnimplementedExecutorServer) FileList 

func (UnimplementedExecutorServer) FileList(context.Context, *emptypb.Empty) (*FileListType, error)

type UnsafeExecutorServer added in v0.9.6 

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

UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServer will result in compilation errors.

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.