Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)
- type CreateSessionRequest
- func (*CreateSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionRequest) GetEnvs() []string
- func (x *CreateSessionRequest) GetMetadata() map[string]string
- func (*CreateSessionRequest) ProtoMessage()
- func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSessionRequest) Reset()
- func (x *CreateSessionRequest) String() string
- type CreateSessionResponse
- func (*CreateSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionResponse) GetSession() *Session
- func (*CreateSessionResponse) ProtoMessage()
- func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSessionResponse) Reset()
- func (x *CreateSessionResponse) String() string
- type DeleteSessionRequest
- func (*DeleteSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSessionRequest) GetId() string
- func (*DeleteSessionRequest) ProtoMessage()
- func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSessionRequest) Reset()
- func (x *DeleteSessionRequest) String() string
- type DeleteSessionResponse
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteRequest) GetArguments() []string
- func (x *ExecuteRequest) GetBackground() bool
- func (x *ExecuteRequest) GetCommands() []string
- func (x *ExecuteRequest) GetDirectory() string
- func (x *ExecuteRequest) GetEnvs() []string
- func (x *ExecuteRequest) GetInputData() []byte
- func (x *ExecuteRequest) GetProgramName() string
- func (x *ExecuteRequest) GetProject() *Project
- func (x *ExecuteRequest) GetScript() string
- func (x *ExecuteRequest) GetSessionId() string
- func (x *ExecuteRequest) GetSessionStrategy() SessionStrategy
- func (x *ExecuteRequest) GetStop() ExecuteStop
- func (x *ExecuteRequest) GetStoreLastOutput() bool
- func (x *ExecuteRequest) GetTty() bool
- func (x *ExecuteRequest) GetWinsize() *Winsize
- func (*ExecuteRequest) ProtoMessage()
- func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteRequest) Reset()
- func (x *ExecuteRequest) String() string
- type ExecuteResponse
- func (*ExecuteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteResponse) GetExitCode() *wrapperspb.UInt32Value
- func (x *ExecuteResponse) GetPid() *ProcessPID
- func (x *ExecuteResponse) GetStderrData() []byte
- func (x *ExecuteResponse) GetStdoutData() []byte
- func (*ExecuteResponse) ProtoMessage()
- func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteResponse) Reset()
- func (x *ExecuteResponse) String() string
- type ExecuteStop
- func (ExecuteStop) Descriptor() protoreflect.EnumDescriptor
- func (x ExecuteStop) Enum() *ExecuteStop
- func (ExecuteStop) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExecuteStop) Number() protoreflect.EnumNumber
- func (x ExecuteStop) String() string
- func (ExecuteStop) Type() protoreflect.EnumType
- type GetSessionRequest
- type GetSessionResponse
- func (*GetSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSessionResponse) GetSession() *Session
- func (*GetSessionResponse) ProtoMessage()
- func (x *GetSessionResponse) ProtoReflect() protoreflect.Message
- func (x *GetSessionResponse) Reset()
- func (x *GetSessionResponse) String() string
- type ListSessionsRequest
- type ListSessionsResponse
- func (*ListSessionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSessionsResponse) GetSessions() []*Session
- func (*ListSessionsResponse) ProtoMessage()
- func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSessionsResponse) Reset()
- func (x *ListSessionsResponse) String() string
- type ProcessPID
- type Project
- type RunnerServiceClient
- type RunnerServiceServer
- type RunnerService_ExecuteClient
- type RunnerService_ExecuteServer
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetEnvs() []string
- func (x *Session) GetId() string
- func (x *Session) GetMetadata() map[string]string
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SessionStrategy
- func (SessionStrategy) Descriptor() protoreflect.EnumDescriptor
- func (x SessionStrategy) Enum() *SessionStrategy
- func (SessionStrategy) EnumDescriptor() ([]byte, []int)deprecated
- func (x SessionStrategy) Number() protoreflect.EnumNumber
- func (x SessionStrategy) String() string
- func (SessionStrategy) Type() protoreflect.EnumType
- type UnimplementedRunnerServiceServer
- func (UnimplementedRunnerServiceServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
- func (UnimplementedRunnerServiceServer) DeleteSession(context.Context, *DeleteSessionRequest) (*DeleteSessionResponse, error)
- func (UnimplementedRunnerServiceServer) Execute(RunnerService_ExecuteServer) error
- func (UnimplementedRunnerServiceServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
- func (UnimplementedRunnerServiceServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
- type UnsafeRunnerServiceServer
- type Winsize
- func (*Winsize) Descriptor() ([]byte, []int)deprecated
- func (x *Winsize) GetCols() uint32
- func (x *Winsize) GetRows() uint32
- func (x *Winsize) GetX() uint32
- func (x *Winsize) GetY() uint32
- func (*Winsize) ProtoMessage()
- func (x *Winsize) ProtoReflect() protoreflect.Message
- func (x *Winsize) Reset()
- func (x *Winsize) String() string
Constants ¶
const ( RunnerService_CreateSession_FullMethodName = "/runme.runner.v1.RunnerService/CreateSession" RunnerService_GetSession_FullMethodName = "/runme.runner.v1.RunnerService/GetSession" RunnerService_ListSessions_FullMethodName = "/runme.runner.v1.RunnerService/ListSessions" RunnerService_DeleteSession_FullMethodName = "/runme.runner.v1.RunnerService/DeleteSession" RunnerService_Execute_FullMethodName = "/runme.runner.v1.RunnerService/Execute" )
Variables ¶
var ( ExecuteStop_name = map[int32]string{ 0: "EXECUTE_STOP_UNSPECIFIED", 1: "EXECUTE_STOP_INTERRUPT", 2: "EXECUTE_STOP_KILL", } ExecuteStop_value = map[string]int32{ "EXECUTE_STOP_UNSPECIFIED": 0, "EXECUTE_STOP_INTERRUPT": 1, "EXECUTE_STOP_KILL": 2, } )
Enum value maps for ExecuteStop.
var ( SessionStrategy_name = map[int32]string{ 0: "SESSION_STRATEGY_UNSPECIFIED", 1: "SESSION_STRATEGY_MOST_RECENT", } SessionStrategy_value = map[string]int32{ "SESSION_STRATEGY_UNSPECIFIED": 0, "SESSION_STRATEGY_MOST_RECENT": 1, } )
Enum value maps for SessionStrategy.
var File_runme_runner_v1_runner_proto protoreflect.FileDescriptor
var RunnerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runme.runner.v1.RunnerService", HandlerType: (*RunnerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateSession", Handler: _RunnerService_CreateSession_Handler, }, { MethodName: "GetSession", Handler: _RunnerService_GetSession_Handler, }, { MethodName: "ListSessions", Handler: _RunnerService_ListSessions_Handler, }, { MethodName: "DeleteSession", Handler: _RunnerService_DeleteSession_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Execute", Handler: _RunnerService_Execute_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "runme/runner/v1/runner.proto", }
RunnerService_ServiceDesc is the grpc.ServiceDesc for RunnerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRunnerServiceServer ¶
func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)
Types ¶
type CreateSessionRequest ¶
type CreateSessionRequest struct { // metadata is a map of client specific metadata. Metadata map[string]string `` /* 157-byte string literal not displayed */ // envs field provides an initial set of environment variables // for a newly created session. Envs []string `protobuf:"bytes,2,rep,name=envs,proto3" json:"envs,omitempty"` // contains filtered or unexported fields }
func (*CreateSessionRequest) Descriptor
deprecated
func (*CreateSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.
func (*CreateSessionRequest) GetEnvs ¶
func (x *CreateSessionRequest) GetEnvs() []string
func (*CreateSessionRequest) GetMetadata ¶
func (x *CreateSessionRequest) GetMetadata() map[string]string
func (*CreateSessionRequest) ProtoMessage ¶
func (*CreateSessionRequest) ProtoMessage()
func (*CreateSessionRequest) ProtoReflect ¶
func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
func (*CreateSessionRequest) Reset ¶
func (x *CreateSessionRequest) Reset()
func (*CreateSessionRequest) String ¶
func (x *CreateSessionRequest) String() string
type CreateSessionResponse ¶
type CreateSessionResponse struct { Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*CreateSessionResponse) Descriptor
deprecated
func (*CreateSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.
func (*CreateSessionResponse) GetSession ¶
func (x *CreateSessionResponse) GetSession() *Session
func (*CreateSessionResponse) ProtoMessage ¶
func (*CreateSessionResponse) ProtoMessage()
func (*CreateSessionResponse) ProtoReflect ¶
func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
func (*CreateSessionResponse) Reset ¶
func (x *CreateSessionResponse) Reset()
func (*CreateSessionResponse) String ¶
func (x *CreateSessionResponse) String() string
type DeleteSessionRequest ¶
type DeleteSessionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteSessionRequest) Descriptor
deprecated
func (*DeleteSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionRequest.ProtoReflect.Descriptor instead.
func (*DeleteSessionRequest) GetId ¶
func (x *DeleteSessionRequest) GetId() string
func (*DeleteSessionRequest) ProtoMessage ¶
func (*DeleteSessionRequest) ProtoMessage()
func (*DeleteSessionRequest) ProtoReflect ¶
func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
func (*DeleteSessionRequest) Reset ¶
func (x *DeleteSessionRequest) Reset()
func (*DeleteSessionRequest) String ¶
func (x *DeleteSessionRequest) String() string
type DeleteSessionResponse ¶
type DeleteSessionResponse struct {
// contains filtered or unexported fields
}
func (*DeleteSessionResponse) Descriptor
deprecated
func (*DeleteSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionResponse.ProtoReflect.Descriptor instead.
func (*DeleteSessionResponse) ProtoMessage ¶
func (*DeleteSessionResponse) ProtoMessage()
func (*DeleteSessionResponse) ProtoReflect ¶
func (x *DeleteSessionResponse) ProtoReflect() protoreflect.Message
func (*DeleteSessionResponse) Reset ¶
func (x *DeleteSessionResponse) Reset()
func (*DeleteSessionResponse) String ¶
func (x *DeleteSessionResponse) String() string
type ExecuteRequest ¶
type ExecuteRequest struct { // program_name is a name of the program to execute. // If it's not a path (relative or absolute), the runner // will try to resolve the name. // For example: "sh", "/bin/bash". ProgramName string `protobuf:"bytes,1,opt,name=program_name,json=programName,proto3" json:"program_name,omitempty"` // arguments is a list of arguments passed to the program. Arguments []string `protobuf:"bytes,2,rep,name=arguments,proto3" json:"arguments,omitempty"` // directory to execute the program in. Directory string `protobuf:"bytes,3,opt,name=directory,proto3" json:"directory,omitempty"` // envs is a list of additional environment variables // that will be injected to the executed program. Envs []string `protobuf:"bytes,4,rep,name=envs,proto3" json:"envs,omitempty"` // commands are commands to be executed by the program. // The commands are joined and executed as a script. // For example: "echo 'Hello, World'", "ls -l /etc". // This is mutually exclusive with the script field. Commands []string `protobuf:"bytes,5,rep,name=commands,proto3" json:"commands,omitempty"` // script is code to be executed by the program. // Individual lines are joined with the new line character. // This is mutually exclusive with the commands field. Script string `protobuf:"bytes,6,opt,name=script,proto3" json:"script,omitempty"` // tty when true allocates a pseudo-TTY. Tty bool `protobuf:"varint,7,opt,name=tty,proto3" json:"tty,omitempty"` // input_data is a byte array that will be send as input // to the program. InputData []byte `protobuf:"bytes,8,opt,name=input_data,json=inputData,proto3" json:"input_data,omitempty"` // stop requests the running process to be stopped. // It is allowed only in the consecutive calls. Stop ExecuteStop `protobuf:"varint,9,opt,name=stop,proto3,enum=runme.runner.v1.ExecuteStop" json:"stop,omitempty"` // sets pty winsize // has no effect in non-interactive mode Winsize *Winsize `protobuf:"bytes,10,opt,name=winsize,proto3,oneof" json:"winsize,omitempty"` // background indiciates a background process // this will send the process' PID as a first response Background bool `protobuf:"varint,11,opt,name=background,proto3" json:"background,omitempty"` // session_id indicates in which Session the program should execute. // Executing in a Session might provide additional context like // environment variables. SessionId string `protobuf:"bytes,20,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // strategy for selecting session SessionStrategy SessionStrategy `` /* 145-byte string literal not displayed */ // project for this runner // used to load environment variables from .env files Project *Project `protobuf:"bytes,22,opt,name=project,proto3,oneof" json:"project,omitempty"` // whether to store the stdout of the last ran // block in the environment variable `__` StoreLastOutput bool `protobuf:"varint,23,opt,name=store_last_output,json=storeLastOutput,proto3" json:"store_last_output,omitempty"` // contains filtered or unexported fields }
func (*ExecuteRequest) Descriptor
deprecated
func (*ExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
func (*ExecuteRequest) GetArguments ¶
func (x *ExecuteRequest) GetArguments() []string
func (*ExecuteRequest) GetBackground ¶ added in v1.0.1
func (x *ExecuteRequest) GetBackground() bool
func (*ExecuteRequest) GetCommands ¶
func (x *ExecuteRequest) GetCommands() []string
func (*ExecuteRequest) GetDirectory ¶
func (x *ExecuteRequest) GetDirectory() string
func (*ExecuteRequest) GetEnvs ¶
func (x *ExecuteRequest) GetEnvs() []string
func (*ExecuteRequest) GetInputData ¶
func (x *ExecuteRequest) GetInputData() []byte
func (*ExecuteRequest) GetProgramName ¶
func (x *ExecuteRequest) GetProgramName() string
func (*ExecuteRequest) GetProject ¶ added in v1.2.0
func (x *ExecuteRequest) GetProject() *Project
func (*ExecuteRequest) GetScript ¶
func (x *ExecuteRequest) GetScript() string
func (*ExecuteRequest) GetSessionId ¶
func (x *ExecuteRequest) GetSessionId() string
func (*ExecuteRequest) GetSessionStrategy ¶ added in v0.7.0
func (x *ExecuteRequest) GetSessionStrategy() SessionStrategy
func (*ExecuteRequest) GetStop ¶
func (x *ExecuteRequest) GetStop() ExecuteStop
func (*ExecuteRequest) GetStoreLastOutput ¶ added in v1.2.0
func (x *ExecuteRequest) GetStoreLastOutput() bool
func (*ExecuteRequest) GetTty ¶
func (x *ExecuteRequest) GetTty() bool
func (*ExecuteRequest) GetWinsize ¶ added in v0.6.2
func (x *ExecuteRequest) GetWinsize() *Winsize
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) ProtoReflect ¶
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
func (*ExecuteRequest) Reset ¶
func (x *ExecuteRequest) Reset()
func (*ExecuteRequest) String ¶
func (x *ExecuteRequest) String() string
type ExecuteResponse ¶
type ExecuteResponse struct { // exit_code is sent only in the final message. ExitCode *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // stdout_data contains bytes from stdout since the last response. StdoutData []byte `protobuf:"bytes,2,opt,name=stdout_data,json=stdoutData,proto3" json:"stdout_data,omitempty"` // stderr_data contains bytes from stderr since the last response. StderrData []byte `protobuf:"bytes,3,opt,name=stderr_data,json=stderrData,proto3" json:"stderr_data,omitempty"` // pid contains the process' PID // this is only sent once in an initial response for background processes. Pid *ProcessPID `protobuf:"bytes,4,opt,name=pid,proto3" json:"pid,omitempty"` // contains filtered or unexported fields }
func (*ExecuteResponse) Descriptor
deprecated
func (*ExecuteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
func (*ExecuteResponse) GetExitCode ¶
func (x *ExecuteResponse) GetExitCode() *wrapperspb.UInt32Value
func (*ExecuteResponse) GetPid ¶ added in v1.0.1
func (x *ExecuteResponse) GetPid() *ProcessPID
func (*ExecuteResponse) GetStderrData ¶
func (x *ExecuteResponse) GetStderrData() []byte
func (*ExecuteResponse) GetStdoutData ¶
func (x *ExecuteResponse) GetStdoutData() []byte
func (*ExecuteResponse) ProtoMessage ¶
func (*ExecuteResponse) ProtoMessage()
func (*ExecuteResponse) ProtoReflect ¶
func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
func (*ExecuteResponse) Reset ¶
func (x *ExecuteResponse) Reset()
func (*ExecuteResponse) String ¶
func (x *ExecuteResponse) String() string
type ExecuteStop ¶
type ExecuteStop int32
const ( ExecuteStop_EXECUTE_STOP_UNSPECIFIED ExecuteStop = 0 ExecuteStop_EXECUTE_STOP_INTERRUPT ExecuteStop = 1 ExecuteStop_EXECUTE_STOP_KILL ExecuteStop = 2 )
func (ExecuteStop) Descriptor ¶
func (ExecuteStop) Descriptor() protoreflect.EnumDescriptor
func (ExecuteStop) Enum ¶
func (x ExecuteStop) Enum() *ExecuteStop
func (ExecuteStop) EnumDescriptor
deprecated
func (ExecuteStop) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecuteStop.Descriptor instead.
func (ExecuteStop) Number ¶
func (x ExecuteStop) Number() protoreflect.EnumNumber
func (ExecuteStop) String ¶
func (x ExecuteStop) String() string
func (ExecuteStop) Type ¶
func (ExecuteStop) Type() protoreflect.EnumType
type GetSessionRequest ¶
type GetSessionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetSessionRequest) Descriptor
deprecated
func (*GetSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionRequest.ProtoReflect.Descriptor instead.
func (*GetSessionRequest) GetId ¶
func (x *GetSessionRequest) GetId() string
func (*GetSessionRequest) ProtoMessage ¶
func (*GetSessionRequest) ProtoMessage()
func (*GetSessionRequest) ProtoReflect ¶
func (x *GetSessionRequest) ProtoReflect() protoreflect.Message
func (*GetSessionRequest) Reset ¶
func (x *GetSessionRequest) Reset()
func (*GetSessionRequest) String ¶
func (x *GetSessionRequest) String() string
type GetSessionResponse ¶
type GetSessionResponse struct { Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*GetSessionResponse) Descriptor
deprecated
func (*GetSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionResponse.ProtoReflect.Descriptor instead.
func (*GetSessionResponse) GetSession ¶
func (x *GetSessionResponse) GetSession() *Session
func (*GetSessionResponse) ProtoMessage ¶
func (*GetSessionResponse) ProtoMessage()
func (*GetSessionResponse) ProtoReflect ¶
func (x *GetSessionResponse) ProtoReflect() protoreflect.Message
func (*GetSessionResponse) Reset ¶
func (x *GetSessionResponse) Reset()
func (*GetSessionResponse) String ¶
func (x *GetSessionResponse) String() string
type ListSessionsRequest ¶
type ListSessionsRequest struct {
// contains filtered or unexported fields
}
func (*ListSessionsRequest) Descriptor
deprecated
func (*ListSessionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSessionsRequest.ProtoReflect.Descriptor instead.
func (*ListSessionsRequest) ProtoMessage ¶
func (*ListSessionsRequest) ProtoMessage()
func (*ListSessionsRequest) ProtoReflect ¶
func (x *ListSessionsRequest) ProtoReflect() protoreflect.Message
func (*ListSessionsRequest) Reset ¶
func (x *ListSessionsRequest) Reset()
func (*ListSessionsRequest) String ¶
func (x *ListSessionsRequest) String() string
type ListSessionsResponse ¶
type ListSessionsResponse struct { Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"` // contains filtered or unexported fields }
func (*ListSessionsResponse) Descriptor
deprecated
func (*ListSessionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSessionsResponse.ProtoReflect.Descriptor instead.
func (*ListSessionsResponse) GetSessions ¶
func (x *ListSessionsResponse) GetSessions() []*Session
func (*ListSessionsResponse) ProtoMessage ¶
func (*ListSessionsResponse) ProtoMessage()
func (*ListSessionsResponse) ProtoReflect ¶
func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message
func (*ListSessionsResponse) Reset ¶
func (x *ListSessionsResponse) Reset()
func (*ListSessionsResponse) String ¶
func (x *ListSessionsResponse) String() string
type ProcessPID ¶ added in v1.0.1
type ProcessPID struct { Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` // contains filtered or unexported fields }
func (*ProcessPID) Descriptor
deprecated
added in
v1.0.1
func (*ProcessPID) Descriptor() ([]byte, []int)
Deprecated: Use ProcessPID.ProtoReflect.Descriptor instead.
func (*ProcessPID) GetPid ¶ added in v1.0.1
func (x *ProcessPID) GetPid() int64
func (*ProcessPID) ProtoMessage ¶ added in v1.0.1
func (*ProcessPID) ProtoMessage()
func (*ProcessPID) ProtoReflect ¶ added in v1.0.1
func (x *ProcessPID) ProtoReflect() protoreflect.Message
func (*ProcessPID) Reset ¶ added in v1.0.1
func (x *ProcessPID) Reset()
func (*ProcessPID) String ¶ added in v1.0.1
func (x *ProcessPID) String() string
type Project ¶ added in v1.2.0
type Project struct { // project root folder Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"` // list of environment files to try and load // start with EnvLoadOrder []string `protobuf:"bytes,2,rep,name=env_load_order,json=envLoadOrder,proto3" json:"env_load_order,omitempty"` // contains filtered or unexported fields }
func (*Project) Descriptor
deprecated
added in
v1.2.0
func (*Project) GetEnvLoadOrder ¶ added in v1.2.0
func (*Project) ProtoMessage ¶ added in v1.2.0
func (*Project) ProtoMessage()
func (*Project) ProtoReflect ¶ added in v1.2.0
func (x *Project) ProtoReflect() protoreflect.Message
type RunnerServiceClient ¶
type RunnerServiceClient interface { CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error) GetSession(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error) ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) DeleteSession(ctx context.Context, in *DeleteSessionRequest, opts ...grpc.CallOption) (*DeleteSessionResponse, error) // Execute executes a program. Examine "ExecuteRequest" to explore // configuration options. // // It's a bidirectional stream RPC method. It expects the first // "ExecuteRequest" to contain details of a program to execute. // Subsequent "ExecuteRequest" should only contain "input_data" as // other fields will be ignored. Execute(ctx context.Context, opts ...grpc.CallOption) (RunnerService_ExecuteClient, error) }
RunnerServiceClient is the client API for RunnerService 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 NewRunnerServiceClient ¶
func NewRunnerServiceClient(cc grpc.ClientConnInterface) RunnerServiceClient
type RunnerServiceServer ¶
type RunnerServiceServer interface { CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) DeleteSession(context.Context, *DeleteSessionRequest) (*DeleteSessionResponse, error) // Execute executes a program. Examine "ExecuteRequest" to explore // configuration options. // // It's a bidirectional stream RPC method. It expects the first // "ExecuteRequest" to contain details of a program to execute. // Subsequent "ExecuteRequest" should only contain "input_data" as // other fields will be ignored. Execute(RunnerService_ExecuteServer) error // contains filtered or unexported methods }
RunnerServiceServer is the server API for RunnerService service. All implementations must embed UnimplementedRunnerServiceServer for forward compatibility
type RunnerService_ExecuteClient ¶
type RunnerService_ExecuteClient interface { Send(*ExecuteRequest) error Recv() (*ExecuteResponse, error) grpc.ClientStream }
type RunnerService_ExecuteServer ¶
type RunnerService_ExecuteServer interface { Send(*ExecuteResponse) error Recv() (*ExecuteRequest, error) grpc.ServerStream }
type Session ¶
type Session struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // envs keeps track of session environment variables. // They can be modified by executing programs which // alter them through "export" and "unset" commands. Envs []string `protobuf:"bytes,2,rep,name=envs,proto3" json:"envs,omitempty"` // metadata is a map of client specific metadata. Metadata map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Session) Descriptor
deprecated
func (*Session) GetMetadata ¶
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SessionStrategy ¶ added in v0.7.0
type SessionStrategy int32
strategy for selecting a session in an initial execute request
const ( // uses session_id field to determine session // if none is present, a new session is created SessionStrategy_SESSION_STRATEGY_UNSPECIFIED SessionStrategy = 0 // uses most recently used session on the grpc server // if there is none, a new one is created SessionStrategy_SESSION_STRATEGY_MOST_RECENT SessionStrategy = 1 )
func (SessionStrategy) Descriptor ¶ added in v0.7.0
func (SessionStrategy) Descriptor() protoreflect.EnumDescriptor
func (SessionStrategy) Enum ¶ added in v0.7.0
func (x SessionStrategy) Enum() *SessionStrategy
func (SessionStrategy) EnumDescriptor
deprecated
added in
v0.7.0
func (SessionStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use SessionStrategy.Descriptor instead.
func (SessionStrategy) Number ¶ added in v0.7.0
func (x SessionStrategy) Number() protoreflect.EnumNumber
func (SessionStrategy) String ¶ added in v0.7.0
func (x SessionStrategy) String() string
func (SessionStrategy) Type ¶ added in v0.7.0
func (SessionStrategy) Type() protoreflect.EnumType
type UnimplementedRunnerServiceServer ¶
type UnimplementedRunnerServiceServer struct { }
UnimplementedRunnerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRunnerServiceServer) CreateSession ¶
func (UnimplementedRunnerServiceServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
func (UnimplementedRunnerServiceServer) DeleteSession ¶
func (UnimplementedRunnerServiceServer) DeleteSession(context.Context, *DeleteSessionRequest) (*DeleteSessionResponse, error)
func (UnimplementedRunnerServiceServer) Execute ¶
func (UnimplementedRunnerServiceServer) Execute(RunnerService_ExecuteServer) error
func (UnimplementedRunnerServiceServer) GetSession ¶
func (UnimplementedRunnerServiceServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
func (UnimplementedRunnerServiceServer) ListSessions ¶
func (UnimplementedRunnerServiceServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
type UnsafeRunnerServiceServer ¶
type UnsafeRunnerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRunnerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunnerServiceServer will result in compilation errors.
type Winsize ¶ added in v0.6.2
type Winsize struct { // number of rows (in cells) Rows uint32 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"` // number of columns (in cells) Cols uint32 `protobuf:"varint,2,opt,name=cols,proto3" json:"cols,omitempty"` // width in pixels X uint32 `protobuf:"varint,3,opt,name=x,proto3" json:"x,omitempty"` // height in pixels Y uint32 `protobuf:"varint,4,opt,name=y,proto3" json:"y,omitempty"` // contains filtered or unexported fields }
func (*Winsize) Descriptor
deprecated
added in
v0.6.2
func (*Winsize) ProtoMessage ¶ added in v0.6.2
func (*Winsize) ProtoMessage()
func (*Winsize) ProtoReflect ¶ added in v0.6.2
func (x *Winsize) ProtoReflect() protoreflect.Message