mirror of
https://github.com/eosswedenorg/antelope-api-healthcheck
synced 2026-07-03 11:53:43 +02:00
src/server.go: Minor cleanup.
This commit is contained in:
parent
66bc6f97af
commit
ef13af4eb7
1 changed files with 11 additions and 3 deletions
|
|
@ -135,30 +135,38 @@ func main() {
|
||||||
});
|
});
|
||||||
|
|
||||||
// TCP Client sends message.
|
// TCP Client sends message.
|
||||||
server.OnNewMessage(func(c *tcp_server.Client, message string) {
|
server.OnNewMessage(func(c *tcp_server.Client, args string) {
|
||||||
params := eosapi.ReqParams{}
|
params := eosapi.ReqParams{}
|
||||||
var block_time int = 10
|
var block_time int = 10
|
||||||
var version string = "v1"
|
var version string = "v1"
|
||||||
|
|
||||||
// Parse host + port.
|
// Parse arguments.
|
||||||
split := strings.Split(strings.TrimSpace(message), "|")
|
// -------------------
|
||||||
|
split := strings.Split(strings.TrimSpace(args), "|")
|
||||||
|
|
||||||
|
// 1. url (scheme + ip/domain + port)
|
||||||
params.Url = split[0]
|
params.Url = split[0]
|
||||||
|
|
||||||
|
// 2. Block time.
|
||||||
if len(split) > 1 {
|
if len(split) > 1 {
|
||||||
p, err := strconv.ParseInt(split[1], 10, 32)
|
p, err := strconv.ParseInt(split[1], 10, 32)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
block_time = int(p)
|
block_time = int(p)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 3. Version
|
||||||
if len(split) > 2 {
|
if len(split) > 2 {
|
||||||
version = split[2]
|
version = split[2]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 4. Host
|
||||||
if len(split) > 3 {
|
if len(split) > 3 {
|
||||||
params.Host = split[3]
|
params.Host = split[3]
|
||||||
}
|
}
|
||||||
|
|
||||||
// Check api.
|
// Check api.
|
||||||
|
// -------------------
|
||||||
var status haproxy.HealthCheckStatus
|
var status haproxy.HealthCheckStatus
|
||||||
var msg string
|
var msg string
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue