mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-15 17:51:15 +00:00
Code Activity

renamed message field replyTimeout to replyACKTimeout

Browse source
This commit is contained in:
postmannen 2021-04-15 10:52:38 +02:00
parent 8efecdb18e
commit 9bbff0ad84
7 changed files with 18 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
README.md
View file

@ -7,13 +7,17 @@ Command And Control anything like Servers, Containers, VM's or other by creating
```json ```json
[ [
{ {
"directory":"/var/steward/cli-command/executed-result", "directory":"cli_command__result",
"fileExtension": ".result",
"toNode": "ship1", "toNode": "ship1",
"data": ["bash","-c","sleep 3 & tree ./"], "data": ["bash","-c","sleep 5 & tree ./"],
"method":"REQCliCommand", "method":"REQCliCommand",
"ACKTimeout":10, "replyMethod":"REQToFileAppend",
"ACKTimeout":5,
"retries":3, "retries":3,
"methodTimeout": 4 "replyACKTimeout":5,
"replyRetries":3,
"methodTimeout": 10
} }
] ]
``` ```
@ -276,7 +280,7 @@ ACKTimeout
// Normal Resend retries // Normal Resend retries
retries retries
// The ACK timeout of the new message created via a request event. // The ACK timeout of the new message created via a request event.
replyTimeout replyACKTimeout
// The retries of the new message created via a request event. // The retries of the new message created via a request event.
replyRetries replyRetries
// Timeout for long a process should be allowed to operate // Timeout for long a process should be allowed to operate
@ -404,7 +408,7 @@ To send a Op Command message for process listing with custom timeout and amount
}, },
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }
@ -431,7 +435,7 @@ To send and Op Command to stop a subscriber on a node
}, },
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }
@ -457,7 +461,7 @@ To send and Op Command to start a subscriber on a node
}, },
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }

2
example/toShip1-REQCliCommand.json
View file

@ -8,7 +8,7 @@
"replyMethod":"REQToFileAppend", "replyMethod":"REQToFileAppend",
"ACKTimeout":5, "ACKTimeout":5,
"retries":3, "retries":3,
"replyTimeout":5, "replyACKTimeout":5,
"replyRetries":3, "replyRetries":3,
"methodTimeout": 10 "methodTimeout": 10
} }

2
example/toShip2-REQOpCmdStart_REQHttpGet.json
View file

@ -15,7 +15,7 @@
"replyMethod":"REQToFileAppend", "replyMethod":"REQToFileAppend",
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }

2
example/toShip2-REQOpCmdStop_REQHttpGet.json
View file

@ -16,7 +16,7 @@
"replyMethod":"REQToFileAppend", "replyMethod":"REQToFileAppend",
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }

2
example/toShip2-REQOpPs.json
View file

@ -11,7 +11,7 @@
"replyMethod":"REQToFileAppend", "replyMethod":"REQToFileAppend",
"ACKTimeout":3, "ACKTimeout":3,
"retries":3, "retries":3,
"replyTimeout":3, "replyACKTimeout":3,
"replyRetries":3, "replyRetries":3,
"MethodTimeout": 7 "MethodTimeout": 7
} }

2
message_and_subject.go
View file

@ -31,7 +31,7 @@ type Message struct {
// Resend retries // Resend retries
Retries int `json:"retries" yaml:"retries"` Retries int `json:"retries" yaml:"retries"`
// The ACK timeout of the new message created via a request event. // The ACK timeout of the new message created via a request event.
ReplyTimeout int `json:"replyTimeout" yaml:"replyTimeout"` ReplyACKTimeout int `json:"replyACKTimeout" yaml:"replyACKTimeout"`
// The retries of the new message created via a request event. // The retries of the new message created via a request event.
ReplyRetries int `json:"replyRetries" yaml:"replyRetries"` ReplyRetries int `json:"replyRetries" yaml:"replyRetries"`
// Timeout for long a process should be allowed to operate // Timeout for long a process should be allowed to operate

2
subscriber_method_types.go
View file

@ -408,7 +408,7 @@ func newReplyMessage(proc process, message Message, outData []byte) {
ToNode: message.FromNode, ToNode: message.FromNode,
Data: []string{string(outData)}, Data: []string{string(outData)},
Method: message.ReplyMethod, Method: message.ReplyMethod,
ACKTimeout: message.ReplyTimeout, ACKTimeout: message.ReplyACKTimeout,
Retries: message.ReplyRetries, Retries: message.ReplyRetries,
// Put in a copy of the initial request message, so we can use it's properties if // Put in a copy of the initial request message, so we can use it's properties if