Based on code-base, we should need correctly communication of producer,
worker along with central services following items:
1. Producer and Central.
- The producer will call Central via RPC as following code-base:
self.central_api.purge_zones(
ctxt,
criterion,
limit=self.options.batch_size,
)
2. Worker and Central.
- The worker will call Central to get pool via RPC firstly:
pool = self.central_api.get_pool(context, pool_id)
Change-Id: I9c98c2c1fb441a333bc8d917e122a4e0371ef7ce
dba2a8bc78
