Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGoProcServer(s grpc.ServiceRegistrar, srv GoProcServer)
- type ExecProcessExited
- func (*ExecProcessExited) Descriptor() ([]byte, []int)deprecated
- func (x *ExecProcessExited) GetErrorMsg() string
- func (x *ExecProcessExited) GetExitCode() int32
- func (x *ExecProcessExited) GetPid() int32
- func (*ExecProcessExited) ProtoMessage()
- func (x *ExecProcessExited) ProtoReflect() protoreflect.Message
- func (x *ExecProcessExited) Reset()
- func (x *ExecProcessExited) String() string
- type ExecProcessRequest
- func (*ExecProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecProcessRequest) GetArgs() []string
- func (x *ExecProcessRequest) GetCwd() string
- func (x *ExecProcessRequest) GetEnv() []string
- func (x *ExecProcessRequest) GetWait() bool
- func (*ExecProcessRequest) ProtoMessage()
- func (x *ExecProcessRequest) ProtoReflect() protoreflect.Message
- func (x *ExecProcessRequest) Reset()
- func (x *ExecProcessRequest) String() string
- type ExecProcessResponse
- func (*ExecProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecProcessResponse) GetErrorMsg() string
- func (x *ExecProcessResponse) GetExitCode() int32
- func (x *ExecProcessResponse) GetOk() bool
- func (x *ExecProcessResponse) GetPid() int32
- func (*ExecProcessResponse) ProtoMessage()
- func (x *ExecProcessResponse) ProtoReflect() protoreflect.Message
- func (x *ExecProcessResponse) Reset()
- func (x *ExecProcessResponse) String() string
- type ExecProcessStarted
- type GoProcClient
- type GoProcServer
- type GoProc_StreamExecClient
- type GoProc_StreamExecServer
- type KillProcessRequest
- type KillProcessResponse
- func (*KillProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KillProcessResponse) GetErrorMsg() string
- func (x *KillProcessResponse) GetOk() bool
- func (*KillProcessResponse) ProtoMessage()
- func (x *KillProcessResponse) ProtoReflect() protoreflect.Message
- func (x *KillProcessResponse) Reset()
- func (x *KillProcessResponse) String() string
- type ListProcessesRequest
- type ListProcessesResponse
- func (*ListProcessesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListProcessesResponse) GetErrorMsg() string
- func (x *ListProcessesResponse) GetOk() bool
- func (x *ListProcessesResponse) GetProcesses() []*ProcessInfo
- func (*ListProcessesResponse) ProtoMessage()
- func (x *ListProcessesResponse) ProtoReflect() protoreflect.Message
- func (x *ListProcessesResponse) Reset()
- func (x *ListProcessesResponse) String() string
- type ProcessInfo
- func (*ProcessInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInfo) GetCmd() string
- func (x *ProcessInfo) GetCwd() string
- func (x *ProcessInfo) GetEnv() []string
- func (x *ProcessInfo) GetExitCode() int32
- func (x *ProcessInfo) GetPid() int32
- func (x *ProcessInfo) GetRunning() bool
- func (*ProcessInfo) ProtoMessage()
- func (x *ProcessInfo) ProtoReflect() protoreflect.Message
- func (x *ProcessInfo) Reset()
- func (x *ProcessInfo) String() string
- type ProcessLogAck
- func (*ProcessLogAck) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessLogAck) GetErrorMsg() string
- func (x *ProcessLogAck) GetOk() bool
- func (x *ProcessLogAck) GetSeq() uint64
- func (*ProcessLogAck) ProtoMessage()
- func (x *ProcessLogAck) ProtoReflect() protoreflect.Message
- func (x *ProcessLogAck) Reset()
- func (x *ProcessLogAck) String() string
- type ProcessLogChunk
- func (*ProcessLogChunk) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessLogChunk) GetData() []byte
- func (x *ProcessLogChunk) GetPid() int32
- func (x *ProcessLogChunk) GetSeq() uint64
- func (x *ProcessLogChunk) GetStream() string
- func (*ProcessLogChunk) ProtoMessage()
- func (x *ProcessLogChunk) ProtoReflect() protoreflect.Message
- func (x *ProcessLogChunk) Reset()
- func (x *ProcessLogChunk) String() string
- type ReadyRequest
- type ReadyResponse
- func (*ReadyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadyResponse) GetErrorMsg() string
- func (x *ReadyResponse) GetOk() bool
- func (*ReadyResponse) ProtoMessage()
- func (x *ReadyResponse) ProtoReflect() protoreflect.Message
- func (x *ReadyResponse) Reset()
- func (x *ReadyResponse) String() string
- type SignalProcessRequest
- func (*SignalProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignalProcessRequest) GetPid() int32
- func (x *SignalProcessRequest) GetSignal() int32
- func (*SignalProcessRequest) ProtoMessage()
- func (x *SignalProcessRequest) ProtoReflect() protoreflect.Message
- func (x *SignalProcessRequest) Reset()
- func (x *SignalProcessRequest) String() string
- type SignalProcessResponse
- func (*SignalProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SignalProcessResponse) GetErrorMsg() string
- func (x *SignalProcessResponse) GetOk() bool
- func (*SignalProcessResponse) ProtoMessage()
- func (x *SignalProcessResponse) ProtoReflect() protoreflect.Message
- func (x *SignalProcessResponse) Reset()
- func (x *SignalProcessResponse) String() string
- type StatusProcessRequest
- func (*StatusProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusProcessRequest) GetPid() int32
- func (*StatusProcessRequest) ProtoMessage()
- func (x *StatusProcessRequest) ProtoReflect() protoreflect.Message
- func (x *StatusProcessRequest) Reset()
- func (x *StatusProcessRequest) String() string
- type StatusProcessResponse
- func (*StatusProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusProcessResponse) GetErrorMsg() string
- func (x *StatusProcessResponse) GetOk() bool
- func (x *StatusProcessResponse) GetProcess() *ProcessInfo
- func (*StatusProcessResponse) ProtoMessage()
- func (x *StatusProcessResponse) ProtoReflect() protoreflect.Message
- func (x *StatusProcessResponse) Reset()
- func (x *StatusProcessResponse) String() string
- type StderrProcessRequest
- func (*StderrProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StderrProcessRequest) GetPid() int32
- func (*StderrProcessRequest) ProtoMessage()
- func (x *StderrProcessRequest) ProtoReflect() protoreflect.Message
- func (x *StderrProcessRequest) Reset()
- func (x *StderrProcessRequest) String() string
- type StderrProcessResponse
- func (*StderrProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StderrProcessResponse) GetErrorMsg() string
- func (x *StderrProcessResponse) GetOk() bool
- func (x *StderrProcessResponse) GetStderr() string
- func (*StderrProcessResponse) ProtoMessage()
- func (x *StderrProcessResponse) ProtoReflect() protoreflect.Message
- func (x *StderrProcessResponse) Reset()
- func (x *StderrProcessResponse) String() string
- type StdoutProcessRequest
- func (*StdoutProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StdoutProcessRequest) GetPid() int32
- func (*StdoutProcessRequest) ProtoMessage()
- func (x *StdoutProcessRequest) ProtoReflect() protoreflect.Message
- func (x *StdoutProcessRequest) Reset()
- func (x *StdoutProcessRequest) String() string
- type StdoutProcessResponse
- func (*StdoutProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StdoutProcessResponse) GetErrorMsg() string
- func (x *StdoutProcessResponse) GetOk() bool
- func (x *StdoutProcessResponse) GetStdout() string
- func (*StdoutProcessResponse) ProtoMessage()
- func (x *StdoutProcessResponse) ProtoReflect() protoreflect.Message
- func (x *StdoutProcessResponse) Reset()
- func (x *StdoutProcessResponse) String() string
- type StreamExecRequest
- func (*StreamExecRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamExecRequest) GetAck() *ProcessLogAck
- func (x *StreamExecRequest) GetExec() *ExecProcessRequest
- func (m *StreamExecRequest) GetMessage() isStreamExecRequest_Message
- func (*StreamExecRequest) ProtoMessage()
- func (x *StreamExecRequest) ProtoReflect() protoreflect.Message
- func (x *StreamExecRequest) Reset()
- func (x *StreamExecRequest) String() string
- type StreamExecRequest_Ack
- type StreamExecRequest_Exec
- type StreamExecResponse
- func (*StreamExecResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamExecResponse) GetChunk() *ProcessLogChunk
- func (x *StreamExecResponse) GetExited() *ExecProcessExited
- func (m *StreamExecResponse) GetMessage() isStreamExecResponse_Message
- func (x *StreamExecResponse) GetStarted() *ExecProcessStarted
- func (*StreamExecResponse) ProtoMessage()
- func (x *StreamExecResponse) ProtoReflect() protoreflect.Message
- func (x *StreamExecResponse) Reset()
- func (x *StreamExecResponse) String() string
- type StreamExecResponse_Chunk
- type StreamExecResponse_Exited
- type StreamExecResponse_Started
- type UnimplementedGoProcServer
- func (UnimplementedGoProcServer) Exec(context.Context, *ExecProcessRequest) (*ExecProcessResponse, error)
- func (UnimplementedGoProcServer) Kill(context.Context, *KillProcessRequest) (*KillProcessResponse, error)
- func (UnimplementedGoProcServer) ListProcesses(context.Context, *ListProcessesRequest) (*ListProcessesResponse, error)
- func (UnimplementedGoProcServer) Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
- func (UnimplementedGoProcServer) Signal(context.Context, *SignalProcessRequest) (*SignalProcessResponse, error)
- func (UnimplementedGoProcServer) Status(context.Context, *StatusProcessRequest) (*StatusProcessResponse, error)
- func (UnimplementedGoProcServer) Stderr(context.Context, *StderrProcessRequest) (*StderrProcessResponse, error)
- func (UnimplementedGoProcServer) Stdout(context.Context, *StdoutProcessRequest) (*StdoutProcessResponse, error)
- func (UnimplementedGoProcServer) StreamExec(GoProc_StreamExecServer) error
- func (UnimplementedGoProcServer) Wait(context.Context, *WaitProcessRequest) (*WaitProcessResponse, error)
- type UnsafeGoProcServer
- type WaitProcessRequest
- type WaitProcessResponse
- func (*WaitProcessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WaitProcessResponse) GetErrorMsg() string
- func (x *WaitProcessResponse) GetExitCode() int32
- func (x *WaitProcessResponse) GetOk() bool
- func (*WaitProcessResponse) ProtoMessage()
- func (x *WaitProcessResponse) ProtoReflect() protoreflect.Message
- func (x *WaitProcessResponse) Reset()
- func (x *WaitProcessResponse) String() string
Constants ¶
const ( GoProc_Exec_FullMethodName = "/goproc.GoProc/Exec" GoProc_StreamExec_FullMethodName = "/goproc.GoProc/StreamExec" GoProc_Wait_FullMethodName = "/goproc.GoProc/Wait" GoProc_Kill_FullMethodName = "/goproc.GoProc/Kill" GoProc_Signal_FullMethodName = "/goproc.GoProc/Signal" GoProc_Status_FullMethodName = "/goproc.GoProc/Status" GoProc_Stdout_FullMethodName = "/goproc.GoProc/Stdout" GoProc_Stderr_FullMethodName = "/goproc.GoProc/Stderr" GoProc_Ready_FullMethodName = "/goproc.GoProc/Ready" GoProc_ListProcesses_FullMethodName = "/goproc.GoProc/ListProcesses" )
Variables ¶
var File_goproc_proto protoreflect.FileDescriptor
var GoProc_ServiceDesc = grpc.ServiceDesc{ ServiceName: "goproc.GoProc", HandlerType: (*GoProcServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Exec", Handler: _GoProc_Exec_Handler, }, { MethodName: "Wait", Handler: _GoProc_Wait_Handler, }, { MethodName: "Kill", Handler: _GoProc_Kill_Handler, }, { MethodName: "Signal", Handler: _GoProc_Signal_Handler, }, { MethodName: "Status", Handler: _GoProc_Status_Handler, }, { MethodName: "Stdout", Handler: _GoProc_Stdout_Handler, }, { MethodName: "Stderr", Handler: _GoProc_Stderr_Handler, }, { MethodName: "Ready", Handler: _GoProc_Ready_Handler, }, { MethodName: "ListProcesses", Handler: _GoProc_ListProcesses_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamExec", Handler: _GoProc_StreamExec_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "goproc.proto", }
GoProc_ServiceDesc is the grpc.ServiceDesc for GoProc service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGoProcServer ¶
func RegisterGoProcServer(s grpc.ServiceRegistrar, srv GoProcServer)
Types ¶
type ExecProcessExited ¶ added in v0.1.6
type ExecProcessExited struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*ExecProcessExited) Descriptor
deprecated
added in
v0.1.6
func (*ExecProcessExited) Descriptor() ([]byte, []int)
Deprecated: Use ExecProcessExited.ProtoReflect.Descriptor instead.
func (*ExecProcessExited) GetErrorMsg ¶ added in v0.1.6
func (x *ExecProcessExited) GetErrorMsg() string
func (*ExecProcessExited) GetExitCode ¶ added in v0.1.6
func (x *ExecProcessExited) GetExitCode() int32
func (*ExecProcessExited) GetPid ¶ added in v0.1.6
func (x *ExecProcessExited) GetPid() int32
func (*ExecProcessExited) ProtoMessage ¶ added in v0.1.6
func (*ExecProcessExited) ProtoMessage()
func (*ExecProcessExited) ProtoReflect ¶ added in v0.1.6
func (x *ExecProcessExited) ProtoReflect() protoreflect.Message
func (*ExecProcessExited) Reset ¶ added in v0.1.6
func (x *ExecProcessExited) Reset()
func (*ExecProcessExited) String ¶ added in v0.1.6
func (x *ExecProcessExited) String() string
type ExecProcessRequest ¶
type ExecProcessRequest struct {
Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
Cwd string `protobuf:"bytes,2,opt,name=cwd,proto3" json:"cwd,omitempty"`
Env []string `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
Wait *bool `protobuf:"varint,4,opt,name=wait,proto3,oneof" json:"wait,omitempty"`
// contains filtered or unexported fields
}
func (*ExecProcessRequest) Descriptor
deprecated
func (*ExecProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecProcessRequest.ProtoReflect.Descriptor instead.
func (*ExecProcessRequest) GetArgs ¶
func (x *ExecProcessRequest) GetArgs() []string
func (*ExecProcessRequest) GetCwd ¶
func (x *ExecProcessRequest) GetCwd() string
func (*ExecProcessRequest) GetEnv ¶
func (x *ExecProcessRequest) GetEnv() []string
func (*ExecProcessRequest) GetWait ¶
func (x *ExecProcessRequest) GetWait() bool
func (*ExecProcessRequest) ProtoMessage ¶
func (*ExecProcessRequest) ProtoMessage()
func (*ExecProcessRequest) ProtoReflect ¶
func (x *ExecProcessRequest) ProtoReflect() protoreflect.Message
func (*ExecProcessRequest) Reset ¶
func (x *ExecProcessRequest) Reset()
func (*ExecProcessRequest) String ¶
func (x *ExecProcessRequest) String() string
type ExecProcessResponse ¶
type ExecProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
ExitCode *int32 `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
// contains filtered or unexported fields
}
func (*ExecProcessResponse) Descriptor
deprecated
func (*ExecProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecProcessResponse.ProtoReflect.Descriptor instead.
func (*ExecProcessResponse) GetErrorMsg ¶
func (x *ExecProcessResponse) GetErrorMsg() string
func (*ExecProcessResponse) GetExitCode ¶
func (x *ExecProcessResponse) GetExitCode() int32
func (*ExecProcessResponse) GetOk ¶
func (x *ExecProcessResponse) GetOk() bool
func (*ExecProcessResponse) GetPid ¶
func (x *ExecProcessResponse) GetPid() int32
func (*ExecProcessResponse) ProtoMessage ¶
func (*ExecProcessResponse) ProtoMessage()
func (*ExecProcessResponse) ProtoReflect ¶
func (x *ExecProcessResponse) ProtoReflect() protoreflect.Message
func (*ExecProcessResponse) Reset ¶
func (x *ExecProcessResponse) Reset()
func (*ExecProcessResponse) String ¶
func (x *ExecProcessResponse) String() string
type ExecProcessStarted ¶ added in v0.1.6
type ExecProcessStarted struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*ExecProcessStarted) Descriptor
deprecated
added in
v0.1.6
func (*ExecProcessStarted) Descriptor() ([]byte, []int)
Deprecated: Use ExecProcessStarted.ProtoReflect.Descriptor instead.
func (*ExecProcessStarted) GetPid ¶ added in v0.1.6
func (x *ExecProcessStarted) GetPid() int32
func (*ExecProcessStarted) ProtoMessage ¶ added in v0.1.6
func (*ExecProcessStarted) ProtoMessage()
func (*ExecProcessStarted) ProtoReflect ¶ added in v0.1.6
func (x *ExecProcessStarted) ProtoReflect() protoreflect.Message
func (*ExecProcessStarted) Reset ¶ added in v0.1.6
func (x *ExecProcessStarted) Reset()
func (*ExecProcessStarted) String ¶ added in v0.1.6
func (x *ExecProcessStarted) String() string
type GoProcClient ¶
type GoProcClient interface {
Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*ExecProcessResponse, error)
StreamExec(ctx context.Context, opts ...grpc.CallOption) (GoProc_StreamExecClient, error)
Wait(ctx context.Context, in *WaitProcessRequest, opts ...grpc.CallOption) (*WaitProcessResponse, error)
Kill(ctx context.Context, in *KillProcessRequest, opts ...grpc.CallOption) (*KillProcessResponse, error)
Signal(ctx context.Context, in *SignalProcessRequest, opts ...grpc.CallOption) (*SignalProcessResponse, error)
Status(ctx context.Context, in *StatusProcessRequest, opts ...grpc.CallOption) (*StatusProcessResponse, error)
Stdout(ctx context.Context, in *StdoutProcessRequest, opts ...grpc.CallOption) (*StdoutProcessResponse, error)
Stderr(ctx context.Context, in *StderrProcessRequest, opts ...grpc.CallOption) (*StderrProcessResponse, error)
Ready(ctx context.Context, in *ReadyRequest, opts ...grpc.CallOption) (*ReadyResponse, error)
ListProcesses(ctx context.Context, in *ListProcessesRequest, opts ...grpc.CallOption) (*ListProcessesResponse, error)
}
GoProcClient is the client API for GoProc 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 NewGoProcClient ¶
func NewGoProcClient(cc grpc.ClientConnInterface) GoProcClient
type GoProcServer ¶
type GoProcServer interface {
Exec(context.Context, *ExecProcessRequest) (*ExecProcessResponse, error)
StreamExec(GoProc_StreamExecServer) error
Wait(context.Context, *WaitProcessRequest) (*WaitProcessResponse, error)
Kill(context.Context, *KillProcessRequest) (*KillProcessResponse, error)
Signal(context.Context, *SignalProcessRequest) (*SignalProcessResponse, error)
Status(context.Context, *StatusProcessRequest) (*StatusProcessResponse, error)
Stdout(context.Context, *StdoutProcessRequest) (*StdoutProcessResponse, error)
Stderr(context.Context, *StderrProcessRequest) (*StderrProcessResponse, error)
Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
ListProcesses(context.Context, *ListProcessesRequest) (*ListProcessesResponse, error)
// contains filtered or unexported methods
}
GoProcServer is the server API for GoProc service. All implementations must embed UnimplementedGoProcServer for forward compatibility
type GoProc_StreamExecClient ¶ added in v0.1.6
type GoProc_StreamExecClient interface {
Send(*StreamExecRequest) error
Recv() (*StreamExecResponse, error)
grpc.ClientStream
}
type GoProc_StreamExecServer ¶ added in v0.1.6
type GoProc_StreamExecServer interface {
Send(*StreamExecResponse) error
Recv() (*StreamExecRequest, error)
grpc.ServerStream
}
type KillProcessRequest ¶
type KillProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*KillProcessRequest) Descriptor
deprecated
func (*KillProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use KillProcessRequest.ProtoReflect.Descriptor instead.
func (*KillProcessRequest) GetPid ¶
func (x *KillProcessRequest) GetPid() int32
func (*KillProcessRequest) ProtoMessage ¶
func (*KillProcessRequest) ProtoMessage()
func (*KillProcessRequest) ProtoReflect ¶
func (x *KillProcessRequest) ProtoReflect() protoreflect.Message
func (*KillProcessRequest) Reset ¶
func (x *KillProcessRequest) Reset()
func (*KillProcessRequest) String ¶
func (x *KillProcessRequest) String() string
type KillProcessResponse ¶
type KillProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*KillProcessResponse) Descriptor
deprecated
func (*KillProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use KillProcessResponse.ProtoReflect.Descriptor instead.
func (*KillProcessResponse) GetErrorMsg ¶
func (x *KillProcessResponse) GetErrorMsg() string
func (*KillProcessResponse) GetOk ¶
func (x *KillProcessResponse) GetOk() bool
func (*KillProcessResponse) ProtoMessage ¶
func (*KillProcessResponse) ProtoMessage()
func (*KillProcessResponse) ProtoReflect ¶
func (x *KillProcessResponse) ProtoReflect() protoreflect.Message
func (*KillProcessResponse) Reset ¶
func (x *KillProcessResponse) Reset()
func (*KillProcessResponse) String ¶
func (x *KillProcessResponse) String() string
type ListProcessesRequest ¶
type ListProcessesRequest struct {
// contains filtered or unexported fields
}
func (*ListProcessesRequest) Descriptor
deprecated
func (*ListProcessesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListProcessesRequest.ProtoReflect.Descriptor instead.
func (*ListProcessesRequest) ProtoMessage ¶
func (*ListProcessesRequest) ProtoMessage()
func (*ListProcessesRequest) ProtoReflect ¶
func (x *ListProcessesRequest) ProtoReflect() protoreflect.Message
func (*ListProcessesRequest) Reset ¶
func (x *ListProcessesRequest) Reset()
func (*ListProcessesRequest) String ¶
func (x *ListProcessesRequest) String() string
type ListProcessesResponse ¶
type ListProcessesResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
Processes []*ProcessInfo `protobuf:"bytes,2,rep,name=processes,proto3" json:"processes,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*ListProcessesResponse) Descriptor
deprecated
func (*ListProcessesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListProcessesResponse.ProtoReflect.Descriptor instead.
func (*ListProcessesResponse) GetErrorMsg ¶
func (x *ListProcessesResponse) GetErrorMsg() string
func (*ListProcessesResponse) GetOk ¶
func (x *ListProcessesResponse) GetOk() bool
func (*ListProcessesResponse) GetProcesses ¶
func (x *ListProcessesResponse) GetProcesses() []*ProcessInfo
func (*ListProcessesResponse) ProtoMessage ¶
func (*ListProcessesResponse) ProtoMessage()
func (*ListProcessesResponse) ProtoReflect ¶
func (x *ListProcessesResponse) ProtoReflect() protoreflect.Message
func (*ListProcessesResponse) Reset ¶
func (x *ListProcessesResponse) Reset()
func (*ListProcessesResponse) String ¶
func (x *ListProcessesResponse) String() string
type ProcessInfo ¶
type ProcessInfo struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
Cwd string `protobuf:"bytes,3,opt,name=cwd,proto3" json:"cwd,omitempty"`
Env []string `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
Running bool `protobuf:"varint,5,opt,name=running,proto3" json:"running,omitempty"`
ExitCode int32 `protobuf:"varint,6,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
// contains filtered or unexported fields
}
func (*ProcessInfo) Descriptor
deprecated
func (*ProcessInfo) Descriptor() ([]byte, []int)
Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.
func (*ProcessInfo) GetCmd ¶
func (x *ProcessInfo) GetCmd() string
func (*ProcessInfo) GetCwd ¶
func (x *ProcessInfo) GetCwd() string
func (*ProcessInfo) GetEnv ¶
func (x *ProcessInfo) GetEnv() []string
func (*ProcessInfo) GetExitCode ¶
func (x *ProcessInfo) GetExitCode() int32
func (*ProcessInfo) GetPid ¶
func (x *ProcessInfo) GetPid() int32
func (*ProcessInfo) GetRunning ¶
func (x *ProcessInfo) GetRunning() bool
func (*ProcessInfo) ProtoMessage ¶
func (*ProcessInfo) ProtoMessage()
func (*ProcessInfo) ProtoReflect ¶
func (x *ProcessInfo) ProtoReflect() protoreflect.Message
func (*ProcessInfo) Reset ¶
func (x *ProcessInfo) Reset()
func (*ProcessInfo) String ¶
func (x *ProcessInfo) String() string
type ProcessLogAck ¶ added in v0.1.6
type ProcessLogAck struct {
Seq uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*ProcessLogAck) Descriptor
deprecated
added in
v0.1.6
func (*ProcessLogAck) Descriptor() ([]byte, []int)
Deprecated: Use ProcessLogAck.ProtoReflect.Descriptor instead.
func (*ProcessLogAck) GetErrorMsg ¶ added in v0.1.6
func (x *ProcessLogAck) GetErrorMsg() string
func (*ProcessLogAck) GetOk ¶ added in v0.1.6
func (x *ProcessLogAck) GetOk() bool
func (*ProcessLogAck) GetSeq ¶ added in v0.1.6
func (x *ProcessLogAck) GetSeq() uint64
func (*ProcessLogAck) ProtoMessage ¶ added in v0.1.6
func (*ProcessLogAck) ProtoMessage()
func (*ProcessLogAck) ProtoReflect ¶ added in v0.1.6
func (x *ProcessLogAck) ProtoReflect() protoreflect.Message
func (*ProcessLogAck) Reset ¶ added in v0.1.6
func (x *ProcessLogAck) Reset()
func (*ProcessLogAck) String ¶ added in v0.1.6
func (x *ProcessLogAck) String() string
type ProcessLogChunk ¶ added in v0.1.6
type ProcessLogChunk struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Stream string `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*ProcessLogChunk) Descriptor
deprecated
added in
v0.1.6
func (*ProcessLogChunk) Descriptor() ([]byte, []int)
Deprecated: Use ProcessLogChunk.ProtoReflect.Descriptor instead.
func (*ProcessLogChunk) GetData ¶ added in v0.1.6
func (x *ProcessLogChunk) GetData() []byte
func (*ProcessLogChunk) GetPid ¶ added in v0.1.6
func (x *ProcessLogChunk) GetPid() int32
func (*ProcessLogChunk) GetSeq ¶ added in v0.1.6
func (x *ProcessLogChunk) GetSeq() uint64
func (*ProcessLogChunk) GetStream ¶ added in v0.1.6
func (x *ProcessLogChunk) GetStream() string
func (*ProcessLogChunk) ProtoMessage ¶ added in v0.1.6
func (*ProcessLogChunk) ProtoMessage()
func (*ProcessLogChunk) ProtoReflect ¶ added in v0.1.6
func (x *ProcessLogChunk) ProtoReflect() protoreflect.Message
func (*ProcessLogChunk) Reset ¶ added in v0.1.6
func (x *ProcessLogChunk) Reset()
func (*ProcessLogChunk) String ¶ added in v0.1.6
func (x *ProcessLogChunk) String() string
type ReadyRequest ¶ added in v0.1.7
type ReadyRequest struct {
// contains filtered or unexported fields
}
func (*ReadyRequest) Descriptor
deprecated
added in
v0.1.7
func (*ReadyRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadyRequest.ProtoReflect.Descriptor instead.
func (*ReadyRequest) ProtoMessage ¶ added in v0.1.7
func (*ReadyRequest) ProtoMessage()
func (*ReadyRequest) ProtoReflect ¶ added in v0.1.7
func (x *ReadyRequest) ProtoReflect() protoreflect.Message
func (*ReadyRequest) Reset ¶ added in v0.1.7
func (x *ReadyRequest) Reset()
func (*ReadyRequest) String ¶ added in v0.1.7
func (x *ReadyRequest) String() string
type ReadyResponse ¶ added in v0.1.7
type ReadyResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*ReadyResponse) Descriptor
deprecated
added in
v0.1.7
func (*ReadyResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadyResponse.ProtoReflect.Descriptor instead.
func (*ReadyResponse) GetErrorMsg ¶ added in v0.1.7
func (x *ReadyResponse) GetErrorMsg() string
func (*ReadyResponse) GetOk ¶ added in v0.1.7
func (x *ReadyResponse) GetOk() bool
func (*ReadyResponse) ProtoMessage ¶ added in v0.1.7
func (*ReadyResponse) ProtoMessage()
func (*ReadyResponse) ProtoReflect ¶ added in v0.1.7
func (x *ReadyResponse) ProtoReflect() protoreflect.Message
func (*ReadyResponse) Reset ¶ added in v0.1.7
func (x *ReadyResponse) Reset()
func (*ReadyResponse) String ¶ added in v0.1.7
func (x *ReadyResponse) String() string
type SignalProcessRequest ¶
type SignalProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Signal int32 `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"`
// contains filtered or unexported fields
}
func (*SignalProcessRequest) Descriptor
deprecated
func (*SignalProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use SignalProcessRequest.ProtoReflect.Descriptor instead.
func (*SignalProcessRequest) GetPid ¶
func (x *SignalProcessRequest) GetPid() int32
func (*SignalProcessRequest) GetSignal ¶
func (x *SignalProcessRequest) GetSignal() int32
func (*SignalProcessRequest) ProtoMessage ¶
func (*SignalProcessRequest) ProtoMessage()
func (*SignalProcessRequest) ProtoReflect ¶
func (x *SignalProcessRequest) ProtoReflect() protoreflect.Message
func (*SignalProcessRequest) Reset ¶
func (x *SignalProcessRequest) Reset()
func (*SignalProcessRequest) String ¶
func (x *SignalProcessRequest) String() string
type SignalProcessResponse ¶
type SignalProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*SignalProcessResponse) Descriptor
deprecated
func (*SignalProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use SignalProcessResponse.ProtoReflect.Descriptor instead.
func (*SignalProcessResponse) GetErrorMsg ¶
func (x *SignalProcessResponse) GetErrorMsg() string
func (*SignalProcessResponse) GetOk ¶
func (x *SignalProcessResponse) GetOk() bool
func (*SignalProcessResponse) ProtoMessage ¶
func (*SignalProcessResponse) ProtoMessage()
func (*SignalProcessResponse) ProtoReflect ¶
func (x *SignalProcessResponse) ProtoReflect() protoreflect.Message
func (*SignalProcessResponse) Reset ¶
func (x *SignalProcessResponse) Reset()
func (*SignalProcessResponse) String ¶
func (x *SignalProcessResponse) String() string
type StatusProcessRequest ¶
type StatusProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*StatusProcessRequest) Descriptor
deprecated
func (*StatusProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusProcessRequest.ProtoReflect.Descriptor instead.
func (*StatusProcessRequest) GetPid ¶
func (x *StatusProcessRequest) GetPid() int32
func (*StatusProcessRequest) ProtoMessage ¶
func (*StatusProcessRequest) ProtoMessage()
func (*StatusProcessRequest) ProtoReflect ¶
func (x *StatusProcessRequest) ProtoReflect() protoreflect.Message
func (*StatusProcessRequest) Reset ¶
func (x *StatusProcessRequest) Reset()
func (*StatusProcessRequest) String ¶
func (x *StatusProcessRequest) String() string
type StatusProcessResponse ¶
type StatusProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
Process *ProcessInfo `protobuf:"bytes,2,opt,name=process,proto3" json:"process,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*StatusProcessResponse) Descriptor
deprecated
func (*StatusProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusProcessResponse.ProtoReflect.Descriptor instead.
func (*StatusProcessResponse) GetErrorMsg ¶
func (x *StatusProcessResponse) GetErrorMsg() string
func (*StatusProcessResponse) GetOk ¶
func (x *StatusProcessResponse) GetOk() bool
func (*StatusProcessResponse) GetProcess ¶
func (x *StatusProcessResponse) GetProcess() *ProcessInfo
func (*StatusProcessResponse) ProtoMessage ¶
func (*StatusProcessResponse) ProtoMessage()
func (*StatusProcessResponse) ProtoReflect ¶
func (x *StatusProcessResponse) ProtoReflect() protoreflect.Message
func (*StatusProcessResponse) Reset ¶
func (x *StatusProcessResponse) Reset()
func (*StatusProcessResponse) String ¶
func (x *StatusProcessResponse) String() string
type StderrProcessRequest ¶
type StderrProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*StderrProcessRequest) Descriptor
deprecated
func (*StderrProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use StderrProcessRequest.ProtoReflect.Descriptor instead.
func (*StderrProcessRequest) GetPid ¶
func (x *StderrProcessRequest) GetPid() int32
func (*StderrProcessRequest) ProtoMessage ¶
func (*StderrProcessRequest) ProtoMessage()
func (*StderrProcessRequest) ProtoReflect ¶
func (x *StderrProcessRequest) ProtoReflect() protoreflect.Message
func (*StderrProcessRequest) Reset ¶
func (x *StderrProcessRequest) Reset()
func (*StderrProcessRequest) String ¶
func (x *StderrProcessRequest) String() string
type StderrProcessResponse ¶
type StderrProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
Stderr string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
// contains filtered or unexported fields
}
func (*StderrProcessResponse) Descriptor
deprecated
func (*StderrProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use StderrProcessResponse.ProtoReflect.Descriptor instead.
func (*StderrProcessResponse) GetErrorMsg ¶
func (x *StderrProcessResponse) GetErrorMsg() string
func (*StderrProcessResponse) GetOk ¶
func (x *StderrProcessResponse) GetOk() bool
func (*StderrProcessResponse) GetStderr ¶
func (x *StderrProcessResponse) GetStderr() string
func (*StderrProcessResponse) ProtoMessage ¶
func (*StderrProcessResponse) ProtoMessage()
func (*StderrProcessResponse) ProtoReflect ¶
func (x *StderrProcessResponse) ProtoReflect() protoreflect.Message
func (*StderrProcessResponse) Reset ¶
func (x *StderrProcessResponse) Reset()
func (*StderrProcessResponse) String ¶
func (x *StderrProcessResponse) String() string
type StdoutProcessRequest ¶
type StdoutProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*StdoutProcessRequest) Descriptor
deprecated
func (*StdoutProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use StdoutProcessRequest.ProtoReflect.Descriptor instead.
func (*StdoutProcessRequest) GetPid ¶
func (x *StdoutProcessRequest) GetPid() int32
func (*StdoutProcessRequest) ProtoMessage ¶
func (*StdoutProcessRequest) ProtoMessage()
func (*StdoutProcessRequest) ProtoReflect ¶
func (x *StdoutProcessRequest) ProtoReflect() protoreflect.Message
func (*StdoutProcessRequest) Reset ¶
func (x *StdoutProcessRequest) Reset()
func (*StdoutProcessRequest) String ¶
func (x *StdoutProcessRequest) String() string
type StdoutProcessResponse ¶
type StdoutProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
Stdout string `protobuf:"bytes,3,opt,name=stdout,proto3" json:"stdout,omitempty"`
// contains filtered or unexported fields
}
func (*StdoutProcessResponse) Descriptor
deprecated
func (*StdoutProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use StdoutProcessResponse.ProtoReflect.Descriptor instead.
func (*StdoutProcessResponse) GetErrorMsg ¶
func (x *StdoutProcessResponse) GetErrorMsg() string
func (*StdoutProcessResponse) GetOk ¶
func (x *StdoutProcessResponse) GetOk() bool
func (*StdoutProcessResponse) GetStdout ¶
func (x *StdoutProcessResponse) GetStdout() string
func (*StdoutProcessResponse) ProtoMessage ¶
func (*StdoutProcessResponse) ProtoMessage()
func (*StdoutProcessResponse) ProtoReflect ¶
func (x *StdoutProcessResponse) ProtoReflect() protoreflect.Message
func (*StdoutProcessResponse) Reset ¶
func (x *StdoutProcessResponse) Reset()
func (*StdoutProcessResponse) String ¶
func (x *StdoutProcessResponse) String() string
type StreamExecRequest ¶ added in v0.1.6
type StreamExecRequest struct {
// Types that are assignable to Message:
//
// *StreamExecRequest_Exec
// *StreamExecRequest_Ack
Message isStreamExecRequest_Message `protobuf_oneof:"message"`
// contains filtered or unexported fields
}
func (*StreamExecRequest) Descriptor
deprecated
added in
v0.1.6
func (*StreamExecRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamExecRequest.ProtoReflect.Descriptor instead.
func (*StreamExecRequest) GetAck ¶ added in v0.1.6
func (x *StreamExecRequest) GetAck() *ProcessLogAck
func (*StreamExecRequest) GetExec ¶ added in v0.1.6
func (x *StreamExecRequest) GetExec() *ExecProcessRequest
func (*StreamExecRequest) GetMessage ¶ added in v0.1.6
func (m *StreamExecRequest) GetMessage() isStreamExecRequest_Message
func (*StreamExecRequest) ProtoMessage ¶ added in v0.1.6
func (*StreamExecRequest) ProtoMessage()
func (*StreamExecRequest) ProtoReflect ¶ added in v0.1.6
func (x *StreamExecRequest) ProtoReflect() protoreflect.Message
func (*StreamExecRequest) Reset ¶ added in v0.1.6
func (x *StreamExecRequest) Reset()
func (*StreamExecRequest) String ¶ added in v0.1.6
func (x *StreamExecRequest) String() string
type StreamExecRequest_Ack ¶ added in v0.1.6
type StreamExecRequest_Ack struct {
Ack *ProcessLogAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}
type StreamExecRequest_Exec ¶ added in v0.1.6
type StreamExecRequest_Exec struct {
Exec *ExecProcessRequest `protobuf:"bytes,1,opt,name=exec,proto3,oneof"`
}
type StreamExecResponse ¶ added in v0.1.6
type StreamExecResponse struct {
// Types that are assignable to Message:
//
// *StreamExecResponse_Started
// *StreamExecResponse_Chunk
// *StreamExecResponse_Exited
Message isStreamExecResponse_Message `protobuf_oneof:"message"`
// contains filtered or unexported fields
}
func (*StreamExecResponse) Descriptor
deprecated
added in
v0.1.6
func (*StreamExecResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamExecResponse.ProtoReflect.Descriptor instead.
func (*StreamExecResponse) GetChunk ¶ added in v0.1.6
func (x *StreamExecResponse) GetChunk() *ProcessLogChunk
func (*StreamExecResponse) GetExited ¶ added in v0.1.6
func (x *StreamExecResponse) GetExited() *ExecProcessExited
func (*StreamExecResponse) GetMessage ¶ added in v0.1.6
func (m *StreamExecResponse) GetMessage() isStreamExecResponse_Message
func (*StreamExecResponse) GetStarted ¶ added in v0.1.6
func (x *StreamExecResponse) GetStarted() *ExecProcessStarted
func (*StreamExecResponse) ProtoMessage ¶ added in v0.1.6
func (*StreamExecResponse) ProtoMessage()
func (*StreamExecResponse) ProtoReflect ¶ added in v0.1.6
func (x *StreamExecResponse) ProtoReflect() protoreflect.Message
func (*StreamExecResponse) Reset ¶ added in v0.1.6
func (x *StreamExecResponse) Reset()
func (*StreamExecResponse) String ¶ added in v0.1.6
func (x *StreamExecResponse) String() string
type StreamExecResponse_Chunk ¶ added in v0.1.6
type StreamExecResponse_Chunk struct {
Chunk *ProcessLogChunk `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}
type StreamExecResponse_Exited ¶ added in v0.1.6
type StreamExecResponse_Exited struct {
Exited *ExecProcessExited `protobuf:"bytes,3,opt,name=exited,proto3,oneof"`
}
type StreamExecResponse_Started ¶ added in v0.1.6
type StreamExecResponse_Started struct {
Started *ExecProcessStarted `protobuf:"bytes,1,opt,name=started,proto3,oneof"`
}
type UnimplementedGoProcServer ¶
type UnimplementedGoProcServer struct {
}
UnimplementedGoProcServer must be embedded to have forward compatible implementations.
func (UnimplementedGoProcServer) Exec ¶
func (UnimplementedGoProcServer) Exec(context.Context, *ExecProcessRequest) (*ExecProcessResponse, error)
func (UnimplementedGoProcServer) Kill ¶
func (UnimplementedGoProcServer) Kill(context.Context, *KillProcessRequest) (*KillProcessResponse, error)
func (UnimplementedGoProcServer) ListProcesses ¶
func (UnimplementedGoProcServer) ListProcesses(context.Context, *ListProcessesRequest) (*ListProcessesResponse, error)
func (UnimplementedGoProcServer) Ready ¶ added in v0.1.7
func (UnimplementedGoProcServer) Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
func (UnimplementedGoProcServer) Signal ¶
func (UnimplementedGoProcServer) Signal(context.Context, *SignalProcessRequest) (*SignalProcessResponse, error)
func (UnimplementedGoProcServer) Status ¶
func (UnimplementedGoProcServer) Status(context.Context, *StatusProcessRequest) (*StatusProcessResponse, error)
func (UnimplementedGoProcServer) Stderr ¶
func (UnimplementedGoProcServer) Stderr(context.Context, *StderrProcessRequest) (*StderrProcessResponse, error)
func (UnimplementedGoProcServer) Stdout ¶
func (UnimplementedGoProcServer) Stdout(context.Context, *StdoutProcessRequest) (*StdoutProcessResponse, error)
func (UnimplementedGoProcServer) StreamExec ¶ added in v0.1.6
func (UnimplementedGoProcServer) StreamExec(GoProc_StreamExecServer) error
func (UnimplementedGoProcServer) Wait ¶
func (UnimplementedGoProcServer) Wait(context.Context, *WaitProcessRequest) (*WaitProcessResponse, error)
type UnsafeGoProcServer ¶
type UnsafeGoProcServer interface {
// contains filtered or unexported methods
}
UnsafeGoProcServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GoProcServer will result in compilation errors.
type WaitProcessRequest ¶
type WaitProcessRequest struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*WaitProcessRequest) Descriptor
deprecated
func (*WaitProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use WaitProcessRequest.ProtoReflect.Descriptor instead.
func (*WaitProcessRequest) GetPid ¶
func (x *WaitProcessRequest) GetPid() int32
func (*WaitProcessRequest) ProtoMessage ¶
func (*WaitProcessRequest) ProtoMessage()
func (*WaitProcessRequest) ProtoReflect ¶
func (x *WaitProcessRequest) ProtoReflect() protoreflect.Message
func (*WaitProcessRequest) Reset ¶
func (x *WaitProcessRequest) Reset()
func (*WaitProcessRequest) String ¶
func (x *WaitProcessRequest) String() string
type WaitProcessResponse ¶
type WaitProcessResponse struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// contains filtered or unexported fields
}
func (*WaitProcessResponse) Descriptor
deprecated
func (*WaitProcessResponse) Descriptor() ([]byte, []int)
Deprecated: Use WaitProcessResponse.ProtoReflect.Descriptor instead.
func (*WaitProcessResponse) GetErrorMsg ¶
func (x *WaitProcessResponse) GetErrorMsg() string
func (*WaitProcessResponse) GetExitCode ¶
func (x *WaitProcessResponse) GetExitCode() int32
func (*WaitProcessResponse) GetOk ¶
func (x *WaitProcessResponse) GetOk() bool
func (*WaitProcessResponse) ProtoMessage ¶
func (*WaitProcessResponse) ProtoMessage()
func (*WaitProcessResponse) ProtoReflect ¶
func (x *WaitProcessResponse) ProtoReflect() protoreflect.Message
func (*WaitProcessResponse) Reset ¶
func (x *WaitProcessResponse) Reset()
func (*WaitProcessResponse) String ¶
func (x *WaitProcessResponse) String() string