Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterProcessManagerServer(s grpc.ServiceRegistrar, srv ProcessManagerServer)
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRequest) GetAfter() []string
- func (x *CreateRequest) GetArgs() []string
- func (x *CreateRequest) GetAutoStart() bool
- func (x *CreateRequest) GetBefore() []string
- func (x *CreateRequest) GetCommand() string
- func (x *CreateRequest) GetConditionPathExists() string
- func (x *CreateRequest) GetDescription() string
- func (x *CreateRequest) GetEnv() map[string]string
- func (x *CreateRequest) GetName() string
- func (x *CreateRequest) GetRestartPolicy() string
- func (x *CreateRequest) GetStderr() string
- func (x *CreateRequest) GetStdout() string
- func (x *CreateRequest) GetWorkingDir() string
- func (*CreateRequest) ProtoMessage()
- func (x *CreateRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRequest) Reset()
- func (x *CreateRequest) String() string
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResponse) GetUuid() string
- func (x *CreateResponse) GetWarnings() []string
- func (*CreateResponse) ProtoMessage()
- func (x *CreateResponse) ProtoReflect() protoreflect.Message
- func (x *CreateResponse) Reset()
- func (x *CreateResponse) String() string
- type DescribeRequest
- type DescribeResponse
- type GetConfigRequest
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigResponse) GetLoadedProcesses() uint32
- func (x *GetConfigResponse) GetLocation() string
- func (x *GetConfigResponse) GetRuntimeProcesses() uint32
- func (x *GetConfigResponse) GetSource() string
- func (*GetConfigResponse) ProtoMessage()
- func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigResponse) Reset()
- func (x *GetConfigResponse) String() string
- type GetStatusRequest
- type GetStatusResponse
- func (*GetStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusResponse) GetCreatedProcesses() uint32
- func (x *GetStatusResponse) GetExitedProcesses() uint32
- func (x *GetStatusResponse) GetFailedProcesses() uint32
- func (x *GetStatusResponse) GetReady() bool
- func (x *GetStatusResponse) GetRunningProcesses() uint32
- func (x *GetStatusResponse) GetStartingProcesses() uint32
- func (x *GetStatusResponse) GetStoppedProcesses() uint32
- func (x *GetStatusResponse) GetStoppingProcesses() uint32
- func (x *GetStatusResponse) GetTotalProcesses() uint32
- func (x *GetStatusResponse) GetUptimeSeconds() uint64
- func (x *GetStatusResponse) GetVersion() string
- func (*GetStatusResponse) ProtoMessage()
- func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusResponse) Reset()
- func (x *GetStatusResponse) String() string
- type ListRequest
- type ListResponse
- type Process
- func (*Process) Descriptor() ([]byte, []int)deprecated
- func (x *Process) GetArgs() []string
- func (x *Process) GetCommand() string
- func (x *Process) GetLastExitCode() int32
- func (x *Process) GetLastSignal() int32
- func (x *Process) GetName() string
- func (x *Process) GetPid() uint32
- func (x *Process) GetRestartCount() uint32
- func (x *Process) GetState() ProcessState
- func (x *Process) GetUuid() string
- func (*Process) ProtoMessage()
- func (x *Process) ProtoReflect() protoreflect.Message
- func (x *Process) Reset()
- func (x *Process) String() string
- type ProcessDetail
- func (*ProcessDetail) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessDetail) GetAfter() []string
- func (x *ProcessDetail) GetArgs() []string
- func (x *ProcessDetail) GetAutoStart() bool
- func (x *ProcessDetail) GetBefore() []string
- func (x *ProcessDetail) GetCommand() string
- func (x *ProcessDetail) GetConditionPathExists() string
- func (x *ProcessDetail) GetDescription() string
- func (x *ProcessDetail) GetEnv() map[string]string
- func (x *ProcessDetail) GetLastExitCode() int32
- func (x *ProcessDetail) GetLastSignal() int32
- func (x *ProcessDetail) GetName() string
- func (x *ProcessDetail) GetPid() uint32
- func (x *ProcessDetail) GetRestartCount() uint32
- func (x *ProcessDetail) GetRestartPolicy() string
- func (x *ProcessDetail) GetState() ProcessState
- func (x *ProcessDetail) GetStderr() string
- func (x *ProcessDetail) GetStdout() string
- func (x *ProcessDetail) GetUuid() string
- func (x *ProcessDetail) GetWorkingDir() string
- func (*ProcessDetail) ProtoMessage()
- func (x *ProcessDetail) ProtoReflect() protoreflect.Message
- func (x *ProcessDetail) Reset()
- func (x *ProcessDetail) String() string
- type ProcessManagerClient
- type ProcessManagerServer
- type ProcessState
- func (ProcessState) Descriptor() protoreflect.EnumDescriptor
- func (x ProcessState) Enum() *ProcessState
- func (ProcessState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProcessState) Number() protoreflect.EnumNumber
- func (x ProcessState) String() string
- func (ProcessState) Type() protoreflect.EnumType
- type ReloadConfigRequest
- type ReloadConfigResponse
- func (*ReloadConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadConfigResponse) GetAdded() []string
- func (x *ReloadConfigResponse) GetModified() []string
- func (x *ReloadConfigResponse) GetRemoved() []string
- func (x *ReloadConfigResponse) GetUnchanged() []string
- func (*ReloadConfigResponse) ProtoMessage()
- func (x *ReloadConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ReloadConfigResponse) Reset()
- func (x *ReloadConfigResponse) String() string
- type StartRequest
- type StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartResponse) GetPid() uint32
- func (x *StartResponse) GetState() ProcessState
- func (x *StartResponse) GetUuid() string
- func (*StartResponse) ProtoMessage()
- func (x *StartResponse) ProtoReflect() protoreflect.Message
- func (x *StartResponse) Reset()
- func (x *StartResponse) String() string
- type StopRequest
- type StopResponse
- func (*StopResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopResponse) GetState() ProcessState
- func (x *StopResponse) GetUuid() string
- func (*StopResponse) ProtoMessage()
- func (x *StopResponse) ProtoReflect() protoreflect.Message
- func (x *StopResponse) Reset()
- func (x *StopResponse) String() string
- type UnimplementedProcessManagerServer
- func (UnimplementedProcessManagerServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
- func (UnimplementedProcessManagerServer) Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
- func (UnimplementedProcessManagerServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedProcessManagerServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
- func (UnimplementedProcessManagerServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedProcessManagerServer) ReloadConfig(context.Context, *ReloadConfigRequest) (*ReloadConfigResponse, error)
- func (UnimplementedProcessManagerServer) Start(context.Context, *StartRequest) (*StartResponse, error)
- func (UnimplementedProcessManagerServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- type UnsafeProcessManagerServer
Constants ¶
const ( ProcessManager_List_FullMethodName = "/datadog.procmgr.ProcessManager/List" ProcessManager_Describe_FullMethodName = "/datadog.procmgr.ProcessManager/Describe" ProcessManager_GetStatus_FullMethodName = "/datadog.procmgr.ProcessManager/GetStatus" ProcessManager_Create_FullMethodName = "/datadog.procmgr.ProcessManager/Create" ProcessManager_Start_FullMethodName = "/datadog.procmgr.ProcessManager/Start" ProcessManager_Stop_FullMethodName = "/datadog.procmgr.ProcessManager/Stop" ProcessManager_ReloadConfig_FullMethodName = "/datadog.procmgr.ProcessManager/ReloadConfig" ProcessManager_GetConfig_FullMethodName = "/datadog.procmgr.ProcessManager/GetConfig" )
Variables ¶
var ( ProcessState_name = map[int32]string{ 0: "UNKNOWN", 1: "CREATED", 2: "STARTING", 3: "RUNNING", 4: "STOPPING", 5: "STOPPED", 6: "CRASHED", 7: "EXITED", 8: "FAILED", } ProcessState_value = map[string]int32{ "UNKNOWN": 0, "CREATED": 1, "STARTING": 2, "RUNNING": 3, "STOPPING": 4, "STOPPED": 5, "CRASHED": 6, "EXITED": 7, "FAILED": 8, } )
Enum value maps for ProcessState.
var File_datadog_procmgr_process_manager_proto protoreflect.FileDescriptor
var ProcessManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datadog.procmgr.ProcessManager", HandlerType: (*ProcessManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "List", Handler: _ProcessManager_List_Handler, }, { MethodName: "Describe", Handler: _ProcessManager_Describe_Handler, }, { MethodName: "GetStatus", Handler: _ProcessManager_GetStatus_Handler, }, { MethodName: "Create", Handler: _ProcessManager_Create_Handler, }, { MethodName: "Start", Handler: _ProcessManager_Start_Handler, }, { MethodName: "Stop", Handler: _ProcessManager_Stop_Handler, }, { MethodName: "ReloadConfig", Handler: _ProcessManager_ReloadConfig_Handler, }, { MethodName: "GetConfig", Handler: _ProcessManager_GetConfig_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datadog/procmgr/process_manager.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 CreateRequest ¶
type CreateRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
Env map[string]string `` /* 133-byte string literal not displayed */
WorkingDir string `protobuf:"bytes,5,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
Stdout string `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
Stderr string `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
RestartPolicy string `protobuf:"bytes,8,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
Description string `protobuf:"bytes,9,opt,name=description,proto3" json:"description,omitempty"`
ConditionPathExists string `protobuf:"bytes,10,opt,name=condition_path_exists,json=conditionPathExists,proto3" json:"condition_path_exists,omitempty"`
AutoStart *bool `protobuf:"varint,11,opt,name=auto_start,json=autoStart,proto3,oneof" json:"auto_start,omitempty"`
After []string `protobuf:"bytes,12,rep,name=after,proto3" json:"after,omitempty"`
Before []string `protobuf:"bytes,13,rep,name=before,proto3" json:"before,omitempty"`
// contains filtered or unexported fields
}
func (*CreateRequest) Descriptor
deprecated
func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetAfter ¶
func (x *CreateRequest) GetAfter() []string
func (*CreateRequest) GetArgs ¶
func (x *CreateRequest) GetArgs() []string
func (*CreateRequest) GetAutoStart ¶
func (x *CreateRequest) GetAutoStart() bool
func (*CreateRequest) GetBefore ¶
func (x *CreateRequest) GetBefore() []string
func (*CreateRequest) GetCommand ¶
func (x *CreateRequest) GetCommand() string
func (*CreateRequest) GetConditionPathExists ¶
func (x *CreateRequest) GetConditionPathExists() string
func (*CreateRequest) GetDescription ¶
func (x *CreateRequest) GetDescription() string
func (*CreateRequest) GetEnv ¶
func (x *CreateRequest) GetEnv() map[string]string
func (*CreateRequest) GetName ¶
func (x *CreateRequest) GetName() string
func (*CreateRequest) GetRestartPolicy ¶
func (x *CreateRequest) GetRestartPolicy() string
func (*CreateRequest) GetStderr ¶
func (x *CreateRequest) GetStderr() string
func (*CreateRequest) GetStdout ¶
func (x *CreateRequest) GetStdout() string
func (*CreateRequest) GetWorkingDir ¶
func (x *CreateRequest) GetWorkingDir() string
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (x *CreateRequest) String() string
type CreateResponse ¶
type CreateResponse struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
// contains filtered or unexported fields
}
func (*CreateResponse) Descriptor
deprecated
func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) GetUuid ¶
func (x *CreateResponse) GetUuid() string
func (*CreateResponse) GetWarnings ¶
func (x *CreateResponse) GetWarnings() []string
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type DescribeRequest ¶
type DescribeRequest struct {
NameOrUuid string `protobuf:"bytes,1,opt,name=name_or_uuid,json=nameOrUuid,proto3" json:"name_or_uuid,omitempty"`
// contains filtered or unexported fields
}
func (*DescribeRequest) Descriptor
deprecated
func (*DescribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DescribeRequest.ProtoReflect.Descriptor instead.
func (*DescribeRequest) GetNameOrUuid ¶
func (x *DescribeRequest) GetNameOrUuid() string
func (*DescribeRequest) ProtoMessage ¶
func (*DescribeRequest) ProtoMessage()
func (*DescribeRequest) ProtoReflect ¶
func (x *DescribeRequest) ProtoReflect() protoreflect.Message
func (*DescribeRequest) Reset ¶
func (x *DescribeRequest) Reset()
func (*DescribeRequest) String ¶
func (x *DescribeRequest) String() string
type DescribeResponse ¶
type DescribeResponse struct {
Detail *ProcessDetail `protobuf:"bytes,1,opt,name=detail,proto3" json:"detail,omitempty"`
// contains filtered or unexported fields
}
func (*DescribeResponse) Descriptor
deprecated
func (*DescribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use DescribeResponse.ProtoReflect.Descriptor instead.
func (*DescribeResponse) GetDetail ¶
func (x *DescribeResponse) GetDetail() *ProcessDetail
func (*DescribeResponse) ProtoMessage ¶
func (*DescribeResponse) ProtoMessage()
func (*DescribeResponse) ProtoReflect ¶
func (x *DescribeResponse) ProtoReflect() protoreflect.Message
func (*DescribeResponse) Reset ¶
func (x *DescribeResponse) Reset()
func (*DescribeResponse) String ¶
func (x *DescribeResponse) String() string
type GetConfigRequest ¶
type GetConfigRequest struct {
// contains filtered or unexported fields
}
func (*GetConfigRequest) Descriptor
deprecated
func (*GetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) ProtoReflect ¶
func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
func (*GetConfigRequest) Reset ¶
func (x *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (x *GetConfigRequest) String() string
type GetConfigResponse ¶
type GetConfigResponse struct {
Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
LoadedProcesses uint32 `protobuf:"varint,3,opt,name=loaded_processes,json=loadedProcesses,proto3" json:"loaded_processes,omitempty"`
RuntimeProcesses uint32 `protobuf:"varint,4,opt,name=runtime_processes,json=runtimeProcesses,proto3" json:"runtime_processes,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigResponse) Descriptor
deprecated
func (*GetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.
func (*GetConfigResponse) GetLoadedProcesses ¶
func (x *GetConfigResponse) GetLoadedProcesses() uint32
func (*GetConfigResponse) GetLocation ¶
func (x *GetConfigResponse) GetLocation() string
func (*GetConfigResponse) GetRuntimeProcesses ¶
func (x *GetConfigResponse) GetRuntimeProcesses() uint32
func (*GetConfigResponse) GetSource ¶
func (x *GetConfigResponse) GetSource() string
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) ProtoReflect ¶
func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
func (*GetConfigResponse) Reset ¶
func (x *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (x *GetConfigResponse) String() string
type GetStatusRequest ¶
type GetStatusRequest struct {
// contains filtered or unexported fields
}
func (*GetStatusRequest) Descriptor
deprecated
func (*GetStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.
func (*GetStatusRequest) ProtoMessage ¶
func (*GetStatusRequest) ProtoMessage()
func (*GetStatusRequest) ProtoReflect ¶
func (x *GetStatusRequest) ProtoReflect() protoreflect.Message
func (*GetStatusRequest) Reset ¶
func (x *GetStatusRequest) Reset()
func (*GetStatusRequest) String ¶
func (x *GetStatusRequest) String() string
type GetStatusResponse ¶
type GetStatusResponse struct {
Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
UptimeSeconds uint64 `protobuf:"varint,3,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
TotalProcesses uint32 `protobuf:"varint,4,opt,name=total_processes,json=totalProcesses,proto3" json:"total_processes,omitempty"`
RunningProcesses uint32 `protobuf:"varint,5,opt,name=running_processes,json=runningProcesses,proto3" json:"running_processes,omitempty"`
StoppedProcesses uint32 `protobuf:"varint,6,opt,name=stopped_processes,json=stoppedProcesses,proto3" json:"stopped_processes,omitempty"`
FailedProcesses uint32 `protobuf:"varint,7,opt,name=failed_processes,json=failedProcesses,proto3" json:"failed_processes,omitempty"`
CreatedProcesses uint32 `protobuf:"varint,8,opt,name=created_processes,json=createdProcesses,proto3" json:"created_processes,omitempty"`
ExitedProcesses uint32 `protobuf:"varint,9,opt,name=exited_processes,json=exitedProcesses,proto3" json:"exited_processes,omitempty"`
StartingProcesses uint32 `protobuf:"varint,10,opt,name=starting_processes,json=startingProcesses,proto3" json:"starting_processes,omitempty"`
StoppingProcesses uint32 `protobuf:"varint,11,opt,name=stopping_processes,json=stoppingProcesses,proto3" json:"stopping_processes,omitempty"`
// contains filtered or unexported fields
}
func (*GetStatusResponse) Descriptor
deprecated
func (*GetStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.
func (*GetStatusResponse) GetCreatedProcesses ¶
func (x *GetStatusResponse) GetCreatedProcesses() uint32
func (*GetStatusResponse) GetExitedProcesses ¶
func (x *GetStatusResponse) GetExitedProcesses() uint32
func (*GetStatusResponse) GetFailedProcesses ¶
func (x *GetStatusResponse) GetFailedProcesses() uint32
func (*GetStatusResponse) GetReady ¶
func (x *GetStatusResponse) GetReady() bool
func (*GetStatusResponse) GetRunningProcesses ¶
func (x *GetStatusResponse) GetRunningProcesses() uint32
func (*GetStatusResponse) GetStartingProcesses ¶
func (x *GetStatusResponse) GetStartingProcesses() uint32
func (*GetStatusResponse) GetStoppedProcesses ¶
func (x *GetStatusResponse) GetStoppedProcesses() uint32
func (*GetStatusResponse) GetStoppingProcesses ¶
func (x *GetStatusResponse) GetStoppingProcesses() uint32
func (*GetStatusResponse) GetTotalProcesses ¶
func (x *GetStatusResponse) GetTotalProcesses() uint32
func (*GetStatusResponse) GetUptimeSeconds ¶
func (x *GetStatusResponse) GetUptimeSeconds() uint64
func (*GetStatusResponse) GetVersion ¶
func (x *GetStatusResponse) GetVersion() string
func (*GetStatusResponse) ProtoMessage ¶
func (*GetStatusResponse) ProtoMessage()
func (*GetStatusResponse) ProtoReflect ¶
func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
func (*GetStatusResponse) Reset ¶
func (x *GetStatusResponse) Reset()
func (*GetStatusResponse) String ¶
func (x *GetStatusResponse) String() string
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 ListResponse ¶
type ListResponse struct {
Processes []*Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
// contains filtered or unexported fields
}
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetProcesses ¶
func (x *ListResponse) GetProcesses() []*Process
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type Process ¶
type Process struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Pid uint32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
State ProcessState `protobuf:"varint,6,opt,name=state,proto3,enum=datadog.procmgr.ProcessState" json:"state,omitempty"`
RestartCount uint32 `protobuf:"varint,7,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
LastExitCode *int32 `protobuf:"varint,8,opt,name=last_exit_code,json=lastExitCode,proto3,oneof" json:"last_exit_code,omitempty"`
LastSignal *int32 `protobuf:"varint,9,opt,name=last_signal,json=lastSignal,proto3,oneof" json:"last_signal,omitempty"`
// contains filtered or unexported fields
}
func (*Process) Descriptor
deprecated
func (*Process) GetCommand ¶
func (*Process) GetLastExitCode ¶
func (*Process) GetLastSignal ¶
func (*Process) GetRestartCount ¶
func (*Process) GetState ¶
func (x *Process) GetState() ProcessState
func (*Process) ProtoMessage ¶
func (*Process) ProtoMessage()
func (*Process) ProtoReflect ¶
func (x *Process) ProtoReflect() protoreflect.Message
type ProcessDetail ¶
type ProcessDetail struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
Pid uint32 `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
State ProcessState `protobuf:"varint,5,opt,name=state,proto3,enum=datadog.procmgr.ProcessState" json:"state,omitempty"`
Command string `protobuf:"bytes,6,opt,name=command,proto3" json:"command,omitempty"`
Args []string `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"`
WorkingDir string `protobuf:"bytes,8,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
Env map[string]string `` /* 133-byte string literal not displayed */
RestartPolicy string `protobuf:"bytes,10,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
Stdout string `protobuf:"bytes,11,opt,name=stdout,proto3" json:"stdout,omitempty"`
Stderr string `protobuf:"bytes,12,opt,name=stderr,proto3" json:"stderr,omitempty"`
AutoStart bool `protobuf:"varint,13,opt,name=auto_start,json=autoStart,proto3" json:"auto_start,omitempty"`
ConditionPathExists string `protobuf:"bytes,14,opt,name=condition_path_exists,json=conditionPathExists,proto3" json:"condition_path_exists,omitempty"`
After []string `protobuf:"bytes,15,rep,name=after,proto3" json:"after,omitempty"`
Before []string `protobuf:"bytes,16,rep,name=before,proto3" json:"before,omitempty"`
RestartCount uint32 `protobuf:"varint,17,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
LastExitCode *int32 `protobuf:"varint,18,opt,name=last_exit_code,json=lastExitCode,proto3,oneof" json:"last_exit_code,omitempty"`
LastSignal *int32 `protobuf:"varint,19,opt,name=last_signal,json=lastSignal,proto3,oneof" json:"last_signal,omitempty"`
// contains filtered or unexported fields
}
func (*ProcessDetail) Descriptor
deprecated
func (*ProcessDetail) Descriptor() ([]byte, []int)
Deprecated: Use ProcessDetail.ProtoReflect.Descriptor instead.
func (*ProcessDetail) GetAfter ¶
func (x *ProcessDetail) GetAfter() []string
func (*ProcessDetail) GetArgs ¶
func (x *ProcessDetail) GetArgs() []string
func (*ProcessDetail) GetAutoStart ¶
func (x *ProcessDetail) GetAutoStart() bool
func (*ProcessDetail) GetBefore ¶
func (x *ProcessDetail) GetBefore() []string
func (*ProcessDetail) GetCommand ¶
func (x *ProcessDetail) GetCommand() string
func (*ProcessDetail) GetConditionPathExists ¶
func (x *ProcessDetail) GetConditionPathExists() string
func (*ProcessDetail) GetDescription ¶
func (x *ProcessDetail) GetDescription() string
func (*ProcessDetail) GetEnv ¶
func (x *ProcessDetail) GetEnv() map[string]string
func (*ProcessDetail) GetLastExitCode ¶
func (x *ProcessDetail) GetLastExitCode() int32
func (*ProcessDetail) GetLastSignal ¶
func (x *ProcessDetail) GetLastSignal() int32
func (*ProcessDetail) GetName ¶
func (x *ProcessDetail) GetName() string
func (*ProcessDetail) GetPid ¶
func (x *ProcessDetail) GetPid() uint32
func (*ProcessDetail) GetRestartCount ¶
func (x *ProcessDetail) GetRestartCount() uint32
func (*ProcessDetail) GetRestartPolicy ¶
func (x *ProcessDetail) GetRestartPolicy() string
func (*ProcessDetail) GetState ¶
func (x *ProcessDetail) GetState() ProcessState
func (*ProcessDetail) GetStderr ¶
func (x *ProcessDetail) GetStderr() string
func (*ProcessDetail) GetStdout ¶
func (x *ProcessDetail) GetStdout() string
func (*ProcessDetail) GetUuid ¶
func (x *ProcessDetail) GetUuid() string
func (*ProcessDetail) GetWorkingDir ¶
func (x *ProcessDetail) GetWorkingDir() string
func (*ProcessDetail) ProtoMessage ¶
func (*ProcessDetail) ProtoMessage()
func (*ProcessDetail) ProtoReflect ¶
func (x *ProcessDetail) ProtoReflect() protoreflect.Message
func (*ProcessDetail) Reset ¶
func (x *ProcessDetail) Reset()
func (*ProcessDetail) String ¶
func (x *ProcessDetail) String() string
type ProcessManagerClient ¶
type ProcessManagerClient interface {
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
ReloadConfig(ctx context.Context, in *ReloadConfigRequest, opts ...grpc.CallOption) (*ReloadConfigResponse, error)
GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, 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 {
List(context.Context, *ListRequest) (*ListResponse, error)
Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
Create(context.Context, *CreateRequest) (*CreateResponse, error)
Start(context.Context, *StartRequest) (*StartResponse, error)
Stop(context.Context, *StopRequest) (*StopResponse, error)
ReloadConfig(context.Context, *ReloadConfigRequest) (*ReloadConfigResponse, error)
GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
// contains filtered or unexported methods
}
ProcessManagerServer is the server API for ProcessManager service. All implementations must embed UnimplementedProcessManagerServer for forward compatibility.
type ProcessState ¶
type ProcessState int32
const ( ProcessState_UNKNOWN ProcessState = 0 ProcessState_CREATED ProcessState = 1 ProcessState_STARTING ProcessState = 2 ProcessState_RUNNING ProcessState = 3 ProcessState_STOPPING ProcessState = 4 ProcessState_STOPPED ProcessState = 5 ProcessState_CRASHED ProcessState = 6 ProcessState_EXITED ProcessState = 7 ProcessState_FAILED ProcessState = 8 )
func (ProcessState) Descriptor ¶
func (ProcessState) Descriptor() protoreflect.EnumDescriptor
func (ProcessState) Enum ¶
func (x ProcessState) Enum() *ProcessState
func (ProcessState) EnumDescriptor
deprecated
func (ProcessState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProcessState.Descriptor instead.
func (ProcessState) Number ¶
func (x ProcessState) Number() protoreflect.EnumNumber
func (ProcessState) String ¶
func (x ProcessState) String() string
func (ProcessState) Type ¶
func (ProcessState) Type() protoreflect.EnumType
type ReloadConfigRequest ¶
type ReloadConfigRequest struct {
// contains filtered or unexported fields
}
func (*ReloadConfigRequest) Descriptor
deprecated
func (*ReloadConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReloadConfigRequest.ProtoReflect.Descriptor instead.
func (*ReloadConfigRequest) ProtoMessage ¶
func (*ReloadConfigRequest) ProtoMessage()
func (*ReloadConfigRequest) ProtoReflect ¶
func (x *ReloadConfigRequest) ProtoReflect() protoreflect.Message
func (*ReloadConfigRequest) Reset ¶
func (x *ReloadConfigRequest) Reset()
func (*ReloadConfigRequest) String ¶
func (x *ReloadConfigRequest) String() string
type ReloadConfigResponse ¶
type ReloadConfigResponse struct {
Added []string `protobuf:"bytes,1,rep,name=added,proto3" json:"added,omitempty"`
Removed []string `protobuf:"bytes,2,rep,name=removed,proto3" json:"removed,omitempty"`
Modified []string `protobuf:"bytes,3,rep,name=modified,proto3" json:"modified,omitempty"`
Unchanged []string `protobuf:"bytes,4,rep,name=unchanged,proto3" json:"unchanged,omitempty"`
// contains filtered or unexported fields
}
func (*ReloadConfigResponse) Descriptor
deprecated
func (*ReloadConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReloadConfigResponse.ProtoReflect.Descriptor instead.
func (*ReloadConfigResponse) GetAdded ¶
func (x *ReloadConfigResponse) GetAdded() []string
func (*ReloadConfigResponse) GetModified ¶
func (x *ReloadConfigResponse) GetModified() []string
func (*ReloadConfigResponse) GetRemoved ¶
func (x *ReloadConfigResponse) GetRemoved() []string
func (*ReloadConfigResponse) GetUnchanged ¶
func (x *ReloadConfigResponse) GetUnchanged() []string
func (*ReloadConfigResponse) ProtoMessage ¶
func (*ReloadConfigResponse) ProtoMessage()
func (*ReloadConfigResponse) ProtoReflect ¶
func (x *ReloadConfigResponse) ProtoReflect() protoreflect.Message
func (*ReloadConfigResponse) Reset ¶
func (x *ReloadConfigResponse) Reset()
func (*ReloadConfigResponse) String ¶
func (x *ReloadConfigResponse) String() string
type StartRequest ¶
type StartRequest struct {
NameOrUuid string `protobuf:"bytes,1,opt,name=name_or_uuid,json=nameOrUuid,proto3" json:"name_or_uuid,omitempty"`
// contains filtered or unexported fields
}
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetNameOrUuid ¶
func (x *StartRequest) GetNameOrUuid() string
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 StartResponse ¶
type StartResponse struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
State ProcessState `protobuf:"varint,3,opt,name=state,proto3,enum=datadog.procmgr.ProcessState" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetPid ¶
func (x *StartResponse) GetPid() uint32
func (*StartResponse) GetState ¶
func (x *StartResponse) GetState() ProcessState
func (*StartResponse) GetUuid ¶
func (x *StartResponse) GetUuid() string
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) String ¶
func (x *StartResponse) String() string
type StopRequest ¶
type StopRequest struct {
NameOrUuid string `protobuf:"bytes,1,opt,name=name_or_uuid,json=nameOrUuid,proto3" json:"name_or_uuid,omitempty"`
// contains filtered or unexported fields
}
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) GetNameOrUuid ¶
func (x *StopRequest) GetNameOrUuid() 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 StopResponse ¶
type StopResponse struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
State ProcessState `protobuf:"varint,2,opt,name=state,proto3,enum=datadog.procmgr.ProcessState" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetState ¶
func (x *StopResponse) GetState() ProcessState
func (*StopResponse) GetUuid ¶
func (x *StopResponse) GetUuid() string
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type UnimplementedProcessManagerServer ¶
type UnimplementedProcessManagerServer struct{}
UnimplementedProcessManagerServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedProcessManagerServer) Create ¶
func (UnimplementedProcessManagerServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
func (UnimplementedProcessManagerServer) Describe ¶
func (UnimplementedProcessManagerServer) Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
func (UnimplementedProcessManagerServer) GetConfig ¶
func (UnimplementedProcessManagerServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedProcessManagerServer) GetStatus ¶
func (UnimplementedProcessManagerServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
func (UnimplementedProcessManagerServer) List ¶
func (UnimplementedProcessManagerServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedProcessManagerServer) ReloadConfig ¶
func (UnimplementedProcessManagerServer) ReloadConfig(context.Context, *ReloadConfigRequest) (*ReloadConfigResponse, error)
func (UnimplementedProcessManagerServer) Start ¶
func (UnimplementedProcessManagerServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedProcessManagerServer) Stop ¶
func (UnimplementedProcessManagerServer) Stop(context.Context, *StopRequest) (*StopResponse, 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.