README
¶
Probes
Probes is a simple package to implement readiness and liveness endpoints.
⚙️ Installation
go get -u czechia.dev/probes
👀 Example
package main
import (
"time"
"czechia.dev/probes"
"github.com/gofiber/fiber/v2"
)
func NewFiberRoute(p *probes.Probe) func(ctx *fiber.Ctx) error {
return func(ctx *fiber.Ctx) error {
switch p.IsDown() {
case false:
return ctx.SendStatus(fiber.StatusOK)
case true:
return ctx.SendStatus(fiber.StatusServiceUnavailable)
}
}
}
func main() {
go probes.RunProbe(probes.Liveness)
go probes.RunProbe(probes.Readiness)
app := fiber.New()
app.Get("/liveness", NewFiberRoute(probes.Liveness))
app.Get("/readiness", NewFiberRoute(probes.Readiness))
go app.Listen(":8080")
for ; true; <-time.NewTicker(3 * time.Second).C {
probes.LivenessProbe(probes.Liveness)
probes.ReadinessProbe(probes.Readiness, func() error { return nil })
}
}
Documentation
¶
Index ¶
Constants ¶
const ( Up status = "UP" Down status = "DOWN" )
Variables ¶
This section is empty.
Functions ¶
func LivenessProbe ¶
LivenessProbe sets the given Liveness probe to DOWN if any given Readiness probe is DOWN for more than 5 minutes.
This function typically runs in its own goroutine. The return parameter may be used for tests.
func ReadinessProbe ¶
ReadinessProbe runs any test functions passed to it. If any of the tests fail the given probe is set to DOWN.
This function typically runs in its own goroutine. The return parameter may be used for tests.
func RunProbe ¶
RunProbe waits for status messages on the probe channel.
The probe status is updated if the recieved status differs from the current status. The probe timestamp is also updated when the status changes to DOWN.
This function typically runs in its own goroutine. The return parameter may be used for tests.
Source Files