probe

package

v0.0.0-...-5e666d9 Latest Latest Go to latest Published: Oct 30, 2025 License: Apache-2.0 Imports: 8 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type HealthService interface {
	Register(server *grpc.Server)
	SetServing()
	Shutdown()
}

func NewHealthService() HealthService

type LivenessProbe struct {
	// contains filtered or unexported fields
}

LivenessProbe wraps a liveness probe handler.

func (p *LivenessProbe) LivenessHandler(w goHttp.ResponseWriter, r *goHttp.Request)

LivenessHandler writes back the HTTP status code 200 if the operator is ready, and 500 otherwise.

func (p *LivenessProbe) Lock()

Lock the probe, preventing the LivenessHandler from responding to requests.

func (p *LivenessProbe) Unlock()

Unlock the probe, allowing the LivenessHandler to respond to requests.

type ReadyProbe struct {
	// contains filtered or unexported fields
}

ReadyProbe wraps a readiness probe handler.

func (p *ReadyProbe) IsReady() bool

IsReady returns true when the given probe has been marked ready.

func (p *ReadyProbe) ReadyHandler(w goHttp.ResponseWriter, r *goHttp.Request)

ReadyHandler writes back the HTTP status code 200 if the operator is ready, and 500 otherwise.

func (p *ReadyProbe) SetReady()

SetReady marks the probe as ready.