From da7dc4ec8372f1b4e19d12db813bdf828ce76ec7 Mon Sep 17 00:00:00 2001 From: Milan M Bhagwat Date: Mon, 13 Jun 2022 13:50:22 +0530 Subject: [PATCH] Updating consuming code after func renaming --- flow-state/server/rest/endpoints.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow-state/server/rest/endpoints.go b/flow-state/server/rest/endpoints.go index 663c7f5..1debeca 100644 --- a/flow-state/server/rest/endpoints.go +++ b/flow-state/server/rest/endpoints.go @@ -88,7 +88,7 @@ func AppendEndpoints(router *httprouter.Router, logger log.Logger, exposeRecorde router.POST("/v1/instances/end", sm.saveEnd) } // start saveStep worker go routines - maxOpenConn := sm.stepStore.GetMaxOpenConn() + maxOpenConn := sm.stepStore.MaxConcurrencyLimit() for i := 0; i < maxOpenConn; i++ { go saveStepWorker(sm) } @@ -98,7 +98,7 @@ func (se *ServiceEndpoints) getHealthCheck(response http.ResponseWriter, request se.logger.Debugf("Endpoint[GET:/health] : Called") switch request.Method { case http.MethodGet: - if se.stepStore.GetDBPingStatus() { + if se.stepStore.Status() { response.WriteHeader(http.StatusOK) } else { se.logger.Info("Health check status failed")