Documentation
¶
Index ¶
- Variables
- type AddWorkerRequest
- type GetJobsRequest
- type GetWorkersRequest
- type JobState
- func (*JobState) Descriptor() ([]byte, []int)deprecated
- func (x *JobState) GetActive() int64
- func (x *JobState) GetDelayed() int64
- func (x *JobState) GetDriver() string
- func (x *JobState) GetErrorMessage() string
- func (x *JobState) GetPipeline() string
- func (x *JobState) GetPriority() uint64
- func (x *JobState) GetQueue() string
- func (x *JobState) GetReady() bool
- func (x *JobState) GetReserved() int64
- func (*JobState) ProtoMessage()
- func (x *JobState) ProtoReflect() protoreflect.Message
- func (x *JobState) Reset()
- func (x *JobState) String() string
- type JobsList
- type ListPluginsRequest
- type PluginsList
- type ProcessState
- func (*ProcessState) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessState) GetCommand() string
- func (x *ProcessState) GetCpuPercent() float32
- func (x *ProcessState) GetCreated() int64
- func (x *ProcessState) GetMemoryUsage() uint64
- func (x *ProcessState) GetNumExecs() uint64
- func (x *ProcessState) GetPid() int32
- func (x *ProcessState) GetStatus() int64
- func (x *ProcessState) GetStatusStr() string
- func (*ProcessState) ProtoMessage()
- func (x *ProcessState) ProtoReflect() protoreflect.Message
- func (x *ProcessState) Reset()
- func (x *ProcessState) String() string
- type RemoveWorkerRequest
- func (*RemoveWorkerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveWorkerRequest) GetPlugin() string
- func (*RemoveWorkerRequest) ProtoMessage()
- func (x *RemoveWorkerRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveWorkerRequest) Reset()
- func (x *RemoveWorkerRequest) String() string
- type Response
- type WorkersList
Constants ¶
This section is empty.
Variables ¶
var File_informer_v1_service_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AddWorkerRequest ¶
type AddWorkerRequest struct {
Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
// contains filtered or unexported fields
}
func (*AddWorkerRequest) Descriptor
deprecated
func (*AddWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddWorkerRequest.ProtoReflect.Descriptor instead.
func (*AddWorkerRequest) GetPlugin ¶
func (x *AddWorkerRequest) GetPlugin() string
func (*AddWorkerRequest) ProtoMessage ¶
func (*AddWorkerRequest) ProtoMessage()
func (*AddWorkerRequest) ProtoReflect ¶
func (x *AddWorkerRequest) ProtoReflect() protoreflect.Message
func (*AddWorkerRequest) Reset ¶
func (x *AddWorkerRequest) Reset()
func (*AddWorkerRequest) String ¶
func (x *AddWorkerRequest) String() string
type GetJobsRequest ¶
type GetJobsRequest struct {
Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
// contains filtered or unexported fields
}
func (*GetJobsRequest) Descriptor
deprecated
func (*GetJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJobsRequest.ProtoReflect.Descriptor instead.
func (*GetJobsRequest) GetPlugin ¶
func (x *GetJobsRequest) GetPlugin() string
func (*GetJobsRequest) ProtoMessage ¶
func (*GetJobsRequest) ProtoMessage()
func (*GetJobsRequest) ProtoReflect ¶
func (x *GetJobsRequest) ProtoReflect() protoreflect.Message
func (*GetJobsRequest) Reset ¶
func (x *GetJobsRequest) Reset()
func (*GetJobsRequest) String ¶
func (x *GetJobsRequest) String() string
type GetWorkersRequest ¶
type GetWorkersRequest struct {
Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
// contains filtered or unexported fields
}
func (*GetWorkersRequest) Descriptor
deprecated
func (*GetWorkersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkersRequest.ProtoReflect.Descriptor instead.
func (*GetWorkersRequest) GetPlugin ¶
func (x *GetWorkersRequest) GetPlugin() string
func (*GetWorkersRequest) ProtoMessage ¶
func (*GetWorkersRequest) ProtoMessage()
func (*GetWorkersRequest) ProtoReflect ¶
func (x *GetWorkersRequest) ProtoReflect() protoreflect.Message
func (*GetWorkersRequest) Reset ¶
func (x *GetWorkersRequest) Reset()
func (*GetWorkersRequest) String ¶
func (x *GetWorkersRequest) String() string
type JobState ¶
type JobState struct {
Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
Active int64 `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
Delayed int64 `protobuf:"varint,5,opt,name=delayed,proto3" json:"delayed,omitempty"`
Reserved int64 `protobuf:"varint,6,opt,name=reserved,proto3" json:"reserved,omitempty"`
Ready bool `protobuf:"varint,7,opt,name=ready,proto3" json:"ready,omitempty"`
Priority uint64 `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"`
ErrorMessage string `protobuf:"bytes,9,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
// contains filtered or unexported fields
}
JobState mirrors github.com/roadrunner-server/api-plugins/v6/jobs.State — one entry per consumer pipeline registered with the jobs plugin.
func (*JobState) Descriptor
deprecated
func (*JobState) GetDelayed ¶
func (*JobState) GetErrorMessage ¶
func (*JobState) GetPipeline ¶
func (*JobState) GetPriority ¶
func (*JobState) GetReserved ¶
func (*JobState) ProtoMessage ¶
func (*JobState) ProtoMessage()
func (*JobState) ProtoReflect ¶
func (x *JobState) ProtoReflect() protoreflect.Message
type JobsList ¶
type JobsList struct {
States []*JobState `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
// contains filtered or unexported fields
}
func (*JobsList) Descriptor
deprecated
func (*JobsList) ProtoMessage ¶
func (*JobsList) ProtoMessage()
func (*JobsList) ProtoReflect ¶
func (x *JobsList) ProtoReflect() protoreflect.Message
type ListPluginsRequest ¶
type ListPluginsRequest struct {
// contains filtered or unexported fields
}
func (*ListPluginsRequest) Descriptor
deprecated
func (*ListPluginsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListPluginsRequest.ProtoReflect.Descriptor instead.
func (*ListPluginsRequest) ProtoMessage ¶
func (*ListPluginsRequest) ProtoMessage()
func (*ListPluginsRequest) ProtoReflect ¶
func (x *ListPluginsRequest) ProtoReflect() protoreflect.Message
func (*ListPluginsRequest) Reset ¶
func (x *ListPluginsRequest) Reset()
func (*ListPluginsRequest) String ¶
func (x *ListPluginsRequest) String() string
type PluginsList ¶
type PluginsList struct {
Plugins []string `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
// contains filtered or unexported fields
}
func (*PluginsList) Descriptor
deprecated
func (*PluginsList) Descriptor() ([]byte, []int)
Deprecated: Use PluginsList.ProtoReflect.Descriptor instead.
func (*PluginsList) GetPlugins ¶
func (x *PluginsList) GetPlugins() []string
func (*PluginsList) ProtoMessage ¶
func (*PluginsList) ProtoMessage()
func (*PluginsList) ProtoReflect ¶
func (x *PluginsList) ProtoReflect() protoreflect.Message
func (*PluginsList) Reset ¶
func (x *PluginsList) Reset()
func (*PluginsList) String ¶
func (x *PluginsList) String() string
type ProcessState ¶
type ProcessState struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Status int64 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
NumExecs uint64 `protobuf:"varint,3,opt,name=num_execs,json=numExecs,proto3" json:"num_execs,omitempty"`
Created int64 `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"`
MemoryUsage uint64 `protobuf:"varint,5,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
CpuPercent float32 `protobuf:"fixed32,6,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
Command string `protobuf:"bytes,7,opt,name=command,proto3" json:"command,omitempty"`
StatusStr string `protobuf:"bytes,8,opt,name=status_str,json=statusStr,proto3" json:"status_str,omitempty"`
// contains filtered or unexported fields
}
ProcessState mirrors github.com/roadrunner-server/pool/v2/state/process.State — one entry per OS-level worker process managed by a plugin. Field widths match the existing service.v1.Status convention (int32 pid, float cpu_percent) rather than the Go-source int64/float64; PIDs fit in int32 per POSIX, and a percentage value comfortably fits in float32.
func (*ProcessState) Descriptor
deprecated
func (*ProcessState) Descriptor() ([]byte, []int)
Deprecated: Use ProcessState.ProtoReflect.Descriptor instead.
func (*ProcessState) GetCommand ¶
func (x *ProcessState) GetCommand() string
func (*ProcessState) GetCpuPercent ¶
func (x *ProcessState) GetCpuPercent() float32
func (*ProcessState) GetCreated ¶
func (x *ProcessState) GetCreated() int64
func (*ProcessState) GetMemoryUsage ¶
func (x *ProcessState) GetMemoryUsage() uint64
func (*ProcessState) GetNumExecs ¶
func (x *ProcessState) GetNumExecs() uint64
func (*ProcessState) GetPid ¶
func (x *ProcessState) GetPid() int32
func (*ProcessState) GetStatus ¶
func (x *ProcessState) GetStatus() int64
func (*ProcessState) GetStatusStr ¶
func (x *ProcessState) GetStatusStr() string
func (*ProcessState) ProtoMessage ¶
func (*ProcessState) ProtoMessage()
func (*ProcessState) ProtoReflect ¶
func (x *ProcessState) ProtoReflect() protoreflect.Message
func (*ProcessState) Reset ¶
func (x *ProcessState) Reset()
func (*ProcessState) String ¶
func (x *ProcessState) String() string
type RemoveWorkerRequest ¶
type RemoveWorkerRequest struct {
Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveWorkerRequest) Descriptor
deprecated
func (*RemoveWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveWorkerRequest.ProtoReflect.Descriptor instead.
func (*RemoveWorkerRequest) GetPlugin ¶
func (x *RemoveWorkerRequest) GetPlugin() string
func (*RemoveWorkerRequest) ProtoMessage ¶
func (*RemoveWorkerRequest) ProtoMessage()
func (*RemoveWorkerRequest) ProtoReflect ¶
func (x *RemoveWorkerRequest) ProtoReflect() protoreflect.Message
func (*RemoveWorkerRequest) Reset ¶
func (x *RemoveWorkerRequest) Reset()
func (*RemoveWorkerRequest) String ¶
func (x *RemoveWorkerRequest) String() string
type Response ¶
type Response struct {
Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
// contains filtered or unexported fields
}
func (*Response) Descriptor
deprecated
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type WorkersList ¶
type WorkersList struct {
Workers []*ProcessState `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
// contains filtered or unexported fields
}
func (*WorkersList) Descriptor
deprecated
func (*WorkersList) Descriptor() ([]byte, []int)
Deprecated: Use WorkersList.ProtoReflect.Descriptor instead.
func (*WorkersList) GetWorkers ¶
func (x *WorkersList) GetWorkers() []*ProcessState
func (*WorkersList) ProtoMessage ¶
func (*WorkersList) ProtoMessage()
func (*WorkersList) ProtoReflect ¶
func (x *WorkersList) ProtoReflect() protoreflect.Message
func (*WorkersList) Reset ¶
func (x *WorkersList) Reset()
func (*WorkersList) String ¶
func (x *WorkersList) String() string