runnerv2alpha1

package
v3.2.7 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RunnerService_CreateSession_FullMethodName  = "/runme.runner.v2alpha1.RunnerService/CreateSession"
	RunnerService_GetSession_FullMethodName     = "/runme.runner.v2alpha1.RunnerService/GetSession"
	RunnerService_ListSessions_FullMethodName   = "/runme.runner.v2alpha1.RunnerService/ListSessions"
	RunnerService_UpdateSession_FullMethodName  = "/runme.runner.v2alpha1.RunnerService/UpdateSession"
	RunnerService_DeleteSession_FullMethodName  = "/runme.runner.v2alpha1.RunnerService/DeleteSession"
	RunnerService_Execute_FullMethodName        = "/runme.runner.v2alpha1.RunnerService/Execute"
	RunnerService_ResolveProgram_FullMethodName = "/runme.runner.v2alpha1.RunnerService/ResolveProgram"
)

Variables

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

Enum value maps for CommandMode.

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 (
	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 (
	ResolveProgramRequest_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "MODE_PROMPT_ALL",
		2: "MODE_SKIP_ALL",
	}
	ResolveProgramRequest_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"MODE_PROMPT_ALL":  1,
		"MODE_SKIP_ALL":    2,
	}
)

Enum value maps for ResolveProgramRequest_Mode.

View Source
var (
	ResolveProgramResponse_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_UNRESOLVED_WITH_MESSAGE",
		2: "STATUS_UNRESOLVED_WITH_PLACEHOLDER",
		3: "STATUS_RESOLVED",
	}
	ResolveProgramResponse_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED":                 0,
		"STATUS_UNRESOLVED_WITH_MESSAGE":     1,
		"STATUS_UNRESOLVED_WITH_PLACEHOLDER": 2,
		"STATUS_RESOLVED":                    3,
	}
)

Enum value maps for ResolveProgramResponse_Status.

