peerhealth

Feb 5, 2024

Changes in this version

type HealthRequest

+ MachineName string

+ func (x *HealthRequest) GetMachineName() string

Feb 20, 2023

Changes in this version

+ var File_pkg_peerhealth_peerhealth_proto protoreflect.FileDescriptor

+ var PeerHealth_ServiceDesc = grpc.ServiceDesc

+ func RegisterPeerHealthServer(s grpc.ServiceRegistrar, srv PeerHealthServer)

+ type Client struct

+ func NewClient(serverAddr string, peerDialTimeout time.Duration, log logr.Logger, ...) (*Client, error)

+ func (c *Client) Close()

+ type HealthRequest struct

+ NodeName string

+ func (*HealthRequest) Descriptor() ([]byte, []int)

+ func (*HealthRequest) ProtoMessage()

+ func (x *HealthRequest) GetNodeName() string

+ func (x *HealthRequest) ProtoReflect() protoreflect.Message

+ func (x *HealthRequest) Reset()

+ func (x *HealthRequest) String() string

+ type HealthResponse struct

+ Status int32

+ func (*HealthResponse) Descriptor() ([]byte, []int)

+ func (*HealthResponse) ProtoMessage()

+ func (x *HealthResponse) GetStatus() int32

+ func (x *HealthResponse) ProtoReflect() protoreflect.Message

+ func (x *HealthResponse) Reset()

+ func (x *HealthResponse) String() string

+ type PeerHealthClient interface

+ IsHealthy func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ func NewPeerHealthClient(cc grpc.ClientConnInterface) PeerHealthClient

+ type PeerHealthServer interface

+ IsHealthy func(context.Context, *HealthRequest) (*HealthResponse, error)

+ type Server struct

+ func NewServer(snr *controllers.SelfNodeRemediationReconciler, conf *rest.Config, ...) (*Server, error)

+ func (s *Server) Start(ctx context.Context) error

+ func (s Server) IsHealthy(ctx context.Context, request *HealthRequest) (*HealthResponse, error)

+ type UnimplementedPeerHealthServer struct

+ func (UnimplementedPeerHealthServer) IsHealthy(context.Context, *HealthRequest) (*HealthResponse, error)

+ type UnsafePeerHealthServer interface