...

2. Container Creation Flow

Image Modified

① When a new queue is created, it immediately sends a container creation request to the ContainerManager because there is no container yet.

...

⑦ At the same time, once a new container is created, it stores its data to ETCD. This data is used while scheduling containers.

3. Activation Flow

Image Modified

① While the queue and the containers are being created, activation flows the system like above. PoolBalancer just sends the request to the scheduler topic in Kafka. The MessageConsumer who subscribes to the topic receives the request and deserializes it. The message is sent to the leader queue. If there is no queue for the given activation message, it will forward it to the proper scheduler by fetching the queue endpoint information from ETCD.

...