process_worker

Documentation

Index

• func Process()
• type ProcessWorker
  • func NewProcessWorker(arg *service.ProcessLoadArg) (*ProcessWorker, error)
  • func (w *ProcessWorker) OpenMetricsServer() error
  • func (w *ProcessWorker) Start() error
• type WorkerServer
  • func NewWorkerServer(masterPid int, extends extends.IExtenderRegister, initHandlers ...func()) (*WorkerServer, error)
  • func (ws *WorkerServer) Stop()

Functions

func Process

func Process()

Types

type ProcessWorker

type ProcessWorker struct {
	// contains filtered or unexported fields
}

func NewProcessWorker

func NewProcessWorker(arg *service.ProcessLoadArg) (*ProcessWorker, error)

NewProcessWorker 创建新的worker进程 启动时通过stdin传输配置信息

func (*ProcessWorker) OpenMetricsServer

func (w *ProcessWorker) OpenMetricsServer() error

func (*ProcessWorker) Start

func (w *ProcessWorker) Start() error

type WorkerServer

type WorkerServer struct {
	// contains filtered or unexported fields
}

func NewWorkerServer

func NewWorkerServer(masterPid int, extends extends.IExtenderRegister, initHandlers ...func()) (*WorkerServer, error)

func (*WorkerServer) Stop

func (ws *WorkerServer) Stop()