informerV1

package
v6.0.0-beta.13 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use JobState.ProtoReflect.Descriptor instead.

func (*JobState) GetActive

func (x *JobState) GetActive() int64

func (*JobState) GetDelayed

func (x *JobState) GetDelayed() int64

func (*JobState) GetDriver

func (x *JobState) GetDriver() string

func (*JobState) GetErrorMessage

func (x *JobState) GetErrorMessage() string

func (*JobState) GetPipeline

func (x *JobState) GetPipeline() string

func (*JobState) GetPriority

func (x *JobState) GetPriority() uint64

func (*JobState) GetQueue

func (x *JobState) GetQueue() string

func (*JobState) GetReady

func (x *JobState) GetReady() bool

func (*JobState) GetReserved

func (x *JobState) GetReserved() int64

func (*JobState) ProtoMessage

func (*JobState) ProtoMessage()

func (*JobState) ProtoReflect

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

func (*JobState) Reset

func (x *JobState) Reset()

func (*JobState) String

func (x *JobState) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use JobsList.ProtoReflect.Descriptor instead.

func (*JobsList) GetStates

func (x *JobsList) GetStates() []*JobState

func (*JobsList) ProtoMessage

func (*JobsList) ProtoMessage()

func (*JobsList) ProtoReflect

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

func (*JobsList) Reset

func (x *JobsList) Reset()

func (*JobsList) String

func (x *JobsList) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetOk

func (x *Response) GetOk() bool

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

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

Jump to

Keyboard shortcuts

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