Commit dd0f3183 authored by NILANJAN DAW's avatar NILANJAN DAW

Update readme.md to reflect new nomencleture for DM

parent b2c7f892
...@@ -77,8 +77,8 @@ and whoever needs the data is allowed to read it. Each message is required to ha ...@@ -77,8 +77,8 @@ and whoever needs the data is allowed to read it. Each message is required to ha
``` ```
## Dispatch System (DS) ## Dispatch System (DS)
The DS is divided into two submodules the **Dispatch Manager** and the **Dispatch Daemon**. The Dispatcher runs on the Master node while the Dispatch Daemon The DS is divided into two submodules the **Dispatch Manager** and the **Dispatch Daemon**. The Dispatch Manager runs on the Master node while the Dispatch Daemon
runs on each Worker nodes. When a request arrives at the dispatcher, it queries the RM for resources and on receiving the resource requests the Dispatch Daemon runs on each Worker nodes. When a request arrives at the Dispatch Manager, it queries the RM for resources and on receiving the resource requests the Dispatch Daemon
to run and execute the function on the specified worker node. to run and execute the function on the specified worker node.
### Directory Structure ### Directory Structure
...@@ -95,7 +95,7 @@ to run and execute the function on the specified worker node. ...@@ -95,7 +95,7 @@ to run and execute the function on the specified worker node.
│   ├── local_repository │   ├── local_repository
│   ├── package.json │   ├── package.json
│   └── package-lock.json │   └── package-lock.json
├── dispatcher ├── dispatch_manager
│   ├── index.js │   ├── index.js
│   ├── isolate.js │   ├── isolate.js
│   ├── lib.js │   ├── lib.js
...@@ -125,14 +125,14 @@ to run and execute the function on the specified worker node. ...@@ -125,14 +125,14 @@ to run and execute the function on the specified worker node.
### Internal Communication Interfaces ### Internal Communication Interfaces
#### Dispatcher #### Dispatch Manager (DM)
Internally DM uses Apache Kafka for interaction between the Dispatcher and the Dispatch Agents, while the messages are in JSON format. Internally DM uses Apache Kafka for interaction between the Dispatch Manager (DM) and the Dispatch Agents, while the messages are in JSON format.
Every Dispatch Agent listens on a topic which is its own UID (Currently the primary IP Address), the Dispatcher listens on the topics *"response"* and Every Dispatch Agent listens on a topic which is its own UID (Currently the primary IP Address), the Dispatch Manager listens on the topics *"response"* and
*"heartbeat"*. *"heartbeat"*.
- **Request Message:** When a request is received at the Dispatcher, it directs the Dispatch Agent to start a worker environment. A message is sent via the - **Request Message:** When a request is received at the Dispatch Manager, it directs the Dispatch Agent to start a worker environment. A message is sent via the
- chose Worker's ID topic. \ - chose Worker's ID topic. \
Format: Format:
...@@ -152,7 +152,7 @@ Format: ...@@ -152,7 +152,7 @@ Format:
function_id: 'onetime unique ID' } function_id: 'onetime unique ID' }
``` ```
- **Heartbeat Message:** The Dispatch Daemons also publish a periodic Heartbeat message back to the Dispatcher as a liveness test.\ - **Heartbeat Message:** The Dispatch Daemons also publish a periodic Heartbeat message back to the Dispatch Manager as a liveness test.\
Format: Format:
```javascript ```javascript
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment