statusService

package

v1.7.2 Latest Latest Go to latest Published: May 16, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func CheckServicesStatus(services []string, command CmdExecutor) (int, int, []string)

CheckServicesStatus checks the status of the services, custom CmdExecutor is used to enhance testability

func ProbeEndpoint(ctx context.Context, endpoint string) error

type CmdExecutor = func(name string, args ...string) *exec.Cmd

type StatusService struct {
	pb.UnimplementedStatusServiceServer
	// contains filtered or unexported fields
}

func InitStatusService(confs *config.NodeAgentConfig) (*grpc.Server, *StatusService)

func (s *StatusService) GatherStatus(confs *config.NodeAgentConfig) (string, bool)

func (s *StatusService) GetStatusInterval(ctx context.Context, in *pb.GetStatusIntervalRequest) (*pb.GetStatusIntervalResponse, error)

func (s *StatusService) PollNetworkEndpoints(ctx context.Context, endpoints []config.NetworkEndpoint)

PollNetworkEndpoints polls the given endpoints and logs their status

func (s *StatusService) ReportStatus(ctx context.Context, in *pb.ReportStatusRequest) (*pb.ReportStatusResponse, error)

type StatusValue struct {
	Status    pb.Status
	Timestamp int64
}