diff options
Diffstat (limited to 'internal/api/health')
| -rw-r--r-- | internal/api/health/health.go | 48 | ||||
| -rw-r--r-- | internal/api/health/live.go | 54 | ||||
| -rw-r--r-- | internal/api/health/ready.go | 74 | 
3 files changed, 176 insertions, 0 deletions
| diff --git a/internal/api/health/health.go b/internal/api/health/health.go new file mode 100644 index 000000000..cf81f550a --- /dev/null +++ b/internal/api/health/health.go @@ -0,0 +1,48 @@ +// GoToSocial +// Copyright (C) GoToSocial Authors admin@gotosocial.org +// SPDX-License-Identifier: AGPL-3.0-or-later +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. + +package health + +import ( +	"context" +	"net/http" + +	"github.com/gin-gonic/gin" +) + +const ( +	LivePath  = "/livez" +	ReadyPath = "/readyz" +) + +type Module struct { +	readyF func(context.Context) error +} + +func New(readyF func(context.Context) error) *Module { +	return &Module{ +		readyF: readyF, +	} +} + +func (m *Module) Route(attachHandler func(method string, path string, f ...gin.HandlerFunc) gin.IRoutes) { +	attachHandler(http.MethodGet, LivePath, m.LiveGETRequest) +	attachHandler(http.MethodHead, LivePath, m.LiveHEADRequest) + +	attachHandler(http.MethodGet, ReadyPath, m.ReadyGETRequest) +	attachHandler(http.MethodHead, ReadyPath, m.ReadyHEADRequest) +} diff --git a/internal/api/health/live.go b/internal/api/health/live.go new file mode 100644 index 000000000..d8841b913 --- /dev/null +++ b/internal/api/health/live.go @@ -0,0 +1,54 @@ +// GoToSocial +// Copyright (C) GoToSocial Authors admin@gotosocial.org +// SPDX-License-Identifier: AGPL-3.0-or-later +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. + +package health + +import ( +	"net/http" + +	"github.com/gin-gonic/gin" +) + +// LiveGETRequest swagger:operation GET /livez liveGet +// +// Returns code 200 with no body if GoToSocial is "live", ie., able to respond to HTTP requests. +// +//	--- +//	tags: +//	- health +// +//	responses: +//		'200': +//			description: OK +func (m *Module) LiveGETRequest(c *gin.Context) { +	c.Status(http.StatusOK) +} + +// LiveHEADRequest swagger:operation HEAD /livez liveHead +// +// Returns code 200 if GoToSocial is "live", ie., able to respond to HTTP requests. +// +//	--- +//	tags: +//	- health +// +//	responses: +//		'200': +//			description: OK +func (m *Module) LiveHEADRequest(c *gin.Context) { +	c.Status(http.StatusOK) +} diff --git a/internal/api/health/ready.go b/internal/api/health/ready.go new file mode 100644 index 000000000..70e3a324a --- /dev/null +++ b/internal/api/health/ready.go @@ -0,0 +1,74 @@ +// GoToSocial +// Copyright (C) GoToSocial Authors admin@gotosocial.org +// SPDX-License-Identifier: AGPL-3.0-or-later +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. + +package health + +import ( +	"net/http" + +	"github.com/superseriousbusiness/gotosocial/internal/gtserror" + +	"github.com/gin-gonic/gin" +) + +func (m *Module) ready(c *gin.Context) { +	if err := m.readyF(c.Request.Context()); err != nil { +		// Set error on the gin context so +		// it's logged by the logging middleware. +		errWithCode := gtserror.NewErrorInternalError(err) +		c.Error(errWithCode) //nolint:errcheck +		c.Status(http.StatusInternalServerError) +	} else { +		c.Status(http.StatusOK) +	} +} + +// ReadyGETRequest swagger:operation GET /readyz readyGet +// +// Returns code 200 with no body if GoToSocial is "ready", ie., able to connect to the database backend and do a simple SELECT. +// +// If GtS is not ready, 500 Internal Error will be returned, and an error will be logged (but not returned to the caller, to avoid leaking internals). +// +//	--- +//	tags: +//	- health +// +//	responses: +//		'200': +//			description: OK +//		'500': +//			description: Not ready. Check logs for error message. +func (m *Module) ReadyGETRequest(c *gin.Context) { +	m.ready(c) +} + +// ReadyHEADRequest swagger:operation HEAD /readyz readyHead +// +// Returns code 200 with no body if GoToSocial is "ready", ie., able to connect to the database backend and do a simple SELECT. +// +// If GtS is not ready, 500 Internal Error will be returned, and an error will be logged (but not returned to the caller, to avoid leaking internals). +// +//	--- +//	tags: +//	- health +// +//	responses: +//		'200': +//			description: OK +func (m *Module) ReadyHEADRequest(c *gin.Context) { +	m.ready(c) +} | 
