runnerv1

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

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

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

View Source 
var (
	CommandMode_name = map[int32]string{
		0: "COMMAND_MODE_UNSPECIFIED",
		1: "COMMAND_MODE_INLINE_SHELL",
		2: "COMMAND_MODE_TEMP_FILE",
	}
	CommandMode_value = map[string]int32{
		"COMMAND_MODE_UNSPECIFIED":  0,
		"COMMAND_MODE_INLINE_SHELL": 1,
		"COMMAND_MODE_TEMP_FILE":    2,
	}
)

Enum value maps for CommandMode.

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

View Source 
var File_runme_runner_v1_runner_proto protoreflect.FileDescriptor
View Source 
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 CommandMode added in v1.6.0 

type CommandMode int32
const (
	CommandMode_COMMAND_MODE_UNSPECIFIED  CommandMode = 0
	CommandMode_COMMAND_MODE_INLINE_SHELL CommandMode = 1
	CommandMode_COMMAND_MODE_TEMP_FILE    CommandMode = 2
)

func (CommandMode) Descriptor added in v1.6.0 

func (CommandMode) Descriptor() protoreflect.EnumDescriptor

func (CommandMode) Enum added in v1.6.0 

func (x CommandMode) Enum() *CommandMode

func (CommandMode) EnumDescriptor deprecated added in v1.6.0 

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

Deprecated: Use CommandMode.Descriptor instead.

func (CommandMode) Number added in v1.6.0 

func (x CommandMode) Number() protoreflect.EnumNumber

func (CommandMode) String added in v1.6.0 

func (x CommandMode) String() string

func (CommandMode) Type added in v1.6.0 

func (CommandMode) Type() protoreflect.EnumType

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"`
	// optional project from which to immediately load environment variables
	Project *Project `protobuf:"bytes,3,opt,name=project,proto3,oneof" json:"project,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) GetProject added in v1.4.0 

func (x *CreateSessionRequest) GetProject() *Project

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"`
	CommandMode     CommandMode `` /* 129-byte string literal not displayed */
	// language id associated with script
	LanguageId string `protobuf:"bytes,25,opt,name=language_id,json=languageId,proto3" json:"language_id,omitempty"`
	// file extension associated with script
	FileExtension string `protobuf:"bytes,26,opt,name=file_extension,json=fileExtension,proto3" json:"file_extension,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) GetCommandMode added in v1.6.0 

func (x *ExecuteRequest) GetCommandMode() CommandMode

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) GetFileExtension added in v1.6.0 

func (x *ExecuteRequest) GetFileExtension() string

func (*ExecuteRequest) GetInputData 

func (x *ExecuteRequest) GetInputData() []byte

func (*ExecuteRequest) GetLanguageId added in v1.6.0 

func (x *ExecuteRequest) GetLanguageId() string

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetEnvLoadOrder added in v1.2.0 

func (x *Project) GetEnvLoadOrder() []string

func (*Project) GetRoot added in v1.2.0 

func (x *Project) GetRoot() string

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

func (*Project) Reset added in v1.2.0 

func (x *Project) Reset()

func (*Project) String added in v1.2.0 

func (x *Project) String() string

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetEnvs 

func (x *Session) GetEnvs() []string

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetMetadata 

func (x *Session) GetMetadata() map[string]string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

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

Deprecated: Use Winsize.ProtoReflect.Descriptor instead.

func (*Winsize) GetCols added in v0.6.2 

func (x *Winsize) GetCols() uint32

func (*Winsize) GetRows added in v0.6.2 

func (x *Winsize) GetRows() uint32

func (*Winsize) GetX added in v0.6.2 

func (x *Winsize) GetX() uint32

func (*Winsize) GetY added in v0.6.2 

func (x *Winsize) GetY() uint32

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

func (*Winsize) Reset added in v0.6.2 

func (x *Winsize) Reset()

func (*Winsize) String added in v0.6.2 

func (x *Winsize) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.