Documentation
¶
Index ¶
- type Agent
- func (a *Agent) BirthCry() error
- func (a *Agent) DestroyProcess(procID string) error
- func (a *Agent) GetProcsFomeCache() map[string]*proc.ProcessStatus
- func (a *Agent) ListAllMachines() (res map[string]*machine.MachineStatus, err error)
- func (a *Agent) ListAllProcesses() (res map[string]*proc.ProcessStatus, err error)
- func (a *Agent) ListMachine(machID string) (res *machine.MachineStatus, err error)
- func (a *Agent) ListProcess(procID string) (res *proc.ProcessStatus, err error)
- func (a *Agent) ListProcessesByMachID(machID string) (res map[string]*proc.ProcessStatus, err error)
- func (a *Agent) ListProcessesBySvcName(svcName string) (res map[string]*proc.ProcessStatus, err error)
- func (a *Agent) SaveProcsToCache(procs map[string]*proc.ProcessStatus)
- func (a *Agent) ShowTiDBRealPerfermance() *service.TiDBPerfMetrics
- func (a *Agent) StartNewProcess(machID, svcName string, runinfo *proc.ProcessRunInfo) error
- func (a *Agent) StartProcess(procID string) error
- func (a *Agent) StopProcess(procID string) error
- type AgentHeartbeat
- type AgentReconciler
- type ProcessStatePublisher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Agent ¶
type Agent struct {
Reg registry.Registry
ProcMgr proc.ProcMgr
Mach machine.Machine
TTL time.Duration
// contains filtered or unexported fields
}
func (*Agent) DestroyProcess ¶
func (*Agent) GetProcsFomeCache ¶
func (a *Agent) GetProcsFomeCache() map[string]*proc.ProcessStatus
func (*Agent) ListAllMachines ¶
func (a *Agent) ListAllMachines() (res map[string]*machine.MachineStatus, err error)
func (*Agent) ListAllProcesses ¶
func (a *Agent) ListAllProcesses() (res map[string]*proc.ProcessStatus, err error)
func (*Agent) ListMachine ¶
func (a *Agent) ListMachine(machID string) (res *machine.MachineStatus, err error)
func (*Agent) ListProcess ¶
func (a *Agent) ListProcess(procID string) (res *proc.ProcessStatus, err error)
func (*Agent) ListProcessesByMachID ¶
func (*Agent) ListProcessesBySvcName ¶
func (*Agent) SaveProcsToCache ¶
func (a *Agent) SaveProcsToCache(procs map[string]*proc.ProcessStatus)
func (*Agent) ShowTiDBRealPerfermance ¶
func (a *Agent) ShowTiDBRealPerfermance() *service.TiDBPerfMetrics
func (*Agent) StartNewProcess ¶
func (a *Agent) StartNewProcess(machID, svcName string, runinfo *proc.ProcessRunInfo) error
func (*Agent) StartProcess ¶
func (*Agent) StopProcess ¶
type AgentHeartbeat ¶
type AgentHeartbeat struct {
// contains filtered or unexported fields
}
func NewAgentHeartbeat ¶
func (*AgentHeartbeat) Run ¶
func (h *AgentHeartbeat) Run(stopc <-chan struct{})
type AgentReconciler ¶
type AgentReconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶
func NewReconciler(reg registry.Registry, es pkg.EventStream, ag *Agent) *AgentReconciler
func (*AgentReconciler) Run ¶
func (ar *AgentReconciler) Run(stopc <-chan struct{})
type ProcessStatePublisher ¶
type ProcessStatePublisher struct {
// contains filtered or unexported fields
}
func (*ProcessStatePublisher) Run ¶
func (p *ProcessStatePublisher) Run(stopc <-chan struct{})
Source Files
Click to show internal directories.
Click to hide internal directories.