agent - OpenStack Neutron 源码分析

返回介绍

agent

发布于 2019-11-12 字数4504 浏览 679 评论 0

agent

包括 agent.py、agent_api.py、agent_device_driver.py
agent_manager.py 等模块,实现 LBaaS 服务的 agent 部分。

agent.py

按照标准流程,启动了一个 LbaasAgentService 服务,主代码如下。

def main():
    cfg.CONF.register_opts(OPTS)
    cfg.CONF.register_opts(manager.OPTS)
    # import interface options just in case the driver uses namespaces
    cfg.CONF.register_opts(interface.OPTS)
    config.register_interface_driver_opts_helper(cfg.CONF)
    config.register_agent_state_opts_helper(cfg.CONF)
    config.register_root_helper(cfg.CONF)

    common_config.init(sys.argv[1:])
    config.setup_logging()

    mgr = manager.LbaasAgentManager(cfg.CONF)
    svc = LbaasAgentService(
        host=cfg.CONF.host,
        topic=topics.LOADBALANCER_AGENT,
        manager=mgr
    )
    service.launch(svc).wait()

其中,管理服务类为 agent_manager 中的 LbaasAgentManager 类。

LbaasAgentService 类是一个 rpc 服务类,定期执行管理服务类中的周期性任务。

class LbaasAgentService(n_rpc.Service):
    def start(self):
        super(LbaasAgentService, self).start()
        self.tg.add_timer(
            cfg.CONF.periodic_interval,
            self.manager.run_periodic_tasks,
            None,
            None
        )
agent_manager.py

主要就是定义了 LbaasAgentManager 类,继承自 n_rpc.RpcCallback 和 periodic_task.PeriodicTasks。

作为 agent 中的管理类。它实现了 LBaaS 中定义的各种操作 API,包括:

  • agent_updated
  • collect_stats
  • create_member
  • create_pool
  • create_pool_health_monitor
  • create_vip
  • delete_member
  • delete_pool
  • delete_pool_health_monitor
  • delete_vip
  • initialize_service_hook
  • periodic_resync
  • remove_orphans
  • sync_state
  • update_member
  • update_pool
  • update_pool_health_monitor
  • update_vip
    这些操作又是通过调用更下一层的 driver 来实现。

同时,它定义了一个 rpc api 调用成员,向 topics.LOADBALANCER_PLUGIN 主题发送消息。

self.plugin_rpc = agent_api.LbaasAgentApi(
            topics.LOADBALANCER_PLUGIN,
            self.context,
            self.conf.host
        )
agent_api.py

主要定义了 LbaasAgentApi 类,继承自 n_rpc.RpcProxy,也是一个典型的 RPC 代理类。

这个类在 LbaasAgentManager 类中使用,用来负责替 agent 向指定的主题发送消息,调用监听者的对应方法。主要包括:

  • get_logical_device
  • get_ready_devices
  • plug_vip_port
  • pool_deployed
  • pool_destroyed
  • unplug_vip_port
  • update_pool_stats
  • update_status
agent_device_driver.py

主要定义了 AgentDeviceDriver 类,是一个抽象类,抽象出来支持 LBaaS agent 所需要 API 的一个驱动类。这些 API 包括对 pool、member 等资源的 CRUD 等。

上一篇:loadbalancer

下一篇:agent_scheduler.py

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

目前还没有任何评论,快来抢沙发吧!