agent

Documentation

Index

• type Agent
  • func New(reg registry.Registry, pm proc.ProcMgr, m machine.Machine, ttl time.Duration) *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
  • func NewAgentHeartbeat(reg registry.Registry, ag *Agent, ttl time.Duration) *AgentHeartbeat
  • func (h *AgentHeartbeat) Run(stopc <-chan struct{})
• type AgentReconciler
  • func NewReconciler(reg registry.Registry, es pkg.EventStream, ag *Agent) *AgentReconciler
  • func (ar *AgentReconciler) Run(stopc <-chan struct{})
• type ProcessStatePublisher
  • func NewProcessStatePublisher(reg registry.Registry, ag *Agent, ttl time.Duration) *ProcessStatePublisher
  • func (p *ProcessStatePublisher) Run(stopc <-chan struct{})

Types

type Agent

type Agent struct {
	Reg     registry.Registry
	ProcMgr proc.ProcMgr
	Mach    machine.Machine
	TTL     time.Duration
	// contains filtered or unexported fields
}

func New

func New(reg registry.Registry, pm proc.ProcMgr, m machine.Machine, ttl time.Duration) *Agent

func (*Agent) BirthCry

func (a *Agent) BirthCry() error

func (*Agent) DestroyProcess

func (a *Agent) DestroyProcess(procID string) error

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 (a *Agent) ListProcessesByMachID(machID string) (res map[string]*proc.ProcessStatus, err error)

func (*Agent) ListProcessesBySvcName

func (a *Agent) ListProcessesBySvcName(svcName string) (res map[string]*proc.ProcessStatus, err error)

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 (a *Agent) StartProcess(procID string) error

func (*Agent) StopProcess

func (a *Agent) StopProcess(procID string) error

type AgentHeartbeat

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

func NewAgentHeartbeat

func NewAgentHeartbeat(reg registry.Registry, ag *Agent, ttl time.Duration) *AgentHeartbeat

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 NewProcessStatePublisher

func NewProcessStatePublisher(reg registry.Registry, ag *Agent, ttl time.Duration) *ProcessStatePublisher

func (*ProcessStatePublisher) Run

func (p *ProcessStatePublisher) Run(stopc <-chan struct{})