Documentation
¶
Index ¶
- Constants
- Variables
- func CreateChecker(ctx context.Context, options ...Option) context.Context
- func RegisterReadinesSubservices(ctx context.Context, services ...string) error
- func SetServingStatus(ctx context.Context, service string, serving bool)
- func WithHealthServer(parent context.Context, server *Checker) context.Context
- type Checker
- func (c *Checker) Check(ctx context.Context, in *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
- func (c *Checker) RegisterServices(probeSvc string, services ...string)
- func (c *Checker) SetServingStatus(service string, servingStatus grpc_health_v1.HealthCheckResponse_ServingStatus)
- func (c *Checker) Start() error
- type HealthServerStatusModifier
- type Option
Constants ¶
const ( Startup string = "Startup" Readiness string = "Readiness" Liveness string = "Liveness" )
const ( IPAMSvc string = "IPAM" IPAMCliSvc string = "IPAMCli" NSPCliSvc string = "NSPCli" EgressSvc string = "Egress" NSMEndpointSvc string = "NSMEndpoint" TargetRegistryCliSvc string = "TargetRegistryCli" StreamSvc string = "Stream" FlowSvc string = "Flow" )
const (
DefaultURL string = "unix:///tmp/health.sock"
)
Variables ¶
var FEReadinessServices []string = []string{NSPCliSvc, TargetRegistryCliSvc, EgressSvc}
var IPAMReadinessServices []string = []string{NSPCliSvc, IPAMSvc}
var LBReadinessServices []string = []string{NSPCliSvc, NSMEndpointSvc, EgressSvc, StreamSvc, FlowSvc}
var ProxyReadinessServices []string = []string{IPAMCliSvc, NSPCliSvc, NSMEndpointSvc, EgressSvc}
Functions ¶
func CreateChecker ¶
CreateChecker - Wraps NewChecker() and saves Checker into context, also starts Checker in a goroutine TODO: revisit if it's really needed to fail the program on error
func RegisterReadinesSubservices ¶
RegisterReadinesSubservices - Wraps Checker.RegisterServices() by fetching the health server (i.e. Checker) from context
func SetServingStatus ¶
SetServingStatus - Wraps Checker.SetServingStatus() by fetching the health server (i.e. Checker) from context
Types ¶
type Checker ¶
type Checker struct {
grpc_health_v1.HealthServer
HealthServerStatusModifier
// contains filtered or unexported fields
}
func HealthServer ¶
Server - Returns Health Server (Checker) from the context.Context
func NewChecker ¶
NewChecker - Creates gRPC health server
func (*Checker) Check ¶
func (c *Checker) Check(ctx context.Context, in *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
Check - Re-implements Check() function of grpc_health_v1.HealthServer interface in order to log if a probe service is about to fail.
func (*Checker) RegisterServices ¶
RegisterServices - Registers subservices for a probe service whose serving status will be deterimined by the serving status of the subservices. Note: currently a subservice can only belong to one probe service
func (*Checker) SetServingStatus ¶
func (c *Checker) SetServingStatus(service string, servingStatus grpc_health_v1.HealthCheckResponse_ServingStatus)
Re-implements SetServingStatus function in order to evaluate probe service status in case a related subservice is subject to the call
type HealthServerStatusModifier ¶
type HealthServerStatusModifier interface {
SetServingStatus(service string, servingStatus grpc_health_v1.HealthCheckResponse_ServingStatus)
Shutdown()
}
Source Files
Directories