Table of Contents | ||
---|---|---|
|
...
Akka-grpc is required to define a grpc message, there are some advantages in akka-cluster when it is being used for simple inter-cluster communication.
Entire system is comprised of three flows, 1. queue creation flow, 2. container creation flow, 3. activation flow.
1. Queue Creation Flow
① Once a new request comes, there is no queue for the action, a PoolBalancer starts queue creation flow by randomly choosing a scheduler and calling QueueCreationAPI(Akka-grpc).
...
2. Container Creation Flow
① When a new queue is created, it immediately sends a container creation request to the ContainerManager because there is no container yet.
...
⑥ Once the ContainerManager receives the ack message. It finishes the ContainerCreation in the normal case, and if it receives Rescheduling ack, it chooses another invoker and send ContainerCreation to it.
3. Activation Flow
① While the queue and the containers are being created, activation flows the system like above. PoolBalancer just sends the request to the action topic in Kafka.
...