1
0
Fork 0
mirror of https://github.com/eosswedenorg/antelope-api-healthcheck synced 2026-06-18 05:00:03 +02:00

replace github.com/firstrow/tcp_server with github.com/eosswedenorg-go/tcp_server

This commit is contained in:
Henrik Hautakoski 2022-01-03 17:12:11 +01:00
parent 59bd699065
commit 3a4c827f8e
No known key found for this signature in database
GPG key ID: 608414D93E862CCD
3 changed files with 6 additions and 6 deletions

2
go.mod
View file

@ -9,7 +9,7 @@ require (
github.com/eosswedenorg-go/pid v1.0.0
github.com/eosswedenorg-go/haproxy v0.0.0-20220101140534-fccfdd93a8cd
github.com/firstrow/tcp_server v0.1.0
github.com/eosswedenorg-go/tcp_server v0.1.0
github.com/pborman/getopt/v2 v2.1.0
)

4
go.sum
View file

@ -5,8 +5,8 @@ github.com/eosswedenorg-go/haproxy v0.0.0-20220101140534-fccfdd93a8cd h1:e59v3Hn
github.com/eosswedenorg-go/haproxy v0.0.0-20220101140534-fccfdd93a8cd/go.mod h1:l5DTEb0dcTZyATo2cuaYQPqwBRuzDw0UgupNo8SAgXo=
github.com/eosswedenorg-go/pid v1.0.0 h1:k1ra19cgWBHnX5gWQq+eUhNHIjT7hdhsYGp+Ovfvd2U=
github.com/eosswedenorg-go/pid v1.0.0/go.mod h1:c9nVBDmo8pa3dVjrZjDUN4/DT1ChmfuCWXt6lHsagRc=
github.com/firstrow/tcp_server v0.1.0 h1:SeaKjoPUqSgwb8NLbXtcWEQS1H+QZ2hwPBBLd1TnGo4=
github.com/firstrow/tcp_server v0.1.0/go.mod h1:Yw3e670k1AHRzhd+WrOEvXLCMh5NDH01Kc/o0QR1GVQ=
github.com/eosswedenorg-go/tcp_server v0.1.0 h1:nbXJK4sPSGn3zGPGWR2vdmj+s/Ywp58k7dZ9fuYNZlI=
github.com/eosswedenorg-go/tcp_server v0.1.0/go.mod h1:PZd1z/KzNlEpmKtW0Zu9dHJLs5PAMTNR3jPbMGWhZIw=
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
github.com/imroc/req v0.3.2 h1:M/JkeU6RPmX+WYvT2vaaOL0K+q8ufL5LxwvJc4xeB4o=
github.com/imroc/req v0.3.2/go.mod h1:F+NZ+2EFSo6EFXdeIbpfE9hcC233id70kf0byW97Caw=

View file

@ -9,7 +9,7 @@ import (
"internal/eosapi"
"internal/utils"
"github.com/eosswedenorg-go/haproxy"
"github.com/firstrow/tcp_server"
"github.com/eosswedenorg-go/tcp_server"
)
// check_api - Validates head block time.
@ -144,7 +144,7 @@ func onTcpMessage(c *tcp_server.Client, args string) {
}
// Report status to HAproxy
c.Send(fmt.Sprintln(status))
c.WriteString(fmt.Sprintln(status))
c.Close()
}
@ -154,6 +154,6 @@ func onTcpMessage(c *tcp_server.Client, args string) {
func spawnTcpServer(addr string) {
server := tcp_server.New(addr)
server.OnNewMessage(onTcpMessage);
server.OnMessage(onTcpMessage)
server.Listen()
}