Dkron RunJob
2024-02-18 10:28:47 0 举报Dkron 核心实现，关键请求交互
作者其他创作
大纲/内容
Raft Leader
手动调，不判断 (j *Job) isRunnable
(c *dkronClient) RunJob
Serf layer
(a *Agent) establishLeadership
Dkron 任务调度 defaultSelector 采用随机选择方式
(s *Store) GetJob
Plugin
Streaming call
Agent Server
(m *ExecutorClient) Execute
(a *Agent) monitorLeadership()
grpcs.agent.raft.Apply
(grpcc *GRPCClient) ExecutionDone
(s *Shell) Execute
Raft 的 Leader 即作为 Dkron 的 Leader
RPC
Raft layer
(a *Agent) getTargetNodes
GRPCStatusHelperServer
(grpcc *GRPCClient) RunJob
(a *Agent) Run
(as *AgentServer) AgentRun
(c *executorClient) Execute
(m ExecutorServer) Execute
(grpcs *GRPCServer) RunJob
(j *Job) Run()
Bind
grpcc.agent.raft.Leader
GRPCStatusHelperClient
(grpcc *GRPCClient) AgentRun
stream
(h *HTTPTransport) jobRunHandler
Agent Worker
(s *Scheduler) Start
(j *Job) isRunnable
statusAgentHelper
(c *agentClient) AgentRun
0 条评论
下一页
