Documentation
¶
Index ¶
- Variables
- func Process()
- func ProcessDo(handler *MasterHandler)
- type AdminController
- type CtxManager
- type CtxWidthCancel
- type DataController
- type DispatcherServer
- type EtcdSender
- type ForkStatus
- type Master
- func (m *Master) Close()
- func (m *Master) EtcdInfoHandler(w http.ResponseWriter, r *http.Request)
- func (m *Master) EtcdNodesHandler(w http.ResponseWriter, r *http.Request)
- 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 UnixClient
- type WorkerController
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrorAdminProcessNotInit = errors.New("admin process not init")
)
Functions ¶
func ProcessDo ¶ added in v0.5.0
func ProcessDo(handler *MasterHandler)
Types ¶
type AdminController ¶ added in v0.5.0
type AdminController struct {
// contains filtered or unexported fields
}
AdminController admin控制器,管理admin进程的启动、重启
func NewAdminConfig ¶ added in v0.5.0
func NewAdminConfig(raftData dispatcher.IDispatchCenter, adminProcess *process.ProcessController) *AdminController
func (*AdminController) LeaderChange ¶ added in v0.6.0
func (ac *AdminController) LeaderChange(isLeader bool)
func (*AdminController) Stop ¶ added in v0.5.0
func (ac *AdminController) Stop()
type CtxManager ¶ added in v0.5.0
type CtxManager struct {
// contains filtered or unexported fields
}
func NewCtxManager ¶ added in v0.5.0
func NewCtxManager() *CtxManager
func (*CtxManager) Close ¶ added in v0.5.0
func (c *CtxManager) Close() error
func (*CtxManager) Stop ¶ added in v0.5.0
func (c *CtxManager) Stop(namespace string)
type CtxWidthCancel ¶ added in v0.5.0
type CtxWidthCancel struct {
// contains filtered or unexported fields
}
type DataController ¶ added in v0.5.0
type DataController struct {
// contains filtered or unexported fields
}
func NewDataController ¶ added in v0.5.0
func NewDataController(raftData dispatcher.IDispatchCenter, extenderManager *extender.Manager, dispatcherService *DispatcherServer) *DataController
func (*DataController) Close ¶ added in v0.5.0
func (c *DataController) Close()
type DispatcherServer ¶ added in v0.5.0
type DispatcherServer struct { service.UnimplementedMasterDispatcherServer // contains filtered or unexported fields }
func NewDispatcherServer ¶ added in v0.5.0
func NewDispatcherServer() *DispatcherServer
func (*DispatcherServer) Close ¶ added in v0.5.0
func (d *DispatcherServer) Close() error
func (*DispatcherServer) Dispatch ¶ added in v0.5.0
func (d *DispatcherServer) Dispatch(event dispatcher.IEvent)
func (*DispatcherServer) Listen ¶ added in v0.5.0
func (d *DispatcherServer) Listen(request *service.EmptyRequest, server service.MasterDispatcher_ListenServer) error
type EtcdSender ¶ added in v0.6.0
func NewEtcdSender ¶ added in v0.6.0
func NewEtcdSender(etcd etcd.Etcd) *EtcdSender
type ForkStatus ¶ added in v0.3.0
type ForkStatus struct {
// contains filtered or unexported fields
}
func (*ForkStatus) IsRunningFork ¶ added in v0.3.0
func (fs *ForkStatus) IsRunningFork() bool
func (*ForkStatus) Start ¶ added in v0.3.0
func (fs *ForkStatus) Start() bool
func (*ForkStatus) Stop ¶ added in v0.3.0
func (fs *ForkStatus) Stop() bool
type Master ¶
type Master struct {
// contains filtered or unexported fields
}
func NewMasterHandle ¶
func (*Master) EtcdInfoHandler ¶ added in v0.7.0
func (m *Master) EtcdInfoHandler(w http.ResponseWriter, r *http.Request)
func (*Master) EtcdNodesHandler ¶ added in v0.7.0
func (m *Master) EtcdNodesHandler(w http.ResponseWriter, r *http.Request)
func (*Master) Start ¶
func (m *Master) Start(handler *MasterHandler) error
type MasterHandler ¶
type UnixClient ¶ added in v0.7.0
type UnixClient struct {
// contains filtered or unexported fields
}
func NewUnixClient ¶ added in v0.5.0
func NewUnixClient() *UnixClient
func (*UnixClient) DialContext ¶ added in v0.7.0
func (*UnixClient) ServeHTTP ¶ added in v0.7.0
func (uc *UnixClient) ServeHTTP(writer http.ResponseWriter, request *http.Request)
func (*UnixClient) Update ¶ added in v0.7.0
func (uc *UnixClient) Update(process *exec.Cmd)
type WorkerController ¶
type WorkerController struct {
// contains filtered or unexported fields
}
func NewWorkerController ¶
func NewWorkerController(tfd *traffic.TrafficData, listensMsg config.ListenUrl, workerProcess *process.ProcessController) *WorkerController
func (*WorkerController) Stop ¶
func (wc *WorkerController) Stop()
Source Files
¶
Click to show internal directories.
Click to hide internal directories.