Documentation ¶
Index ¶
- Variables
- func RegisterProcessManagerServer(s grpc.ServiceRegistrar, srv ProcessManagerServer)
- type Error
- type GetReply
- func (*GetReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetReply) GetError() *Error
- func (x *GetReply) GetProcess() *ProcessInformation
- func (m *GetReply) GetResponse() isGetReply_Response
- func (*GetReply) ProtoMessage()
- func (x *GetReply) ProtoReflect() protoreflect.Message
- func (x *GetReply) Reset()
- func (x *GetReply) String() string
- type GetReply_Error
- type GetReply_Process
- type GetRequest
- type ListReply
- type ListRequest
- type ProcessConfiguration
- func (*ProcessConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessConfiguration) GetArguments() []string
- func (x *ProcessConfiguration) GetCommand() string
- func (x *ProcessConfiguration) GetEnvironment() map[string]string
- func (x *ProcessConfiguration) GetName() string
- func (x *ProcessConfiguration) GetPersist() bool
- func (x *ProcessConfiguration) GetRestartPolicy() *ProcessConfiguration_RestartPolicy
- func (x *ProcessConfiguration) GetWorkingDirectory() string
- func (*ProcessConfiguration) ProtoMessage()
- func (x *ProcessConfiguration) ProtoReflect() protoreflect.Message
- func (x *ProcessConfiguration) Reset()
- func (x *ProcessConfiguration) String() string
- type ProcessConfiguration_RestartPolicy
- func (*ProcessConfiguration_RestartPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessConfiguration_RestartPolicy) GetAutoRestart() bool
- func (x *ProcessConfiguration_RestartPolicy) GetDelay() *durationpb.Duration
- func (x *ProcessConfiguration_RestartPolicy) GetMaxRetries() uint32
- func (*ProcessConfiguration_RestartPolicy) ProtoMessage()
- func (x *ProcessConfiguration_RestartPolicy) ProtoReflect() protoreflect.Message
- func (x *ProcessConfiguration_RestartPolicy) Reset()
- func (x *ProcessConfiguration_RestartPolicy) String() string
- type ProcessInformation
- func (*ProcessInformation) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInformation) GetConfiguration() *ProcessConfiguration
- func (x *ProcessInformation) GetExitState() *ProcessInformation_ExitState
- func (x *ProcessInformation) GetId() string
- func (x *ProcessInformation) GetPid() int64
- func (x *ProcessInformation) GetRestarts() uint32
- func (x *ProcessInformation) GetStartedAt() *timestamppb.Timestamp
- func (x *ProcessInformation) GetStatus() string
- func (x *ProcessInformation) GetStdout() string
- func (*ProcessInformation) ProtoMessage()
- func (x *ProcessInformation) ProtoReflect() protoreflect.Message
- func (x *ProcessInformation) Reset()
- func (x *ProcessInformation) String() string
- type ProcessInformation_ExitState
- func (*ProcessInformation_ExitState) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInformation_ExitState) GetCode() int64
- func (x *ProcessInformation_ExitState) GetExitedAt() *timestamppb.Timestamp
- func (*ProcessInformation_ExitState) ProtoMessage()
- func (x *ProcessInformation_ExitState) ProtoReflect() protoreflect.Message
- func (x *ProcessInformation_ExitState) Reset()
- func (x *ProcessInformation_ExitState) String() string
- type ProcessManagerClient
- type ProcessManagerServer
- type RemoveReply
- type RemoveRequest
- type RestartReply
- type RestartRequest
- type StartReply
- func (*StartReply) Descriptor() ([]byte, []int)deprecated
- func (x *StartReply) GetError() *Error
- func (x *StartReply) GetProcess() *ProcessInformation
- func (m *StartReply) GetResponse() isStartReply_Response
- func (*StartReply) ProtoMessage()
- func (x *StartReply) ProtoReflect() protoreflect.Message
- func (x *StartReply) Reset()
- func (x *StartReply) String() string
- type StartReply_Error
- type StartReply_Process
- type StartRequest
- type StopReply
- type StopRequest
- type UnimplementedProcessManagerServer
- func (UnimplementedProcessManagerServer) Get(context.Context, *GetRequest) (*GetReply, error)
- func (UnimplementedProcessManagerServer) List(context.Context, *ListRequest) (*ListReply, error)
- func (UnimplementedProcessManagerServer) Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
- func (UnimplementedProcessManagerServer) Restart(context.Context, *RestartRequest) (*RestartReply, error)
- func (UnimplementedProcessManagerServer) Start(context.Context, *StartRequest) (*StartReply, error)
- func (UnimplementedProcessManagerServer) Stop(context.Context, *StopRequest) (*StopReply, error)
- func (UnimplementedProcessManagerServer) Update(context.Context, *UpdateRequest) (*UpdateReply, error)
- type UnsafeProcessManagerServer
- type UpdateReply
- func (*UpdateReply) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateReply) GetError() *Error
- func (x *UpdateReply) GetProcess() *ProcessInformation
- func (m *UpdateReply) GetResponse() isUpdateReply_Response
- func (*UpdateReply) ProtoMessage()
- func (x *UpdateReply) ProtoReflect() protoreflect.Message
- func (x *UpdateReply) Reset()
- func (x *UpdateReply) String() string
- type UpdateReply_Error
- type UpdateReply_Process
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetConfiguration() *ProcessConfiguration
- func (x *UpdateRequest) GetProcess() string
- func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var File_pb_common_proto protoreflect.FileDescriptor
var File_pb_process_proto protoreflect.FileDescriptor
var File_pb_processmanager_proto protoreflect.FileDescriptor
var ProcessManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "processmanager.ProcessManager", HandlerType: (*ProcessManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _ProcessManager_Start_Handler, }, { MethodName: "List", Handler: _ProcessManager_List_Handler, }, { MethodName: "Restart", Handler: _ProcessManager_Restart_Handler, }, { MethodName: "Stop", Handler: _ProcessManager_Stop_Handler, }, { MethodName: "Update", Handler: _ProcessManager_Update_Handler, }, { MethodName: "Remove", Handler: _ProcessManager_Remove_Handler, }, { MethodName: "Get", Handler: _ProcessManager_Get_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pb/processmanager.proto", }
ProcessManager_ServiceDesc is the grpc.ServiceDesc for ProcessManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProcessManagerServer ¶
func RegisterProcessManagerServer(s grpc.ServiceRegistrar, srv ProcessManagerServer)
Types ¶
type Error ¶
type Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type GetReply ¶
type GetReply struct { // Types that are assignable to Response: // // *GetReply_Error // *GetReply_Process Response isGetReply_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*GetReply) Descriptor
deprecated
func (*GetReply) GetProcess ¶
func (x *GetReply) GetProcess() *ProcessInformation
func (*GetReply) GetResponse ¶
func (m *GetReply) GetResponse() isGetReply_Response
func (*GetReply) ProtoMessage ¶
func (*GetReply) ProtoMessage()
func (*GetReply) ProtoReflect ¶
func (x *GetReply) ProtoReflect() protoreflect.Message
type GetReply_Error ¶
type GetReply_Error struct {
Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}
type GetReply_Process ¶
type GetReply_Process struct {
Process *ProcessInformation `protobuf:"bytes,2,opt,name=process,proto3,oneof"`
}
type GetRequest ¶
type GetRequest struct { Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetProcess ¶
func (x *GetRequest) GetProcess() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type ListReply ¶
type ListReply struct { Processes []*ProcessInformation `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes"` // contains filtered or unexported fields }
func (*ListReply) Descriptor
deprecated
func (*ListReply) GetProcesses ¶
func (x *ListReply) GetProcesses() []*ProcessInformation
func (*ListReply) ProtoMessage ¶
func (*ListReply) ProtoMessage()
func (*ListReply) ProtoReflect ¶
func (x *ListReply) ProtoReflect() protoreflect.Message
type ListRequest ¶
type ListRequest struct {
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ProcessConfiguration ¶
type ProcessConfiguration struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"` Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command"` Arguments []string `protobuf:"bytes,3,rep,name=arguments,proto3" json:"arguments"` Environment map[string]string `` /* 153-byte string literal not displayed */ Persist bool `protobuf:"varint,5,opt,name=persist,proto3" json:"persist"` RestartPolicy *ProcessConfiguration_RestartPolicy `protobuf:"bytes,6,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy"` WorkingDirectory string `protobuf:"bytes,7,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory"` // contains filtered or unexported fields }
func (*ProcessConfiguration) Descriptor
deprecated
func (*ProcessConfiguration) Descriptor() ([]byte, []int)
Deprecated: Use ProcessConfiguration.ProtoReflect.Descriptor instead.
func (*ProcessConfiguration) GetArguments ¶
func (x *ProcessConfiguration) GetArguments() []string
func (*ProcessConfiguration) GetCommand ¶
func (x *ProcessConfiguration) GetCommand() string
func (*ProcessConfiguration) GetEnvironment ¶
func (x *ProcessConfiguration) GetEnvironment() map[string]string
func (*ProcessConfiguration) GetName ¶
func (x *ProcessConfiguration) GetName() string
func (*ProcessConfiguration) GetPersist ¶
func (x *ProcessConfiguration) GetPersist() bool
func (*ProcessConfiguration) GetRestartPolicy ¶
func (x *ProcessConfiguration) GetRestartPolicy() *ProcessConfiguration_RestartPolicy
func (*ProcessConfiguration) GetWorkingDirectory ¶
func (x *ProcessConfiguration) GetWorkingDirectory() string
func (*ProcessConfiguration) ProtoMessage ¶
func (*ProcessConfiguration) ProtoMessage()
func (*ProcessConfiguration) ProtoReflect ¶
func (x *ProcessConfiguration) ProtoReflect() protoreflect.Message
func (*ProcessConfiguration) Reset ¶
func (x *ProcessConfiguration) Reset()
func (*ProcessConfiguration) String ¶
func (x *ProcessConfiguration) String() string
type ProcessConfiguration_RestartPolicy ¶
type ProcessConfiguration_RestartPolicy struct { AutoRestart bool `protobuf:"varint,1,opt,name=auto_restart,json=autoRestart,proto3" json:"auto_restart"` Delay *durationpb.Duration `protobuf:"bytes,2,opt,name=delay,proto3" json:"delay"` MaxRetries uint32 `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries"` // contains filtered or unexported fields }
func (*ProcessConfiguration_RestartPolicy) Descriptor
deprecated
func (*ProcessConfiguration_RestartPolicy) Descriptor() ([]byte, []int)
Deprecated: Use ProcessConfiguration_RestartPolicy.ProtoReflect.Descriptor instead.
func (*ProcessConfiguration_RestartPolicy) GetAutoRestart ¶
func (x *ProcessConfiguration_RestartPolicy) GetAutoRestart() bool
func (*ProcessConfiguration_RestartPolicy) GetDelay ¶
func (x *ProcessConfiguration_RestartPolicy) GetDelay() *durationpb.Duration
func (*ProcessConfiguration_RestartPolicy) GetMaxRetries ¶
func (x *ProcessConfiguration_RestartPolicy) GetMaxRetries() uint32
func (*ProcessConfiguration_RestartPolicy) ProtoMessage ¶
func (*ProcessConfiguration_RestartPolicy) ProtoMessage()
func (*ProcessConfiguration_RestartPolicy) ProtoReflect ¶
func (x *ProcessConfiguration_RestartPolicy) ProtoReflect() protoreflect.Message
func (*ProcessConfiguration_RestartPolicy) Reset ¶
func (x *ProcessConfiguration_RestartPolicy) Reset()
func (*ProcessConfiguration_RestartPolicy) String ¶
func (x *ProcessConfiguration_RestartPolicy) String() string
type ProcessInformation ¶
type ProcessInformation struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` Pid int64 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid"` Configuration *ProcessConfiguration `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration"` ExitState *ProcessInformation_ExitState `protobuf:"bytes,4,opt,name=exit_state,json=exitState,proto3,oneof" json:"exit_state"` Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status"` Stdout string `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout"` Restarts uint32 `protobuf:"varint,7,opt,name=restarts,proto3" json:"restarts"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=started_at,json=startedAt,proto3,oneof" json:"started_at"` // contains filtered or unexported fields }
func (*ProcessInformation) Descriptor
deprecated
func (*ProcessInformation) Descriptor() ([]byte, []int)
Deprecated: Use ProcessInformation.ProtoReflect.Descriptor instead.
func (*ProcessInformation) GetConfiguration ¶
func (x *ProcessInformation) GetConfiguration() *ProcessConfiguration
func (*ProcessInformation) GetExitState ¶
func (x *ProcessInformation) GetExitState() *ProcessInformation_ExitState
func (*ProcessInformation) GetId ¶
func (x *ProcessInformation) GetId() string
func (*ProcessInformation) GetPid ¶
func (x *ProcessInformation) GetPid() int64
func (*ProcessInformation) GetRestarts ¶
func (x *ProcessInformation) GetRestarts() uint32
func (*ProcessInformation) GetStartedAt ¶
func (x *ProcessInformation) GetStartedAt() *timestamppb.Timestamp
func (*ProcessInformation) GetStatus ¶
func (x *ProcessInformation) GetStatus() string
func (*ProcessInformation) GetStdout ¶
func (x *ProcessInformation) GetStdout() string
func (*ProcessInformation) ProtoMessage ¶
func (*ProcessInformation) ProtoMessage()
func (*ProcessInformation) ProtoReflect ¶
func (x *ProcessInformation) ProtoReflect() protoreflect.Message
func (*ProcessInformation) Reset ¶
func (x *ProcessInformation) Reset()
func (*ProcessInformation) String ¶
func (x *ProcessInformation) String() string
type ProcessInformation_ExitState ¶
type ProcessInformation_ExitState struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code"` ExitedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3" json:"exited_at"` // contains filtered or unexported fields }
func (*ProcessInformation_ExitState) Descriptor
deprecated
func (*ProcessInformation_ExitState) Descriptor() ([]byte, []int)
Deprecated: Use ProcessInformation_ExitState.ProtoReflect.Descriptor instead.
func (*ProcessInformation_ExitState) GetCode ¶
func (x *ProcessInformation_ExitState) GetCode() int64
func (*ProcessInformation_ExitState) GetExitedAt ¶
func (x *ProcessInformation_ExitState) GetExitedAt() *timestamppb.Timestamp
func (*ProcessInformation_ExitState) ProtoMessage ¶
func (*ProcessInformation_ExitState) ProtoMessage()
func (*ProcessInformation_ExitState) ProtoReflect ¶
func (x *ProcessInformation_ExitState) ProtoReflect() protoreflect.Message
func (*ProcessInformation_ExitState) Reset ¶
func (x *ProcessInformation_ExitState) Reset()
func (*ProcessInformation_ExitState) String ¶
func (x *ProcessInformation_ExitState) String() string
type ProcessManagerClient ¶
type ProcessManagerClient interface { Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error) Restart(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartReply, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopReply, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateReply, error) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error) }
ProcessManagerClient is the client API for ProcessManager 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 NewProcessManagerClient ¶
func NewProcessManagerClient(cc grpc.ClientConnInterface) ProcessManagerClient
type ProcessManagerServer ¶
type ProcessManagerServer interface { Start(context.Context, *StartRequest) (*StartReply, error) List(context.Context, *ListRequest) (*ListReply, error) Restart(context.Context, *RestartRequest) (*RestartReply, error) Stop(context.Context, *StopRequest) (*StopReply, error) Update(context.Context, *UpdateRequest) (*UpdateReply, error) Remove(context.Context, *RemoveRequest) (*RemoveReply, error) Get(context.Context, *GetRequest) (*GetReply, error) // contains filtered or unexported methods }
ProcessManagerServer is the server API for ProcessManager service. All implementations must embed UnimplementedProcessManagerServer for forward compatibility
type RemoveReply ¶
type RemoveReply struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error"` // contains filtered or unexported fields }
func (*RemoveReply) Descriptor
deprecated
func (*RemoveReply) Descriptor() ([]byte, []int)
Deprecated: Use RemoveReply.ProtoReflect.Descriptor instead.
func (*RemoveReply) GetError ¶
func (x *RemoveReply) GetError() *Error
func (*RemoveReply) ProtoMessage ¶
func (*RemoveReply) ProtoMessage()
func (*RemoveReply) ProtoReflect ¶
func (x *RemoveReply) ProtoReflect() protoreflect.Message
func (*RemoveReply) Reset ¶
func (x *RemoveReply) Reset()
func (*RemoveReply) String ¶
func (x *RemoveReply) String() string
type RemoveRequest ¶
type RemoveRequest struct { Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` // contains filtered or unexported fields }
func (*RemoveRequest) Descriptor
deprecated
func (*RemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.
func (*RemoveRequest) GetProcess ¶
func (x *RemoveRequest) GetProcess() string
func (*RemoveRequest) ProtoMessage ¶
func (*RemoveRequest) ProtoMessage()
func (*RemoveRequest) ProtoReflect ¶
func (x *RemoveRequest) ProtoReflect() protoreflect.Message
func (*RemoveRequest) Reset ¶
func (x *RemoveRequest) Reset()
func (*RemoveRequest) String ¶
func (x *RemoveRequest) String() string
type RestartReply ¶
type RestartReply struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error"` // contains filtered or unexported fields }
func (*RestartReply) Descriptor
deprecated
func (*RestartReply) Descriptor() ([]byte, []int)
Deprecated: Use RestartReply.ProtoReflect.Descriptor instead.
func (*RestartReply) GetError ¶
func (x *RestartReply) GetError() *Error
func (*RestartReply) ProtoMessage ¶
func (*RestartReply) ProtoMessage()
func (*RestartReply) ProtoReflect ¶
func (x *RestartReply) ProtoReflect() protoreflect.Message
func (*RestartReply) Reset ¶
func (x *RestartReply) Reset()
func (*RestartReply) String ¶
func (x *RestartReply) String() string
type RestartRequest ¶
type RestartRequest struct { Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` // contains filtered or unexported fields }
func (*RestartRequest) Descriptor
deprecated
func (*RestartRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartRequest.ProtoReflect.Descriptor instead.
func (*RestartRequest) GetProcess ¶
func (x *RestartRequest) GetProcess() string
func (*RestartRequest) ProtoMessage ¶
func (*RestartRequest) ProtoMessage()
func (*RestartRequest) ProtoReflect ¶
func (x *RestartRequest) ProtoReflect() protoreflect.Message
func (*RestartRequest) Reset ¶
func (x *RestartRequest) Reset()
func (*RestartRequest) String ¶
func (x *RestartRequest) String() string
type StartReply ¶
type StartReply struct { // Types that are assignable to Response: // // *StartReply_Error // *StartReply_Process Response isStartReply_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*StartReply) Descriptor
deprecated
func (*StartReply) Descriptor() ([]byte, []int)
Deprecated: Use StartReply.ProtoReflect.Descriptor instead.
func (*StartReply) GetError ¶
func (x *StartReply) GetError() *Error
func (*StartReply) GetProcess ¶
func (x *StartReply) GetProcess() *ProcessInformation
func (*StartReply) GetResponse ¶
func (m *StartReply) GetResponse() isStartReply_Response
func (*StartReply) ProtoMessage ¶
func (*StartReply) ProtoMessage()
func (*StartReply) ProtoReflect ¶
func (x *StartReply) ProtoReflect() protoreflect.Message
func (*StartReply) Reset ¶
func (x *StartReply) Reset()
func (*StartReply) String ¶
func (x *StartReply) String() string
type StartReply_Error ¶
type StartReply_Error struct {
Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}
type StartReply_Process ¶
type StartReply_Process struct {
Process *ProcessInformation `protobuf:"bytes,2,opt,name=process,proto3,oneof"`
}
type StartRequest ¶
type StartRequest struct { Configuration *ProcessConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration"` // contains filtered or unexported fields }
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetConfiguration ¶
func (x *StartRequest) GetConfiguration() *ProcessConfiguration
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) String ¶
func (x *StartRequest) String() string
type StopReply ¶
type StopReply struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error"` // contains filtered or unexported fields }
func (*StopReply) Descriptor
deprecated
func (*StopReply) ProtoMessage ¶
func (*StopReply) ProtoMessage()
func (*StopReply) ProtoReflect ¶
func (x *StopReply) ProtoReflect() protoreflect.Message
type StopRequest ¶
type StopRequest struct { Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` // contains filtered or unexported fields }
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) GetProcess ¶
func (x *StopRequest) GetProcess() string
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type UnimplementedProcessManagerServer ¶
type UnimplementedProcessManagerServer struct { }
UnimplementedProcessManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedProcessManagerServer) Get ¶
func (UnimplementedProcessManagerServer) Get(context.Context, *GetRequest) (*GetReply, error)
func (UnimplementedProcessManagerServer) List ¶
func (UnimplementedProcessManagerServer) List(context.Context, *ListRequest) (*ListReply, error)
func (UnimplementedProcessManagerServer) Remove ¶
func (UnimplementedProcessManagerServer) Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
func (UnimplementedProcessManagerServer) Restart ¶
func (UnimplementedProcessManagerServer) Restart(context.Context, *RestartRequest) (*RestartReply, error)
func (UnimplementedProcessManagerServer) Start ¶
func (UnimplementedProcessManagerServer) Start(context.Context, *StartRequest) (*StartReply, error)
func (UnimplementedProcessManagerServer) Stop ¶
func (UnimplementedProcessManagerServer) Stop(context.Context, *StopRequest) (*StopReply, error)
func (UnimplementedProcessManagerServer) Update ¶
func (UnimplementedProcessManagerServer) Update(context.Context, *UpdateRequest) (*UpdateReply, error)
type UnsafeProcessManagerServer ¶
type UnsafeProcessManagerServer interface {
// contains filtered or unexported methods
}
UnsafeProcessManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcessManagerServer will result in compilation errors.
type UpdateReply ¶
type UpdateReply struct { // Types that are assignable to Response: // // *UpdateReply_Error // *UpdateReply_Process Response isUpdateReply_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*UpdateReply) Descriptor
deprecated
func (*UpdateReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateReply.ProtoReflect.Descriptor instead.
func (*UpdateReply) GetError ¶
func (x *UpdateReply) GetError() *Error
func (*UpdateReply) GetProcess ¶
func (x *UpdateReply) GetProcess() *ProcessInformation
func (*UpdateReply) GetResponse ¶
func (m *UpdateReply) GetResponse() isUpdateReply_Response
func (*UpdateReply) ProtoMessage ¶
func (*UpdateReply) ProtoMessage()
func (*UpdateReply) ProtoReflect ¶
func (x *UpdateReply) ProtoReflect() protoreflect.Message
func (*UpdateReply) Reset ¶
func (x *UpdateReply) Reset()
func (*UpdateReply) String ¶
func (x *UpdateReply) String() string
type UpdateReply_Error ¶
type UpdateReply_Error struct {
Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}
type UpdateReply_Process ¶
type UpdateReply_Process struct {
Process *ProcessInformation `protobuf:"bytes,2,opt,name=process,proto3,oneof"`
}
type UpdateRequest ¶
type UpdateRequest struct { Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` Configuration *ProcessConfiguration `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration"` UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask"` // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetConfiguration ¶
func (x *UpdateRequest) GetConfiguration() *ProcessConfiguration
func (*UpdateRequest) GetProcess ¶
func (x *UpdateRequest) GetProcess() string
func (*UpdateRequest) GetUpdateMask ¶
func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string