process_master

Documentation

Index

• Variables
• func Process()
• func ProcessDo(handler *MasterHandler)
• type AdminController
  • func NewAdminConfig(raftData dispatcher.IDispatchCenter, adminProcess *process.ProcessController) *AdminController
  • func (ac *AdminController) LeaderChange(isLeader bool)
  • func (ac *AdminController) Stop()
• type CtxManager
  • func NewCtxManager() *CtxManager
  • func (c *CtxManager) Close() error
  • func (c *CtxManager) Get(name string) context.Context
  • func (c *CtxManager) Stop(namespace string)
• type CtxWidthCancel
• type DataController
  • func NewDataController(raftData dispatcher.IDispatchCenter, extenderManager *extender.Manager, ...) *DataController
  • func (c *DataController) Close()
• type DispatcherServer
  • func NewDispatcherServer() *DispatcherServer
  • func (d *DispatcherServer) Close() error
  • func (d *DispatcherServer) Dispatch(event dispatcher.IEvent)
  • func (d *DispatcherServer) Listen(request *service.EmptyRequest, server service.MasterDispatcher_ListenServer) error
  • func (d *DispatcherServer) Update(es []*extender.Status, success bool)
• type EtcdSender
  • func NewEtcdSender(etcd etcd.Etcd) *EtcdSender
  • func (e *EtcdSender) Send(event string, namespace string, key string, data []byte) error
• type ForkStatus
  • func (fs *ForkStatus) IsRunningFork() bool
  • func (fs *ForkStatus) Start() bool
  • func (fs *ForkStatus) Stop() bool
• type Master
  • func NewMasterHandle(logWriter io.Writer) *Master
  • func (m *Master) Close()
  • func (m *Master) Fork(pFile *pidfile.PidFile) error
  • func (m *Master) Start(handler *MasterHandler) error
  • func (m *Master) Wait(pFile *pidfile.PidFile) error
• type MasterHandler
• type UnixAdminProcess
  • func NewUnixClient() *UnixAdminProcess
  • func (uc *UnixAdminProcess) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
  • func (uc *UnixAdminProcess) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (uc *UnixAdminProcess) Update(process *exec.Cmd)
• type WorkerController
  • func NewWorkerController(traffic traffic.IController, listensMsg *config.ListensMsg, ...) *WorkerController
  • func (wc *WorkerController) Stop()
  • func (wc *WorkerController) Update(status []*extender.Status, success bool)

Variables

var (
	ErrorAdminProcessNotInit = errors.New("admin process not init")
)

Functions

func Process

func Process()

func ProcessDo

func ProcessDo(handler *MasterHandler)

Types

type AdminController

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

AdminController admin控制器，管理admin进程的启动、重启

func NewAdminConfig

func NewAdminConfig(raftData dispatcher.IDispatchCenter, adminProcess *process.ProcessController) *AdminController

func (*AdminController) LeaderChange

func (ac *AdminController) LeaderChange(isLeader bool)

func (*AdminController) Stop

func (ac *AdminController) Stop()

type CtxManager

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

func NewCtxManager

func NewCtxManager() *CtxManager

func (*CtxManager) Close

func (c *CtxManager) Close() error

func (*CtxManager) Get

func (c *CtxManager) Get(name string) context.Context

func (*CtxManager) Stop

func (c *CtxManager) Stop(namespace string)

type CtxWidthCancel

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

type DataController

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

func NewDataController

func NewDataController(raftData dispatcher.IDispatchCenter, extenderManager *extender.Manager, dispatcherService *DispatcherServer) *DataController

func (*DataController) Close

func (c *DataController) Close()

type DispatcherServer

type DispatcherServer struct {
	service.UnimplementedMasterDispatcherServer
	// contains filtered or unexported fields
}

func NewDispatcherServer

func NewDispatcherServer() *DispatcherServer

func (*DispatcherServer) Close

func (d *DispatcherServer) Close() error

func (*DispatcherServer) Dispatch

func (d *DispatcherServer) Dispatch(event dispatcher.IEvent)

func (*DispatcherServer) Listen

func (d *DispatcherServer) Listen(request *service.EmptyRequest, server service.MasterDispatcher_ListenServer) error

func (*DispatcherServer) Update

func (d *DispatcherServer) Update(es []*extender.Status, success bool)

type EtcdSender

type EtcdSender struct {
	etcd.Etcd
}

func NewEtcdSender

func NewEtcdSender(etcd etcd.Etcd) *EtcdSender

func (*EtcdSender) Send

func (e *EtcdSender) Send(event string, namespace string, key string, data []byte) error

type ForkStatus

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

func (*ForkStatus) IsRunningFork

func (fs *ForkStatus) IsRunningFork() bool

func (*ForkStatus) Start

func (fs *ForkStatus) Start() bool

func (*ForkStatus) Stop

func (fs *ForkStatus) Stop() bool

type Master

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

func NewMasterHandle

func NewMasterHandle(logWriter io.Writer) *Master

func (*Master) Close

func (m *Master) Close()

func (*Master) Fork

func (m *Master) Fork(pFile *pidfile.PidFile) error

Fork Master fork 子进程，入参为子进程需要的内容

func (*Master) Start

func (m *Master) Start(handler *MasterHandler) error

func (*Master) Wait

func (m *Master) Wait(pFile *pidfile.PidFile) error

type MasterHandler

type MasterHandler struct {
	InitProfession func() []*eosc.ProfessionConfig
}

type UnixAdminProcess

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

func NewUnixClient

func NewUnixClient() *UnixAdminProcess

func (*UnixAdminProcess) DialContext

func (uc *UnixAdminProcess) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

func (*UnixAdminProcess) ServeHTTP

func (uc *UnixAdminProcess) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*UnixAdminProcess) Update

func (uc *UnixAdminProcess) Update(process *exec.Cmd)

type WorkerController

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

func NewWorkerController

func NewWorkerController(traffic traffic.IController, listensMsg *config.ListensMsg, workerProcess *process.ProcessController) *WorkerController

func (*WorkerController) Stop

func (wc *WorkerController) Stop()

func (*WorkerController) Update

func (wc *WorkerController) Update(status []*extender.Status, success bool)