Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + const CollectionTaskService_DistributeTasks_FullMethodName + const CollectionTaskService_GetTaskStatus_FullMethodName + const CollectionTaskService_GetTasks_FullMethodName + const CollectionTaskService_UpdateTaskStatus_FullMethodName + const Command_ExecCommandSignal_FullMethodName + const Command_ExecCommand_FullMethodName + const Command_GetCommandStatus_FullMethodName + const File_CreateDirectory_FullMethodName + const File_DeleteFile_FullMethodName + const File_DownloadFile_FullMethodName + const File_GetFileInfo_FullMethodName + const File_GetUploadStatus_FullMethodName + const File_ListFiles_FullMethodName + const File_StartFileUpload_FullMethodName + const File_UploadFileChunk_FullMethodName + const Health_GetHealthHistory_FullMethodName + const Health_GetHealthStatus_FullMethodName + const Health_ListHealthStatuses_FullMethodName + const Lua_ExecLuaScript_FullMethodName + const Metrics_GetApplicationMetrics_FullMethodName + const Metrics_GetMetricsHistory_FullMethodName + const Metrics_GetServiceMetrics_FullMethodName + const Metrics_GetSystemMetrics_FullMethodName + const Metrics_ListServiceMetrics_FullMethodName + const Package_ApplyConfigs_FullMethodName + const Package_GetConfigs_FullMethodName + const Package_GetRecentLogs_FullMethodName + const Package_PackageList_FullMethodName + const Package_QueryLogs_FullMethodName + const Package_Restart_FullMethodName + const Package_Start_FullMethodName + const Package_Stop_FullMethodName + const Package_StreamLogs_FullMethodName + var CollectionTaskService_ServiceDesc = grpc.ServiceDesc + var Command_ServiceDesc = grpc.ServiceDesc + var ExecCommandSignalType_name = map[int32]string + var ExecCommandSignalType_value = map[string]int32 + var File_ServiceDesc = grpc.ServiceDesc + var File_collection_task_proto protoreflect.FileDescriptor + var File_command_proto protoreflect.FileDescriptor + var File_file_proto protoreflect.FileDescriptor + var File_health_proto protoreflect.FileDescriptor + var File_lua_proto protoreflect.FileDescriptor + var File_metrics_proto protoreflect.FileDescriptor + var File_package_proto protoreflect.FileDescriptor + var HealthStatus_name = map[int32]string + var HealthStatus_value = map[string]int32 + var Health_ServiceDesc = grpc.ServiceDesc + var Lua_ServiceDesc = grpc.ServiceDesc + var Metrics_ServiceDesc = grpc.ServiceDesc + var OutputFormat_name = map[int32]string + var OutputFormat_value = map[string]int32 + var Package_ServiceDesc = grpc.ServiceDesc + var TaskStatus_name = map[int32]string + var TaskStatus_value = map[string]int32 + func RegisterCollectionTaskServiceServer(s grpc.ServiceRegistrar, srv CollectionTaskServiceServer) + func RegisterCommandServer(s grpc.ServiceRegistrar, srv CommandServer) + func RegisterFileServer(s grpc.ServiceRegistrar, srv FileServer) + func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer) + func RegisterLuaServer(s grpc.ServiceRegistrar, srv LuaServer) + func RegisterMetricsServer(s grpc.ServiceRegistrar, srv MetricsServer) + func RegisterPackageServer(s grpc.ServiceRegistrar, srv PackageServer) + type ApplicationMetrics struct + Labels map[string]string + Metrics map[string]float64 + ServiceName string + Timestamp *timestamppb.Timestamp + func (*ApplicationMetrics) Descriptor() ([]byte, []int) + func (*ApplicationMetrics) ProtoMessage() + func (x *ApplicationMetrics) GetLabels() map[string]string + func (x *ApplicationMetrics) GetMetrics() map[string]float64 + func (x *ApplicationMetrics) GetServiceName() string + func (x *ApplicationMetrics) GetTimestamp() *timestamppb.Timestamp + func (x *ApplicationMetrics) ProtoReflect() protoreflect.Message + func (x *ApplicationMetrics) Reset() + func (x *ApplicationMetrics) String() string + type ApplyConfigsReq struct + Configs []*ConfigItem + Package string + func (*ApplyConfigsReq) Descriptor() ([]byte, []int) + func (*ApplyConfigsReq) ProtoMessage() + func (x *ApplyConfigsReq) GetConfigs() []*ConfigItem + func (x *ApplyConfigsReq) GetPackage() string + func (x *ApplyConfigsReq) ProtoReflect() protoreflect.Message + func (x *ApplyConfigsReq) Reset() + func (x *ApplyConfigsReq) String() string + type ApplyConfigsResp struct + Message string + Success bool + UpdatedFiles []*UpdatedFileDetail + func (*ApplyConfigsResp) Descriptor() ([]byte, []int) + func (*ApplyConfigsResp) ProtoMessage() + func (x *ApplyConfigsResp) GetMessage() string + func (x *ApplyConfigsResp) GetSuccess() bool + func (x *ApplyConfigsResp) GetUpdatedFiles() []*UpdatedFileDetail + func (x *ApplyConfigsResp) ProtoReflect() protoreflect.Message + func (x *ApplyConfigsResp) Reset() + func (x *ApplyConfigsResp) String() string + type CollectionTask struct + CollectionRules map[string]string + Enabled bool + OutputRules []*OutputRule + ProcessingRules []*ProcessingRule + Scope map[string]string + Target map[string]string + TaskType string + func (*CollectionTask) Descriptor() ([]byte, []int) + func (*CollectionTask) ProtoMessage() + func (x *CollectionTask) GetCollectionRules() map[string]string + func (x *CollectionTask) GetEnabled() bool + func (x *CollectionTask) GetOutputRules() []*OutputRule + func (x *CollectionTask) GetProcessingRules() []*ProcessingRule + func (x *CollectionTask) GetScope() map[string]string + func (x *CollectionTask) GetTarget() map[string]string + func (x *CollectionTask) GetTaskType() string + func (x *CollectionTask) ProtoReflect() protoreflect.Message + func (x *CollectionTask) Reset() + func (x *CollectionTask) String() string + type CollectionTaskServiceClient interface + DistributeTasks func(ctx context.Context, in *DistributeTasksReq, opts ...grpc.CallOption) (*DistributeTasksResp, error) + GetTaskStatus func(ctx context.Context, in *GetTaskStatusReq, opts ...grpc.CallOption) (*GetTaskStatusResp, error) + GetTasks func(ctx context.Context, in *GetTasksReq, opts ...grpc.CallOption) (*GetTasksResp, error) + UpdateTaskStatus func(ctx context.Context, in *UpdateTaskStatusReq, opts ...grpc.CallOption) (*UpdateTaskStatusResp, error) + func NewCollectionTaskServiceClient(cc grpc.ClientConnInterface) CollectionTaskServiceClient + type CollectionTaskServiceServer interface + DistributeTasks func(context.Context, *DistributeTasksReq) (*DistributeTasksResp, error) + GetTaskStatus func(context.Context, *GetTaskStatusReq) (*GetTaskStatusResp, error) + GetTasks func(context.Context, *GetTasksReq) (*GetTasksResp, error) + UpdateTaskStatus func(context.Context, *UpdateTaskStatusReq) (*UpdateTaskStatusResp, error) + type CommandClient interface + ExecCommand func(ctx context.Context, in *ExecCommandReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecCommandResp], error) + ExecCommandSignal func(ctx context.Context, in *ExecCommandSignalReq, opts ...grpc.CallOption) (*ExecCommandSignalResp, error) + GetCommandStatus func(ctx context.Context, in *GetCommandStatusReq, opts ...grpc.CallOption) (*GetCommandStatusResp, error) + func NewCommandClient(cc grpc.ClientConnInterface) CommandClient + type CommandServer interface + ExecCommand func(*ExecCommandReq, grpc.ServerStreamingServer[ExecCommandResp]) error + ExecCommandSignal func(context.Context, *ExecCommandSignalReq) (*ExecCommandSignalResp, error) + GetCommandStatus func(context.Context, *GetCommandStatusReq) (*GetCommandStatusResp, error) + type Command_ExecCommandClient = grpc.ServerStreamingClient[ExecCommandResp] + type Command_ExecCommandServer = grpc.ServerStreamingServer[ExecCommandResp] + type ConfigItem struct + Content string + FileName string + func (*ConfigItem) Descriptor() ([]byte, []int) + func (*ConfigItem) ProtoMessage() + func (x *ConfigItem) GetContent() string + func (x *ConfigItem) GetFileName() string + func (x *ConfigItem) ProtoReflect() protoreflect.Message + func (x *ConfigItem) Reset() + func (x *ConfigItem) String() string + type CreateDirectoryReq struct + Mode uint32 + Path string + func (*CreateDirectoryReq) Descriptor() ([]byte, []int) + func (*CreateDirectoryReq) ProtoMessage() + func (x *CreateDirectoryReq) GetMode() uint32 + func (x *CreateDirectoryReq) GetPath() string + func (x *CreateDirectoryReq) ProtoReflect() protoreflect.Message + func (x *CreateDirectoryReq) Reset() + func (x *CreateDirectoryReq) String() string + type CreateDirectoryResp struct + Message string + Success bool + func (*CreateDirectoryResp) Descriptor() ([]byte, []int) + func (*CreateDirectoryResp) ProtoMessage() + func (x *CreateDirectoryResp) GetMessage() string + func (x *CreateDirectoryResp) GetSuccess() bool + func (x *CreateDirectoryResp) ProtoReflect() protoreflect.Message + func (x *CreateDirectoryResp) Reset() + func (x *CreateDirectoryResp) String() string + type DeleteFileReq struct + Path string + Recursive bool + func (*DeleteFileReq) Descriptor() ([]byte, []int) + func (*DeleteFileReq) ProtoMessage() + func (x *DeleteFileReq) GetPath() string + func (x *DeleteFileReq) GetRecursive() bool + func (x *DeleteFileReq) ProtoReflect() protoreflect.Message + func (x *DeleteFileReq) Reset() + func (x *DeleteFileReq) String() string + type DeleteFileResp struct + Message string + Success bool + func (*DeleteFileResp) Descriptor() ([]byte, []int) + func (*DeleteFileResp) ProtoMessage() + func (x *DeleteFileResp) GetMessage() string + func (x *DeleteFileResp) GetSuccess() bool + func (x *DeleteFileResp) ProtoReflect() protoreflect.Message + func (x *DeleteFileResp) Reset() + func (x *DeleteFileResp) String() string + type DistributeTasksReq struct + AgentCode string + DistributedAt *timestamppb.Timestamp + Tasks []*CollectionTask + Version int64 + func (*DistributeTasksReq) Descriptor() ([]byte, []int) + func (*DistributeTasksReq) ProtoMessage() + func (x *DistributeTasksReq) GetAgentCode() string + func (x *DistributeTasksReq) GetDistributedAt() *timestamppb.Timestamp + func (x *DistributeTasksReq) GetTasks() []*CollectionTask + func (x *DistributeTasksReq) GetVersion() int64 + func (x *DistributeTasksReq) ProtoReflect() protoreflect.Message + func (x *DistributeTasksReq) Reset() + func (x *DistributeTasksReq) String() string + type DistributeTasksResp struct + Message string + Success bool + TasksCount int32 + func (*DistributeTasksResp) Descriptor() ([]byte, []int) + func (*DistributeTasksResp) ProtoMessage() + func (x *DistributeTasksResp) GetMessage() string + func (x *DistributeTasksResp) GetSuccess() bool + func (x *DistributeTasksResp) GetTasksCount() int32 + func (x *DistributeTasksResp) ProtoReflect() protoreflect.Message + func (x *DistributeTasksResp) Reset() + func (x *DistributeTasksResp) String() string + type DownloadFileReq struct + Length int64 + Offset int64 + Path string + func (*DownloadFileReq) Descriptor() ([]byte, []int) + func (*DownloadFileReq) ProtoMessage() + func (x *DownloadFileReq) GetLength() int64 + func (x *DownloadFileReq) GetOffset() int64 + func (x *DownloadFileReq) GetPath() string + func (x *DownloadFileReq) ProtoReflect() protoreflect.Message + func (x *DownloadFileReq) Reset() + func (x *DownloadFileReq) String() string + type DownloadFileResp struct + Data []byte + Eof bool + Offset int64 + func (*DownloadFileResp) Descriptor() ([]byte, []int) + func (*DownloadFileResp) ProtoMessage() + func (x *DownloadFileResp) GetData() []byte + func (x *DownloadFileResp) GetEof() bool + func (x *DownloadFileResp) GetOffset() int64 + func (x *DownloadFileResp) ProtoReflect() protoreflect.Message + func (x *DownloadFileResp) Reset() + func (x *DownloadFileResp) String() string + type ExecCommandReq struct + Command string + Continuous bool + func (*ExecCommandReq) Descriptor() ([]byte, []int) + func (*ExecCommandReq) ProtoMessage() + func (x *ExecCommandReq) GetCommand() string + func (x *ExecCommandReq) GetContinuous() bool + func (x *ExecCommandReq) ProtoReflect() protoreflect.Message + func (x *ExecCommandReq) Reset() + func (x *ExecCommandReq) String() string + type ExecCommandResp struct + CommandId string + Err string + Out string + func (*ExecCommandResp) Descriptor() ([]byte, []int) + func (*ExecCommandResp) ProtoMessage() + func (x *ExecCommandResp) GetCommandId() string + func (x *ExecCommandResp) GetErr() string + func (x *ExecCommandResp) GetOut() string + func (x *ExecCommandResp) ProtoReflect() protoreflect.Message + func (x *ExecCommandResp) Reset() + func (x *ExecCommandResp) String() string + type ExecCommandSignalReq struct + CommandId string + Signal ExecCommandSignalType + func (*ExecCommandSignalReq) Descriptor() ([]byte, []int) + func (*ExecCommandSignalReq) ProtoMessage() + func (x *ExecCommandSignalReq) GetCommandId() string + func (x *ExecCommandSignalReq) GetSignal() ExecCommandSignalType + func (x *ExecCommandSignalReq) ProtoReflect() protoreflect.Message + func (x *ExecCommandSignalReq) Reset() + func (x *ExecCommandSignalReq) String() string + type ExecCommandSignalResp struct + Success bool + func (*ExecCommandSignalResp) Descriptor() ([]byte, []int) + func (*ExecCommandSignalResp) ProtoMessage() + func (x *ExecCommandSignalResp) GetSuccess() bool + func (x *ExecCommandSignalResp) ProtoReflect() protoreflect.Message + func (x *ExecCommandSignalResp) Reset() + func (x *ExecCommandSignalResp) String() string + type ExecCommandSignalType int32 + const ExecCommandSignalType_CANCEL + const ExecCommandSignalType_PAUSE + const ExecCommandSignalType_RESUME + func (ExecCommandSignalType) Descriptor() protoreflect.EnumDescriptor + func (ExecCommandSignalType) EnumDescriptor() ([]byte, []int) + func (ExecCommandSignalType) Type() protoreflect.EnumType + func (x ExecCommandSignalType) Enum() *ExecCommandSignalType + func (x ExecCommandSignalType) Number() protoreflect.EnumNumber + func (x ExecCommandSignalType) String() string + type ExecLuaScriptReq struct + AgentCode string + Lua string + func (*ExecLuaScriptReq) Descriptor() ([]byte, []int) + func (*ExecLuaScriptReq) ProtoMessage() + func (x *ExecLuaScriptReq) GetAgentCode() string + func (x *ExecLuaScriptReq) GetLua() string + func (x *ExecLuaScriptReq) ProtoReflect() protoreflect.Message + func (x *ExecLuaScriptReq) Reset() + func (x *ExecLuaScriptReq) String() string + type ExecLuaScriptResp struct + AgentCode string + Output string + func (*ExecLuaScriptResp) Descriptor() ([]byte, []int) + func (*ExecLuaScriptResp) ProtoMessage() + func (x *ExecLuaScriptResp) GetAgentCode() string + func (x *ExecLuaScriptResp) GetOutput() string + func (x *ExecLuaScriptResp) ProtoReflect() protoreflect.Message + func (x *ExecLuaScriptResp) Reset() + func (x *ExecLuaScriptResp) String() string + type FileClient interface + CreateDirectory func(ctx context.Context, in *CreateDirectoryReq, opts ...grpc.CallOption) (*CreateDirectoryResp, error) + DeleteFile func(ctx context.Context, in *DeleteFileReq, opts ...grpc.CallOption) (*DeleteFileResp, error) + DownloadFile func(ctx context.Context, in *DownloadFileReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadFileResp], error) + GetFileInfo func(ctx context.Context, in *GetFileInfoReq, opts ...grpc.CallOption) (*GetFileInfoResp, error) + GetUploadStatus func(ctx context.Context, in *GetUploadStatusReq, opts ...grpc.CallOption) (*GetUploadStatusResp, error) + ListFiles func(ctx context.Context, in *ListFilesReq, opts ...grpc.CallOption) (*ListFilesResp, error) + StartFileUpload func(ctx context.Context, in *StartFileUploadReq, opts ...grpc.CallOption) (*StartFileUploadResp, error) + UploadFileChunk func(ctx context.Context, in *UploadFileChunkReq, opts ...grpc.CallOption) (*UploadFileChunkResp, error) + func NewFileClient(cc grpc.ClientConnInterface) FileClient + type FileInfo struct + IsDir bool + Md5 string + ModTime *timestamppb.Timestamp + Mode string + Path string + Sha256 string + Size int64 + func (*FileInfo) Descriptor() ([]byte, []int) + func (*FileInfo) ProtoMessage() + func (x *FileInfo) GetIsDir() bool + func (x *FileInfo) GetMd5() string + func (x *FileInfo) GetModTime() *timestamppb.Timestamp + func (x *FileInfo) GetMode() string + func (x *FileInfo) GetPath() string + func (x *FileInfo) GetSha256() string + func (x *FileInfo) GetSize() int64 + func (x *FileInfo) ProtoReflect() protoreflect.Message + func (x *FileInfo) Reset() + func (x *FileInfo) String() string + type FileServer interface + CreateDirectory func(context.Context, *CreateDirectoryReq) (*CreateDirectoryResp, error) + DeleteFile func(context.Context, *DeleteFileReq) (*DeleteFileResp, error) + DownloadFile func(*DownloadFileReq, grpc.ServerStreamingServer[DownloadFileResp]) error + GetFileInfo func(context.Context, *GetFileInfoReq) (*GetFileInfoResp, error) + GetUploadStatus func(context.Context, *GetUploadStatusReq) (*GetUploadStatusResp, error) + ListFiles func(context.Context, *ListFilesReq) (*ListFilesResp, error) + StartFileUpload func(context.Context, *StartFileUploadReq) (*StartFileUploadResp, error) + UploadFileChunk func(context.Context, *UploadFileChunkReq) (*UploadFileChunkResp, error) + type File_DownloadFileClient = grpc.ServerStreamingClient[DownloadFileResp] + type File_DownloadFileServer = grpc.ServerStreamingServer[DownloadFileResp] + type GetApplicationMetricsReq struct + ServiceName string + func (*GetApplicationMetricsReq) Descriptor() ([]byte, []int) + func (*GetApplicationMetricsReq) ProtoMessage() + func (x *GetApplicationMetricsReq) GetServiceName() string + func (x *GetApplicationMetricsReq) ProtoReflect() protoreflect.Message + func (x *GetApplicationMetricsReq) Reset() + func (x *GetApplicationMetricsReq) String() string + type GetApplicationMetricsResp struct + Metrics *ApplicationMetrics + Services map[string]*ApplicationMetrics + func (*GetApplicationMetricsResp) Descriptor() ([]byte, []int) + func (*GetApplicationMetricsResp) ProtoMessage() + func (x *GetApplicationMetricsResp) GetMetrics() *ApplicationMetrics + func (x *GetApplicationMetricsResp) GetServices() map[string]*ApplicationMetrics + func (x *GetApplicationMetricsResp) ProtoReflect() protoreflect.Message + func (x *GetApplicationMetricsResp) Reset() + func (x *GetApplicationMetricsResp) String() string + type GetCommandStatusReq struct + CommandId string + func (*GetCommandStatusReq) Descriptor() ([]byte, []int) + func (*GetCommandStatusReq) ProtoMessage() + func (x *GetCommandStatusReq) GetCommandId() string + func (x *GetCommandStatusReq) ProtoReflect() protoreflect.Message + func (x *GetCommandStatusReq) Reset() + func (x *GetCommandStatusReq) String() string + type GetCommandStatusResp struct + CommandId string + Duration float64 + StartTime int64 + Status string + func (*GetCommandStatusResp) Descriptor() ([]byte, []int) + func (*GetCommandStatusResp) ProtoMessage() + func (x *GetCommandStatusResp) GetCommandId() string + func (x *GetCommandStatusResp) GetDuration() float64 + func (x *GetCommandStatusResp) GetStartTime() int64 + func (x *GetCommandStatusResp) GetStatus() string + func (x *GetCommandStatusResp) ProtoReflect() protoreflect.Message + func (x *GetCommandStatusResp) Reset() + func (x *GetCommandStatusResp) String() string + type GetConfigsReq struct + Package string + func (*GetConfigsReq) Descriptor() ([]byte, []int) + func (*GetConfigsReq) ProtoMessage() + func (x *GetConfigsReq) GetPackage() string + func (x *GetConfigsReq) ProtoReflect() protoreflect.Message + func (x *GetConfigsReq) Reset() + func (x *GetConfigsReq) String() string + type GetConfigsResp struct + Configs []*ConfigItem + func (*GetConfigsResp) Descriptor() ([]byte, []int) + func (*GetConfigsResp) ProtoMessage() + func (x *GetConfigsResp) GetConfigs() []*ConfigItem + func (x *GetConfigsResp) ProtoReflect() protoreflect.Message + func (x *GetConfigsResp) Reset() + func (x *GetConfigsResp) String() string + type GetFileInfoReq struct + Path string + func (*GetFileInfoReq) Descriptor() ([]byte, []int) + func (*GetFileInfoReq) ProtoMessage() + func (x *GetFileInfoReq) GetPath() string + func (x *GetFileInfoReq) ProtoReflect() protoreflect.Message + func (x *GetFileInfoReq) Reset() + func (x *GetFileInfoReq) String() string + type GetFileInfoResp struct + Exists bool + File *FileInfo + func (*GetFileInfoResp) Descriptor() ([]byte, []int) + func (*GetFileInfoResp) ProtoMessage() + func (x *GetFileInfoResp) GetExists() bool + func (x *GetFileInfoResp) GetFile() *FileInfo + func (x *GetFileInfoResp) ProtoReflect() protoreflect.Message + func (x *GetFileInfoResp) Reset() + func (x *GetFileInfoResp) String() string + type GetHealthHistoryReq struct + Limit int32 + Package string + func (*GetHealthHistoryReq) Descriptor() ([]byte, []int) + func (*GetHealthHistoryReq) ProtoMessage() + func (x *GetHealthHistoryReq) GetLimit() int32 + func (x *GetHealthHistoryReq) GetPackage() string + func (x *GetHealthHistoryReq) ProtoReflect() protoreflect.Message + func (x *GetHealthHistoryReq) Reset() + func (x *GetHealthHistoryReq) String() string + type GetHealthHistoryResp struct + Entries []*HealthHistoryEntry + Package string + func (*GetHealthHistoryResp) Descriptor() ([]byte, []int) + func (*GetHealthHistoryResp) ProtoMessage() + func (x *GetHealthHistoryResp) GetEntries() []*HealthHistoryEntry + func (x *GetHealthHistoryResp) GetPackage() string + func (x *GetHealthHistoryResp) ProtoReflect() protoreflect.Message + func (x *GetHealthHistoryResp) Reset() + func (x *GetHealthHistoryResp) String() string + type GetHealthStatusReq struct + Package string + func (*GetHealthStatusReq) Descriptor() ([]byte, []int) + func (*GetHealthStatusReq) ProtoMessage() + func (x *GetHealthStatusReq) GetPackage() string + func (x *GetHealthStatusReq) ProtoReflect() protoreflect.Message + func (x *GetHealthStatusReq) Reset() + func (x *GetHealthStatusReq) String() string + type GetHealthStatusResp struct + Health *ServiceHealth + func (*GetHealthStatusResp) Descriptor() ([]byte, []int) + func (*GetHealthStatusResp) ProtoMessage() + func (x *GetHealthStatusResp) GetHealth() *ServiceHealth + func (x *GetHealthStatusResp) ProtoReflect() protoreflect.Message + func (x *GetHealthStatusResp) Reset() + func (x *GetHealthStatusResp) String() string + type GetMetricsHistoryReq struct + EndTime *timestamppb.Timestamp + ServiceName string + StartTime *timestamppb.Timestamp + Type string + func (*GetMetricsHistoryReq) Descriptor() ([]byte, []int) + func (*GetMetricsHistoryReq) ProtoMessage() + func (x *GetMetricsHistoryReq) GetEndTime() *timestamppb.Timestamp + func (x *GetMetricsHistoryReq) GetServiceName() string + func (x *GetMetricsHistoryReq) GetStartTime() *timestamppb.Timestamp + func (x *GetMetricsHistoryReq) GetType() string + func (x *GetMetricsHistoryReq) ProtoReflect() protoreflect.Message + func (x *GetMetricsHistoryReq) Reset() + func (x *GetMetricsHistoryReq) String() string + type GetMetricsHistoryResp struct + DataPoints []*MetricsHistoryPoint + EndTime *timestamppb.Timestamp + ServiceName string + StartTime *timestamppb.Timestamp + Type string + func (*GetMetricsHistoryResp) Descriptor() ([]byte, []int) + func (*GetMetricsHistoryResp) ProtoMessage() + func (x *GetMetricsHistoryResp) GetDataPoints() []*MetricsHistoryPoint + func (x *GetMetricsHistoryResp) GetEndTime() *timestamppb.Timestamp + func (x *GetMetricsHistoryResp) GetServiceName() string + func (x *GetMetricsHistoryResp) GetStartTime() *timestamppb.Timestamp + func (x *GetMetricsHistoryResp) GetType() string + func (x *GetMetricsHistoryResp) ProtoReflect() protoreflect.Message + func (x *GetMetricsHistoryResp) Reset() + func (x *GetMetricsHistoryResp) String() string + type GetRecentLogsReq struct + Count int32 + Package string + func (*GetRecentLogsReq) Descriptor() ([]byte, []int) + func (*GetRecentLogsReq) ProtoMessage() + func (x *GetRecentLogsReq) GetCount() int32 + func (x *GetRecentLogsReq) GetPackage() string + func (x *GetRecentLogsReq) ProtoReflect() protoreflect.Message + func (x *GetRecentLogsReq) Reset() + func (x *GetRecentLogsReq) String() string + type GetRecentLogsResp struct + Logs []string + func (*GetRecentLogsResp) Descriptor() ([]byte, []int) + func (*GetRecentLogsResp) ProtoMessage() + func (x *GetRecentLogsResp) GetLogs() []string + func (x *GetRecentLogsResp) ProtoReflect() protoreflect.Message + func (x *GetRecentLogsResp) Reset() + func (x *GetRecentLogsResp) String() string + type GetServiceMetricsReq struct + Package string + func (*GetServiceMetricsReq) Descriptor() ([]byte, []int) + func (*GetServiceMetricsReq) ProtoMessage() + func (x *GetServiceMetricsReq) GetPackage() string + func (x *GetServiceMetricsReq) ProtoReflect() protoreflect.Message + func (x *GetServiceMetricsReq) Reset() + func (x *GetServiceMetricsReq) String() string + type GetServiceMetricsResp struct + Metrics *ServiceMetrics + func (*GetServiceMetricsResp) Descriptor() ([]byte, []int) + func (*GetServiceMetricsResp) ProtoMessage() + func (x *GetServiceMetricsResp) GetMetrics() *ServiceMetrics + func (x *GetServiceMetricsResp) ProtoReflect() protoreflect.Message + func (x *GetServiceMetricsResp) Reset() + func (x *GetServiceMetricsResp) String() string + type GetSystemMetricsReq struct + func (*GetSystemMetricsReq) Descriptor() ([]byte, []int) + func (*GetSystemMetricsReq) ProtoMessage() + func (x *GetSystemMetricsReq) ProtoReflect() protoreflect.Message + func (x *GetSystemMetricsReq) Reset() + func (x *GetSystemMetricsReq) String() string + type GetSystemMetricsResp struct + Metrics *SystemMetrics + func (*GetSystemMetricsResp) Descriptor() ([]byte, []int) + func (*GetSystemMetricsResp) ProtoMessage() + func (x *GetSystemMetricsResp) GetMetrics() *SystemMetrics + func (x *GetSystemMetricsResp) ProtoReflect() protoreflect.Message + func (x *GetSystemMetricsResp) Reset() + func (x *GetSystemMetricsResp) String() string + type GetTaskStatusReq struct + AgentCode string + TaskType string + func (*GetTaskStatusReq) Descriptor() ([]byte, []int) + func (*GetTaskStatusReq) ProtoMessage() + func (x *GetTaskStatusReq) GetAgentCode() string + func (x *GetTaskStatusReq) GetTaskType() string + func (x *GetTaskStatusReq) ProtoReflect() protoreflect.Message + func (x *GetTaskStatusReq) Reset() + func (x *GetTaskStatusReq) String() string + type GetTaskStatusResp struct + TaskStatuses []*TaskStatusInfo + func (*GetTaskStatusResp) Descriptor() ([]byte, []int) + func (*GetTaskStatusResp) ProtoMessage() + func (x *GetTaskStatusResp) GetTaskStatuses() []*TaskStatusInfo + func (x *GetTaskStatusResp) ProtoReflect() protoreflect.Message + func (x *GetTaskStatusResp) Reset() + func (x *GetTaskStatusResp) String() string + type GetTasksReq struct + AgentCode string + LastVersion int64 + func (*GetTasksReq) Descriptor() ([]byte, []int) + func (*GetTasksReq) ProtoMessage() + func (x *GetTasksReq) GetAgentCode() string + func (x *GetTasksReq) GetLastVersion() int64 + func (x *GetTasksReq) ProtoReflect() protoreflect.Message + func (x *GetTasksReq) Reset() + func (x *GetTasksReq) String() string + type GetTasksResp struct + HasUpdates bool + MonitoringTasks []*MonitoringTask + Tasks []*CollectionTask + Version int64 + func (*GetTasksResp) Descriptor() ([]byte, []int) + func (*GetTasksResp) ProtoMessage() + func (x *GetTasksResp) GetHasUpdates() bool + func (x *GetTasksResp) GetMonitoringTasks() []*MonitoringTask + func (x *GetTasksResp) GetTasks() []*CollectionTask + func (x *GetTasksResp) GetVersion() int64 + func (x *GetTasksResp) ProtoReflect() protoreflect.Message + func (x *GetTasksResp) Reset() + func (x *GetTasksResp) String() string + type GetUploadStatusReq struct + SessionId string + func (*GetUploadStatusReq) Descriptor() ([]byte, []int) + func (*GetUploadStatusReq) ProtoMessage() + func (x *GetUploadStatusReq) GetSessionId() string + func (x *GetUploadStatusReq) ProtoReflect() protoreflect.Message + func (x *GetUploadStatusReq) Reset() + func (x *GetUploadStatusReq) String() string + type GetUploadStatusResp struct + Progress float64 + ReceivedSize int64 + SessionId string + Status string + TotalSize int64 + func (*GetUploadStatusResp) Descriptor() ([]byte, []int) + func (*GetUploadStatusResp) ProtoMessage() + func (x *GetUploadStatusResp) GetProgress() float64 + func (x *GetUploadStatusResp) GetReceivedSize() int64 + func (x *GetUploadStatusResp) GetSessionId() string + func (x *GetUploadStatusResp) GetStatus() string + func (x *GetUploadStatusResp) GetTotalSize() int64 + func (x *GetUploadStatusResp) ProtoReflect() protoreflect.Message + func (x *GetUploadStatusResp) Reset() + func (x *GetUploadStatusResp) String() string + type HealthClient interface + GetHealthHistory func(ctx context.Context, in *GetHealthHistoryReq, opts ...grpc.CallOption) (*GetHealthHistoryResp, error) + GetHealthStatus func(ctx context.Context, in *GetHealthStatusReq, opts ...grpc.CallOption) (*GetHealthStatusResp, error) + ListHealthStatuses func(ctx context.Context, in *ListHealthStatusesReq, opts ...grpc.CallOption) (*ListHealthStatusesResp, error) + func NewHealthClient(cc grpc.ClientConnInterface) HealthClient + type HealthHistoryEntry struct + CheckType string + Error string + Message string + ResponseTimeMs int64 + Status HealthStatus + Timestamp *timestamppb.Timestamp + func (*HealthHistoryEntry) Descriptor() ([]byte, []int) + func (*HealthHistoryEntry) ProtoMessage() + func (x *HealthHistoryEntry) GetCheckType() string + func (x *HealthHistoryEntry) GetError() string + func (x *HealthHistoryEntry) GetMessage() string + func (x *HealthHistoryEntry) GetResponseTimeMs() int64 + func (x *HealthHistoryEntry) GetStatus() HealthStatus + func (x *HealthHistoryEntry) GetTimestamp() *timestamppb.Timestamp + func (x *HealthHistoryEntry) ProtoReflect() protoreflect.Message + func (x *HealthHistoryEntry) Reset() + func (x *HealthHistoryEntry) String() string + type HealthServer interface + GetHealthHistory func(context.Context, *GetHealthHistoryReq) (*GetHealthHistoryResp, error) + GetHealthStatus func(context.Context, *GetHealthStatusReq) (*GetHealthStatusResp, error) + ListHealthStatuses func(context.Context, *ListHealthStatusesReq) (*ListHealthStatusesResp, error) + type HealthStatus int32 + const HealthStatus_HEALTH_STATUS_DEGRADED + const HealthStatus_HEALTH_STATUS_HEALTHY + const HealthStatus_HEALTH_STATUS_UNHEALTHY + const HealthStatus_HEALTH_STATUS_UNKNOWN + func (HealthStatus) Descriptor() protoreflect.EnumDescriptor + func (HealthStatus) EnumDescriptor() ([]byte, []int) + func (HealthStatus) Type() protoreflect.EnumType + func (x HealthStatus) Enum() *HealthStatus + func (x HealthStatus) Number() protoreflect.EnumNumber + func (x HealthStatus) String() string + type HealthStatusDetail struct + CheckType string + Error string + LastCheck *timestamppb.Timestamp + Message string + ResponseTimeMs int64 + Status HealthStatus + func (*HealthStatusDetail) Descriptor() ([]byte, []int) + func (*HealthStatusDetail) ProtoMessage() + func (x *HealthStatusDetail) GetCheckType() string + func (x *HealthStatusDetail) GetError() string + func (x *HealthStatusDetail) GetLastCheck() *timestamppb.Timestamp + func (x *HealthStatusDetail) GetMessage() string + func (x *HealthStatusDetail) GetResponseTimeMs() int64 + func (x *HealthStatusDetail) GetStatus() HealthStatus + func (x *HealthStatusDetail) ProtoReflect() protoreflect.Message + func (x *HealthStatusDetail) Reset() + func (x *HealthStatusDetail) String() string + type ListConfigReq struct + ConfName string + Format OutputFormat + Package string + func (*ListConfigReq) Descriptor() ([]byte, []int) + func (*ListConfigReq) ProtoMessage() + func (x *ListConfigReq) GetConfName() string + func (x *ListConfigReq) GetFormat() OutputFormat + func (x *ListConfigReq) GetPackage() string + func (x *ListConfigReq) ProtoReflect() protoreflect.Message + func (x *ListConfigReq) Reset() + func (x *ListConfigReq) String() string + type ListFilesReq struct + Path string + func (*ListFilesReq) Descriptor() ([]byte, []int) + func (*ListFilesReq) ProtoMessage() + func (x *ListFilesReq) GetPath() string + func (x *ListFilesReq) ProtoReflect() protoreflect.Message + func (x *ListFilesReq) Reset() + func (x *ListFilesReq) String() string + type ListFilesResp struct + Files []*FileInfo + Path string + func (*ListFilesResp) Descriptor() ([]byte, []int) + func (*ListFilesResp) ProtoMessage() + func (x *ListFilesResp) GetFiles() []*FileInfo + func (x *ListFilesResp) GetPath() string + func (x *ListFilesResp) ProtoReflect() protoreflect.Message + func (x *ListFilesResp) Reset() + func (x *ListFilesResp) String() string + type ListHealthStatusesReq struct + FilterStatus []HealthStatus + func (*ListHealthStatusesReq) Descriptor() ([]byte, []int) + func (*ListHealthStatusesReq) ProtoMessage() + func (x *ListHealthStatusesReq) GetFilterStatus() []HealthStatus + func (x *ListHealthStatusesReq) ProtoReflect() protoreflect.Message + func (x *ListHealthStatusesReq) Reset() + func (x *ListHealthStatusesReq) String() string + type ListHealthStatusesResp struct + HealthStatuses []*ServiceHealth + func (*ListHealthStatusesResp) Descriptor() ([]byte, []int) + func (*ListHealthStatusesResp) ProtoMessage() + func (x *ListHealthStatusesResp) GetHealthStatuses() []*ServiceHealth + func (x *ListHealthStatusesResp) ProtoReflect() protoreflect.Message + func (x *ListHealthStatusesResp) Reset() + func (x *ListHealthStatusesResp) String() string + type ListServiceMetricsReq struct + RunningOnly bool + func (*ListServiceMetricsReq) Descriptor() ([]byte, []int) + func (*ListServiceMetricsReq) ProtoMessage() + func (x *ListServiceMetricsReq) GetRunningOnly() bool + func (x *ListServiceMetricsReq) ProtoReflect() protoreflect.Message + func (x *ListServiceMetricsReq) Reset() + func (x *ListServiceMetricsReq) String() string + type ListServiceMetricsResp struct + Metrics []*ServiceMetrics + func (*ListServiceMetricsResp) Descriptor() ([]byte, []int) + func (*ListServiceMetricsResp) ProtoMessage() + func (x *ListServiceMetricsResp) GetMetrics() []*ServiceMetrics + func (x *ListServiceMetricsResp) ProtoReflect() protoreflect.Message + func (x *ListServiceMetricsResp) Reset() + func (x *ListServiceMetricsResp) String() string + type LuaClient interface + ExecLuaScript func(ctx context.Context, in *ExecLuaScriptReq, opts ...grpc.CallOption) (*ExecLuaScriptResp, error) + func NewLuaClient(cc grpc.ClientConnInterface) LuaClient + type LuaServer interface + ExecLuaScript func(context.Context, *ExecLuaScriptReq) (*ExecLuaScriptResp, error) + type MetricsClient interface + GetApplicationMetrics func(ctx context.Context, in *GetApplicationMetricsReq, opts ...grpc.CallOption) (*GetApplicationMetricsResp, error) + GetMetricsHistory func(ctx context.Context, in *GetMetricsHistoryReq, opts ...grpc.CallOption) (*GetMetricsHistoryResp, error) + GetServiceMetrics func(ctx context.Context, in *GetServiceMetricsReq, opts ...grpc.CallOption) (*GetServiceMetricsResp, error) + GetSystemMetrics func(ctx context.Context, in *GetSystemMetricsReq, opts ...grpc.CallOption) (*GetSystemMetricsResp, error) + ListServiceMetrics func(ctx context.Context, in *ListServiceMetricsReq, opts ...grpc.CallOption) (*ListServiceMetricsResp, error) + func NewMetricsClient(cc grpc.ClientConnInterface) MetricsClient + type MetricsHistoryPoint struct + Metrics map[string]string + Timestamp *timestamppb.Timestamp + func (*MetricsHistoryPoint) Descriptor() ([]byte, []int) + func (*MetricsHistoryPoint) ProtoMessage() + func (x *MetricsHistoryPoint) GetMetrics() map[string]string + func (x *MetricsHistoryPoint) GetTimestamp() *timestamppb.Timestamp + func (x *MetricsHistoryPoint) ProtoReflect() protoreflect.Message + func (x *MetricsHistoryPoint) Reset() + func (x *MetricsHistoryPoint) String() string + type MetricsServer interface + GetApplicationMetrics func(context.Context, *GetApplicationMetricsReq) (*GetApplicationMetricsResp, error) + GetMetricsHistory func(context.Context, *GetMetricsHistoryReq) (*GetMetricsHistoryResp, error) + GetServiceMetrics func(context.Context, *GetServiceMetricsReq) (*GetServiceMetricsResp, error) + GetSystemMetrics func(context.Context, *GetSystemMetricsReq) (*GetSystemMetricsResp, error) + ListServiceMetrics func(context.Context, *ListServiceMetricsReq) (*ListServiceMetricsResp, error) + type MonitoringTask struct + AgentCode string + CreatedAt *timestamppb.Timestamp + Description string + Id string + Name string + OutputType string + PublishedAt *timestamppb.Timestamp + RevokedAt *timestamppb.Timestamp + Status string + StrategyId string + TargetIds []string + UpdatedAt *timestamppb.Timestamp + func (*MonitoringTask) Descriptor() ([]byte, []int) + func (*MonitoringTask) ProtoMessage() + func (x *MonitoringTask) GetAgentCode() string + func (x *MonitoringTask) GetCreatedAt() *timestamppb.Timestamp + func (x *MonitoringTask) GetDescription() string + func (x *MonitoringTask) GetId() string + func (x *MonitoringTask) GetName() string + func (x *MonitoringTask) GetOutputType() string + func (x *MonitoringTask) GetPublishedAt() *timestamppb.Timestamp + func (x *MonitoringTask) GetRevokedAt() *timestamppb.Timestamp + func (x *MonitoringTask) GetStatus() string + func (x *MonitoringTask) GetStrategyId() string + func (x *MonitoringTask) GetTargetIds() []string + func (x *MonitoringTask) GetUpdatedAt() *timestamppb.Timestamp + func (x *MonitoringTask) ProtoReflect() protoreflect.Message + func (x *MonitoringTask) Reset() + func (x *MonitoringTask) String() string + type NetworkInterface struct + Name string + RxBytes int64 + TxBytes int64 + func (*NetworkInterface) Descriptor() ([]byte, []int) + func (*NetworkInterface) ProtoMessage() + func (x *NetworkInterface) GetName() string + func (x *NetworkInterface) GetRxBytes() int64 + func (x *NetworkInterface) GetTxBytes() int64 + func (x *NetworkInterface) ProtoReflect() protoreflect.Message + func (x *NetworkInterface) Reset() + func (x *NetworkInterface) String() string + type OutputFormat int32 + const OutputFormat_JSON + const OutputFormat_TOML + const OutputFormat_YAML + func (OutputFormat) Descriptor() protoreflect.EnumDescriptor + func (OutputFormat) EnumDescriptor() ([]byte, []int) + func (OutputFormat) Type() protoreflect.EnumType + func (x OutputFormat) Enum() *OutputFormat + func (x OutputFormat) Number() protoreflect.EnumNumber + func (x OutputFormat) String() string + type OutputRule struct + Rule map[string]string + func (*OutputRule) Descriptor() ([]byte, []int) + func (*OutputRule) ProtoMessage() + func (x *OutputRule) GetRule() map[string]string + func (x *OutputRule) ProtoReflect() protoreflect.Message + func (x *OutputRule) Reset() + func (x *OutputRule) String() string + type PackItem struct + IsRunning bool + Package string + RunningDuration int64 + Schema string + Version string + func (*PackItem) Descriptor() ([]byte, []int) + func (*PackItem) ProtoMessage() + func (x *PackItem) GetIsRunning() bool + func (x *PackItem) GetPackage() string + func (x *PackItem) GetRunningDuration() int64 + func (x *PackItem) GetSchema() string + func (x *PackItem) GetVersion() string + func (x *PackItem) ProtoReflect() protoreflect.Message + func (x *PackItem) Reset() + func (x *PackItem) String() string + type PackageClient interface + ApplyConfigs func(ctx context.Context, in *ApplyConfigsReq, opts ...grpc.CallOption) (*ApplyConfigsResp, error) + GetConfigs func(ctx context.Context, in *GetConfigsReq, opts ...grpc.CallOption) (*GetConfigsResp, error) + GetRecentLogs func(ctx context.Context, in *GetRecentLogsReq, opts ...grpc.CallOption) (*GetRecentLogsResp, error) + PackageList func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PackageListResp, error) + QueryLogs func(ctx context.Context, in *QueryLogsReq, opts ...grpc.CallOption) (*QueryLogsResp, error) + Restart func(ctx context.Context, in *RestartReq, opts ...grpc.CallOption) (*emptypb.Empty, error) + Start func(ctx context.Context, in *StartReq, opts ...grpc.CallOption) (*emptypb.Empty, error) + Stop func(ctx context.Context, in *StopReq, opts ...grpc.CallOption) (*emptypb.Empty, error) + StreamLogs func(ctx context.Context, in *StreamLogsReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamLogsResp], error) + func NewPackageClient(cc grpc.ClientConnInterface) PackageClient + type PackageListResp struct + AgentCode string + Packages []*PackItem + func (*PackageListResp) Descriptor() ([]byte, []int) + func (*PackageListResp) ProtoMessage() + func (x *PackageListResp) GetAgentCode() string + func (x *PackageListResp) GetPackages() []*PackItem + func (x *PackageListResp) ProtoReflect() protoreflect.Message + func (x *PackageListResp) Reset() + func (x *PackageListResp) String() string + type PackageServer interface + ApplyConfigs func(context.Context, *ApplyConfigsReq) (*ApplyConfigsResp, error) + GetConfigs func(context.Context, *GetConfigsReq) (*GetConfigsResp, error) + GetRecentLogs func(context.Context, *GetRecentLogsReq) (*GetRecentLogsResp, error) + PackageList func(context.Context, *emptypb.Empty) (*PackageListResp, error) + QueryLogs func(context.Context, *QueryLogsReq) (*QueryLogsResp, error) + Restart func(context.Context, *RestartReq) (*emptypb.Empty, error) + Start func(context.Context, *StartReq) (*emptypb.Empty, error) + Stop func(context.Context, *StopReq) (*emptypb.Empty, error) + StreamLogs func(*StreamLogsReq, grpc.ServerStreamingServer[StreamLogsResp]) error + type Package_StreamLogsClient = grpc.ServerStreamingClient[StreamLogsResp] + type Package_StreamLogsServer = grpc.ServerStreamingServer[StreamLogsResp] + type ProcessingRule struct + Rule map[string]string + func (*ProcessingRule) Descriptor() ([]byte, []int) + func (*ProcessingRule) ProtoMessage() + func (x *ProcessingRule) GetRule() map[string]string + func (x *ProcessingRule) ProtoReflect() protoreflect.Message + func (x *ProcessingRule) Reset() + func (x *ProcessingRule) String() string + type QueryLogsReq struct + EndTime int64 + Keyword string + Level string + Limit int32 + Offset int32 + Package string + Reverse bool + StartTime int64 + func (*QueryLogsReq) Descriptor() ([]byte, []int) + func (*QueryLogsReq) ProtoMessage() + func (x *QueryLogsReq) GetEndTime() int64 + func (x *QueryLogsReq) GetKeyword() string + func (x *QueryLogsReq) GetLevel() string + func (x *QueryLogsReq) GetLimit() int32 + func (x *QueryLogsReq) GetOffset() int32 + func (x *QueryLogsReq) GetPackage() string + func (x *QueryLogsReq) GetReverse() bool + func (x *QueryLogsReq) GetStartTime() int64 + func (x *QueryLogsReq) ProtoReflect() protoreflect.Message + func (x *QueryLogsReq) Reset() + func (x *QueryLogsReq) String() string + type QueryLogsResp struct + HasMore bool + Logs []string + Total int32 + func (*QueryLogsResp) Descriptor() ([]byte, []int) + func (*QueryLogsResp) ProtoMessage() + func (x *QueryLogsResp) GetHasMore() bool + func (x *QueryLogsResp) GetLogs() []string + func (x *QueryLogsResp) GetTotal() int32 + func (x *QueryLogsResp) ProtoReflect() protoreflect.Message + func (x *QueryLogsResp) Reset() + func (x *QueryLogsResp) String() string + type RestartReq struct + Package string + func (*RestartReq) Descriptor() ([]byte, []int) + func (*RestartReq) ProtoMessage() + func (x *RestartReq) GetPackage() string + func (x *RestartReq) ProtoReflect() protoreflect.Message + func (x *RestartReq) Reset() + func (x *RestartReq) String() string + type ServiceHealth struct + Details []*HealthStatusDetail + LastCheck *timestamppb.Timestamp + Message string + Package string + Status HealthStatus + func (*ServiceHealth) Descriptor() ([]byte, []int) + func (*ServiceHealth) ProtoMessage() + func (x *ServiceHealth) GetDetails() []*HealthStatusDetail + func (x *ServiceHealth) GetLastCheck() *timestamppb.Timestamp + func (x *ServiceHealth) GetMessage() string + func (x *ServiceHealth) GetPackage() string + func (x *ServiceHealth) GetStatus() HealthStatus + func (x *ServiceHealth) ProtoReflect() protoreflect.Message + func (x *ServiceHealth) Reset() + func (x *ServiceHealth) String() string + type ServiceMetrics struct + CpuUsage float64 + DiskUsage float64 + ErrorCount int64 + LastUpdated *timestamppb.Timestamp + MemoryBytes int64 + MemoryUsage float64 + NetworkIn int64 + NetworkOut int64 + Package string + RequestCount int64 + ResponseTimeMs int64 + func (*ServiceMetrics) Descriptor() ([]byte, []int) + func (*ServiceMetrics) ProtoMessage() + func (x *ServiceMetrics) GetCpuUsage() float64 + func (x *ServiceMetrics) GetDiskUsage() float64 + func (x *ServiceMetrics) GetErrorCount() int64 + func (x *ServiceMetrics) GetLastUpdated() *timestamppb.Timestamp + func (x *ServiceMetrics) GetMemoryBytes() int64 + func (x *ServiceMetrics) GetMemoryUsage() float64 + func (x *ServiceMetrics) GetNetworkIn() int64 + func (x *ServiceMetrics) GetNetworkOut() int64 + func (x *ServiceMetrics) GetPackage() string + func (x *ServiceMetrics) GetRequestCount() int64 + func (x *ServiceMetrics) GetResponseTimeMs() int64 + func (x *ServiceMetrics) ProtoReflect() protoreflect.Message + func (x *ServiceMetrics) Reset() + func (x *ServiceMetrics) String() string + type StartFileUploadReq struct + FilePath string + FileSize int64 + Md5 string + Sha256 string + func (*StartFileUploadReq) Descriptor() ([]byte, []int) + func (*StartFileUploadReq) ProtoMessage() + func (x *StartFileUploadReq) GetFilePath() string + func (x *StartFileUploadReq) GetFileSize() int64 + func (x *StartFileUploadReq) GetMd5() string + func (x *StartFileUploadReq) GetSha256() string + func (x *StartFileUploadReq) ProtoReflect() protoreflect.Message + func (x *StartFileUploadReq) Reset() + func (x *StartFileUploadReq) String() string + type StartFileUploadResp struct + ChunkSize int64 + FilePath string + SessionId string + func (*StartFileUploadResp) Descriptor() ([]byte, []int) + func (*StartFileUploadResp) ProtoMessage() + func (x *StartFileUploadResp) GetChunkSize() int64 + func (x *StartFileUploadResp) GetFilePath() string + func (x *StartFileUploadResp) GetSessionId() string + func (x *StartFileUploadResp) ProtoReflect() protoreflect.Message + func (x *StartFileUploadResp) Reset() + func (x *StartFileUploadResp) String() string + type StartReq struct + Package string + func (*StartReq) Descriptor() ([]byte, []int) + func (*StartReq) ProtoMessage() + func (x *StartReq) GetPackage() string + func (x *StartReq) ProtoReflect() protoreflect.Message + func (x *StartReq) Reset() + func (x *StartReq) String() string + type StopReq struct + Package string + func (*StopReq) Descriptor() ([]byte, []int) + func (*StopReq) ProtoMessage() + func (x *StopReq) GetPackage() string + func (x *StopReq) ProtoReflect() protoreflect.Message + func (x *StopReq) Reset() + func (x *StopReq) String() string + type StreamLogsReq struct + Follow bool + Package string + TailLines int32 + func (*StreamLogsReq) Descriptor() ([]byte, []int) + func (*StreamLogsReq) ProtoMessage() + func (x *StreamLogsReq) GetFollow() bool + func (x *StreamLogsReq) GetPackage() string + func (x *StreamLogsReq) GetTailLines() int32 + func (x *StreamLogsReq) ProtoReflect() protoreflect.Message + func (x *StreamLogsReq) Reset() + func (x *StreamLogsReq) String() string + type StreamLogsResp struct + IsEof bool + LogLine string + func (*StreamLogsResp) Descriptor() ([]byte, []int) + func (*StreamLogsResp) ProtoMessage() + func (x *StreamLogsResp) GetIsEof() bool + func (x *StreamLogsResp) GetLogLine() string + func (x *StreamLogsResp) ProtoReflect() protoreflect.Message + func (x *StreamLogsResp) Reset() + func (x *StreamLogsResp) String() string + type SystemMetrics struct + CpuCores int32 + CpuUsage float64 + DiskFree int64 + DiskTotal int64 + DiskUsage float64 + LastUpdated *timestamppb.Timestamp + LoadAvg_1 float64 + LoadAvg_15 float64 + LoadAvg_5 float64 + MemoryFree int64 + MemoryTotal int64 + MemoryUsage float64 + NetworkIn int64 + NetworkInterfaces []*NetworkInterface + NetworkOut int64 + func (*SystemMetrics) Descriptor() ([]byte, []int) + func (*SystemMetrics) ProtoMessage() + func (x *SystemMetrics) GetCpuCores() int32 + func (x *SystemMetrics) GetCpuUsage() float64 + func (x *SystemMetrics) GetDiskFree() int64 + func (x *SystemMetrics) GetDiskTotal() int64 + func (x *SystemMetrics) GetDiskUsage() float64 + func (x *SystemMetrics) GetLastUpdated() *timestamppb.Timestamp + func (x *SystemMetrics) GetLoadAvg_1() float64 + func (x *SystemMetrics) GetLoadAvg_15() float64 + func (x *SystemMetrics) GetLoadAvg_5() float64 + func (x *SystemMetrics) GetMemoryFree() int64 + func (x *SystemMetrics) GetMemoryTotal() int64 + func (x *SystemMetrics) GetMemoryUsage() float64 + func (x *SystemMetrics) GetNetworkIn() int64 + func (x *SystemMetrics) GetNetworkInterfaces() []*NetworkInterface + func (x *SystemMetrics) GetNetworkOut() int64 + func (x *SystemMetrics) ProtoReflect() protoreflect.Message + func (x *SystemMetrics) Reset() + func (x *SystemMetrics) String() string + type TaskStatus int32 + const TaskStatus_TASK_STATUS_CANCELLED + const TaskStatus_TASK_STATUS_COMPLETED + const TaskStatus_TASK_STATUS_FAILED + const TaskStatus_TASK_STATUS_PENDING + const TaskStatus_TASK_STATUS_RUNNING + const TaskStatus_TASK_STATUS_UNKNOWN + func (TaskStatus) Descriptor() protoreflect.EnumDescriptor + func (TaskStatus) EnumDescriptor() ([]byte, []int) + func (TaskStatus) Type() protoreflect.EnumType + func (x TaskStatus) Enum() *TaskStatus + func (x TaskStatus) Number() protoreflect.EnumNumber + func (x TaskStatus) String() string + type TaskStatusInfo struct + LastUpdated *timestamppb.Timestamp + Message string + Status TaskStatus + TaskType string + func (*TaskStatusInfo) Descriptor() ([]byte, []int) + func (*TaskStatusInfo) ProtoMessage() + func (x *TaskStatusInfo) GetLastUpdated() *timestamppb.Timestamp + func (x *TaskStatusInfo) GetMessage() string + func (x *TaskStatusInfo) GetStatus() TaskStatus + func (x *TaskStatusInfo) GetTaskType() string + func (x *TaskStatusInfo) ProtoReflect() protoreflect.Message + func (x *TaskStatusInfo) Reset() + func (x *TaskStatusInfo) String() string + type UnimplementedCollectionTaskServiceServer struct + func (UnimplementedCollectionTaskServiceServer) DistributeTasks(context.Context, *DistributeTasksReq) (*DistributeTasksResp, error) + func (UnimplementedCollectionTaskServiceServer) GetTaskStatus(context.Context, *GetTaskStatusReq) (*GetTaskStatusResp, error) + func (UnimplementedCollectionTaskServiceServer) GetTasks(context.Context, *GetTasksReq) (*GetTasksResp, error) + func (UnimplementedCollectionTaskServiceServer) UpdateTaskStatus(context.Context, *UpdateTaskStatusReq) (*UpdateTaskStatusResp, error) + type UnimplementedCommandServer struct + func (UnimplementedCommandServer) ExecCommand(*ExecCommandReq, grpc.ServerStreamingServer[ExecCommandResp]) error + func (UnimplementedCommandServer) ExecCommandSignal(context.Context, *ExecCommandSignalReq) (*ExecCommandSignalResp, error) + func (UnimplementedCommandServer) GetCommandStatus(context.Context, *GetCommandStatusReq) (*GetCommandStatusResp, error) + type UnimplementedFileServer struct + func (UnimplementedFileServer) CreateDirectory(context.Context, *CreateDirectoryReq) (*CreateDirectoryResp, error) + func (UnimplementedFileServer) DeleteFile(context.Context, *DeleteFileReq) (*DeleteFileResp, error) + func (UnimplementedFileServer) DownloadFile(*DownloadFileReq, grpc.ServerStreamingServer[DownloadFileResp]) error + func (UnimplementedFileServer) GetFileInfo(context.Context, *GetFileInfoReq) (*GetFileInfoResp, error) + func (UnimplementedFileServer) GetUploadStatus(context.Context, *GetUploadStatusReq) (*GetUploadStatusResp, error) + func (UnimplementedFileServer) ListFiles(context.Context, *ListFilesReq) (*ListFilesResp, error) + func (UnimplementedFileServer) StartFileUpload(context.Context, *StartFileUploadReq) (*StartFileUploadResp, error) + func (UnimplementedFileServer) UploadFileChunk(context.Context, *UploadFileChunkReq) (*UploadFileChunkResp, error) + type UnimplementedHealthServer struct + func (UnimplementedHealthServer) GetHealthHistory(context.Context, *GetHealthHistoryReq) (*GetHealthHistoryResp, error) + func (UnimplementedHealthServer) GetHealthStatus(context.Context, *GetHealthStatusReq) (*GetHealthStatusResp, error) + func (UnimplementedHealthServer) ListHealthStatuses(context.Context, *ListHealthStatusesReq) (*ListHealthStatusesResp, error) + type UnimplementedLuaServer struct + func (UnimplementedLuaServer) ExecLuaScript(context.Context, *ExecLuaScriptReq) (*ExecLuaScriptResp, error) + type UnimplementedMetricsServer struct + func (UnimplementedMetricsServer) GetApplicationMetrics(context.Context, *GetApplicationMetricsReq) (*GetApplicationMetricsResp, error) + func (UnimplementedMetricsServer) GetMetricsHistory(context.Context, *GetMetricsHistoryReq) (*GetMetricsHistoryResp, error) + func (UnimplementedMetricsServer) GetServiceMetrics(context.Context, *GetServiceMetricsReq) (*GetServiceMetricsResp, error) + func (UnimplementedMetricsServer) GetSystemMetrics(context.Context, *GetSystemMetricsReq) (*GetSystemMetricsResp, error) + func (UnimplementedMetricsServer) ListServiceMetrics(context.Context, *ListServiceMetricsReq) (*ListServiceMetricsResp, error) + type UnimplementedPackageServer struct + func (UnimplementedPackageServer) ApplyConfigs(context.Context, *ApplyConfigsReq) (*ApplyConfigsResp, error) + func (UnimplementedPackageServer) GetConfigs(context.Context, *GetConfigsReq) (*GetConfigsResp, error) + func (UnimplementedPackageServer) GetRecentLogs(context.Context, *GetRecentLogsReq) (*GetRecentLogsResp, error) + func (UnimplementedPackageServer) PackageList(context.Context, *emptypb.Empty) (*PackageListResp, error) + func (UnimplementedPackageServer) QueryLogs(context.Context, *QueryLogsReq) (*QueryLogsResp, error) + func (UnimplementedPackageServer) Restart(context.Context, *RestartReq) (*emptypb.Empty, error) + func (UnimplementedPackageServer) Start(context.Context, *StartReq) (*emptypb.Empty, error) + func (UnimplementedPackageServer) Stop(context.Context, *StopReq) (*emptypb.Empty, error) + func (UnimplementedPackageServer) StreamLogs(*StreamLogsReq, grpc.ServerStreamingServer[StreamLogsResp]) error + type UnsafeCollectionTaskServiceServer interface + type UnsafeCommandServer interface + type UnsafeFileServer interface + type UnsafeHealthServer interface + type UnsafeLuaServer interface + type UnsafeMetricsServer interface + type UnsafePackageServer interface + type UpdateTaskStatusReq struct + AgentCode string + Message string + Status TaskStatus + TaskType string + UpdatedAt *timestamppb.Timestamp + func (*UpdateTaskStatusReq) Descriptor() ([]byte, []int) + func (*UpdateTaskStatusReq) ProtoMessage() + func (x *UpdateTaskStatusReq) GetAgentCode() string + func (x *UpdateTaskStatusReq) GetMessage() string + func (x *UpdateTaskStatusReq) GetStatus() TaskStatus + func (x *UpdateTaskStatusReq) GetTaskType() string + func (x *UpdateTaskStatusReq) GetUpdatedAt() *timestamppb.Timestamp + func (x *UpdateTaskStatusReq) ProtoReflect() protoreflect.Message + func (x *UpdateTaskStatusReq) Reset() + func (x *UpdateTaskStatusReq) String() string + type UpdateTaskStatusResp struct + Message string + Success bool + func (*UpdateTaskStatusResp) Descriptor() ([]byte, []int) + func (*UpdateTaskStatusResp) ProtoMessage() + func (x *UpdateTaskStatusResp) GetMessage() string + func (x *UpdateTaskStatusResp) GetSuccess() bool + func (x *UpdateTaskStatusResp) ProtoReflect() protoreflect.Message + func (x *UpdateTaskStatusResp) Reset() + func (x *UpdateTaskStatusResp) String() string + type UpdatedFileDetail struct + ByteCount int32 + FileName string + func (*UpdatedFileDetail) Descriptor() ([]byte, []int) + func (*UpdatedFileDetail) ProtoMessage() + func (x *UpdatedFileDetail) GetByteCount() int32 + func (x *UpdatedFileDetail) GetFileName() string + func (x *UpdatedFileDetail) ProtoReflect() protoreflect.Message + func (x *UpdatedFileDetail) Reset() + func (x *UpdatedFileDetail) String() string + type UploadFileChunkReq struct + ChunkIndex int64 + Data []byte + SessionId string + func (*UploadFileChunkReq) Descriptor() ([]byte, []int) + func (*UploadFileChunkReq) ProtoMessage() + func (x *UploadFileChunkReq) GetChunkIndex() int64 + func (x *UploadFileChunkReq) GetData() []byte + func (x *UploadFileChunkReq) GetSessionId() string + func (x *UploadFileChunkReq) ProtoReflect() protoreflect.Message + func (x *UploadFileChunkReq) Reset() + func (x *UploadFileChunkReq) String() string + type UploadFileChunkResp struct + ChunkIndex int64 + SessionId string + Status string + func (*UploadFileChunkResp) Descriptor() ([]byte, []int) + func (*UploadFileChunkResp) ProtoMessage() + func (x *UploadFileChunkResp) GetChunkIndex() int64 + func (x *UploadFileChunkResp) GetSessionId() string + func (x *UploadFileChunkResp) GetStatus() string + func (x *UploadFileChunkResp) ProtoReflect() protoreflect.Message + func (x *UploadFileChunkResp) Reset() + func (x *UploadFileChunkResp) String() string
Go to main page