eosswedenorg/antelope-api-healthcheck
1
0
Fork 0
mirror of https://github.com/eosswedenorg/antelope-api-healthcheck synced 2026-07-02 11:43:42 +02:00
Code Releases Activity

go mod: Update github.com/eosswedenorg-go/haproxy to v1.0.1

Browse source
This commit is contained in:
Henrik Hautakoski 2022-12-22 12:41:26 +01:00
parent 64d46ed460
commit 2caad14e44
No known key found for this signature in database
GPG key ID: 217490840C18A5D9
9 changed files with 16 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

2
go.mod
View file

@ -4,7 +4,7 @@ go 1.18
require ( require (
github.com/eosswedenorg-go/atomicasset v0.1.0 github.com/eosswedenorg-go/atomicasset v0.1.0
github.com/eosswedenorg-go/haproxy v0.1.1 github.com/eosswedenorg-go/haproxy v1.0.1
github.com/eosswedenorg-go/leapapi v0.2.1 github.com/eosswedenorg-go/leapapi v0.2.1
github.com/eosswedenorg-go/pid v1.0.1 github.com/eosswedenorg-go/pid v1.0.1
github.com/eosswedenorg-go/tcp_server v0.2.1 github.com/eosswedenorg-go/tcp_server v0.2.1

4
go.sum
View file

@ -21,8 +21,8 @@ github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSs
github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk= github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
github.com/eosswedenorg-go/atomicasset v0.1.0 h1:HRxFO7tOdyyygbxJjPm810x09sOUPbJW6pleslAjU+c= github.com/eosswedenorg-go/atomicasset v0.1.0 h1:HRxFO7tOdyyygbxJjPm810x09sOUPbJW6pleslAjU+c=
github.com/eosswedenorg-go/atomicasset v0.1.0/go.mod h1:QWm39AIPrv0CsYI2SRajNxpRyrHg5kcQwa/a0hf0wVo= github.com/eosswedenorg-go/atomicasset v0.1.0/go.mod h1:QWm39AIPrv0CsYI2SRajNxpRyrHg5kcQwa/a0hf0wVo=
github.com/eosswedenorg-go/haproxy v0.1.1 h1:ClOhoK3uGn70KzGCKHdYNvHoU72whfNq3LbqT/lWlOY= github.com/eosswedenorg-go/haproxy v1.0.1 h1:N9tyQSvEDG9Fq+gBP0b7A8R5iZAqYCms2K6Nvqq8TfE=
github.com/eosswedenorg-go/haproxy v0.1.1/go.mod h1:WnDKkwYbgrpuKUOtUtWlGCgj43DMV+r4VKGdWSTYQeA= github.com/eosswedenorg-go/haproxy v1.0.1/go.mod h1:rBXDRd72ifA/IvsZUpW8Q4gR5rbV/4DAuKC/lqDrwWQ=
github.com/eosswedenorg-go/leapapi v0.2.1 h1:zeY4TtVbgIPpLcD4wl42u+G/K+YfTN9YtpY4cb51KMQ= github.com/eosswedenorg-go/leapapi v0.2.1 h1:zeY4TtVbgIPpLcD4wl42u+G/K+YfTN9YtpY4cb51KMQ=
github.com/eosswedenorg-go/leapapi v0.2.1/go.mod h1:RZPrRzqh3SqhEQiutvld6960xFCOUq7Xk2h8jhHw/lc= github.com/eosswedenorg-go/leapapi v0.2.1/go.mod h1:RZPrRzqh3SqhEQiutvld6960xFCOUq7Xk2h8jhHw/lc=
github.com/eosswedenorg-go/pid v1.0.1 h1:W4AEnnNwb041SpNR1uTZ/KbJ0OTA5eqiqIR1Q5Ah6A0= github.com/eosswedenorg-go/pid v1.0.1 h1:W4AEnnNwb041SpNR1uTZ/KbJ0OTA5eqiqIR1Q5Ah6A0=

2
internal/api/atomicasset.go
View file

@ -38,7 +38,7 @@ func (e AtomicAsset) LogInfo() LogParams {
func (e AtomicAsset) Call() (agentcheck.Response, string) { func (e AtomicAsset) Call() (agentcheck.Response, string) {
h, err := e.client.GetHealth() h, err := e.client.GetHealth()
if err != nil { if err != nil {
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") resp := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
return resp, err.Error() return resp, err.Error()
} }

2
internal/api/atomicasset_test.go
View file

@ -52,7 +52,7 @@ func TestAtomicAsset_JsonFailure(t *testing.T) {
api := NewAtomicAsset(srv.URL, 120) api := NewAtomicAsset(srv.URL, 120)
check, _ := api.Call() check, _ := api.Call()
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }

2
internal/api/eosio_v1.go
View file

@ -47,7 +47,7 @@ func (e AntelopeV1) LogInfo() LogParams {
func (e AntelopeV1) Call() (agentcheck.Response, string) { func (e AntelopeV1) Call() (agentcheck.Response, string) {
info, err := e.client.GetInfo() info, err := e.client.GetInfo()
if err != nil { if err != nil {
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") resp := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
return resp, err.Error() return resp, err.Error()
} }

4
internal/api/eosio_v1_test.go
View file

@ -53,7 +53,7 @@ func TestAntelopeV1_JsonFailure(t *testing.T) {
api := NewAntelopeV1(srv.URL, "", 120) api := NewAntelopeV1(srv.URL, "", 120)
check, _ := api.Call() check, _ := api.Call()
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }
@ -69,7 +69,7 @@ func TestAntelopeV1_HTTP500Failed(t *testing.T) {
assert.Equal(t, "server returned HTTP 500 Internal Server Error", status) assert.Equal(t, "server returned HTTP 500 Internal Server Error", status)
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }

4
internal/api/eosio_v2.go
View file

@ -46,7 +46,7 @@ func (e AntelopeV2) LogInfo() LogParams {
func (e AntelopeV2) Call() (agentcheck.Response, string) { func (e AntelopeV2) Call() (agentcheck.Response, string) {
health, err := e.client.GetHealth() health, err := e.client.GetHealth()
if err != nil { if err != nil {
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") resp := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
return resp, err.Error() return resp, err.Error()
} }
@ -67,7 +67,7 @@ func (e AntelopeV2) Call() (agentcheck.Response, string) {
msg := fmt.Sprintf("Failed to get Elasticsearch and/or nodeos "+ msg := fmt.Sprintf("Failed to get Elasticsearch and/or nodeos "+
"block numbers (es: %d, eos: %d)", es_block, node_block) "block numbers (es: %d, eos: %d)", es_block, node_block)
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") resp := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
return resp, msg return resp, msg
} }

10
internal/api/eosio_v2_test.go
View file

@ -41,7 +41,7 @@ func TestAntelopeV2_JsonFailure(t *testing.T) {
api := NewAntelopeV2(srv.URL, "", 120) api := NewAntelopeV2(srv.URL, "", 120)
check, _ := api.Call() check, _ := api.Call()
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }
@ -57,7 +57,7 @@ func TestAntelopeV2_HTTP500Failed(t *testing.T) {
assert.Equal(t, "server returned HTTP 500 Internal Server Error", status) assert.Equal(t, "server returned HTTP 500 Internal Server Error", status)
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }
@ -292,7 +292,7 @@ func TestAntelopeV2_ElasticsFailed(t *testing.T) {
assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 0, eos: 263148621)", status) assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 0, eos: 263148621)", status)
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }
@ -339,7 +339,7 @@ func TestAntelopeV2_NodeosRPCFailed(t *testing.T) {
assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 263148121, eos: 0)", status) assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 263148121, eos: 0)", status)
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }
@ -376,6 +376,6 @@ func TestAntelopeV2_ElasticsNodeosRPCFailed(t *testing.T) {
assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 0, eos: 0)", status) assert.Equal(t, "Failed to get Elasticsearch and/or nodeos block numbers (es: 0, eos: 0)", status)
expected := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") expected := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
assert.Equal(t, expected, check) assert.Equal(t, expected, check)
} }

2
internal/server/server.go
View file

@ -20,7 +20,7 @@ func onTcpMessage(c *tcp_server.Client, args string) {
healthCheckApi, err := ParseRequest(args) healthCheckApi, err := ParseRequest(args)
if err != nil { if err != nil {
logger.Warn("Agent request error", "message", err) logger.Warn("Agent request error", "message", err)
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "") resp := agentcheck.NewStatusMessageResponse(agentcheck.Fail, "")
_, err = c.WriteString(resp.String()) _, err = c.WriteString(resp.String())
if err != nil { if err != nil {