Versions in this module Expand all Collapse all v0 v0.0.1 Sep 30, 2023 Changes in this version + 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 + func RegisterProcessManagerServer(s grpc.ServiceRegistrar, srv ProcessManagerServer) + type Error struct + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetMessage() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type GetReply struct + Response isGetReply_Response + func (*GetReply) Descriptor() ([]byte, []int) + func (*GetReply) ProtoMessage() + func (m *GetReply) GetResponse() isGetReply_Response + func (x *GetReply) GetError() *Error + func (x *GetReply) GetProcess() *ProcessInformation + func (x *GetReply) ProtoReflect() protoreflect.Message + func (x *GetReply) Reset() + func (x *GetReply) String() string + type GetReply_Error struct + Error *Error + type GetReply_Process struct + Process *ProcessInformation + type GetRequest struct + Process string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetProcess() string + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type ListReply struct + Processes []*ProcessInformation + func (*ListReply) Descriptor() ([]byte, []int) + func (*ListReply) ProtoMessage() + func (x *ListReply) GetProcesses() []*ProcessInformation + func (x *ListReply) ProtoReflect() protoreflect.Message + func (x *ListReply) Reset() + func (x *ListReply) String() string + type ListRequest struct + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (x *ListRequest) ProtoReflect() protoreflect.Message + func (x *ListRequest) Reset() + func (x *ListRequest) String() string + type ProcessConfiguration struct + Arguments []string + Command string + Environment map[string]string + Name string + Persist bool + RestartPolicy *ProcessConfiguration_RestartPolicy + WorkingDirectory string + func (*ProcessConfiguration) Descriptor() ([]byte, []int) + func (*ProcessConfiguration) ProtoMessage() + 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 (x *ProcessConfiguration) ProtoReflect() protoreflect.Message + func (x *ProcessConfiguration) Reset() + func (x *ProcessConfiguration) String() string + type ProcessConfiguration_RestartPolicy struct + AutoRestart bool + Delay *durationpb.Duration + MaxRetries uint32 + func (*ProcessConfiguration_RestartPolicy) Descriptor() ([]byte, []int) + func (*ProcessConfiguration_RestartPolicy) ProtoMessage() + func (x *ProcessConfiguration_RestartPolicy) GetAutoRestart() bool + func (x *ProcessConfiguration_RestartPolicy) GetDelay() *durationpb.Duration + func (x *ProcessConfiguration_RestartPolicy) GetMaxRetries() uint32 + func (x *ProcessConfiguration_RestartPolicy) ProtoReflect() protoreflect.Message + func (x *ProcessConfiguration_RestartPolicy) Reset() + func (x *ProcessConfiguration_RestartPolicy) String() string + type ProcessInformation struct + Configuration *ProcessConfiguration + ExitState *ProcessInformation_ExitState + Id string + Pid int64 + Restarts uint32 + StartedAt *timestamppb.Timestamp + Status string + Stdout string + func (*ProcessInformation) Descriptor() ([]byte, []int) + func (*ProcessInformation) ProtoMessage() + 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 (x *ProcessInformation) ProtoReflect() protoreflect.Message + func (x *ProcessInformation) Reset() + func (x *ProcessInformation) String() string + type ProcessInformation_ExitState struct + Code int64 + ExitedAt *timestamppb.Timestamp + func (*ProcessInformation_ExitState) Descriptor() ([]byte, []int) + func (*ProcessInformation_ExitState) ProtoMessage() + func (x *ProcessInformation_ExitState) GetCode() int64 + func (x *ProcessInformation_ExitState) GetExitedAt() *timestamppb.Timestamp + func (x *ProcessInformation_ExitState) ProtoReflect() protoreflect.Message + func (x *ProcessInformation_ExitState) Reset() + func (x *ProcessInformation_ExitState) String() string + type ProcessManagerClient interface + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error) + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error) + Remove func(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error) + Restart func(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartReply, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error) + Stop func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopReply, error) + Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateReply, error) + func NewProcessManagerClient(cc grpc.ClientConnInterface) ProcessManagerClient + type ProcessManagerServer interface + Get func(context.Context, *GetRequest) (*GetReply, error) + List func(context.Context, *ListRequest) (*ListReply, error) + Remove func(context.Context, *RemoveRequest) (*RemoveReply, error) + Restart func(context.Context, *RestartRequest) (*RestartReply, error) + Start func(context.Context, *StartRequest) (*StartReply, error) + Stop func(context.Context, *StopRequest) (*StopReply, error) + Update func(context.Context, *UpdateRequest) (*UpdateReply, error) + type RemoveReply struct + Error *Error + func (*RemoveReply) Descriptor() ([]byte, []int) + func (*RemoveReply) ProtoMessage() + func (x *RemoveReply) GetError() *Error + func (x *RemoveReply) ProtoReflect() protoreflect.Message + func (x *RemoveReply) Reset() + func (x *RemoveReply) String() string + type RemoveRequest struct + Process string + func (*RemoveRequest) Descriptor() ([]byte, []int) + func (*RemoveRequest) ProtoMessage() + func (x *RemoveRequest) GetProcess() string + func (x *RemoveRequest) ProtoReflect() protoreflect.Message + func (x *RemoveRequest) Reset() + func (x *RemoveRequest) String() string + type RestartReply struct + Error *Error + func (*RestartReply) Descriptor() ([]byte, []int) + func (*RestartReply) ProtoMessage() + func (x *RestartReply) GetError() *Error + func (x *RestartReply) ProtoReflect() protoreflect.Message + func (x *RestartReply) Reset() + func (x *RestartReply) String() string + type RestartRequest struct + Process string + func (*RestartRequest) Descriptor() ([]byte, []int) + func (*RestartRequest) ProtoMessage() + func (x *RestartRequest) GetProcess() string + func (x *RestartRequest) ProtoReflect() protoreflect.Message + func (x *RestartRequest) Reset() + func (x *RestartRequest) String() string + type StartReply struct + Response isStartReply_Response + func (*StartReply) Descriptor() ([]byte, []int) + func (*StartReply) ProtoMessage() + func (m *StartReply) GetResponse() isStartReply_Response + func (x *StartReply) GetError() *Error + func (x *StartReply) GetProcess() *ProcessInformation + func (x *StartReply) ProtoReflect() protoreflect.Message + func (x *StartReply) Reset() + func (x *StartReply) String() string + type StartReply_Error struct + Error *Error + type StartReply_Process struct + Process *ProcessInformation + type StartRequest struct + Configuration *ProcessConfiguration + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + func (x *StartRequest) GetConfiguration() *ProcessConfiguration + func (x *StartRequest) ProtoReflect() protoreflect.Message + func (x *StartRequest) Reset() + func (x *StartRequest) String() string + type StopReply struct + Error *Error + func (*StopReply) Descriptor() ([]byte, []int) + func (*StopReply) ProtoMessage() + func (x *StopReply) GetError() *Error + func (x *StopReply) ProtoReflect() protoreflect.Message + func (x *StopReply) Reset() + func (x *StopReply) String() string + type StopRequest struct + Process string + func (*StopRequest) Descriptor() ([]byte, []int) + func (*StopRequest) ProtoMessage() + func (x *StopRequest) GetProcess() string + func (x *StopRequest) ProtoReflect() protoreflect.Message + func (x *StopRequest) Reset() + func (x *StopRequest) String() string + type UnimplementedProcessManagerServer struct + 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 interface + type UpdateReply struct + Response isUpdateReply_Response + func (*UpdateReply) Descriptor() ([]byte, []int) + func (*UpdateReply) ProtoMessage() + func (m *UpdateReply) GetResponse() isUpdateReply_Response + func (x *UpdateReply) GetError() *Error + func (x *UpdateReply) GetProcess() *ProcessInformation + func (x *UpdateReply) ProtoReflect() protoreflect.Message + func (x *UpdateReply) Reset() + func (x *UpdateReply) String() string + type UpdateReply_Error struct + Error *Error + type UpdateReply_Process struct + Process *ProcessInformation + type UpdateRequest struct + Configuration *ProcessConfiguration + Process string + UpdateMask *fieldmaskpb.FieldMask + func (*UpdateRequest) Descriptor() ([]byte, []int) + func (*UpdateRequest) ProtoMessage() + func (x *UpdateRequest) GetConfiguration() *ProcessConfiguration + func (x *UpdateRequest) GetProcess() string + func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask + func (x *UpdateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateRequest) Reset() + func (x *UpdateRequest) String() string
Go to main page