# agent

包括 agent.py、agent\_api.py、agent\_device\_driver.py agent\_manager.py 等模块，实现 LBaaS 服务的 agent 部分。

## agent.py

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

```python
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 服务类，定期执行管理服务类中的周期性任务。

```python
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 主题发送消息。

```python
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 等。