procmgr

package
v0.81.2 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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.

View Source
var File_datadog_procmgr_process_manager_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetArgs

func (x *Process) GetArgs() []string

func (*Process) GetCommand

func (x *Process) GetCommand() string

func (*Process) GetLastExitCode

func (x *Process) GetLastExitCode() int32

func (*Process) GetLastSignal

func (x *Process) GetLastSignal() int32

func (*Process) GetName

func (x *Process) GetName() string

func (*Process) GetPid

func (x *Process) GetPid() uint32

func (*Process) GetRestartCount

func (x *Process) GetRestartCount() uint32

func (*Process) GetState

func (x *Process) GetState() ProcessState

func (*Process) GetUuid

func (x *Process) GetUuid() string

func (*Process) ProtoMessage

func (*Process) ProtoMessage()

func (*Process) ProtoReflect

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

func (*Process) Reset

func (x *Process) Reset()

func (*Process) String

func (x *Process) String() string

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.

type ProcessManagerServer

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

func (x ProcessState) Enum() *ProcessState

func (ProcessState) EnumDescriptor deprecated

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

Deprecated: Use ProcessState.Descriptor instead.

func (ProcessState) Number

func (ProcessState) String

func (x ProcessState) String() string

func (ProcessState) Type

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

func (UnimplementedProcessManagerServer) GetConfig

func (UnimplementedProcessManagerServer) GetStatus

func (UnimplementedProcessManagerServer) List

func (UnimplementedProcessManagerServer) ReloadConfig

func (UnimplementedProcessManagerServer) Start

func (UnimplementedProcessManagerServer) Stop

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.

Jump to

Keyboard shortcuts

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