Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + type CommandInfo struct + Cancel context.CancelFunc + Cmd *exec.Cmd + Continuous bool + IsPaused bool + StartTime time.Time + Status string + type CommandService struct + func NewCommandService(logger *zap.Logger) *CommandService + func (s *CommandService) ExecCommand(req *pb.ExecCommandReq, stream pb.Command_ExecCommandServer) error + func (s *CommandService) ExecCommandSignal(ctx context.Context, req *pb.ExecCommandSignalReq) (*pb.ExecCommandSignalResp, error) + func (s *CommandService) GetCommandStatus(ctx context.Context, req *pb.GetCommandStatusReq) (*pb.GetCommandStatusResp, error) + type FileGRPCService struct + func NewFileGRPCService(fileService *FileService, logger *zap.Logger) *FileGRPCService + func (s *FileGRPCService) CreateDirectory(ctx context.Context, req *pb.CreateDirectoryReq) (*pb.CreateDirectoryResp, error) + func (s *FileGRPCService) DeleteFile(ctx context.Context, req *pb.DeleteFileReq) (*pb.DeleteFileResp, error) + func (s *FileGRPCService) DownloadFile(req *pb.DownloadFileReq, stream pb.File_DownloadFileServer) error + func (s *FileGRPCService) GetFileInfo(ctx context.Context, req *pb.GetFileInfoReq) (*pb.GetFileInfoResp, error) + func (s *FileGRPCService) GetUploadStatus(ctx context.Context, req *pb.GetUploadStatusReq) (*pb.GetUploadStatusResp, error) + func (s *FileGRPCService) ListFiles(ctx context.Context, req *pb.ListFilesReq) (*pb.ListFilesResp, error) + func (s *FileGRPCService) StartFileUpload(ctx context.Context, req *pb.StartFileUploadReq) (*pb.StartFileUploadResp, error) + func (s *FileGRPCService) UploadFileChunk(ctx context.Context, req *pb.UploadFileChunkReq) (*pb.UploadFileChunkResp, error) + type FileInfo struct + IsDir bool + MD5 string + ModTime time.Time + Mode string + Path string + SHA256 string + Size int64 + type FileService struct + func NewFileService(logger *zap.Logger, uploadDir string) *FileService + func (fs *FileService) CopyFile(ctx context.Context, srcPath, dstPath string) error + func (fs *FileService) CreateDirectory(ctx context.Context, dirPath string, perm os.FileMode) error + func (fs *FileService) DeleteDirectory(ctx context.Context, dirPath string) error + func (fs *FileService) DeleteFile(ctx context.Context, filePath string) error + func (fs *FileService) DownloadFile(ctx context.Context, filePath string, offset, length int64) (io.ReadCloser, int64, error) + func (fs *FileService) GetChunkSize() int64 + func (fs *FileService) GetFileInfo(ctx context.Context, filePath string) (*FileInfo, error) + func (fs *FileService) GetUploadStatus(ctx context.Context, sessionID string) (*UploadSession, error) + func (fs *FileService) ListFiles(ctx context.Context, dirPath string) ([]FileInfo, error) + func (fs *FileService) MoveFile(ctx context.Context, srcPath, dstPath string) error + func (fs *FileService) StartUpload(ctx context.Context, filePath string, totalSize int64, md5, sha256 string) (string, error) + func (fs *FileService) UploadChunk(ctx context.Context, sessionID string, chunkIndex int64, data []byte) error + type HealthService struct + func NewHealthService(healthChecker health.HealthChecker, healthCoordinator *health.Coordinator, ...) *HealthService + func (s *HealthService) GetHealthHistory(ctx context.Context, req *pb.GetHealthHistoryReq) (*pb.GetHealthHistoryResp, error) + func (s *HealthService) GetHealthStatus(ctx context.Context, req *pb.GetHealthStatusReq) (*pb.GetHealthStatusResp, error) + func (s *HealthService) ListHealthStatuses(ctx context.Context, req *pb.ListHealthStatusesReq) (*pb.ListHealthStatusesResp, error) + type MetricsService struct + func NewMetricsService(metricsCollector metrics.MetricsCollector, ...) *MetricsService + func (s *MetricsService) GetApplicationMetrics(ctx context.Context, req *pb.GetApplicationMetricsReq) (*pb.GetApplicationMetricsResp, error) + func (s *MetricsService) GetMetricsHistory(ctx context.Context, req *pb.GetMetricsHistoryReq) (*pb.GetMetricsHistoryResp, error) + func (s *MetricsService) GetServiceMetrics(ctx context.Context, req *pb.GetServiceMetricsReq) (*pb.GetServiceMetricsResp, error) + func (s *MetricsService) GetSystemMetrics(ctx context.Context, req *pb.GetSystemMetricsReq) (*pb.GetSystemMetricsResp, error) + func (s *MetricsService) ListServiceMetrics(ctx context.Context, req *pb.ListServiceMetricsReq) (*pb.ListServiceMetricsResp, error) + type PackageService struct + func NewPackageService(serviceManager service.ServiceManager, configManager service.ConfigManager, ...) *PackageService + func (s *PackageService) ApplyConfigs(ctx context.Context, req *pb.ApplyConfigsReq) (*pb.ApplyConfigsResp, error) + func (s *PackageService) GetConfigs(ctx context.Context, req *pb.GetConfigsReq) (*pb.GetConfigsResp, error) + func (s *PackageService) GetRecentLogs(ctx context.Context, req *pb.GetRecentLogsReq) (*pb.GetRecentLogsResp, error) + func (s *PackageService) PackageList(ctx context.Context, _ *emptypb.Empty) (*pb.PackageListResp, error) + func (s *PackageService) QueryLogs(ctx context.Context, req *pb.QueryLogsReq) (*pb.QueryLogsResp, error) + func (s *PackageService) Restart(ctx context.Context, req *pb.RestartReq) (*emptypb.Empty, error) + func (s *PackageService) Start(ctx context.Context, req *pb.StartReq) (*emptypb.Empty, error) + func (s *PackageService) Stop(ctx context.Context, req *pb.StopReq) (*emptypb.Empty, error) + func (s *PackageService) StreamLogs(req *pb.StreamLogsReq, stream pb.Package_StreamLogsServer) error + type UploadSession struct + Chunks map[int64]bool + CreatedAt time.Time + FilePath string + ID string + MD5 string + ReceivedSize int64 + SHA256 string + Status string + TotalSize int64
Go to main page