healthserver

Documentation

Index

• type ExtenderHealthServer
  • func NewExtenderHealthServer(logger *logrus.Logger, isPatchingEnabled bool) (*ExtenderHealthServer, error)
  • func (e *ExtenderHealthServer) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (e *ExtenderHealthServer) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error

Types

type ExtenderHealthServer

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

ExtenderHealthServer provides endpoint for extender readiness check

func NewExtenderHealthServer

func NewExtenderHealthServer(logger *logrus.Logger, isPatchingEnabled bool) (*ExtenderHealthServer, error)

NewExtenderHealthServer constructs ExtenderHealthServer for extender pod

func (*ExtenderHealthServer) Check

func (e *ExtenderHealthServer) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Check does the health check and changes the status of the server based on drives cache size

func (*ExtenderHealthServer) Watch

func (e *ExtenderHealthServer) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error

Watch is used by clients to receive updates when the svc status changes. Watch only dummy implemented just to satisfy the interface.