View Source
var File_runme_runner_v2alpha1_config_proto protoreflect.FileDescriptor
View Source
var File_runme_runner_v2alpha1_runner_proto protoreflect.FileDescriptor
View Source
var RunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runme.runner.v2alpha1.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: "UpdateSession",
			Handler:    _RunnerService_UpdateSession_Handler,
		},
		{
			MethodName: "DeleteSession",
			Handler:    _RunnerService_DeleteSession_Handler,
		},
		{
			MethodName: "ResolveProgram",
			Handler:    _RunnerService_ResolveProgram_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _RunnerService_Execute_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "runme/runner/v2alpha1/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

type CommandMode int32
const (
	CommandMode_COMMAND_MODE_UNSPECIFIED CommandMode = 0
	CommandMode_COMMAND_MODE_INLINE      CommandMode = 1
	CommandMode_COMMAND_MODE_FILE        CommandMode = 2
)

func (CommandMode) Descriptor

func (CommandMode) Enum

func (x CommandMode) Enum() *CommandMode

func (CommandMode) EnumDescriptor deprecated

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

Deprecated: Use CommandMode.Descriptor instead.

func (CommandMode) Number

func (x CommandMode) Number() protoreflect.EnumNumber

func (CommandMode) String

func (x CommandMode) String() string

func (CommandMode) Type

type CreateSessionRequest

type CreateSessionRequest struct {

	// metadata is a map of client specific metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// env field provides an initial set of environment variables
	// for a newly created session.
	Env []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	// project from which to load environment variables.
	// They will be appended to the list from the env field.
	// The env field has a higher priority.
	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) GetEnv

func (x *CreateSessionRequest) GetEnv() []string

func (*CreateSessionRequest) GetMetadata

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

func (*CreateSessionRequest) GetProject

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 {
	Config *ProgramConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,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.v2alpha1.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"`
	// 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"`
	// session_strategy is a strategy for selecting the session.
	SessionStrategy SessionStrategy `` /* 151-byte string literal not displayed */
	// project used to load environment variables from .env files.
	Project *Project `protobuf:"bytes,22,opt,name=project,proto3,oneof" json:"project,omitempty"`
	// store_stdout_in_env, if true, will store the stdout under well known name
	// and the last ran block in the environment variable `__`.
	StoreStdoutInEnv bool `protobuf:"varint,23,opt,name=store_stdout_in_env,json=storeStdoutInEnv,proto3" json:"store_stdout_in_env,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetConfig

func (x *ExecuteRequest) GetConfig() *ProgramConfig

func (*ExecuteRequest) GetInputData

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

func (*ExecuteRequest) GetProject

func (x *ExecuteRequest) GetProject() *Project

func (*ExecuteRequest) GetSessionId

func (x *ExecuteRequest) GetSessionId() string

func (*ExecuteRequest) GetSessionStrategy

func (x *ExecuteRequest) GetSessionStrategy() SessionStrategy

func (*ExecuteRequest) GetStop

func (x *ExecuteRequest) GetStop() ExecuteStop

func (*ExecuteRequest) GetStoreStdoutInEnv added in v3.2.7

func (x *ExecuteRequest) GetStoreStdoutInEnv() bool

func (*ExecuteRequest) GetWinsize

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 *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=pid,proto3" json:"pid,omitempty"`
	// mime_type is a detected MIME type of the stdout_data.
	//
	// This is only sent once in the first response containing stdout_data.
	MimeType string `protobuf:"bytes,5,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,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) GetMimeType added in v3.2.6

func (x *ExecuteResponse) GetMimeType() string

func (*ExecuteResponse) GetPid

func (x *ExecuteResponse) GetPid() *wrapperspb.UInt32Value

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

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 ProgramConfig

type ProgramConfig 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"`
	// env is a list of additional environment variables
	// that will be injected to the executed program.
	Env []string `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	// Types that are assignable to Source:
	//
	//	*ProgramConfig_Commands
	//	*ProgramConfig_Script
	Source isProgramConfig_Source `protobuf_oneof:"source"`
	// interactive, if true, uses a pseudo-tty to execute the program.
	// Otherwise, the program is executed using in-memory buffers for I/O.
	Interactive bool `protobuf:"varint,7,opt,name=interactive,proto3" json:"interactive,omitempty"`
	// TODO(adamb): understand motivation for this. In theory, source
	// should tell whether to execute it inline or as a file.
	Mode CommandMode `protobuf:"varint,8,opt,name=mode,proto3,enum=runme.runner.v2alpha1.CommandMode" json:"mode,omitempty"`
	// optional well known id for cell/block
	KnownId string `protobuf:"bytes,9,opt,name=known_id,json=knownId,proto3" json:"known_id,omitempty"`
	// optional well known name for cell/block
	KnownName string `protobuf:"bytes,10,opt,name=known_name,json=knownName,proto3" json:"known_name,omitempty"`
	// contains filtered or unexported fields
}

ProgramConfig is a configuration for a program to execute. From this configuration, any program can be built.

func (*ProgramConfig) Descriptor deprecated

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

Deprecated: Use ProgramConfig.ProtoReflect.Descriptor instead.

func (*ProgramConfig) GetArguments

func (x *ProgramConfig) GetArguments() []string

func (*ProgramConfig) GetCommands

func (x *ProgramConfig) GetCommands() *ProgramConfig_CommandList

func (*ProgramConfig) GetDirectory

func (x *ProgramConfig) GetDirectory() string

func (*ProgramConfig) GetEnv

func (x *ProgramConfig) GetEnv() []string

func (*ProgramConfig) GetInteractive

func (x *ProgramConfig) GetInteractive() bool

func (*ProgramConfig) GetKnownId added in v3.2.7

func (x *ProgramConfig) GetKnownId() string

func (*ProgramConfig) GetKnownName added in v3.2.7

func (x *ProgramConfig) GetKnownName() string

func (*ProgramConfig) GetMode

func (x *ProgramConfig) GetMode() CommandMode

func (*ProgramConfig) GetProgramName

func (x *ProgramConfig) GetProgramName() string

func (*ProgramConfig) GetScript

func (x *ProgramConfig) GetScript() string

func (*ProgramConfig) GetSource

func (m *ProgramConfig) GetSource() isProgramConfig_Source

func (*ProgramConfig) ProtoMessage

func (*ProgramConfig) ProtoMessage()

func (*ProgramConfig) ProtoReflect

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

func (*ProgramConfig) Reset

func (x *ProgramConfig) Reset()

func (*ProgramConfig) String

func (x *ProgramConfig) String() string

type ProgramConfig_CommandList

type ProgramConfig_CommandList struct {

	// 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"].
	Items []string `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ProgramConfig_CommandList) Descriptor deprecated

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

Deprecated: Use ProgramConfig_CommandList.ProtoReflect.Descriptor instead.

func (*ProgramConfig_CommandList) GetItems

func (x *ProgramConfig_CommandList) GetItems() []string

func (*ProgramConfig_CommandList) ProtoMessage

func (*ProgramConfig_CommandList) ProtoMessage()

func (*ProgramConfig_CommandList) ProtoReflect

func (*ProgramConfig_CommandList) Reset

func (x *ProgramConfig_CommandList) Reset()

func (*ProgramConfig_CommandList) String

func (x *ProgramConfig_CommandList) String() string

type ProgramConfig_Commands

type ProgramConfig_Commands struct {
	// commands are commands to be executed by the program.
	// The commands are joined and executed as a script.
	Commands *ProgramConfig_CommandList `protobuf:"bytes,5,opt,name=commands,proto3,oneof"`
}

type ProgramConfig_Script

type ProgramConfig_Script struct {
	// script is code to be executed by the program.
	// Individual lines are joined with the new line character.
	Script string `protobuf:"bytes,6,opt,name=script,proto3,oneof"`
}

type Project

type Project struct {

	// root is a root directory of the project.
	// The semantic is the same as for the "--project"
	// flag in "runme".
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// env_load_order is list of environment files
	// to try and load env from.
	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

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetEnvLoadOrder

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

func (*Project) GetRoot

func (x *Project) GetRoot() string

func (*Project) ProtoMessage

func (*Project) ProtoMessage()

func (*Project) ProtoReflect

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

func (*Project) Reset

func (x *Project) Reset()

func (*Project) String

func (x *Project) String() string

type ResolveProgramCommandList

type ResolveProgramCommandList struct {

	// 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"].
	Lines []string `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveProgramCommandList) Descriptor deprecated

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

Deprecated: Use ResolveProgramCommandList.ProtoReflect.Descriptor instead.

func (*ResolveProgramCommandList) GetLines

func (x *ResolveProgramCommandList) GetLines() []string

func (*ResolveProgramCommandList) ProtoMessage

func (*ResolveProgramCommandList) ProtoMessage()

func (*ResolveProgramCommandList) ProtoReflect

func (*ResolveProgramCommandList) Reset

func (x *ResolveProgramCommandList) Reset()

func (*ResolveProgramCommandList) String

func (x *ResolveProgramCommandList) String() string

type ResolveProgramRequest

type ResolveProgramRequest struct {

	// use script for unnormalized cell content
	// whereas commands is for normalized shell commands
	//
	// Types that are assignable to Source:
	//
	//	*ResolveProgramRequest_Commands
	//	*ResolveProgramRequest_Script
	Source isResolveProgramRequest_Source `protobuf_oneof:"source"`
	// mode determines how variables resolution occurs.
	// It is usually based on document or cell annotation config.
	Mode ResolveProgramRequest_Mode `protobuf:"varint,3,opt,name=mode,proto3,enum=runme.runner.v2alpha1.ResolveProgramRequest_Mode" json:"mode,omitempty"`
	// env is a list of explicit environment variables that will be used
	// to resolve the environment variables found in the source.
	Env []string `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	// session_id indicates which session is the source of
	// environment variables. If not provided, the most recent
	// session can be used using session_strategy.
	SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// session_strategy is a strategy for selecting the session.
	SessionStrategy SessionStrategy `` /* 150-byte string literal not displayed */
	// project used to load environment variables from .env files.
	Project *Project `protobuf:"bytes,7,opt,name=project,proto3,oneof" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveProgramRequest) Descriptor deprecated

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

Deprecated: Use ResolveProgramRequest.ProtoReflect.Descriptor instead.

func (*ResolveProgramRequest) GetCommands

func (*ResolveProgramRequest) GetEnv

func (x *ResolveProgramRequest) GetEnv() []string

func (*ResolveProgramRequest) GetMode

func (*ResolveProgramRequest) GetProject

func (x *ResolveProgramRequest) GetProject() *Project

func (*ResolveProgramRequest) GetScript

func (x *ResolveProgramRequest) GetScript() string

func (*ResolveProgramRequest) GetSessionId

func (x *ResolveProgramRequest) GetSessionId() string

func (*ResolveProgramRequest) GetSessionStrategy

func (x *ResolveProgramRequest) GetSessionStrategy() SessionStrategy

func (*ResolveProgramRequest) GetSource

func (m *ResolveProgramRequest) GetSource() isResolveProgramRequest_Source

func (*ResolveProgramRequest) ProtoMessage

func (*ResolveProgramRequest) ProtoMessage()

func (*ResolveProgramRequest) ProtoReflect

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

func (*ResolveProgramRequest) Reset

func (x *ResolveProgramRequest) Reset()

func (*ResolveProgramRequest) String

func (x *ResolveProgramRequest) String() string

type ResolveProgramRequest_Commands

type ResolveProgramRequest_Commands struct {
	// commands are commands to be executed by the program.
	// The commands are joined and executed as a script.
	Commands *ResolveProgramCommandList `protobuf:"bytes,1,opt,name=commands,proto3,oneof"`
}

type ResolveProgramRequest_Mode

type ResolveProgramRequest_Mode int32
const (
	// unspecified is auto (default) which prompts for all
	// unresolved environment variables.
	// Subsequent runs will likely resolve via the session.
	ResolveProgramRequest_MODE_UNSPECIFIED ResolveProgramRequest_Mode = 0
	// prompt always means to prompt for all environment variables.
	ResolveProgramRequest_MODE_PROMPT_ALL ResolveProgramRequest_Mode = 1
	// skip means to not prompt for any environment variables.
	// All variables will be marked as resolved.
	ResolveProgramRequest_MODE_SKIP_ALL ResolveProgramRequest_Mode = 2
)

func (ResolveProgramRequest_Mode) Descriptor

func (ResolveProgramRequest_Mode) Enum

func (ResolveProgramRequest_Mode) EnumDescriptor deprecated

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

Deprecated: Use ResolveProgramRequest_Mode.Descriptor instead.

func (ResolveProgramRequest_Mode) Number

func (ResolveProgramRequest_Mode) String

func (ResolveProgramRequest_Mode) Type

type ResolveProgramRequest_Script

type ResolveProgramRequest_Script struct {
	// script is code to be executed by the program.
	// Individual lines are joined with the new line character.
	Script string `protobuf:"bytes,2,opt,name=script,proto3,oneof"`
}

type ResolveProgramResponse

type ResolveProgramResponse struct {
	Script string `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	// use script until commands normalization is implemented
	Commands *ResolveProgramCommandList          `protobuf:"bytes,2,opt,name=commands,proto3" json:"commands,omitempty"`
	Vars     []*ResolveProgramResponse_VarResult `protobuf:"bytes,3,rep,name=vars,proto3" json:"vars,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveProgramResponse) Descriptor deprecated

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

Deprecated: Use ResolveProgramResponse.ProtoReflect.Descriptor instead.

func (*ResolveProgramResponse) GetCommands

func (*ResolveProgramResponse) GetScript

func (x *ResolveProgramResponse) GetScript() string

func (*ResolveProgramResponse) GetVars

func (*ResolveProgramResponse) ProtoMessage

func (*ResolveProgramResponse) ProtoMessage()

func (*ResolveProgramResponse) ProtoReflect

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

func (*ResolveProgramResponse) Reset

func (x *ResolveProgramResponse) Reset()

func (*ResolveProgramResponse) String

func (x *ResolveProgramResponse) String() string

type ResolveProgramResponse_Status

type ResolveProgramResponse_Status int32
const (
	// unspecified is the default value and it means unresolved.
	ResolveProgramResponse_STATUS_UNSPECIFIED ResolveProgramResponse_Status = 0
	// unresolved with message means that the variable is unresolved
	// but it contains a message. E.g. FOO=this is message
	ResolveProgramResponse_STATUS_UNRESOLVED_WITH_MESSAGE ResolveProgramResponse_Status = 1
	// unresolved with placeholder means that the variable is unresolved
	// but it contains a placeholder. E.g. FOO="this is placeholder"
	ResolveProgramResponse_STATUS_UNRESOLVED_WITH_PLACEHOLDER ResolveProgramResponse_Status = 2
	// resolved means that the variable is resolved.
	ResolveProgramResponse_STATUS_RESOLVED ResolveProgramResponse_Status = 3
)

func (ResolveProgramResponse_Status) Descriptor

func (ResolveProgramResponse_Status) Enum

func (ResolveProgramResponse_Status) EnumDescriptor deprecated

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

Deprecated: Use ResolveProgramResponse_Status.Descriptor instead.

func (ResolveProgramResponse_Status) Number

func (ResolveProgramResponse_Status) String

func (ResolveProgramResponse_Status) Type

type ResolveProgramResponse_VarResult

type ResolveProgramResponse_VarResult struct {

	// prompt indicates the resolution status of the env variable.
	Status ResolveProgramResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=runme.runner.v2alpha1.ResolveProgramResponse_Status" json:"status,omitempty"`
	// name is the name of the environment variable.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// original_value is a default value of the environment variable.
	// It might be a value that is assigned to the variable in the script,
	// like FOO=bar or FOO=${FOO:-bar}.
	// If the variable is not assigned, it is an empty string.
	OriginalValue string `protobuf:"bytes,3,opt,name=original_value,json=originalValue,proto3" json:"original_value,omitempty"`
	// resolved_value is a value of the environment variable resolved from a source.
	// If it is an empty string, it means that the environment variable is not resolved.
	ResolvedValue string `protobuf:"bytes,4,opt,name=resolved_value,json=resolvedValue,proto3" json:"resolved_value,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveProgramResponse_VarResult) Descriptor deprecated

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

Deprecated: Use ResolveProgramResponse_VarResult.ProtoReflect.Descriptor instead.

func (*ResolveProgramResponse_VarResult) GetName

func (*ResolveProgramResponse_VarResult) GetOriginalValue

func (x *ResolveProgramResponse_VarResult) GetOriginalValue() string

func (*ResolveProgramResponse_VarResult) GetResolvedValue

func (x *ResolveProgramResponse_VarResult) GetResolvedValue() string

func (*ResolveProgramResponse_VarResult) GetStatus

func (*ResolveProgramResponse_VarResult) ProtoMessage

func (*ResolveProgramResponse_VarResult) ProtoMessage()

func (*ResolveProgramResponse_VarResult) ProtoReflect

func (*ResolveProgramResponse_VarResult) Reset

func (*ResolveProgramResponse_VarResult) 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)
	UpdateSession(ctx context.Context, in *UpdateSessionRequest, opts ...grpc.CallOption) (*UpdateSessionResponse, 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)
	// ResolveProgram resolves variables from a script or a list of commands
	// using the provided sources, which can be a list of environment variables,
	// a session, or a project.
	// For now, the resolved variables are only the exported ones using `export`.
	ResolveProgram(ctx context.Context, in *ResolveProgramRequest, opts ...grpc.CallOption) (*ResolveProgramResponse, 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.

type RunnerServiceServer

type RunnerServiceServer interface {
	CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
	GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
	ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
	UpdateSession(context.Context, *UpdateSessionRequest) (*UpdateSessionResponse, 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
	// ResolveProgram resolves variables from a script or a list of commands
	// using the provided sources, which can be a list of environment variables,
	// a session, or a project.
	// For now, the resolved variables are only the exported ones using `export`.
	ResolveProgram(context.Context, *ResolveProgramRequest) (*ResolveProgramResponse, 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"`
	// env keeps track of session environment variables.
	// They can be modified by executing programs which
	// alter them through "export" and "unset" commands.
	Env []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,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) GetEnv

func (x *Session) GetEnv() []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

type SessionStrategy int32

SessionStrategy determines a session selection in an initial execute request.

const (
	// Uses the session_id field to determine the session.
	// If none is present, a new session is created.
	SessionStrategy_SESSION_STRATEGY_UNSPECIFIED SessionStrategy = 0
	// Uses the most recent session on the server.
	// If there is none, a new one is created.
	SessionStrategy_SESSION_STRATEGY_MOST_RECENT SessionStrategy = 1
)

func (SessionStrategy) Descriptor

func (SessionStrategy) Enum

func (x SessionStrategy) Enum() *SessionStrategy

func (SessionStrategy) EnumDescriptor deprecated

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

Deprecated: Use SessionStrategy.Descriptor instead.

func (SessionStrategy) Number

func (SessionStrategy) String

func (x SessionStrategy) String() string

func (SessionStrategy) Type

type UnimplementedRunnerServiceServer

type UnimplementedRunnerServiceServer struct {
}

UnimplementedRunnerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRunnerServiceServer) CreateSession

func (UnimplementedRunnerServiceServer) DeleteSession

func (UnimplementedRunnerServiceServer) Execute

func (UnimplementedRunnerServiceServer) GetSession

func (UnimplementedRunnerServiceServer) ListSessions

func (UnimplementedRunnerServiceServer) ResolveProgram

func (UnimplementedRunnerServiceServer) UpdateSession

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 UpdateSessionRequest

type UpdateSessionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// metadata is a map of client specific metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// env field provides an initial set of environment variables
	// for a newly created session.
	Env []string `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
	// project from which to load environment variables.
	// They will be appended to the list from the env field.
	// The env field has a higher priority.
	Project *Project `protobuf:"bytes,4,opt,name=project,proto3,oneof" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSessionRequest) Descriptor deprecated

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

Deprecated: Use UpdateSessionRequest.ProtoReflect.Descriptor instead.

func (*UpdateSessionRequest) GetEnv

func (x *UpdateSessionRequest) GetEnv() []string

func (*UpdateSessionRequest) GetId

func (x *UpdateSessionRequest) GetId() string

func (*UpdateSessionRequest) GetMetadata

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

func (*UpdateSessionRequest) GetProject

func (x *UpdateSessionRequest) GetProject() *Project

func (*UpdateSessionRequest) ProtoMessage

func (*UpdateSessionRequest) ProtoMessage()

func (*UpdateSessionRequest) ProtoReflect

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

func (*UpdateSessionRequest) Reset

func (x *UpdateSessionRequest) Reset()

func (*UpdateSessionRequest) String

func (x *UpdateSessionRequest) String() string

type UpdateSessionResponse

type UpdateSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSessionResponse) Descriptor deprecated

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

Deprecated: Use UpdateSessionResponse.ProtoReflect.Descriptor instead.

func (*UpdateSessionResponse) GetSession

func (x *UpdateSessionResponse) GetSession() *Session

func (*UpdateSessionResponse) ProtoMessage

func (*UpdateSessionResponse) ProtoMessage()

func (*UpdateSessionResponse) ProtoReflect

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

func (*UpdateSessionResponse) Reset

func (x *UpdateSessionResponse) Reset()

func (*UpdateSessionResponse) String

func (x *UpdateSessionResponse) String() string

type Winsize

type Winsize struct {
	Rows uint32 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols uint32 `protobuf:"varint,2,opt,name=cols,proto3" json:"cols,omitempty"`
	X    uint32 `protobuf:"varint,3,opt,name=x,proto3" json:"x,omitempty"`
	Y    uint32 `protobuf:"varint,4,opt,name=y,proto3" json:"y,omitempty"`
	// contains filtered or unexported fields
}

func (*Winsize) Descriptor deprecated

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

Deprecated: Use Winsize.ProtoReflect.Descriptor instead.

func (*Winsize) GetCols

func (x *Winsize) GetCols() uint32

func (*Winsize) GetRows

func (x *Winsize) GetRows() uint32

func (*Winsize) GetX

func (x *Winsize) GetX() uint32

func (*Winsize) GetY

func (x *Winsize) GetY() uint32

func (*Winsize) ProtoMessage

func (*Winsize) ProtoMessage()

func (*Winsize) ProtoReflect

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

func (*Winsize) Reset

func (x *Winsize) Reset()

func (*Winsize) String

func (x *Winsize) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL