pb

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 1, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CollectionTaskService_DistributeTasks_FullMethodName  = "/collection_task_pb.CollectionTaskService/DistributeTasks"
	CollectionTaskService_GetTasks_FullMethodName         = "/collection_task_pb.CollectionTaskService/GetTasks"
	CollectionTaskService_UpdateTaskStatus_FullMethodName = "/collection_task_pb.CollectionTaskService/UpdateTaskStatus"
	CollectionTaskService_GetTaskStatus_FullMethodName    = "/collection_task_pb.CollectionTaskService/GetTaskStatus"
)
View Source 
const (
	Command_ExecCommand_FullMethodName       = "/pb.Command/ExecCommand"
	Command_ExecCommandSignal_FullMethodName = "/pb.Command/ExecCommandSignal"
	Command_GetCommandStatus_FullMethodName  = "/pb.Command/GetCommandStatus"
)
View Source 
const (
	File_ListFiles_FullMethodName       = "/pb.File/ListFiles"
	File_GetFileInfo_FullMethodName     = "/pb.File/GetFileInfo"
	File_StartFileUpload_FullMethodName = "/pb.File/StartFileUpload"
	File_UploadFileChunk_FullMethodName = "/pb.File/UploadFileChunk"
	File_GetUploadStatus_FullMethodName = "/pb.File/GetUploadStatus"
	File_DownloadFile_FullMethodName    = "/pb.File/DownloadFile"
	File_DeleteFile_FullMethodName      = "/pb.File/DeleteFile"
	File_CreateDirectory_FullMethodName = "/pb.File/CreateDirectory"
)
View Source 
const (
	Health_GetHealthStatus_FullMethodName    = "/pb.Health/GetHealthStatus"
	Health_ListHealthStatuses_FullMethodName = "/pb.Health/ListHealthStatuses"
	Health_GetHealthHistory_FullMethodName   = "/pb.Health/GetHealthHistory"
)
View Source 
const (
	Metrics_GetSystemMetrics_FullMethodName      = "/pb.Metrics/GetSystemMetrics"
	Metrics_GetServiceMetrics_FullMethodName     = "/pb.Metrics/GetServiceMetrics"
	Metrics_ListServiceMetrics_FullMethodName    = "/pb.Metrics/ListServiceMetrics"
	Metrics_GetApplicationMetrics_FullMethodName = "/pb.Metrics/GetApplicationMetrics"
	Metrics_GetMetricsHistory_FullMethodName     = "/pb.Metrics/GetMetricsHistory"
)
View Source 
const (
	Package_Start_FullMethodName         = "/pb.Package/Start"
	Package_Stop_FullMethodName          = "/pb.Package/Stop"
	Package_Restart_FullMethodName       = "/pb.Package/Restart"
	Package_PackageList_FullMethodName   = "/pb.Package/PackageList"
	Package_GetConfigs_FullMethodName    = "/pb.Package/GetConfigs"
	Package_ApplyConfigs_FullMethodName  = "/pb.Package/ApplyConfigs"
	Package_GetRecentLogs_FullMethodName = "/pb.Package/GetRecentLogs"
	Package_StreamLogs_FullMethodName    = "/pb.Package/StreamLogs"
	Package_QueryLogs_FullMethodName     = "/pb.Package/QueryLogs"
)
View Source 
const (
	Lua_ExecLuaScript_FullMethodName = "/pb.Lua/ExecLuaScript"
)

Variables

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "TASK_STATUS_UNKNOWN",
		1: "TASK_STATUS_PENDING",
		2: "TASK_STATUS_RUNNING",
		3: "TASK_STATUS_COMPLETED",
		4: "TASK_STATUS_FAILED",
		5: "TASK_STATUS_CANCELLED",
	}
	TaskStatus_value = map[string]int32{
		"TASK_STATUS_UNKNOWN":   0,
		"TASK_STATUS_PENDING":   1,
		"TASK_STATUS_RUNNING":   2,
		"TASK_STATUS_COMPLETED": 3,
		"TASK_STATUS_FAILED":    4,
		"TASK_STATUS_CANCELLED": 5,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	ExecCommandSignalType_name = map[int32]string{
		0: "CANCEL",
		1: "PAUSE",
		2: "RESUME",
	}
	ExecCommandSignalType_value = map[string]int32{
		"CANCEL": 0,
		"PAUSE":  1,
		"RESUME": 2,
	}
)

Enum value maps for ExecCommandSignalType.

View Source 
var (
	HealthStatus_name = map[int32]string{
		0: "HEALTH_STATUS_UNKNOWN",
		1: "HEALTH_STATUS_HEALTHY",
		2: "HEALTH_STATUS_UNHEALTHY",
		3: "HEALTH_STATUS_DEGRADED",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNKNOWN":   0,
		"HEALTH_STATUS_HEALTHY":   1,
		"HEALTH_STATUS_UNHEALTHY": 2,
		"HEALTH_STATUS_DEGRADED":  3,
	}
)

Enum value maps for HealthStatus.

View Source 
var (
	OutputFormat_name = map[int32]string{
		0: "JSON",
		1: "YAML",
		2: "TOML",
	}
	OutputFormat_value = map[string]int32{
		"JSON": 0,
		"YAML": 1,
		"TOML": 2,
	}
)

Enum value maps for OutputFormat.

View Source 
var CollectionTaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "collection_task_pb.CollectionTaskService",
	HandlerType: (*CollectionTaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DistributeTasks",
			Handler:    _CollectionTaskService_DistributeTasks_Handler,
		},
		{
			MethodName: "GetTasks",
			Handler:    _CollectionTaskService_GetTasks_Handler,
		},
		{
			MethodName: "UpdateTaskStatus",
			Handler:    _CollectionTaskService_UpdateTaskStatus_Handler,
		},
		{
			MethodName: "GetTaskStatus",
			Handler:    _CollectionTaskService_GetTaskStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "collection_task.proto",
}

CollectionTaskService_ServiceDesc is the grpc.ServiceDesc for CollectionTaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Command_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Command",
	HandlerType: (*CommandServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecCommandSignal",
			Handler:    _Command_ExecCommandSignal_Handler,
		},
		{
			MethodName: "GetCommandStatus",
			Handler:    _Command_GetCommandStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecCommand",
			Handler:       _Command_ExecCommand_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "command.proto",
}

Command_ServiceDesc is the grpc.ServiceDesc for Command service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.File",
	HandlerType: (*FileServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListFiles",
			Handler:    _File_ListFiles_Handler,
		},
		{
			MethodName: "GetFileInfo",
			Handler:    _File_GetFileInfo_Handler,
		},
		{
			MethodName: "StartFileUpload",
			Handler:    _File_StartFileUpload_Handler,
		},
		{
			MethodName: "UploadFileChunk",
			Handler:    _File_UploadFileChunk_Handler,
		},
		{
			MethodName: "GetUploadStatus",
			Handler:    _File_GetUploadStatus_Handler,
		},
		{
			MethodName: "DeleteFile",
			Handler:    _File_DeleteFile_Handler,
		},
		{
			MethodName: "CreateDirectory",
			Handler:    _File_CreateDirectory_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DownloadFile",
			Handler:       _File_DownloadFile_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "file.proto",
}

File_ServiceDesc is the grpc.ServiceDesc for File service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_collection_task_proto protoreflect.FileDescriptor
View Source 
var File_command_proto protoreflect.FileDescriptor
View Source 
var File_file_proto protoreflect.FileDescriptor
View Source 
var File_health_proto protoreflect.FileDescriptor
View Source 
var File_lua_proto protoreflect.FileDescriptor
View Source 
var File_metrics_proto protoreflect.FileDescriptor
View Source 
var File_package_proto protoreflect.FileDescriptor
View Source 
var Health_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Health",
	HandlerType: (*HealthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHealthStatus",
			Handler:    _Health_GetHealthStatus_Handler,
		},
		{
			MethodName: "ListHealthStatuses",
			Handler:    _Health_ListHealthStatuses_Handler,
		},
		{
			MethodName: "GetHealthHistory",
			Handler:    _Health_GetHealthHistory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "health.proto",
}

Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Lua_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Lua",
	HandlerType: (*LuaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecLuaScript",
			Handler:    _Lua_ExecLuaScript_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lua.proto",
}

Lua_ServiceDesc is the grpc.ServiceDesc for Lua service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Metrics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Metrics",
	HandlerType: (*MetricsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSystemMetrics",
			Handler:    _Metrics_GetSystemMetrics_Handler,
		},
		{
			MethodName: "GetServiceMetrics",
			Handler:    _Metrics_GetServiceMetrics_Handler,
		},
		{
			MethodName: "ListServiceMetrics",
			Handler:    _Metrics_ListServiceMetrics_Handler,
		},
		{
			MethodName: "GetApplicationMetrics",
			Handler:    _Metrics_GetApplicationMetrics_Handler,
		},
		{
			MethodName: "GetMetricsHistory",
			Handler:    _Metrics_GetMetricsHistory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metrics.proto",
}

Metrics_ServiceDesc is the grpc.ServiceDesc for Metrics service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Package_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Package",
	HandlerType: (*PackageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _Package_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Package_Stop_Handler,
		},
		{
			MethodName: "Restart",
			Handler:    _Package_Restart_Handler,
		},
		{
			MethodName: "PackageList",
			Handler:    _Package_PackageList_Handler,
		},
		{
			MethodName: "GetConfigs",
			Handler:    _Package_GetConfigs_Handler,
		},
		{
			MethodName: "ApplyConfigs",
			Handler:    _Package_ApplyConfigs_Handler,
		},
		{
			MethodName: "GetRecentLogs",
			Handler:    _Package_GetRecentLogs_Handler,
		},
		{
			MethodName: "QueryLogs",
			Handler:    _Package_QueryLogs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamLogs",
			Handler:       _Package_StreamLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "package.proto",
}

Package_ServiceDesc is the grpc.ServiceDesc for Package service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCollectionTaskServiceServer 

func RegisterCollectionTaskServiceServer(s grpc.ServiceRegistrar, srv CollectionTaskServiceServer)

func RegisterCommandServer 

func RegisterCommandServer(s grpc.ServiceRegistrar, srv CommandServer)

func RegisterFileServer 

func RegisterFileServer(s grpc.ServiceRegistrar, srv FileServer)

func RegisterHealthServer 

func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)

func RegisterLuaServer 

func RegisterLuaServer(s grpc.ServiceRegistrar, srv LuaServer)

func RegisterMetricsServer 

func RegisterMetricsServer(s grpc.ServiceRegistrar, srv MetricsServer)

func RegisterPackageServer 

func RegisterPackageServer(s grpc.ServiceRegistrar, srv PackageServer)

Types

type ApplicationMetrics 

type ApplicationMetrics struct {
	ServiceName string             `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Metrics     map[string]float64 `` // 指标名称 -> 指标值
	/* 143-byte string literal not displayed */
	Labels map[string]string `` // 指标标签
	/* 139-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

ApplicationMetrics 应用指标

func (*ApplicationMetrics) Descriptor deprecated 

func (*ApplicationMetrics) Descriptor() ([]byte, []int)

Deprecated: Use ApplicationMetrics.ProtoReflect.Descriptor instead.

func (*ApplicationMetrics) GetLabels 

func (x *ApplicationMetrics) GetLabels() map[string]string

func (*ApplicationMetrics) GetMetrics 

func (x *ApplicationMetrics) GetMetrics() map[string]float64

func (*ApplicationMetrics) GetServiceName 

func (x *ApplicationMetrics) GetServiceName() string

func (*ApplicationMetrics) GetTimestamp 

func (x *ApplicationMetrics) GetTimestamp() *timestamppb.Timestamp

func (*ApplicationMetrics) ProtoMessage 

func (*ApplicationMetrics) ProtoMessage()

func (*ApplicationMetrics) ProtoReflect 

func (x *ApplicationMetrics) ProtoReflect() protoreflect.Message

func (*ApplicationMetrics) Reset 

func (x *ApplicationMetrics) Reset()

func (*ApplicationMetrics) String 

func (x *ApplicationMetrics) String() string

type ApplyConfigsReq 

type ApplyConfigsReq struct {
	Package string        `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"` // 包名
	Configs []*ConfigItem `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"` // 要应用的配置项列表
	// contains filtered or unexported fields
}

ApplyConfigsReq 用于请求应用配置

func (*ApplyConfigsReq) Descriptor deprecated 

func (*ApplyConfigsReq) Descriptor() ([]byte, []int)

Deprecated: Use ApplyConfigsReq.ProtoReflect.Descriptor instead.

func (*ApplyConfigsReq) GetConfigs 

func (x *ApplyConfigsReq) GetConfigs() []*ConfigItem

func (*ApplyConfigsReq) GetPackage 

func (x *ApplyConfigsReq) GetPackage() string

func (*ApplyConfigsReq) ProtoMessage 

func (*ApplyConfigsReq) ProtoMessage()

func (*ApplyConfigsReq) ProtoReflect 

func (x *ApplyConfigsReq) ProtoReflect() protoreflect.Message

func (*ApplyConfigsReq) Reset 

func (x *ApplyConfigsReq) Reset()

func (*ApplyConfigsReq) String 

func (x *ApplyConfigsReq) String() string

type ApplyConfigsResp 

type ApplyConfigsResp struct {
	Success      bool                 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message      string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	UpdatedFiles []*UpdatedFileDetail `protobuf:"bytes,3,rep,name=updated_files,json=updatedFiles,proto3" json:"updated_files,omitempty"`
	// contains filtered or unexported fields
}

ApplyConfigsResp 用于应用配置的响应

func (*ApplyConfigsResp) Descriptor deprecated 

func (*ApplyConfigsResp) Descriptor() ([]byte, []int)

Deprecated: Use ApplyConfigsResp.ProtoReflect.Descriptor instead.

func (*ApplyConfigsResp) GetMessage 

func (x *ApplyConfigsResp) GetMessage() string

func (*ApplyConfigsResp) GetSuccess 

func (x *ApplyConfigsResp) GetSuccess() bool

func (*ApplyConfigsResp) GetUpdatedFiles 

func (x *ApplyConfigsResp) GetUpdatedFiles() []*UpdatedFileDetail

func (*ApplyConfigsResp) ProtoMessage 

func (*ApplyConfigsResp) ProtoMessage()

func (*ApplyConfigsResp) ProtoReflect 

func (x *ApplyConfigsResp) ProtoReflect() protoreflect.Message

func (*ApplyConfigsResp) Reset 

func (x *ApplyConfigsResp) Reset()

func (*ApplyConfigsResp) String 

func (x *ApplyConfigsResp) String() string

type CollectionTask 

type CollectionTask struct {
	TaskType string            `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"` // 任务类型: system_metrics/application_metrics/log_collection/snmp_polling/snmp_trap/remote_collection
	Enabled  bool              `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`                  // 是否启用
	Target   map[string]string ``                                                                                      // 采集目标（使用string map，JSON序列化后传递）
	/* 139-byte string literal not displayed */
	Scope map[string]string `` // 采集范围
	/* 137-byte string literal not displayed */
	CollectionRules map[string]string `` // 采集规则
	/* 180-byte string literal not displayed */
	ProcessingRules []*ProcessingRule `protobuf:"bytes,6,rep,name=processing_rules,json=processingRules,proto3" json:"processing_rules,omitempty"` // 处理规则列表
	OutputRules     []*OutputRule     `protobuf:"bytes,7,rep,name=output_rules,json=outputRules,proto3" json:"output_rules,omitempty"`             // 输出规则列表
	// contains filtered or unexported fields
}

CollectionTask 采集任务

func (*CollectionTask) Descriptor deprecated 

func (*CollectionTask) Descriptor() ([]byte, []int)

Deprecated: Use CollectionTask.ProtoReflect.Descriptor instead.

func (*CollectionTask) GetCollectionRules 

func (x *CollectionTask) GetCollectionRules() map[string]string

func (*CollectionTask) GetEnabled 

func (x *CollectionTask) GetEnabled() bool

func (*CollectionTask) GetOutputRules 

func (x *CollectionTask) GetOutputRules() []*OutputRule

func (*CollectionTask) GetProcessingRules 

func (x *CollectionTask) GetProcessingRules() []*ProcessingRule

func (*CollectionTask) GetScope 

func (x *CollectionTask) GetScope() map[string]string

func (*CollectionTask) GetTarget 

func (x *CollectionTask) GetTarget() map[string]string

func (*CollectionTask) GetTaskType 

func (x *CollectionTask) GetTaskType() string

func (*CollectionTask) ProtoMessage 

func (*CollectionTask) ProtoMessage()

func (*CollectionTask) ProtoReflect 

func (x *CollectionTask) ProtoReflect() protoreflect.Message

func (*CollectionTask) Reset 

func (x *CollectionTask) Reset()

func (*CollectionTask) String 

func (x *CollectionTask) String() string

type CollectionTaskServiceClient 

type CollectionTaskServiceClient interface {
	// DistributeTasks 分发任务（OneOps -> Controller）
	DistributeTasks(ctx context.Context, in *DistributeTasksReq, opts ...grpc.CallOption) (*DistributeTasksResp, error)
	// GetTasks 获取任务（Agent -> Controller）
	GetTasks(ctx context.Context, in *GetTasksReq, opts ...grpc.CallOption) (*GetTasksResp, error)
	// UpdateTaskStatus 更新任务状态（Agent -> Controller）
	UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusReq, opts ...grpc.CallOption) (*UpdateTaskStatusResp, error)
	// GetTaskStatus 查询任务状态（OneOps -> Controller）
	GetTaskStatus(ctx context.Context, in *GetTaskStatusReq, opts ...grpc.CallOption) (*GetTaskStatusResp, error)
}

CollectionTaskServiceClient is the client API for CollectionTaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

CollectionTaskService 采集任务服务

func NewCollectionTaskServiceClient 

func NewCollectionTaskServiceClient(cc grpc.ClientConnInterface) CollectionTaskServiceClient

type CollectionTaskServiceServer 

type CollectionTaskServiceServer interface {
	// DistributeTasks 分发任务（OneOps -> Controller）
	DistributeTasks(context.Context, *DistributeTasksReq) (*DistributeTasksResp, error)
	// GetTasks 获取任务（Agent -> Controller）
	GetTasks(context.Context, *GetTasksReq) (*GetTasksResp, error)
	// UpdateTaskStatus 更新任务状态（Agent -> Controller）
	UpdateTaskStatus(context.Context, *UpdateTaskStatusReq) (*UpdateTaskStatusResp, error)
	// GetTaskStatus 查询任务状态（OneOps -> Controller）
	GetTaskStatus(context.Context, *GetTaskStatusReq) (*GetTaskStatusResp, error)
	// contains filtered or unexported methods
}

CollectionTaskServiceServer is the server API for CollectionTaskService service. All implementations must embed UnimplementedCollectionTaskServiceServer for forward compatibility.

CollectionTaskService 采集任务服务

type CommandClient 

type CommandClient interface {
	ExecCommand(ctx context.Context, in *ExecCommandReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecCommandResp], error)
	ExecCommandSignal(ctx context.Context, in *ExecCommandSignalReq, opts ...grpc.CallOption) (*ExecCommandSignalResp, error)
	GetCommandStatus(ctx context.Context, in *GetCommandStatusReq, opts ...grpc.CallOption) (*GetCommandStatusResp, error)
}

CommandClient is the client API for Command service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCommandClient 

func NewCommandClient(cc grpc.ClientConnInterface) CommandClient

type CommandServer 

type CommandServer interface {
	ExecCommand(*ExecCommandReq, grpc.ServerStreamingServer[ExecCommandResp]) error
	ExecCommandSignal(context.Context, *ExecCommandSignalReq) (*ExecCommandSignalResp, error)
	GetCommandStatus(context.Context, *GetCommandStatusReq) (*GetCommandStatusResp, error)
	// contains filtered or unexported methods
}

CommandServer is the server API for Command service. All implementations must embed UnimplementedCommandServer for forward compatibility.

type Command_ExecCommandClient 

type Command_ExecCommandClient = grpc.ServerStreamingClient[ExecCommandResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Command_ExecCommandServer 

type Command_ExecCommandServer = grpc.ServerStreamingServer[ExecCommandResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ConfigItem 

type ConfigItem struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // 配置键
	Content  string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`                   // 配置内容
	// contains filtered or unexported fields
}

ConfigItem 表示一个配置项

func (*ConfigItem) Descriptor deprecated 

func (*ConfigItem) Descriptor() ([]byte, []int)

Deprecated: Use ConfigItem.ProtoReflect.Descriptor instead.

func (*ConfigItem) GetContent 

func (x *ConfigItem) GetContent() string

func (*ConfigItem) GetFileName 

func (x *ConfigItem) GetFileName() string

func (*ConfigItem) ProtoMessage 

func (*ConfigItem) ProtoMessage()

func (*ConfigItem) ProtoReflect 

func (x *ConfigItem) ProtoReflect() protoreflect.Message

func (*ConfigItem) Reset 

func (x *ConfigItem) Reset()

func (*ConfigItem) String 

func (x *ConfigItem) String() string

type CreateDirectoryReq 

type CreateDirectoryReq struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"` // 目录权限模式（八进制，如 0755）
	// contains filtered or unexported fields
}

CreateDirectoryReq 创建目录请求

func (*CreateDirectoryReq) Descriptor deprecated 

func (*CreateDirectoryReq) Descriptor() ([]byte, []int)

Deprecated: Use CreateDirectoryReq.ProtoReflect.Descriptor instead.

func (*CreateDirectoryReq) GetMode 

func (x *CreateDirectoryReq) GetMode() uint32

func (*CreateDirectoryReq) GetPath 

func (x *CreateDirectoryReq) GetPath() string

func (*CreateDirectoryReq) ProtoMessage 

func (*CreateDirectoryReq) ProtoMessage()

func (*CreateDirectoryReq) ProtoReflect 

func (x *CreateDirectoryReq) ProtoReflect() protoreflect.Message

func (*CreateDirectoryReq) Reset 

func (x *CreateDirectoryReq) Reset()

func (*CreateDirectoryReq) String 

func (x *CreateDirectoryReq) String() string

type CreateDirectoryResp 

type CreateDirectoryResp struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

CreateDirectoryResp 创建目录响应

func (*CreateDirectoryResp) Descriptor deprecated 

func (*CreateDirectoryResp) Descriptor() ([]byte, []int)

Deprecated: Use CreateDirectoryResp.ProtoReflect.Descriptor instead.

func (*CreateDirectoryResp) GetMessage 

func (x *CreateDirectoryResp) GetMessage() string

func (*CreateDirectoryResp) GetSuccess 

func (x *CreateDirectoryResp) GetSuccess() bool

func (*CreateDirectoryResp) ProtoMessage 

func (*CreateDirectoryResp) ProtoMessage()

func (*CreateDirectoryResp) ProtoReflect 

func (x *CreateDirectoryResp) ProtoReflect() protoreflect.Message

func (*CreateDirectoryResp) Reset 

func (x *CreateDirectoryResp) Reset()

func (*CreateDirectoryResp) String 

func (x *CreateDirectoryResp) String() string

type DeleteFileReq 

type DeleteFileReq struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Recursive bool   `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"` // 如果是目录，是否递归删除
	// contains filtered or unexported fields
}

DeleteFileReq 删除文件请求

func (*DeleteFileReq) Descriptor deprecated 

func (*DeleteFileReq) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileReq.ProtoReflect.Descriptor instead.

func (*DeleteFileReq) GetPath 

func (x *DeleteFileReq) GetPath() string

func (*DeleteFileReq) GetRecursive 

func (x *DeleteFileReq) GetRecursive() bool

func (*DeleteFileReq) ProtoMessage 

func (*DeleteFileReq) ProtoMessage()

func (*DeleteFileReq) ProtoReflect 

func (x *DeleteFileReq) ProtoReflect() protoreflect.Message

func (*DeleteFileReq) Reset 

func (x *DeleteFileReq) Reset()

func (*DeleteFileReq) String 

func (x *DeleteFileReq) String() string

type DeleteFileResp 

type DeleteFileResp struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

DeleteFileResp 删除文件响应

func (*DeleteFileResp) Descriptor deprecated 

func (*DeleteFileResp) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileResp.ProtoReflect.Descriptor instead.

func (*DeleteFileResp) GetMessage 

func (x *DeleteFileResp) GetMessage() string

func (*DeleteFileResp) GetSuccess 

func (x *DeleteFileResp) GetSuccess() bool

func (*DeleteFileResp) ProtoMessage 

func (*DeleteFileResp) ProtoMessage()

func (*DeleteFileResp) ProtoReflect 

func (x *DeleteFileResp) ProtoReflect() protoreflect.Message

func (*DeleteFileResp) Reset 

func (x *DeleteFileResp) Reset()

func (*DeleteFileResp) String 

func (x *DeleteFileResp) String() string

type DistributeTasksReq 

type DistributeTasksReq struct {
	AgentCode     string                 `protobuf:"bytes,1,opt,name=agent_code,json=agentCode,proto3" json:"agent_code,omitempty"`             // Agent标识码
	Tasks         []*CollectionTask      `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`                                      // 任务列表
	Version       int64                  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`                                 // 任务版本号
	DistributedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=distributed_at,json=distributedAt,proto3" json:"distributed_at,omitempty"` // 分发时间
	// contains filtered or unexported fields
}

DistributeTasksReq 分发任务请求

func (*DistributeTasksReq) Descriptor deprecated 

func (*DistributeTasksReq) Descriptor() ([]byte, []int)

Deprecated: Use DistributeTasksReq.ProtoReflect.Descriptor instead.

func (*DistributeTasksReq) GetAgentCode 

func (x *DistributeTasksReq) GetAgentCode() string

func (*DistributeTasksReq) GetDistributedAt 

func (x *DistributeTasksReq) GetDistributedAt() *timestamppb.Timestamp

func (*DistributeTasksReq) GetTasks 

func (x *DistributeTasksReq) GetTasks() []*CollectionTask

func (*DistributeTasksReq) GetVersion 

func (x *DistributeTasksReq) GetVersion() int64

func (*DistributeTasksReq) ProtoMessage 

func (*DistributeTasksReq) ProtoMessage()

func (*DistributeTasksReq) ProtoReflect 

func (x *DistributeTasksReq) ProtoReflect() protoreflect.Message

func (*DistributeTasksReq) Reset 

func (x *DistributeTasksReq) Reset()

func (*DistributeTasksReq) String 

func (x *DistributeTasksReq) String() string

type DistributeTasksResp 

type DistributeTasksResp struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                         // 是否成功
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                          // 响应消息
	TasksCount int32  `protobuf:"varint,3,opt,name=tasks_count,json=tasksCount,proto3" json:"tasks_count,omitempty"` // 接收的任务数量
	// contains filtered or unexported fields
}

DistributeTasksResp 分发任务响应

func (*DistributeTasksResp) Descriptor deprecated 

func (*DistributeTasksResp) Descriptor() ([]byte, []int)

Deprecated: Use DistributeTasksResp.ProtoReflect.Descriptor instead.

func (*DistributeTasksResp) GetMessage 

func (x *DistributeTasksResp) GetMessage() string

func (*DistributeTasksResp) GetSuccess 

func (x *DistributeTasksResp) GetSuccess() bool

func (*DistributeTasksResp) GetTasksCount 

func (x *DistributeTasksResp) GetTasksCount() int32

func (*DistributeTasksResp) ProtoMessage 

func (*DistributeTasksResp) ProtoMessage()

func (*DistributeTasksResp) ProtoReflect 

func (x *DistributeTasksResp) ProtoReflect() protoreflect.Message

func (*DistributeTasksResp) Reset 

func (x *DistributeTasksResp) Reset()

func (*DistributeTasksResp) String 

func (x *DistributeTasksResp) String() string

type DownloadFileReq 

type DownloadFileReq struct {
	Path   string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // 可选：起始偏移量
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"` // 可选：读取长度
	// contains filtered or unexported fields
}

DownloadFileReq 下载文件请求

func (*DownloadFileReq) Descriptor deprecated 

func (*DownloadFileReq) Descriptor() ([]byte, []int)

Deprecated: Use DownloadFileReq.ProtoReflect.Descriptor instead.

func (*DownloadFileReq) GetLength 

func (x *DownloadFileReq) GetLength() int64

func (*DownloadFileReq) GetOffset 

func (x *DownloadFileReq) GetOffset() int64

func (*DownloadFileReq) GetPath 

func (x *DownloadFileReq) GetPath() string

func (*DownloadFileReq) ProtoMessage 

func (*DownloadFileReq) ProtoMessage()

func (*DownloadFileReq) ProtoReflect 

func (x *DownloadFileReq) ProtoReflect() protoreflect.Message

func (*DownloadFileReq) Reset 

func (x *DownloadFileReq) Reset()

func (*DownloadFileReq) String 

func (x *DownloadFileReq) String() string

type DownloadFileResp 

type DownloadFileResp struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Eof    bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
	// contains filtered or unexported fields
}

DownloadFileResp 下载文件响应（流式）

func (*DownloadFileResp) Descriptor deprecated 

func (*DownloadFileResp) Descriptor() ([]byte, []int)

Deprecated: Use DownloadFileResp.ProtoReflect.Descriptor instead.

func (*DownloadFileResp) GetData 

func (x *DownloadFileResp) GetData() []byte

func (*DownloadFileResp) GetEof 

func (x *DownloadFileResp) GetEof() bool

func (*DownloadFileResp) GetOffset 

func (x *DownloadFileResp) GetOffset() int64

func (*DownloadFileResp) ProtoMessage 

func (*DownloadFileResp) ProtoMessage()

func (*DownloadFileResp) ProtoReflect 

func (x *DownloadFileResp) ProtoReflect() protoreflect.Message

func (*DownloadFileResp) Reset 

func (x *DownloadFileResp) Reset()

func (*DownloadFileResp) String 

func (x *DownloadFileResp) String() string

type ExecCommandReq 

type ExecCommandReq struct {
	Command    string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Continuous bool   `protobuf:"varint,2,opt,name=continuous,proto3" json:"continuous,omitempty"` // 标识是否为持续运行的命令
	// contains filtered or unexported fields
}

func (*ExecCommandReq) Descriptor deprecated 

func (*ExecCommandReq) Descriptor() ([]byte, []int)

Deprecated: Use ExecCommandReq.ProtoReflect.Descriptor instead.

func (*ExecCommandReq) GetCommand 

func (x *ExecCommandReq) GetCommand() string

func (*ExecCommandReq) GetContinuous 

func (x *ExecCommandReq) GetContinuous() bool

func (*ExecCommandReq) ProtoMessage 

func (*ExecCommandReq) ProtoMessage()

func (*ExecCommandReq) ProtoReflect 

func (x *ExecCommandReq) ProtoReflect() protoreflect.Message

func (*ExecCommandReq) Reset 

func (x *ExecCommandReq) Reset()

func (*ExecCommandReq) String 

func (x *ExecCommandReq) String() string

type ExecCommandResp 

type ExecCommandResp struct {
	Out       string `protobuf:"bytes,1,opt,name=out,proto3" json:"out,omitempty"`
	Err       string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	CommandId string `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"` // 用于标识持续运行的命令
	// contains filtered or unexported fields
}

func (*ExecCommandResp) Descriptor deprecated 

func (*ExecCommandResp) Descriptor() ([]byte, []int)

Deprecated: Use ExecCommandResp.ProtoReflect.Descriptor instead.

func (*ExecCommandResp) GetCommandId 

func (x *ExecCommandResp) GetCommandId() string

func (*ExecCommandResp) GetErr 

func (x *ExecCommandResp) GetErr() string

func (*ExecCommandResp) GetOut 

func (x *ExecCommandResp) GetOut() string

func (*ExecCommandResp) ProtoMessage 

func (*ExecCommandResp) ProtoMessage()

func (*ExecCommandResp) ProtoReflect 

func (x *ExecCommandResp) ProtoReflect() protoreflect.Message

func (*ExecCommandResp) Reset 

func (x *ExecCommandResp) Reset()

func (*ExecCommandResp) String 

func (x *ExecCommandResp) String() string

type ExecCommandSignalReq 

type ExecCommandSignalReq struct {
	CommandId string                `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Signal    ExecCommandSignalType `protobuf:"varint,2,opt,name=signal,proto3,enum=pb.ExecCommandSignalType" json:"signal,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecCommandSignalReq) Descriptor deprecated 

func (*ExecCommandSignalReq) Descriptor() ([]byte, []int)

Deprecated: Use ExecCommandSignalReq.ProtoReflect.Descriptor instead.

func (*ExecCommandSignalReq) GetCommandId 

func (x *ExecCommandSignalReq) GetCommandId() string

func (*ExecCommandSignalReq) GetSignal 

func (x *ExecCommandSignalReq) GetSignal() ExecCommandSignalType

func (*ExecCommandSignalReq) ProtoMessage 

func (*ExecCommandSignalReq) ProtoMessage()

func (*ExecCommandSignalReq) ProtoReflect 

func (x *ExecCommandSignalReq) ProtoReflect() protoreflect.Message

func (*ExecCommandSignalReq) Reset 

func (x *ExecCommandSignalReq) Reset()

func (*ExecCommandSignalReq) String 

func (x *ExecCommandSignalReq) String() string

type ExecCommandSignalResp 

type ExecCommandSignalResp struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecCommandSignalResp) Descriptor deprecated 

func (*ExecCommandSignalResp) Descriptor() ([]byte, []int)

Deprecated: Use ExecCommandSignalResp.ProtoReflect.Descriptor instead.

func (*ExecCommandSignalResp) GetSuccess 

func (x *ExecCommandSignalResp) GetSuccess() bool

func (*ExecCommandSignalResp) ProtoMessage 

func (*ExecCommandSignalResp) ProtoMessage()

func (*ExecCommandSignalResp) ProtoReflect 

func (x *ExecCommandSignalResp) ProtoReflect() protoreflect.Message

func (*ExecCommandSignalResp) Reset 

func (x *ExecCommandSignalResp) Reset()

func (*ExecCommandSignalResp) String 

func (x *ExecCommandSignalResp) String() string

type ExecCommandSignalType 

type ExecCommandSignalType int32
const (
	ExecCommandSignalType_CANCEL ExecCommandSignalType = 0
	ExecCommandSignalType_PAUSE  ExecCommandSignalType = 1
	ExecCommandSignalType_RESUME ExecCommandSignalType = 2
)

func (ExecCommandSignalType) Descriptor 

func (ExecCommandSignalType) Descriptor() protoreflect.EnumDescriptor

func (ExecCommandSignalType) Enum 

func (x ExecCommandSignalType) Enum() *ExecCommandSignalType

func (ExecCommandSignalType) EnumDescriptor deprecated 

func (ExecCommandSignalType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecCommandSignalType.Descriptor instead.

func (ExecCommandSignalType) Number 

func (x ExecCommandSignalType) Number() protoreflect.EnumNumber

func (ExecCommandSignalType) String 

func (x ExecCommandSignalType) String() string

func (ExecCommandSignalType) Type 

func (ExecCommandSignalType) Type() protoreflect.EnumType

type ExecLuaScriptReq 

type ExecLuaScriptReq struct {
	AgentCode string `protobuf:"bytes,1,opt,name=agentCode,proto3" json:"agentCode,omitempty"`
	Lua       string `protobuf:"bytes,2,opt,name=lua,proto3" json:"lua,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecLuaScriptReq) Descriptor deprecated 

func (*ExecLuaScriptReq) Descriptor() ([]byte, []int)

Deprecated: Use ExecLuaScriptReq.ProtoReflect.Descriptor instead.

func (*ExecLuaScriptReq) GetAgentCode 

func (x *ExecLuaScriptReq) GetAgentCode() string

func (*ExecLuaScriptReq) GetLua 

func (x *ExecLuaScriptReq) GetLua() string

func (*ExecLuaScriptReq) ProtoMessage 

func (*ExecLuaScriptReq) ProtoMessage()

func (*ExecLuaScriptReq) ProtoReflect 

func (x *ExecLuaScriptReq) ProtoReflect() protoreflect.Message

func (*ExecLuaScriptReq) Reset 

func (x *ExecLuaScriptReq) Reset()

func (*ExecLuaScriptReq) String 

func (x *ExecLuaScriptReq) String() string

type ExecLuaScriptResp 

type ExecLuaScriptResp struct {
	AgentCode string `protobuf:"bytes,1,opt,name=agentCode,proto3" json:"agentCode,omitempty"`
	Output    string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecLuaScriptResp) Descriptor deprecated 

func (*ExecLuaScriptResp) Descriptor() ([]byte, []int)

Deprecated: Use ExecLuaScriptResp.ProtoReflect.Descriptor instead.

func (*ExecLuaScriptResp) GetAgentCode 

func (x *ExecLuaScriptResp) GetAgentCode() string

func (*ExecLuaScriptResp) GetOutput 

func (x *ExecLuaScriptResp) GetOutput() string

func (*ExecLuaScriptResp) ProtoMessage 

func (*ExecLuaScriptResp) ProtoMessage()

func (*ExecLuaScriptResp) ProtoReflect 

func (x *ExecLuaScriptResp) ProtoReflect() protoreflect.Message

func (*ExecLuaScriptResp) Reset 

func (x *ExecLuaScriptResp) Reset()

func (*ExecLuaScriptResp) String 

func (x *ExecLuaScriptResp) String() string

type FileClient 

type FileClient interface {
	// ListFiles 列出文件
	ListFiles(ctx context.Context, in *ListFilesReq, opts ...grpc.CallOption) (*ListFilesResp, error)
	// GetFileInfo 获取文件信息
	GetFileInfo(ctx context.Context, in *GetFileInfoReq, opts ...grpc.CallOption) (*GetFileInfoResp, error)
	// StartFileUpload 开始文件上传
	StartFileUpload(ctx context.Context, in *StartFileUploadReq, opts ...grpc.CallOption) (*StartFileUploadResp, error)
	// UploadFileChunk 上传文件块
	UploadFileChunk(ctx context.Context, in *UploadFileChunkReq, opts ...grpc.CallOption) (*UploadFileChunkResp, error)
	// GetUploadStatus 获取上传状态
	GetUploadStatus(ctx context.Context, in *GetUploadStatusReq, opts ...grpc.CallOption) (*GetUploadStatusResp, error)
	// DownloadFile 下载文件（流式）
	DownloadFile(ctx context.Context, in *DownloadFileReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadFileResp], error)
	// DeleteFile 删除文件或目录
	DeleteFile(ctx context.Context, in *DeleteFileReq, opts ...grpc.CallOption) (*DeleteFileResp, error)
	// CreateDirectory 创建目录
	CreateDirectory(ctx context.Context, in *CreateDirectoryReq, opts ...grpc.CallOption) (*CreateDirectoryResp, error)
}

FileClient is the client API for File service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

File 服务定义

func NewFileClient 

func NewFileClient(cc grpc.ClientConnInterface) FileClient

type FileInfo 

type FileInfo struct {
	Path    string                 `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Size    int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	IsDir   bool                   `protobuf:"varint,3,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	Mode    string                 `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	ModTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=mod_time,json=modTime,proto3" json:"mod_time,omitempty"`
	Md5     string                 `protobuf:"bytes,6,opt,name=md5,proto3" json:"md5,omitempty"`
	Sha256  string                 `protobuf:"bytes,7,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

FileInfo 文件信息

func (*FileInfo) Descriptor deprecated 

func (*FileInfo) Descriptor() ([]byte, []int)

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetIsDir 

func (x *FileInfo) GetIsDir() bool

func (*FileInfo) GetMd5 

func (x *FileInfo) GetMd5() string

func (*FileInfo) GetModTime 

func (x *FileInfo) GetModTime() *timestamppb.Timestamp

func (*FileInfo) GetMode 

func (x *FileInfo) GetMode() string

func (*FileInfo) GetPath 

func (x *FileInfo) GetPath() string

func (*FileInfo) GetSha256 

func (x *FileInfo) GetSha256() string

func (*FileInfo) GetSize 

func (x *FileInfo) GetSize() int64

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type FileServer 

type FileServer interface {
	// ListFiles 列出文件
	ListFiles(context.Context, *ListFilesReq) (*ListFilesResp, error)
	// GetFileInfo 获取文件信息
	GetFileInfo(context.Context, *GetFileInfoReq) (*GetFileInfoResp, error)
	// StartFileUpload 开始文件上传
	StartFileUpload(context.Context, *StartFileUploadReq) (*StartFileUploadResp, error)
	// UploadFileChunk 上传文件块
	UploadFileChunk(context.Context, *UploadFileChunkReq) (*UploadFileChunkResp, error)
	// GetUploadStatus 获取上传状态
	GetUploadStatus(context.Context, *GetUploadStatusReq) (*GetUploadStatusResp, error)
	// DownloadFile 下载文件（流式）
	DownloadFile(*DownloadFileReq, grpc.ServerStreamingServer[DownloadFileResp]) error
	// DeleteFile 删除文件或目录
	DeleteFile(context.Context, *DeleteFileReq) (*DeleteFileResp, error)
	// CreateDirectory 创建目录
	CreateDirectory(context.Context, *CreateDirectoryReq) (*CreateDirectoryResp, error)
	// contains filtered or unexported methods
}

FileServer is the server API for File service. All implementations must embed UnimplementedFileServer for forward compatibility.

File 服务定义

type File_DownloadFileClient 

type File_DownloadFileClient = grpc.ServerStreamingClient[DownloadFileResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type File_DownloadFileServer 

type File_DownloadFileServer = grpc.ServerStreamingServer[DownloadFileResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GetApplicationMetricsReq 

type GetApplicationMetricsReq struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // 可选：服务名称，为空则返回所有服务
	// contains filtered or unexported fields
}

GetApplicationMetricsReq 获取应用指标请求

func (*GetApplicationMetricsReq) Descriptor deprecated 

func (*GetApplicationMetricsReq) Descriptor() ([]byte, []int)

Deprecated: Use GetApplicationMetricsReq.ProtoReflect.Descriptor instead.

func (*GetApplicationMetricsReq) GetServiceName 

func (x *GetApplicationMetricsReq) GetServiceName() string

func (*GetApplicationMetricsReq) ProtoMessage 

func (*GetApplicationMetricsReq) ProtoMessage()

func (*GetApplicationMetricsReq) ProtoReflect 

func (x *GetApplicationMetricsReq) ProtoReflect() protoreflect.Message

func (*GetApplicationMetricsReq) Reset 

func (x *GetApplicationMetricsReq) Reset()

func (*GetApplicationMetricsReq) String 

func (x *GetApplicationMetricsReq) String() string

type GetApplicationMetricsResp 

type GetApplicationMetricsResp struct {
	Services map[string]*ApplicationMetrics `` // 服务名称 -> 应用指标
	/* 143-byte string literal not displayed */
	Metrics *ApplicationMetrics `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"` // 单个服务的指标（当指定 service_name 时）
	// contains filtered or unexported fields
}

GetApplicationMetricsResp 获取应用指标响应

func (*GetApplicationMetricsResp) Descriptor deprecated 

func (*GetApplicationMetricsResp) Descriptor() ([]byte, []int)

Deprecated: Use GetApplicationMetricsResp.ProtoReflect.Descriptor instead.

func (*GetApplicationMetricsResp) GetMetrics 

func (x *GetApplicationMetricsResp) GetMetrics() *ApplicationMetrics

func (*GetApplicationMetricsResp) GetServices 

func (x *GetApplicationMetricsResp) GetServices() map[string]*ApplicationMetrics

func (*GetApplicationMetricsResp) ProtoMessage 

func (*GetApplicationMetricsResp) ProtoMessage()

func (*GetApplicationMetricsResp) ProtoReflect 

func (x *GetApplicationMetricsResp) ProtoReflect() protoreflect.Message

func (*GetApplicationMetricsResp) Reset 

func (x *GetApplicationMetricsResp) Reset()

func (*GetApplicationMetricsResp) String 

func (x *GetApplicationMetricsResp) String() string

type GetCommandStatusReq 

type GetCommandStatusReq struct {
	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCommandStatusReq) Descriptor deprecated 

func (*GetCommandStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use GetCommandStatusReq.ProtoReflect.Descriptor instead.

func (*GetCommandStatusReq) GetCommandId 

func (x *GetCommandStatusReq) GetCommandId() string

func (*GetCommandStatusReq) ProtoMessage 

func (*GetCommandStatusReq) ProtoMessage()

func (*GetCommandStatusReq) ProtoReflect 

func (x *GetCommandStatusReq) ProtoReflect() protoreflect.Message

func (*GetCommandStatusReq) Reset 

func (x *GetCommandStatusReq) Reset()

func (*GetCommandStatusReq) String 

func (x *GetCommandStatusReq) String() string

type GetCommandStatusResp 

type GetCommandStatusResp struct {
	CommandId string  `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Status    string  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	StartTime int64   `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Duration  float64 `protobuf:"fixed64,4,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCommandStatusResp) Descriptor deprecated 

func (*GetCommandStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use GetCommandStatusResp.ProtoReflect.Descriptor instead.

func (*GetCommandStatusResp) GetCommandId 

func (x *GetCommandStatusResp) GetCommandId() string

func (*GetCommandStatusResp) GetDuration 

func (x *GetCommandStatusResp) GetDuration() float64

func (*GetCommandStatusResp) GetStartTime 

func (x *GetCommandStatusResp) GetStartTime() int64

func (*GetCommandStatusResp) GetStatus 

func (x *GetCommandStatusResp) GetStatus() string

func (*GetCommandStatusResp) ProtoMessage 

func (*GetCommandStatusResp) ProtoMessage()

func (*GetCommandStatusResp) ProtoReflect 

func (x *GetCommandStatusResp) ProtoReflect() protoreflect.Message

func (*GetCommandStatusResp) Reset 

func (x *GetCommandStatusResp) Reset()

func (*GetCommandStatusResp) String 

func (x *GetCommandStatusResp) String() string

type GetConfigsReq 

type GetConfigsReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"` // 包名
	// contains filtered or unexported fields
}

GetConfigReq 用于请求获取配置

func (*GetConfigsReq) Descriptor deprecated 

func (*GetConfigsReq) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigsReq.ProtoReflect.Descriptor instead.

func (*GetConfigsReq) GetPackage 

func (x *GetConfigsReq) GetPackage() string

func (*GetConfigsReq) ProtoMessage 

func (*GetConfigsReq) ProtoMessage()

func (*GetConfigsReq) ProtoReflect 

func (x *GetConfigsReq) ProtoReflect() protoreflect.Message

func (*GetConfigsReq) Reset 

func (x *GetConfigsReq) Reset()

func (*GetConfigsReq) String 

func (x *GetConfigsReq) String() string

type GetConfigsResp 

type GetConfigsResp struct {
	Configs []*ConfigItem `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

GetConfigResp 用于返回配置信息

func (*GetConfigsResp) Descriptor deprecated 

func (*GetConfigsResp) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigsResp.ProtoReflect.Descriptor instead.

func (*GetConfigsResp) GetConfigs 

func (x *GetConfigsResp) GetConfigs() []*ConfigItem

func (*GetConfigsResp) ProtoMessage 

func (*GetConfigsResp) ProtoMessage()

func (*GetConfigsResp) ProtoReflect 

func (x *GetConfigsResp) ProtoReflect() protoreflect.Message

func (*GetConfigsResp) Reset 

func (x *GetConfigsResp) Reset()

func (*GetConfigsResp) String 

func (x *GetConfigsResp) String() string

type GetFileInfoReq 

type GetFileInfoReq struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

GetFileInfoReq 获取文件信息请求

func (*GetFileInfoReq) Descriptor deprecated 

func (*GetFileInfoReq) Descriptor() ([]byte, []int)

Deprecated: Use GetFileInfoReq.ProtoReflect.Descriptor instead.

func (*GetFileInfoReq) GetPath 

func (x *GetFileInfoReq) GetPath() string

func (*GetFileInfoReq) ProtoMessage 

func (*GetFileInfoReq) ProtoMessage()

func (*GetFileInfoReq) ProtoReflect 

func (x *GetFileInfoReq) ProtoReflect() protoreflect.Message

func (*GetFileInfoReq) Reset 

func (x *GetFileInfoReq) Reset()

func (*GetFileInfoReq) String 

func (x *GetFileInfoReq) String() string

type GetFileInfoResp 

type GetFileInfoResp struct {
	File   *FileInfo `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Exists bool      `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

GetFileInfoResp 获取文件信息响应

func (*GetFileInfoResp) Descriptor deprecated 

func (*GetFileInfoResp) Descriptor() ([]byte, []int)

Deprecated: Use GetFileInfoResp.ProtoReflect.Descriptor instead.

func (*GetFileInfoResp) GetExists 

func (x *GetFileInfoResp) GetExists() bool

func (*GetFileInfoResp) GetFile 

func (x *GetFileInfoResp) GetFile() *FileInfo

func (*GetFileInfoResp) ProtoMessage 

func (*GetFileInfoResp) ProtoMessage()

func (*GetFileInfoResp) ProtoReflect 

func (x *GetFileInfoResp) ProtoReflect() protoreflect.Message

func (*GetFileInfoResp) Reset 

func (x *GetFileInfoResp) Reset()

func (*GetFileInfoResp) String 

func (x *GetFileInfoResp) String() string

type GetHealthHistoryReq 

type GetHealthHistoryReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	Limit   int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // 返回的记录数限制，默认 100
	// contains filtered or unexported fields
}

GetHealthHistoryReq 获取健康检查历史请求

func (*GetHealthHistoryReq) Descriptor deprecated 

func (*GetHealthHistoryReq) Descriptor() ([]byte, []int)

Deprecated: Use GetHealthHistoryReq.ProtoReflect.Descriptor instead.

func (*GetHealthHistoryReq) GetLimit 

func (x *GetHealthHistoryReq) GetLimit() int32

func (*GetHealthHistoryReq) GetPackage 

func (x *GetHealthHistoryReq) GetPackage() string

func (*GetHealthHistoryReq) ProtoMessage 

func (*GetHealthHistoryReq) ProtoMessage()

func (*GetHealthHistoryReq) ProtoReflect 

func (x *GetHealthHistoryReq) ProtoReflect() protoreflect.Message

func (*GetHealthHistoryReq) Reset 

func (x *GetHealthHistoryReq) Reset()

func (*GetHealthHistoryReq) String 

func (x *GetHealthHistoryReq) String() string

type GetHealthHistoryResp 

type GetHealthHistoryResp struct {
	Package string                `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	Entries []*HealthHistoryEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

GetHealthHistoryResp 获取健康检查历史响应

func (*GetHealthHistoryResp) Descriptor deprecated 

func (*GetHealthHistoryResp) Descriptor() ([]byte, []int)

Deprecated: Use GetHealthHistoryResp.ProtoReflect.Descriptor instead.

func (*GetHealthHistoryResp) GetEntries 

func (x *GetHealthHistoryResp) GetEntries() []*HealthHistoryEntry

func (*GetHealthHistoryResp) GetPackage 

func (x *GetHealthHistoryResp) GetPackage() string

func (*GetHealthHistoryResp) ProtoMessage 

func (*GetHealthHistoryResp) ProtoMessage()

func (*GetHealthHistoryResp) ProtoReflect 

func (x *GetHealthHistoryResp) ProtoReflect() protoreflect.Message

func (*GetHealthHistoryResp) Reset 

func (x *GetHealthHistoryResp) Reset()

func (*GetHealthHistoryResp) String 

func (x *GetHealthHistoryResp) String() string

type GetHealthStatusReq 

type GetHealthStatusReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

GetHealthStatusReq 获取健康状态请求

func (*GetHealthStatusReq) Descriptor deprecated 

func (*GetHealthStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use GetHealthStatusReq.ProtoReflect.Descriptor instead.

func (*GetHealthStatusReq) GetPackage 

func (x *GetHealthStatusReq) GetPackage() string

func (*GetHealthStatusReq) ProtoMessage 

func (*GetHealthStatusReq) ProtoMessage()

func (*GetHealthStatusReq) ProtoReflect 

func (x *GetHealthStatusReq) ProtoReflect() protoreflect.Message

func (*GetHealthStatusReq) Reset 

func (x *GetHealthStatusReq) Reset()

func (*GetHealthStatusReq) String 

func (x *GetHealthStatusReq) String() string

type GetHealthStatusResp 

type GetHealthStatusResp struct {
	Health *ServiceHealth `protobuf:"bytes,1,opt,name=health,proto3" json:"health,omitempty"`
	// contains filtered or unexported fields
}

GetHealthStatusResp 获取健康状态响应

func (*GetHealthStatusResp) Descriptor deprecated 

func (*GetHealthStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use GetHealthStatusResp.ProtoReflect.Descriptor instead.

func (*GetHealthStatusResp) GetHealth 

func (x *GetHealthStatusResp) GetHealth() *ServiceHealth

func (*GetHealthStatusResp) ProtoMessage 

func (*GetHealthStatusResp) ProtoMessage()

func (*GetHealthStatusResp) ProtoReflect 

func (x *GetHealthStatusResp) ProtoReflect() protoreflect.Message

func (*GetHealthStatusResp) Reset 

func (x *GetHealthStatusResp) Reset()

func (*GetHealthStatusResp) String 

func (x *GetHealthStatusResp) String() string

type GetMetricsHistoryReq 

type GetMetricsHistoryReq struct {
	Type        string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`                                  // 指标类型：system, service
	ServiceName string                 `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // 服务名称（仅当 type=service 时）
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`       // 开始时间
	EndTime     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`             // 结束时间
	// contains filtered or unexported fields
}

GetMetricsHistoryReq 获取指标历史请求

func (*GetMetricsHistoryReq) Descriptor deprecated 

func (*GetMetricsHistoryReq) Descriptor() ([]byte, []int)

Deprecated: Use GetMetricsHistoryReq.ProtoReflect.Descriptor instead.

func (*GetMetricsHistoryReq) GetEndTime 

func (x *GetMetricsHistoryReq) GetEndTime() *timestamppb.Timestamp

func (*GetMetricsHistoryReq) GetServiceName 

func (x *GetMetricsHistoryReq) GetServiceName() string

func (*GetMetricsHistoryReq) GetStartTime 

func (x *GetMetricsHistoryReq) GetStartTime() *timestamppb.Timestamp

func (*GetMetricsHistoryReq) GetType 

func (x *GetMetricsHistoryReq) GetType() string

func (*GetMetricsHistoryReq) ProtoMessage 

func (*GetMetricsHistoryReq) ProtoMessage()

func (*GetMetricsHistoryReq) ProtoReflect 

func (x *GetMetricsHistoryReq) ProtoReflect() protoreflect.Message

func (*GetMetricsHistoryReq) Reset 

func (x *GetMetricsHistoryReq) Reset()

func (*GetMetricsHistoryReq) String 

func (x *GetMetricsHistoryReq) String() string

type GetMetricsHistoryResp 

type GetMetricsHistoryResp struct {
	Type        string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ServiceName string                 `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	DataPoints  []*MetricsHistoryPoint `protobuf:"bytes,5,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"`
	// contains filtered or unexported fields
}

GetMetricsHistoryResp 获取指标历史响应

func (*GetMetricsHistoryResp) Descriptor deprecated 

func (*GetMetricsHistoryResp) Descriptor() ([]byte, []int)

Deprecated: Use GetMetricsHistoryResp.ProtoReflect.Descriptor instead.

func (*GetMetricsHistoryResp) GetDataPoints 

func (x *GetMetricsHistoryResp) GetDataPoints() []*MetricsHistoryPoint

func (*GetMetricsHistoryResp) GetEndTime 

func (x *GetMetricsHistoryResp) GetEndTime() *timestamppb.Timestamp

func (*GetMetricsHistoryResp) GetServiceName 

func (x *GetMetricsHistoryResp) GetServiceName() string

func (*GetMetricsHistoryResp) GetStartTime 

func (x *GetMetricsHistoryResp) GetStartTime() *timestamppb.Timestamp

func (*GetMetricsHistoryResp) GetType 

func (x *GetMetricsHistoryResp) GetType() string

func (*GetMetricsHistoryResp) ProtoMessage 

func (*GetMetricsHistoryResp) ProtoMessage()

func (*GetMetricsHistoryResp) ProtoReflect 

func (x *GetMetricsHistoryResp) ProtoReflect() protoreflect.Message

func (*GetMetricsHistoryResp) Reset 

func (x *GetMetricsHistoryResp) Reset()

func (*GetMetricsHistoryResp) String 

func (x *GetMetricsHistoryResp) String() string

type GetRecentLogsReq 

type GetRecentLogsReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	Count   int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecentLogsReq) Descriptor deprecated 

func (*GetRecentLogsReq) Descriptor() ([]byte, []int)

Deprecated: Use GetRecentLogsReq.ProtoReflect.Descriptor instead.

func (*GetRecentLogsReq) GetCount 

func (x *GetRecentLogsReq) GetCount() int32

func (*GetRecentLogsReq) GetPackage 

func (x *GetRecentLogsReq) GetPackage() string

func (*GetRecentLogsReq) ProtoMessage 

func (*GetRecentLogsReq) ProtoMessage()

func (*GetRecentLogsReq) ProtoReflect 

func (x *GetRecentLogsReq) ProtoReflect() protoreflect.Message

func (*GetRecentLogsReq) Reset 

func (x *GetRecentLogsReq) Reset()

func (*GetRecentLogsReq) String 

func (x *GetRecentLogsReq) String() string

type GetRecentLogsResp 

type GetRecentLogsResp struct {
	Logs []string `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecentLogsResp) Descriptor deprecated 

func (*GetRecentLogsResp) Descriptor() ([]byte, []int)

Deprecated: Use GetRecentLogsResp.ProtoReflect.Descriptor instead.

func (*GetRecentLogsResp) GetLogs 

func (x *GetRecentLogsResp) GetLogs() []string

func (*GetRecentLogsResp) ProtoMessage 

func (*GetRecentLogsResp) ProtoMessage()

func (*GetRecentLogsResp) ProtoReflect 

func (x *GetRecentLogsResp) ProtoReflect() protoreflect.Message

func (*GetRecentLogsResp) Reset 

func (x *GetRecentLogsResp) Reset()

func (*GetRecentLogsResp) String 

func (x *GetRecentLogsResp) String() string

type GetServiceMetricsReq 

type GetServiceMetricsReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

GetServiceMetricsReq 获取服务指标请求

func (*GetServiceMetricsReq) Descriptor deprecated 

func (*GetServiceMetricsReq) Descriptor() ([]byte, []int)

Deprecated: Use GetServiceMetricsReq.ProtoReflect.Descriptor instead.

func (*GetServiceMetricsReq) GetPackage 

func (x *GetServiceMetricsReq) GetPackage() string

func (*GetServiceMetricsReq) ProtoMessage 

func (*GetServiceMetricsReq) ProtoMessage()

func (*GetServiceMetricsReq) ProtoReflect 

func (x *GetServiceMetricsReq) ProtoReflect() protoreflect.Message

func (*GetServiceMetricsReq) Reset 

func (x *GetServiceMetricsReq) Reset()

func (*GetServiceMetricsReq) String 

func (x *GetServiceMetricsReq) String() string

type GetServiceMetricsResp 

type GetServiceMetricsResp struct {
	Metrics *ServiceMetrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

GetServiceMetricsResp 获取服务指标响应

func (*GetServiceMetricsResp) Descriptor deprecated 

func (*GetServiceMetricsResp) Descriptor() ([]byte, []int)

Deprecated: Use GetServiceMetricsResp.ProtoReflect.Descriptor instead.

func (*GetServiceMetricsResp) GetMetrics 

func (x *GetServiceMetricsResp) GetMetrics() *ServiceMetrics

func (*GetServiceMetricsResp) ProtoMessage 

func (*GetServiceMetricsResp) ProtoMessage()

func (*GetServiceMetricsResp) ProtoReflect 

func (x *GetServiceMetricsResp) ProtoReflect() protoreflect.Message

func (*GetServiceMetricsResp) Reset 

func (x *GetServiceMetricsResp) Reset()

func (*GetServiceMetricsResp) String 

func (x *GetServiceMetricsResp) String() string

type GetSystemMetricsReq 

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

GetSystemMetricsReq 获取系统指标请求

func (*GetSystemMetricsReq) Descriptor deprecated 

func (*GetSystemMetricsReq) Descriptor() ([]byte, []int)

Deprecated: Use GetSystemMetricsReq.ProtoReflect.Descriptor instead.

func (*GetSystemMetricsReq) ProtoMessage 

func (*GetSystemMetricsReq) ProtoMessage()

func (*GetSystemMetricsReq) ProtoReflect 

func (x *GetSystemMetricsReq) ProtoReflect() protoreflect.Message

func (*GetSystemMetricsReq) Reset 

func (x *GetSystemMetricsReq) Reset()

func (*GetSystemMetricsReq) String 

func (x *GetSystemMetricsReq) String() string

type GetSystemMetricsResp 

type GetSystemMetricsResp struct {
	Metrics *SystemMetrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

GetSystemMetricsResp 获取系统指标响应

func (*GetSystemMetricsResp) Descriptor deprecated 

func (*GetSystemMetricsResp) Descriptor() ([]byte, []int)

Deprecated: Use GetSystemMetricsResp.ProtoReflect.Descriptor instead.

func (*GetSystemMetricsResp) GetMetrics 

func (x *GetSystemMetricsResp) GetMetrics() *SystemMetrics

func (*GetSystemMetricsResp) ProtoMessage 

func (*GetSystemMetricsResp) ProtoMessage()

func (*GetSystemMetricsResp) ProtoReflect 

func (x *GetSystemMetricsResp) ProtoReflect() protoreflect.Message

func (*GetSystemMetricsResp) Reset 

func (x *GetSystemMetricsResp) Reset()

func (*GetSystemMetricsResp) String 

func (x *GetSystemMetricsResp) String() string

type GetTaskStatusReq 

type GetTaskStatusReq struct {
	AgentCode string `protobuf:"bytes,1,opt,name=agent_code,json=agentCode,proto3" json:"agent_code,omitempty"` // Agent标识码
	TaskType  string `protobuf:"bytes,2,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`    // 任务类型（可选，为空则查询所有任务）
	// contains filtered or unexported fields
}

GetTaskStatusReq 查询任务状态请求

func (*GetTaskStatusReq) Descriptor deprecated 

func (*GetTaskStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskStatusReq.ProtoReflect.Descriptor instead.

func (*GetTaskStatusReq) GetAgentCode 

func (x *GetTaskStatusReq) GetAgentCode() string

func (*GetTaskStatusReq) GetTaskType 

func (x *GetTaskStatusReq) GetTaskType() string

func (*GetTaskStatusReq) ProtoMessage 

func (*GetTaskStatusReq) ProtoMessage()

func (*GetTaskStatusReq) ProtoReflect 

func (x *GetTaskStatusReq) ProtoReflect() protoreflect.Message

func (*GetTaskStatusReq) Reset 

func (x *GetTaskStatusReq) Reset()

func (*GetTaskStatusReq) String 

func (x *GetTaskStatusReq) String() string

type GetTaskStatusResp 

type GetTaskStatusResp struct {
	TaskStatuses []*TaskStatusInfo `protobuf:"bytes,1,rep,name=task_statuses,json=taskStatuses,proto3" json:"task_statuses,omitempty"` // 任务状态列表
	// contains filtered or unexported fields
}

GetTaskStatusResp 查询任务状态响应

func (*GetTaskStatusResp) Descriptor deprecated 

func (*GetTaskStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskStatusResp.ProtoReflect.Descriptor instead.

func (*GetTaskStatusResp) GetTaskStatuses 

func (x *GetTaskStatusResp) GetTaskStatuses() []*TaskStatusInfo

func (*GetTaskStatusResp) ProtoMessage 

func (*GetTaskStatusResp) ProtoMessage()

func (*GetTaskStatusResp) ProtoReflect 

func (x *GetTaskStatusResp) ProtoReflect() protoreflect.Message

func (*GetTaskStatusResp) Reset 

func (x *GetTaskStatusResp) Reset()

func (*GetTaskStatusResp) String 

func (x *GetTaskStatusResp) String() string

type GetTasksReq 

type GetTasksReq struct {
	AgentCode   string `protobuf:"bytes,1,opt,name=agent_code,json=agentCode,proto3" json:"agent_code,omitempty"`        // Agent标识码
	LastVersion int64  `protobuf:"varint,2,opt,name=last_version,json=lastVersion,proto3" json:"last_version,omitempty"` // 上次获取的版本号（用于增量更新）
	// contains filtered or unexported fields
}

GetTasksReq 获取任务请求

func (*GetTasksReq) Descriptor deprecated 

func (*GetTasksReq) Descriptor() ([]byte, []int)

Deprecated: Use GetTasksReq.ProtoReflect.Descriptor instead.

func (*GetTasksReq) GetAgentCode 

func (x *GetTasksReq) GetAgentCode() string

func (*GetTasksReq) GetLastVersion 

func (x *GetTasksReq) GetLastVersion() int64

func (*GetTasksReq) ProtoMessage 

func (*GetTasksReq) ProtoMessage()

func (*GetTasksReq) ProtoReflect 

func (x *GetTasksReq) ProtoReflect() protoreflect.Message

func (*GetTasksReq) Reset 

func (x *GetTasksReq) Reset()

func (*GetTasksReq) String 

func (x *GetTasksReq) String() string

type GetTasksResp 

type GetTasksResp struct {
	MonitoringTasks []*MonitoringTask `protobuf:"bytes,1,rep,name=monitoring_tasks,json=monitoringTasks,proto3" json:"monitoring_tasks,omitempty"` // 监控任务列表（新架构）
	Tasks           []*CollectionTask `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`                                            // 采集任务列表（向后兼容，已废弃）
	Version         int64             `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`                                       // 任务版本号
	HasUpdates      bool              `protobuf:"varint,4,opt,name=has_updates,json=hasUpdates,proto3" json:"has_updates,omitempty"`               // 是否有更新
	// contains filtered or unexported fields
}

GetTasksResp 获取任务响应

func (*GetTasksResp) Descriptor deprecated 

func (*GetTasksResp) Descriptor() ([]byte, []int)

Deprecated: Use GetTasksResp.ProtoReflect.Descriptor instead.

func (*GetTasksResp) GetHasUpdates 

func (x *GetTasksResp) GetHasUpdates() bool

func (*GetTasksResp) GetMonitoringTasks 

func (x *GetTasksResp) GetMonitoringTasks() []*MonitoringTask

func (*GetTasksResp) GetTasks 

func (x *GetTasksResp) GetTasks() []*CollectionTask

func (*GetTasksResp) GetVersion 

func (x *GetTasksResp) GetVersion() int64

func (*GetTasksResp) ProtoMessage 

func (*GetTasksResp) ProtoMessage()

func (*GetTasksResp) ProtoReflect 

func (x *GetTasksResp) ProtoReflect() protoreflect.Message

func (*GetTasksResp) Reset 

func (x *GetTasksResp) Reset()

func (*GetTasksResp) String 

func (x *GetTasksResp) String() string

type GetUploadStatusReq 

type GetUploadStatusReq struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

GetUploadStatusReq 获取上传状态请求

func (*GetUploadStatusReq) Descriptor deprecated 

func (*GetUploadStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use GetUploadStatusReq.ProtoReflect.Descriptor instead.

func (*GetUploadStatusReq) GetSessionId 

func (x *GetUploadStatusReq) GetSessionId() string

func (*GetUploadStatusReq) ProtoMessage 

func (*GetUploadStatusReq) ProtoMessage()

func (*GetUploadStatusReq) ProtoReflect 

func (x *GetUploadStatusReq) ProtoReflect() protoreflect.Message

func (*GetUploadStatusReq) Reset 

func (x *GetUploadStatusReq) Reset()

func (*GetUploadStatusReq) String 

func (x *GetUploadStatusReq) String() string

type GetUploadStatusResp 

type GetUploadStatusResp struct {
	SessionId    string  `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Status       string  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // uploading, completed, failed
	TotalSize    int64   `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	ReceivedSize int64   `protobuf:"varint,4,opt,name=received_size,json=receivedSize,proto3" json:"received_size,omitempty"`
	Progress     float64 `protobuf:"fixed64,5,opt,name=progress,proto3" json:"progress,omitempty"` // 0-100
	// contains filtered or unexported fields
}

GetUploadStatusResp 获取上传状态响应

func (*GetUploadStatusResp) Descriptor deprecated 

func (*GetUploadStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use GetUploadStatusResp.ProtoReflect.Descriptor instead.

func (*GetUploadStatusResp) GetProgress 

func (x *GetUploadStatusResp) GetProgress() float64

func (*GetUploadStatusResp) GetReceivedSize 

func (x *GetUploadStatusResp) GetReceivedSize() int64

func (*GetUploadStatusResp) GetSessionId 

func (x *GetUploadStatusResp) GetSessionId() string

func (*GetUploadStatusResp) GetStatus 

func (x *GetUploadStatusResp) GetStatus() string

func (*GetUploadStatusResp) GetTotalSize 

func (x *GetUploadStatusResp) GetTotalSize() int64

func (*GetUploadStatusResp) ProtoMessage 

func (*GetUploadStatusResp) ProtoMessage()

func (*GetUploadStatusResp) ProtoReflect 

func (x *GetUploadStatusResp) ProtoReflect() protoreflect.Message

func (*GetUploadStatusResp) Reset 

func (x *GetUploadStatusResp) Reset()

func (*GetUploadStatusResp) String 

func (x *GetUploadStatusResp) String() string

type HealthClient 

type HealthClient interface {
	// GetHealthStatus 获取指定服务的健康状态
	GetHealthStatus(ctx context.Context, in *GetHealthStatusReq, opts ...grpc.CallOption) (*GetHealthStatusResp, error)
	// ListHealthStatuses 列出所有服务的健康状态
	ListHealthStatuses(ctx context.Context, in *ListHealthStatusesReq, opts ...grpc.CallOption) (*ListHealthStatusesResp, error)
	// GetHealthHistory 获取服务的健康检查历史
	GetHealthHistory(ctx context.Context, in *GetHealthHistoryReq, opts ...grpc.CallOption) (*GetHealthHistoryResp, error)
}

HealthClient is the client API for Health service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Health 服务定义

func NewHealthClient 

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthHistoryEntry 

type HealthHistoryEntry struct {
	Status         HealthStatus           `protobuf:"varint,1,opt,name=status,proto3,enum=pb.HealthStatus" json:"status,omitempty"`
	Message        string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CheckType      string                 `protobuf:"bytes,4,opt,name=check_type,json=checkType,proto3" json:"check_type,omitempty"`
	ResponseTimeMs int64                  `protobuf:"varint,5,opt,name=response_time_ms,json=responseTimeMs,proto3" json:"response_time_ms,omitempty"`
	Error          string                 `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

HealthHistoryEntry 健康检查历史记录

func (*HealthHistoryEntry) Descriptor deprecated 

func (*HealthHistoryEntry) Descriptor() ([]byte, []int)

Deprecated: Use HealthHistoryEntry.ProtoReflect.Descriptor instead.

func (*HealthHistoryEntry) GetCheckType 

func (x *HealthHistoryEntry) GetCheckType() string

func (*HealthHistoryEntry) GetError 

func (x *HealthHistoryEntry) GetError() string

func (*HealthHistoryEntry) GetMessage 

func (x *HealthHistoryEntry) GetMessage() string

func (*HealthHistoryEntry) GetResponseTimeMs 

func (x *HealthHistoryEntry) GetResponseTimeMs() int64

func (*HealthHistoryEntry) GetStatus 

func (x *HealthHistoryEntry) GetStatus() HealthStatus

func (*HealthHistoryEntry) GetTimestamp 

func (x *HealthHistoryEntry) GetTimestamp() *timestamppb.Timestamp

func (*HealthHistoryEntry) ProtoMessage 

func (*HealthHistoryEntry) ProtoMessage()

func (*HealthHistoryEntry) ProtoReflect 

func (x *HealthHistoryEntry) ProtoReflect() protoreflect.Message

func (*HealthHistoryEntry) Reset 

func (x *HealthHistoryEntry) Reset()

func (*HealthHistoryEntry) String 

func (x *HealthHistoryEntry) String() string

type HealthServer 

type HealthServer interface {
	// GetHealthStatus 获取指定服务的健康状态
	GetHealthStatus(context.Context, *GetHealthStatusReq) (*GetHealthStatusResp, error)
	// ListHealthStatuses 列出所有服务的健康状态
	ListHealthStatuses(context.Context, *ListHealthStatusesReq) (*ListHealthStatusesResp, error)
	// GetHealthHistory 获取服务的健康检查历史
	GetHealthHistory(context.Context, *GetHealthHistoryReq) (*GetHealthHistoryResp, error)
	// contains filtered or unexported methods
}

HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility.

Health 服务定义

type HealthStatus 

type HealthStatus int32

HealthStatus 健康状态枚举 

const (
	HealthStatus_HEALTH_STATUS_UNKNOWN   HealthStatus = 0
	HealthStatus_HEALTH_STATUS_HEALTHY   HealthStatus = 1
	HealthStatus_HEALTH_STATUS_UNHEALTHY HealthStatus = 2
	HealthStatus_HEALTH_STATUS_DEGRADED  HealthStatus = 3
)

func (HealthStatus) Descriptor 

func (HealthStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthStatus) Enum 

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated 

func (HealthStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number 

func (x HealthStatus) Number() protoreflect.EnumNumber

func (HealthStatus) String 

func (x HealthStatus) String() string

func (HealthStatus) Type 

func (HealthStatus) Type() protoreflect.EnumType

type HealthStatusDetail 

type HealthStatusDetail struct {
	Status         HealthStatus           `protobuf:"varint,1,opt,name=status,proto3,enum=pb.HealthStatus" json:"status,omitempty"`
	Message        string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	LastCheck      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_check,json=lastCheck,proto3" json:"last_check,omitempty"`
	CheckType      string                 `protobuf:"bytes,4,opt,name=check_type,json=checkType,proto3" json:"check_type,omitempty"`
	ResponseTimeMs int64                  `protobuf:"varint,5,opt,name=response_time_ms,json=responseTimeMs,proto3" json:"response_time_ms,omitempty"`
	Error          string                 `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

HealthStatusDetail 健康状态详情

func (*HealthStatusDetail) Descriptor deprecated 

func (*HealthStatusDetail) Descriptor() ([]byte, []int)

Deprecated: Use HealthStatusDetail.ProtoReflect.Descriptor instead.

func (*HealthStatusDetail) GetCheckType 

func (x *HealthStatusDetail) GetCheckType() string

func (*HealthStatusDetail) GetError 

func (x *HealthStatusDetail) GetError() string

func (*HealthStatusDetail) GetLastCheck 

func (x *HealthStatusDetail) GetLastCheck() *timestamppb.Timestamp

func (*HealthStatusDetail) GetMessage 

func (x *HealthStatusDetail) GetMessage() string

func (*HealthStatusDetail) GetResponseTimeMs 

func (x *HealthStatusDetail) GetResponseTimeMs() int64

func (*HealthStatusDetail) GetStatus 

func (x *HealthStatusDetail) GetStatus() HealthStatus

func (*HealthStatusDetail) ProtoMessage 

func (*HealthStatusDetail) ProtoMessage()

func (*HealthStatusDetail) ProtoReflect 

func (x *HealthStatusDetail) ProtoReflect() protoreflect.Message

func (*HealthStatusDetail) Reset 

func (x *HealthStatusDetail) Reset()

func (*HealthStatusDetail) String 

func (x *HealthStatusDetail) String() string

type ListConfigReq 

type ListConfigReq struct {
	Package  string       `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`                     // 服务包名称
	ConfName string       `protobuf:"bytes,2,opt,name=confName,proto3" json:"confName,omitempty"`                   // 配置文件名称
	Format   OutputFormat `protobuf:"varint,3,opt,name=format,proto3,enum=pb.OutputFormat" json:"format,omitempty"` // 输出格式
	// contains filtered or unexported fields
}

func (*ListConfigReq) Descriptor deprecated 

func (*ListConfigReq) Descriptor() ([]byte, []int)

Deprecated: Use ListConfigReq.ProtoReflect.Descriptor instead.

func (*ListConfigReq) GetConfName 

func (x *ListConfigReq) GetConfName() string

func (*ListConfigReq) GetFormat 

func (x *ListConfigReq) GetFormat() OutputFormat

func (*ListConfigReq) GetPackage 

func (x *ListConfigReq) GetPackage() string

func (*ListConfigReq) ProtoMessage 

func (*ListConfigReq) ProtoMessage()

func (*ListConfigReq) ProtoReflect 

func (x *ListConfigReq) ProtoReflect() protoreflect.Message

func (*ListConfigReq) Reset 

func (x *ListConfigReq) Reset()

func (*ListConfigReq) String 

func (x *ListConfigReq) String() string

type ListFilesReq 

type ListFilesReq struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // 目录路径
	// contains filtered or unexported fields
}

ListFilesReq 列出文件请求

func (*ListFilesReq) Descriptor deprecated 

func (*ListFilesReq) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesReq.ProtoReflect.Descriptor instead.

func (*ListFilesReq) GetPath 

func (x *ListFilesReq) GetPath() string

func (*ListFilesReq) ProtoMessage 

func (*ListFilesReq) ProtoMessage()

func (*ListFilesReq) ProtoReflect 

func (x *ListFilesReq) ProtoReflect() protoreflect.Message

func (*ListFilesReq) Reset 

func (x *ListFilesReq) Reset()

func (*ListFilesReq) String 

func (x *ListFilesReq) String() string

type ListFilesResp 

type ListFilesResp struct {
	Path  string      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Files []*FileInfo `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

ListFilesResp 列出文件响应

func (*ListFilesResp) Descriptor deprecated 

func (*ListFilesResp) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesResp.ProtoReflect.Descriptor instead.

func (*ListFilesResp) GetFiles 

func (x *ListFilesResp) GetFiles() []*FileInfo

func (*ListFilesResp) GetPath 

func (x *ListFilesResp) GetPath() string

func (*ListFilesResp) ProtoMessage 

func (*ListFilesResp) ProtoMessage()

func (*ListFilesResp) ProtoReflect 

func (x *ListFilesResp) ProtoReflect() protoreflect.Message

func (*ListFilesResp) Reset 

func (x *ListFilesResp) Reset()

func (*ListFilesResp) String 

func (x *ListFilesResp) String() string

type ListHealthStatusesReq 

type ListHealthStatusesReq struct {

	// 可选：只返回指定状态的服务
	FilterStatus []HealthStatus `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

ListHealthStatusesReq 列出所有健康状态请求

func (*ListHealthStatusesReq) Descriptor deprecated 

func (*ListHealthStatusesReq) Descriptor() ([]byte, []int)

Deprecated: Use ListHealthStatusesReq.ProtoReflect.Descriptor instead.

func (*ListHealthStatusesReq) GetFilterStatus 

func (x *ListHealthStatusesReq) GetFilterStatus() []HealthStatus

func (*ListHealthStatusesReq) ProtoMessage 

func (*ListHealthStatusesReq) ProtoMessage()

func (*ListHealthStatusesReq) ProtoReflect 

func (x *ListHealthStatusesReq) ProtoReflect() protoreflect.Message

func (*ListHealthStatusesReq) Reset 

func (x *ListHealthStatusesReq) Reset()

func (*ListHealthStatusesReq) String 

func (x *ListHealthStatusesReq) String() string

type ListHealthStatusesResp 

type ListHealthStatusesResp struct {
	HealthStatuses []*ServiceHealth `protobuf:"bytes,1,rep,name=health_statuses,json=healthStatuses,proto3" json:"health_statuses,omitempty"`
	// contains filtered or unexported fields
}

ListHealthStatusesResp 列出所有健康状态响应

func (*ListHealthStatusesResp) Descriptor deprecated 

func (*ListHealthStatusesResp) Descriptor() ([]byte, []int)

Deprecated: Use ListHealthStatusesResp.ProtoReflect.Descriptor instead.

func (*ListHealthStatusesResp) GetHealthStatuses 

func (x *ListHealthStatusesResp) GetHealthStatuses() []*ServiceHealth

func (*ListHealthStatusesResp) ProtoMessage 

func (*ListHealthStatusesResp) ProtoMessage()

func (*ListHealthStatusesResp) ProtoReflect 

func (x *ListHealthStatusesResp) ProtoReflect() protoreflect.Message

func (*ListHealthStatusesResp) Reset 

func (x *ListHealthStatusesResp) Reset()

func (*ListHealthStatusesResp) String 

func (x *ListHealthStatusesResp) String() string

type ListServiceMetricsReq 

type ListServiceMetricsReq struct {

	// 可选：只返回运行中的服务
	RunningOnly bool `protobuf:"varint,1,opt,name=running_only,json=runningOnly,proto3" json:"running_only,omitempty"`
	// contains filtered or unexported fields
}

ListServiceMetricsReq 列出所有服务指标请求

func (*ListServiceMetricsReq) Descriptor deprecated 

func (*ListServiceMetricsReq) Descriptor() ([]byte, []int)

Deprecated: Use ListServiceMetricsReq.ProtoReflect.Descriptor instead.

func (*ListServiceMetricsReq) GetRunningOnly 

func (x *ListServiceMetricsReq) GetRunningOnly() bool

func (*ListServiceMetricsReq) ProtoMessage 

func (*ListServiceMetricsReq) ProtoMessage()

func (*ListServiceMetricsReq) ProtoReflect 

func (x *ListServiceMetricsReq) ProtoReflect() protoreflect.Message

func (*ListServiceMetricsReq) Reset 

func (x *ListServiceMetricsReq) Reset()

func (*ListServiceMetricsReq) String 

func (x *ListServiceMetricsReq) String() string

type ListServiceMetricsResp 

type ListServiceMetricsResp struct {
	Metrics []*ServiceMetrics `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

ListServiceMetricsResp 列出所有服务指标响应

func (*ListServiceMetricsResp) Descriptor deprecated 

func (*ListServiceMetricsResp) Descriptor() ([]byte, []int)

Deprecated: Use ListServiceMetricsResp.ProtoReflect.Descriptor instead.

func (*ListServiceMetricsResp) GetMetrics 

func (x *ListServiceMetricsResp) GetMetrics() []*ServiceMetrics

func (*ListServiceMetricsResp) ProtoMessage 

func (*ListServiceMetricsResp) ProtoMessage()

func (*ListServiceMetricsResp) ProtoReflect 

func (x *ListServiceMetricsResp) ProtoReflect() protoreflect.Message

func (*ListServiceMetricsResp) Reset 

func (x *ListServiceMetricsResp) Reset()

func (*ListServiceMetricsResp) String 

func (x *ListServiceMetricsResp) String() string

type LuaClient 

type LuaClient interface {
	ExecLuaScript(ctx context.Context, in *ExecLuaScriptReq, opts ...grpc.CallOption) (*ExecLuaScriptResp, error)
}

LuaClient is the client API for Lua service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLuaClient 

func NewLuaClient(cc grpc.ClientConnInterface) LuaClient

type LuaServer 

type LuaServer interface {
	ExecLuaScript(context.Context, *ExecLuaScriptReq) (*ExecLuaScriptResp, error)
	// contains filtered or unexported methods
}

LuaServer is the server API for Lua service. All implementations must embed UnimplementedLuaServer for forward compatibility.

type MetricsClient 

type MetricsClient interface {
	// GetSystemMetrics 获取系统指标
	GetSystemMetrics(ctx context.Context, in *GetSystemMetricsReq, opts ...grpc.CallOption) (*GetSystemMetricsResp, error)
	// GetServiceMetrics 获取指定服务的指标
	GetServiceMetrics(ctx context.Context, in *GetServiceMetricsReq, opts ...grpc.CallOption) (*GetServiceMetricsResp, error)
	// ListServiceMetrics 列出所有服务的指标
	ListServiceMetrics(ctx context.Context, in *ListServiceMetricsReq, opts ...grpc.CallOption) (*ListServiceMetricsResp, error)
	// GetApplicationMetrics 获取应用指标
	GetApplicationMetrics(ctx context.Context, in *GetApplicationMetricsReq, opts ...grpc.CallOption) (*GetApplicationMetricsResp, error)
	// GetMetricsHistory 获取指标历史数据
	GetMetricsHistory(ctx context.Context, in *GetMetricsHistoryReq, opts ...grpc.CallOption) (*GetMetricsHistoryResp, error)
}

MetricsClient is the client API for Metrics service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Metrics 服务定义

func NewMetricsClient 

func NewMetricsClient(cc grpc.ClientConnInterface) MetricsClient

type MetricsHistoryPoint 

type MetricsHistoryPoint struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metrics   map[string]string      `` // 指标数据（JSON 字符串格式）
	/* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

MetricsHistoryPoint 指标历史数据点

func (*MetricsHistoryPoint) Descriptor deprecated 

func (*MetricsHistoryPoint) Descriptor() ([]byte, []int)

Deprecated: Use MetricsHistoryPoint.ProtoReflect.Descriptor instead.

func (*MetricsHistoryPoint) GetMetrics 

func (x *MetricsHistoryPoint) GetMetrics() map[string]string

func (*MetricsHistoryPoint) GetTimestamp 

func (x *MetricsHistoryPoint) GetTimestamp() *timestamppb.Timestamp

func (*MetricsHistoryPoint) ProtoMessage 

func (*MetricsHistoryPoint) ProtoMessage()

func (*MetricsHistoryPoint) ProtoReflect 

func (x *MetricsHistoryPoint) ProtoReflect() protoreflect.Message

func (*MetricsHistoryPoint) Reset 

func (x *MetricsHistoryPoint) Reset()

func (*MetricsHistoryPoint) String 

func (x *MetricsHistoryPoint) String() string

type MetricsServer 

type MetricsServer interface {
	// GetSystemMetrics 获取系统指标
	GetSystemMetrics(context.Context, *GetSystemMetricsReq) (*GetSystemMetricsResp, error)
	// GetServiceMetrics 获取指定服务的指标
	GetServiceMetrics(context.Context, *GetServiceMetricsReq) (*GetServiceMetricsResp, error)
	// ListServiceMetrics 列出所有服务的指标
	ListServiceMetrics(context.Context, *ListServiceMetricsReq) (*ListServiceMetricsResp, error)
	// GetApplicationMetrics 获取应用指标
	GetApplicationMetrics(context.Context, *GetApplicationMetricsReq) (*GetApplicationMetricsResp, error)
	// GetMetricsHistory 获取指标历史数据
	GetMetricsHistory(context.Context, *GetMetricsHistoryReq) (*GetMetricsHistoryResp, error)
	// contains filtered or unexported methods
}

MetricsServer is the server API for Metrics service. All implementations must embed UnimplementedMetricsServer for forward compatibility.

Metrics 服务定义

type MonitoringTask 

type MonitoringTask struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                       // 任务ID
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                   // 任务名称
	Description string                 `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`                     // 任务描述
	StrategyId  string                 `protobuf:"bytes,4,opt,name=strategy_id,json=strategyId,proto3" json:"strategy_id,omitempty"`     // 关联的策略ID
	AgentCode   string                 `protobuf:"bytes,5,opt,name=agent_code,json=agentCode,proto3" json:"agent_code,omitempty"`        // 关联的Agent
	TargetIds   []string               `protobuf:"bytes,6,rep,name=target_ids,json=targetIds,proto3" json:"target_ids,omitempty"`        // 监控目标ID列表
	OutputType  string                 `protobuf:"bytes,7,opt,name=output_type,json=outputType,proto3" json:"output_type,omitempty"`     // 输出类型（prometheus/loki等）
	Status      string                 `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`                               // 任务状态（created/published/active/paused/stopped/revoked）
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`        // 创建时间
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`       // 更新时间
	PublishedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=published_at,json=publishedAt,proto3" json:"published_at,omitempty"` // 发布时间（可选）
	RevokedAt   *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=revoked_at,json=revokedAt,proto3" json:"revoked_at,omitempty"`       // 撤回时间（可选）
	// contains filtered or unexported fields
}

MonitoringTask 监控任务（新架构）

func (*MonitoringTask) Descriptor deprecated 

func (*MonitoringTask) Descriptor() ([]byte, []int)

Deprecated: Use MonitoringTask.ProtoReflect.Descriptor instead.

func (*MonitoringTask) GetAgentCode 

func (x *MonitoringTask) GetAgentCode() string

func (*MonitoringTask) GetCreatedAt 

func (x *MonitoringTask) GetCreatedAt() *timestamppb.Timestamp

func (*MonitoringTask) GetDescription 

func (x *MonitoringTask) GetDescription() string

func (*MonitoringTask) GetId 

func (x *MonitoringTask) GetId() string

func (*MonitoringTask) GetName 

func (x *MonitoringTask) GetName() string

func (*MonitoringTask) GetOutputType 

func (x *MonitoringTask) GetOutputType() string

func (*MonitoringTask) GetPublishedAt 

func (x *MonitoringTask) GetPublishedAt() *timestamppb.Timestamp

func (*MonitoringTask) GetRevokedAt 

func (x *MonitoringTask) GetRevokedAt() *timestamppb.Timestamp

func (*MonitoringTask) GetStatus 

func (x *MonitoringTask) GetStatus() string

func (*MonitoringTask) GetStrategyId 

func (x *MonitoringTask) GetStrategyId() string

func (*MonitoringTask) GetTargetIds 

func (x *MonitoringTask) GetTargetIds() []string

func (*MonitoringTask) GetUpdatedAt 

func (x *MonitoringTask) GetUpdatedAt() *timestamppb.Timestamp

func (*MonitoringTask) ProtoMessage 

func (*MonitoringTask) ProtoMessage()

func (*MonitoringTask) ProtoReflect 

func (x *MonitoringTask) ProtoReflect() protoreflect.Message

func (*MonitoringTask) Reset 

func (x *MonitoringTask) Reset()

func (*MonitoringTask) String 

func (x *MonitoringTask) String() string

type NetworkInterface 

type NetworkInterface struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                       // 接口名称
	RxBytes int64  `protobuf:"varint,2,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"` // 接收字节数
	TxBytes int64  `protobuf:"varint,3,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"` // 发送字节数
	// contains filtered or unexported fields
}

NetworkInterface 网络接口信息

func (*NetworkInterface) Descriptor deprecated 

func (*NetworkInterface) Descriptor() ([]byte, []int)

Deprecated: Use NetworkInterface.ProtoReflect.Descriptor instead.

func (*NetworkInterface) GetName 

func (x *NetworkInterface) GetName() string

func (*NetworkInterface) GetRxBytes 

func (x *NetworkInterface) GetRxBytes() int64

func (*NetworkInterface) GetTxBytes 

func (x *NetworkInterface) GetTxBytes() int64

func (*NetworkInterface) ProtoMessage 

func (*NetworkInterface) ProtoMessage()

func (*NetworkInterface) ProtoReflect 

func (x *NetworkInterface) ProtoReflect() protoreflect.Message

func (*NetworkInterface) Reset 

func (x *NetworkInterface) Reset()

func (*NetworkInterface) String 

func (x *NetworkInterface) String() string

type OutputFormat 

type OutputFormat int32
const (
	OutputFormat_JSON OutputFormat = 0
	OutputFormat_YAML OutputFormat = 1
	OutputFormat_TOML OutputFormat = 2
)

func (OutputFormat) Descriptor 

func (OutputFormat) Descriptor() protoreflect.EnumDescriptor

func (OutputFormat) Enum 

func (x OutputFormat) Enum() *OutputFormat

func (OutputFormat) EnumDescriptor deprecated 

func (OutputFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use OutputFormat.Descriptor instead.

func (OutputFormat) Number 

func (x OutputFormat) Number() protoreflect.EnumNumber

func (OutputFormat) String 

func (x OutputFormat) String() string

func (OutputFormat) Type 

func (OutputFormat) Type() protoreflect.EnumType

type OutputRule 

type OutputRule struct {
	Rule map[string]string `` // 规则键值对
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

OutputRule 输出规则

func (*OutputRule) Descriptor deprecated 

func (*OutputRule) Descriptor() ([]byte, []int)

Deprecated: Use OutputRule.ProtoReflect.Descriptor instead.

func (*OutputRule) GetRule 

func (x *OutputRule) GetRule() map[string]string

func (*OutputRule) ProtoMessage 

func (*OutputRule) ProtoMessage()

func (*OutputRule) ProtoReflect 

func (x *OutputRule) ProtoReflect() protoreflect.Message

func (*OutputRule) Reset 

func (x *OutputRule) Reset()

func (*OutputRule) String 

func (x *OutputRule) String() string

type PackItem 

type PackItem struct {
	Package         string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	IsRunning       bool   `protobuf:"varint,2,opt,name=isRunning,proto3" json:"isRunning,omitempty"`
	Schema          string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Version         string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	RunningDuration int64  `protobuf:"varint,5,opt,name=running_duration,json=runningDuration,proto3" json:"running_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*PackItem) Descriptor deprecated 

func (*PackItem) Descriptor() ([]byte, []int)

Deprecated: Use PackItem.ProtoReflect.Descriptor instead.

func (*PackItem) GetIsRunning 

func (x *PackItem) GetIsRunning() bool

func (*PackItem) GetPackage 

func (x *PackItem) GetPackage() string

func (*PackItem) GetRunningDuration 

func (x *PackItem) GetRunningDuration() int64

func (*PackItem) GetSchema 

func (x *PackItem) GetSchema() string

func (*PackItem) GetVersion 

func (x *PackItem) GetVersion() string

func (*PackItem) ProtoMessage 

func (*PackItem) ProtoMessage()

func (*PackItem) ProtoReflect 

func (x *PackItem) ProtoReflect() protoreflect.Message

func (*PackItem) Reset 

func (x *PackItem) Reset()

func (*PackItem) String 

func (x *PackItem) String() string

type PackageClient 

type PackageClient interface {
	Start(ctx context.Context, in *StartReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *StopReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Restart(ctx context.Context, in *RestartReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PackageList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PackageListResp, error)
	GetConfigs(ctx context.Context, in *GetConfigsReq, opts ...grpc.CallOption) (*GetConfigsResp, error)
	ApplyConfigs(ctx context.Context, in *ApplyConfigsReq, opts ...grpc.CallOption) (*ApplyConfigsResp, error)
	GetRecentLogs(ctx context.Context, in *GetRecentLogsReq, opts ...grpc.CallOption) (*GetRecentLogsResp, error)
	StreamLogs(ctx context.Context, in *StreamLogsReq, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamLogsResp], error)
	QueryLogs(ctx context.Context, in *QueryLogsReq, opts ...grpc.CallOption) (*QueryLogsResp, error)
}

PackageClient is the client API for Package service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

服务定义

func NewPackageClient 

func NewPackageClient(cc grpc.ClientConnInterface) PackageClient

type PackageListResp 

type PackageListResp struct {
	AgentCode string      `protobuf:"bytes,1,opt,name=agentCode,proto3" json:"agentCode,omitempty"`
	Packages  []*PackItem `protobuf:"bytes,2,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageListResp) Descriptor deprecated 

func (*PackageListResp) Descriptor() ([]byte, []int)

Deprecated: Use PackageListResp.ProtoReflect.Descriptor instead.

func (*PackageListResp) GetAgentCode 

func (x *PackageListResp) GetAgentCode() string

func (*PackageListResp) GetPackages 

func (x *PackageListResp) GetPackages() []*PackItem

func (*PackageListResp) ProtoMessage 

func (*PackageListResp) ProtoMessage()

func (*PackageListResp) ProtoReflect 

func (x *PackageListResp) ProtoReflect() protoreflect.Message

func (*PackageListResp) Reset 

func (x *PackageListResp) Reset()

func (*PackageListResp) String 

func (x *PackageListResp) String() string

type PackageServer 

type PackageServer interface {
	Start(context.Context, *StartReq) (*emptypb.Empty, error)
	Stop(context.Context, *StopReq) (*emptypb.Empty, error)
	Restart(context.Context, *RestartReq) (*emptypb.Empty, error)
	PackageList(context.Context, *emptypb.Empty) (*PackageListResp, error)
	GetConfigs(context.Context, *GetConfigsReq) (*GetConfigsResp, error)
	ApplyConfigs(context.Context, *ApplyConfigsReq) (*ApplyConfigsResp, error)
	GetRecentLogs(context.Context, *GetRecentLogsReq) (*GetRecentLogsResp, error)
	StreamLogs(*StreamLogsReq, grpc.ServerStreamingServer[StreamLogsResp]) error
	QueryLogs(context.Context, *QueryLogsReq) (*QueryLogsResp, error)
	// contains filtered or unexported methods
}

PackageServer is the server API for Package service. All implementations must embed UnimplementedPackageServer for forward compatibility.

服务定义

type Package_StreamLogsClient 

type Package_StreamLogsClient = grpc.ServerStreamingClient[StreamLogsResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Package_StreamLogsServer 

type Package_StreamLogsServer = grpc.ServerStreamingServer[StreamLogsResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProcessingRule 

type ProcessingRule struct {
	Rule map[string]string `` // 规则键值对
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

ProcessingRule 处理规则

func (*ProcessingRule) Descriptor deprecated 

func (*ProcessingRule) Descriptor() ([]byte, []int)

Deprecated: Use ProcessingRule.ProtoReflect.Descriptor instead.

func (*ProcessingRule) GetRule 

func (x *ProcessingRule) GetRule() map[string]string

func (*ProcessingRule) ProtoMessage 

func (*ProcessingRule) ProtoMessage()

func (*ProcessingRule) ProtoReflect 

func (x *ProcessingRule) ProtoReflect() protoreflect.Message

func (*ProcessingRule) Reset 

func (x *ProcessingRule) Reset()

func (*ProcessingRule) String 

func (x *ProcessingRule) String() string

type QueryLogsReq 

type QueryLogsReq struct {
	Package   string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	Keyword   string `protobuf:"bytes,2,opt,name=keyword,proto3" json:"keyword,omitempty"`                       // 搜索关键词（可选）
	Level     string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`                           // 日志级别过滤（可选，如 "error", "warn", "info"）
	StartTime int64  `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // 开始时间戳（Unix 时间戳，秒）
	EndTime   int64  `protobuf:"varint,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`       // 结束时间戳（Unix 时间戳，秒）
	Limit     int32  `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`                          // 返回的最大行数
	Offset    int32  `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`                        // 偏移量（用于分页）
	Reverse   bool   `protobuf:"varint,8,opt,name=reverse,proto3" json:"reverse,omitempty"`                      // 是否反向排序（true 表示从新到旧）
	// contains filtered or unexported fields
}

func (*QueryLogsReq) Descriptor deprecated 

func (*QueryLogsReq) Descriptor() ([]byte, []int)

Deprecated: Use QueryLogsReq.ProtoReflect.Descriptor instead.

func (*QueryLogsReq) GetEndTime 

func (x *QueryLogsReq) GetEndTime() int64

func (*QueryLogsReq) GetKeyword 

func (x *QueryLogsReq) GetKeyword() string

func (*QueryLogsReq) GetLevel 

func (x *QueryLogsReq) GetLevel() string

func (*QueryLogsReq) GetLimit 

func (x *QueryLogsReq) GetLimit() int32

func (*QueryLogsReq) GetOffset 

func (x *QueryLogsReq) GetOffset() int32

func (*QueryLogsReq) GetPackage 

func (x *QueryLogsReq) GetPackage() string

func (*QueryLogsReq) GetReverse 

func (x *QueryLogsReq) GetReverse() bool

func (*QueryLogsReq) GetStartTime 

func (x *QueryLogsReq) GetStartTime() int64

func (*QueryLogsReq) ProtoMessage 

func (*QueryLogsReq) ProtoMessage()

func (*QueryLogsReq) ProtoReflect 

func (x *QueryLogsReq) ProtoReflect() protoreflect.Message

func (*QueryLogsReq) Reset 

func (x *QueryLogsReq) Reset()

func (*QueryLogsReq) String 

func (x *QueryLogsReq) String() string

type QueryLogsResp 

type QueryLogsResp struct {
	Logs    []string `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	Total   int32    `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`                    // 总行数（匹配条件的）
	HasMore bool     `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"` // 是否还有更多结果
	// contains filtered or unexported fields
}

func (*QueryLogsResp) Descriptor deprecated 

func (*QueryLogsResp) Descriptor() ([]byte, []int)

Deprecated: Use QueryLogsResp.ProtoReflect.Descriptor instead.

func (*QueryLogsResp) GetHasMore 

func (x *QueryLogsResp) GetHasMore() bool

func (*QueryLogsResp) GetLogs 

func (x *QueryLogsResp) GetLogs() []string

func (*QueryLogsResp) GetTotal 

func (x *QueryLogsResp) GetTotal() int32

func (*QueryLogsResp) ProtoMessage 

func (*QueryLogsResp) ProtoMessage()

func (*QueryLogsResp) ProtoReflect 

func (x *QueryLogsResp) ProtoReflect() protoreflect.Message

func (*QueryLogsResp) Reset 

func (x *QueryLogsResp) Reset()

func (*QueryLogsResp) String 

func (x *QueryLogsResp) String() string

type RestartReq 

type RestartReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartReq) Descriptor deprecated 

func (*RestartReq) Descriptor() ([]byte, []int)

Deprecated: Use RestartReq.ProtoReflect.Descriptor instead.

func (*RestartReq) GetPackage 

func (x *RestartReq) GetPackage() string

func (*RestartReq) ProtoMessage 

func (*RestartReq) ProtoMessage()

func (*RestartReq) ProtoReflect 

func (x *RestartReq) ProtoReflect() protoreflect.Message

func (*RestartReq) Reset 

func (x *RestartReq) Reset()

func (*RestartReq) String 

func (x *RestartReq) String() string

type ServiceHealth 

type ServiceHealth struct {
	Package   string                 `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	Status    HealthStatus           `protobuf:"varint,2,opt,name=status,proto3,enum=pb.HealthStatus" json:"status,omitempty"`
	LastCheck *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_check,json=lastCheck,proto3" json:"last_check,omitempty"`
	Message   string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Details   []*HealthStatusDetail  `protobuf:"bytes,5,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

ServiceHealth 服务健康状态

func (*ServiceHealth) Descriptor deprecated 

func (*ServiceHealth) Descriptor() ([]byte, []int)

Deprecated: Use ServiceHealth.ProtoReflect.Descriptor instead.

func (*ServiceHealth) GetDetails 

func (x *ServiceHealth) GetDetails() []*HealthStatusDetail

func (*ServiceHealth) GetLastCheck 

func (x *ServiceHealth) GetLastCheck() *timestamppb.Timestamp

func (*ServiceHealth) GetMessage 

func (x *ServiceHealth) GetMessage() string

func (*ServiceHealth) GetPackage 

func (x *ServiceHealth) GetPackage() string

func (*ServiceHealth) GetStatus 

func (x *ServiceHealth) GetStatus() HealthStatus

func (*ServiceHealth) ProtoMessage 

func (*ServiceHealth) ProtoMessage()

func (*ServiceHealth) ProtoReflect 

func (x *ServiceHealth) ProtoReflect() protoreflect.Message

func (*ServiceHealth) Reset 

func (x *ServiceHealth) Reset()

func (*ServiceHealth) String 

func (x *ServiceHealth) String() string

type ServiceMetrics 

type ServiceMetrics struct {
	Package        string                 `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	CpuUsage       float64                `protobuf:"fixed64,2,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`                     // CPU 使用率（百分比）
	MemoryUsage    float64                `protobuf:"fixed64,3,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`            // 内存使用率（百分比）
	MemoryBytes    int64                  `protobuf:"varint,4,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`             // 内存使用量（字节）
	DiskUsage      float64                `protobuf:"fixed64,5,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`                  // 磁盘使用率（百分比）
	NetworkIn      int64                  `protobuf:"varint,6,opt,name=network_in,json=networkIn,proto3" json:"network_in,omitempty"`                   // 网络入流量（字节）
	NetworkOut     int64                  `protobuf:"varint,7,opt,name=network_out,json=networkOut,proto3" json:"network_out,omitempty"`                // 网络出流量（字节）
	RequestCount   int64                  `protobuf:"varint,8,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`          // 请求数
	ErrorCount     int64                  `protobuf:"varint,9,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`                // 错误数
	ResponseTimeMs int64                  `protobuf:"varint,10,opt,name=response_time_ms,json=responseTimeMs,proto3" json:"response_time_ms,omitempty"` // 响应时间（毫秒）
	LastUpdated    *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

ServiceMetrics 服务指标

func (*ServiceMetrics) Descriptor deprecated 

func (*ServiceMetrics) Descriptor() ([]byte, []int)

Deprecated: Use ServiceMetrics.ProtoReflect.Descriptor instead.

func (*ServiceMetrics) GetCpuUsage 

func (x *ServiceMetrics) GetCpuUsage() float64

func (*ServiceMetrics) GetDiskUsage 

func (x *ServiceMetrics) GetDiskUsage() float64

func (*ServiceMetrics) GetErrorCount 

func (x *ServiceMetrics) GetErrorCount() int64

func (*ServiceMetrics) GetLastUpdated 

func (x *ServiceMetrics) GetLastUpdated() *timestamppb.Timestamp

func (*ServiceMetrics) GetMemoryBytes 

func (x *ServiceMetrics) GetMemoryBytes() int64

func (*ServiceMetrics) GetMemoryUsage 

func (x *ServiceMetrics) GetMemoryUsage() float64

func (*ServiceMetrics) GetNetworkIn 

func (x *ServiceMetrics) GetNetworkIn() int64

func (*ServiceMetrics) GetNetworkOut 

func (x *ServiceMetrics) GetNetworkOut() int64

func (*ServiceMetrics) GetPackage 

func (x *ServiceMetrics) GetPackage() string

func (*ServiceMetrics) GetRequestCount 

func (x *ServiceMetrics) GetRequestCount() int64

func (*ServiceMetrics) GetResponseTimeMs 

func (x *ServiceMetrics) GetResponseTimeMs() int64

func (*ServiceMetrics) ProtoMessage 

func (*ServiceMetrics) ProtoMessage()

func (*ServiceMetrics) ProtoReflect 

func (x *ServiceMetrics) ProtoReflect() protoreflect.Message

func (*ServiceMetrics) Reset 

func (x *ServiceMetrics) Reset()

func (*ServiceMetrics) String 

func (x *ServiceMetrics) String() string

type StartFileUploadReq 

type StartFileUploadReq struct {
	FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	FileSize int64  `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Md5      string `protobuf:"bytes,3,opt,name=md5,proto3" json:"md5,omitempty"`
	Sha256   string `protobuf:"bytes,4,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

StartFileUploadReq 开始文件上传请求

func (*StartFileUploadReq) Descriptor deprecated 

func (*StartFileUploadReq) Descriptor() ([]byte, []int)

Deprecated: Use StartFileUploadReq.ProtoReflect.Descriptor instead.

func (*StartFileUploadReq) GetFilePath 

func (x *StartFileUploadReq) GetFilePath() string

func (*StartFileUploadReq) GetFileSize 

func (x *StartFileUploadReq) GetFileSize() int64

func (*StartFileUploadReq) GetMd5 

func (x *StartFileUploadReq) GetMd5() string

func (*StartFileUploadReq) GetSha256 

func (x *StartFileUploadReq) GetSha256() string

func (*StartFileUploadReq) ProtoMessage 

func (*StartFileUploadReq) ProtoMessage()

func (*StartFileUploadReq) ProtoReflect 

func (x *StartFileUploadReq) ProtoReflect() protoreflect.Message

func (*StartFileUploadReq) Reset 

func (x *StartFileUploadReq) Reset()

func (*StartFileUploadReq) String 

func (x *StartFileUploadReq) String() string

type StartFileUploadResp 

type StartFileUploadResp struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	FilePath  string `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	ChunkSize int64  `protobuf:"varint,3,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// contains filtered or unexported fields
}

StartFileUploadResp 开始文件上传响应

func (*StartFileUploadResp) Descriptor deprecated 

func (*StartFileUploadResp) Descriptor() ([]byte, []int)

Deprecated: Use StartFileUploadResp.ProtoReflect.Descriptor instead.

func (*StartFileUploadResp) GetChunkSize 

func (x *StartFileUploadResp) GetChunkSize() int64

func (*StartFileUploadResp) GetFilePath 

func (x *StartFileUploadResp) GetFilePath() string

func (*StartFileUploadResp) GetSessionId 

func (x *StartFileUploadResp) GetSessionId() string

func (*StartFileUploadResp) ProtoMessage 

func (*StartFileUploadResp) ProtoMessage()

func (*StartFileUploadResp) ProtoReflect 

func (x *StartFileUploadResp) ProtoReflect() protoreflect.Message

func (*StartFileUploadResp) Reset 

func (x *StartFileUploadResp) Reset()

func (*StartFileUploadResp) String 

func (x *StartFileUploadResp) String() string

type StartReq 

type StartReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReq) Descriptor deprecated 

func (*StartReq) Descriptor() ([]byte, []int)

Deprecated: Use StartReq.ProtoReflect.Descriptor instead.

func (*StartReq) GetPackage 

func (x *StartReq) GetPackage() string

func (*StartReq) ProtoMessage 

func (*StartReq) ProtoMessage()

func (*StartReq) ProtoReflect 

func (x *StartReq) ProtoReflect() protoreflect.Message

func (*StartReq) Reset 

func (x *StartReq) Reset()

func (*StartReq) String 

func (x *StartReq) String() string

type StopReq 

type StopReq struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReq) Descriptor deprecated 

func (*StopReq) Descriptor() ([]byte, []int)

Deprecated: Use StopReq.ProtoReflect.Descriptor instead.

func (*StopReq) GetPackage 

func (x *StopReq) GetPackage() string

func (*StopReq) ProtoMessage 

func (*StopReq) ProtoMessage()

func (*StopReq) ProtoReflect 

func (x *StopReq) ProtoReflect() protoreflect.Message

func (*StopReq) Reset 

func (x *StopReq) Reset()

func (*StopReq) String 

func (x *StopReq) String() string

type StreamLogsReq 

type StreamLogsReq struct {
	Package   string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	TailLines int32  `protobuf:"varint,2,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"` // 初始返回的行数，0 表示不返回历史日志
	Follow    bool   `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`                        // 是否持续跟踪新日志
	// contains filtered or unexported fields
}

func (*StreamLogsReq) Descriptor deprecated 

func (*StreamLogsReq) Descriptor() ([]byte, []int)

Deprecated: Use StreamLogsReq.ProtoReflect.Descriptor instead.

func (*StreamLogsReq) GetFollow 

func (x *StreamLogsReq) GetFollow() bool

func (*StreamLogsReq) GetPackage 

func (x *StreamLogsReq) GetPackage() string

func (*StreamLogsReq) GetTailLines 

func (x *StreamLogsReq) GetTailLines() int32

func (*StreamLogsReq) ProtoMessage 

func (*StreamLogsReq) ProtoMessage()

func (*StreamLogsReq) ProtoReflect 

func (x *StreamLogsReq) ProtoReflect() protoreflect.Message

func (*StreamLogsReq) Reset 

func (x *StreamLogsReq) Reset()

func (*StreamLogsReq) String 

func (x *StreamLogsReq) String() string

type StreamLogsResp 

type StreamLogsResp struct {
	LogLine string `protobuf:"bytes,1,opt,name=log_line,json=logLine,proto3" json:"log_line,omitempty"`
	IsEof   bool   `protobuf:"varint,2,opt,name=is_eof,json=isEof,proto3" json:"is_eof,omitempty"` // 是否到达文件末尾（仅在 follow=false 时使用）
	// contains filtered or unexported fields
}

func (*StreamLogsResp) Descriptor deprecated 

func (*StreamLogsResp) Descriptor() ([]byte, []int)

Deprecated: Use StreamLogsResp.ProtoReflect.Descriptor instead.

func (*StreamLogsResp) GetIsEof 

func (x *StreamLogsResp) GetIsEof() bool

func (*StreamLogsResp) GetLogLine 

func (x *StreamLogsResp) GetLogLine() string

func (*StreamLogsResp) ProtoMessage 

func (*StreamLogsResp) ProtoMessage()

func (*StreamLogsResp) ProtoReflect 

func (x *StreamLogsResp) ProtoReflect() protoreflect.Message

func (*StreamLogsResp) Reset 

func (x *StreamLogsResp) Reset()

func (*StreamLogsResp) String 

func (x *StreamLogsResp) String() string

type SystemMetrics 

type SystemMetrics struct {
	CpuUsage          float64                `protobuf:"fixed64,1,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`                           // CPU 使用率（百分比）
	CpuCores          int32                  `protobuf:"varint,14,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`                           // CPU 核心数
	MemoryUsage       float64                `protobuf:"fixed64,2,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`                  // 内存使用率（百分比）
	MemoryTotal       int64                  `protobuf:"varint,3,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`                   // 总内存（字节）
	MemoryFree        int64                  `protobuf:"varint,4,opt,name=memory_free,json=memoryFree,proto3" json:"memory_free,omitempty"`                      // 空闲内存（字节）
	DiskUsage         float64                `protobuf:"fixed64,5,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`                        // 磁盘使用率（百分比）
	DiskTotal         int64                  `protobuf:"varint,6,opt,name=disk_total,json=diskTotal,proto3" json:"disk_total,omitempty"`                         // 总磁盘空间（字节）
	DiskFree          int64                  `protobuf:"varint,7,opt,name=disk_free,json=diskFree,proto3" json:"disk_free,omitempty"`                            // 空闲磁盘空间（字节）
	NetworkIn         int64                  `protobuf:"varint,8,opt,name=network_in,json=networkIn,proto3" json:"network_in,omitempty"`                         // 网络入流量（字节，已废弃，使用 network_interfaces）
	NetworkOut        int64                  `protobuf:"varint,9,opt,name=network_out,json=networkOut,proto3" json:"network_out,omitempty"`                      // 网络出流量（字节，已废弃，使用 network_interfaces）
	NetworkInterfaces []*NetworkInterface    `protobuf:"bytes,15,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"` // 网络接口列表
	LoadAvg_1         float64                `protobuf:"fixed64,10,opt,name=load_avg_1,json=loadAvg1,proto3" json:"load_avg_1,omitempty"`                        // 1分钟负载平均值
	LoadAvg_5         float64                `protobuf:"fixed64,11,opt,name=load_avg_5,json=loadAvg5,proto3" json:"load_avg_5,omitempty"`                        // 5分钟负载平均值
	LoadAvg_15        float64                `protobuf:"fixed64,12,opt,name=load_avg_15,json=loadAvg15,proto3" json:"load_avg_15,omitempty"`                     // 15分钟负载平均值
	LastUpdated       *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

SystemMetrics 系统指标

func (*SystemMetrics) Descriptor deprecated 

func (*SystemMetrics) Descriptor() ([]byte, []int)

Deprecated: Use SystemMetrics.ProtoReflect.Descriptor instead.

func (*SystemMetrics) GetCpuCores 

func (x *SystemMetrics) GetCpuCores() int32

func (*SystemMetrics) GetCpuUsage 

func (x *SystemMetrics) GetCpuUsage() float64

func (*SystemMetrics) GetDiskFree 

func (x *SystemMetrics) GetDiskFree() int64

func (*SystemMetrics) GetDiskTotal 

func (x *SystemMetrics) GetDiskTotal() int64

func (*SystemMetrics) GetDiskUsage 

func (x *SystemMetrics) GetDiskUsage() float64

func (*SystemMetrics) GetLastUpdated 

func (x *SystemMetrics) GetLastUpdated() *timestamppb.Timestamp

func (*SystemMetrics) GetLoadAvg_1 

func (x *SystemMetrics) GetLoadAvg_1() float64

func (*SystemMetrics) GetLoadAvg_15 

func (x *SystemMetrics) GetLoadAvg_15() float64

func (*SystemMetrics) GetLoadAvg_5 

func (x *SystemMetrics) GetLoadAvg_5() float64

func (*SystemMetrics) GetMemoryFree 

func (x *SystemMetrics) GetMemoryFree() int64

func (*SystemMetrics) GetMemoryTotal 

func (x *SystemMetrics) GetMemoryTotal() int64

func (*SystemMetrics) GetMemoryUsage 

func (x *SystemMetrics) GetMemoryUsage() float64

func (*SystemMetrics) GetNetworkIn 

func (x *SystemMetrics) GetNetworkIn() int64

func (*SystemMetrics) GetNetworkInterfaces 

func (x *SystemMetrics) GetNetworkInterfaces() []*NetworkInterface

func (*SystemMetrics) GetNetworkOut 

func (x *SystemMetrics) GetNetworkOut() int64

func (*SystemMetrics) ProtoMessage 

func (*SystemMetrics) ProtoMessage()

func (*SystemMetrics) ProtoReflect 

func (x *SystemMetrics) ProtoReflect() protoreflect.Message

func (*SystemMetrics) Reset 

func (x *SystemMetrics) Reset()

func (*SystemMetrics) String 

func (x *SystemMetrics) String() string

type TaskStatus 

type TaskStatus int32

TaskStatus 任务状态 

const (
	TaskStatus_TASK_STATUS_UNKNOWN   TaskStatus = 0
	TaskStatus_TASK_STATUS_PENDING   TaskStatus = 1 // 待执行
	TaskStatus_TASK_STATUS_RUNNING   TaskStatus = 2 // 执行中
	TaskStatus_TASK_STATUS_COMPLETED TaskStatus = 3 // 已完成
	TaskStatus_TASK_STATUS_FAILED    TaskStatus = 4 // 失败
	TaskStatus_TASK_STATUS_CANCELLED TaskStatus = 5 // 已取消
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TaskStatusInfo 

type TaskStatusInfo struct {
	TaskType    string                 `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`                 // 任务类型
	Status      TaskStatus             `protobuf:"varint,2,opt,name=status,proto3,enum=collection_task_pb.TaskStatus" json:"status,omitempty"` // 任务状态
	Message     string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`                                   // 状态消息
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`        // 最后更新时间
	// contains filtered or unexported fields
}

TaskStatusInfo 任务状态信息

func (*TaskStatusInfo) Descriptor deprecated 

func (*TaskStatusInfo) Descriptor() ([]byte, []int)

Deprecated: Use TaskStatusInfo.ProtoReflect.Descriptor instead.

func (*TaskStatusInfo) GetLastUpdated 

func (x *TaskStatusInfo) GetLastUpdated() *timestamppb.Timestamp

func (*TaskStatusInfo) GetMessage 

func (x *TaskStatusInfo) GetMessage() string

func (*TaskStatusInfo) GetStatus 

func (x *TaskStatusInfo) GetStatus() TaskStatus

func (*TaskStatusInfo) GetTaskType 

func (x *TaskStatusInfo) GetTaskType() string

func (*TaskStatusInfo) ProtoMessage 

func (*TaskStatusInfo) ProtoMessage()

func (*TaskStatusInfo) ProtoReflect 

func (x *TaskStatusInfo) ProtoReflect() protoreflect.Message

func (*TaskStatusInfo) Reset 

func (x *TaskStatusInfo) Reset()

func (*TaskStatusInfo) String 

func (x *TaskStatusInfo) String() string

type UnimplementedCollectionTaskServiceServer 

type UnimplementedCollectionTaskServiceServer struct{}

UnimplementedCollectionTaskServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCollectionTaskServiceServer) DistributeTasks 

func (UnimplementedCollectionTaskServiceServer) DistributeTasks(context.Context, *DistributeTasksReq) (*DistributeTasksResp, error)

func (UnimplementedCollectionTaskServiceServer) GetTaskStatus 

func (UnimplementedCollectionTaskServiceServer) GetTaskStatus(context.Context, *GetTaskStatusReq) (*GetTaskStatusResp, error)

func (UnimplementedCollectionTaskServiceServer) GetTasks 

func (UnimplementedCollectionTaskServiceServer) GetTasks(context.Context, *GetTasksReq) (*GetTasksResp, error)

func (UnimplementedCollectionTaskServiceServer) UpdateTaskStatus 

func (UnimplementedCollectionTaskServiceServer) UpdateTaskStatus(context.Context, *UpdateTaskStatusReq) (*UpdateTaskStatusResp, error)

type UnimplementedCommandServer 

type UnimplementedCommandServer struct{}

UnimplementedCommandServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCommandServer) ExecCommand 

func (UnimplementedCommandServer) ExecCommand(*ExecCommandReq, grpc.ServerStreamingServer[ExecCommandResp]) error

func (UnimplementedCommandServer) ExecCommandSignal 

func (UnimplementedCommandServer) ExecCommandSignal(context.Context, *ExecCommandSignalReq) (*ExecCommandSignalResp, error)

func (UnimplementedCommandServer) GetCommandStatus 

func (UnimplementedCommandServer) GetCommandStatus(context.Context, *GetCommandStatusReq) (*GetCommandStatusResp, error)

type UnimplementedFileServer 

type UnimplementedFileServer struct{}

UnimplementedFileServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedFileServer) CreateDirectory 

func (UnimplementedFileServer) CreateDirectory(context.Context, *CreateDirectoryReq) (*CreateDirectoryResp, error)

func (UnimplementedFileServer) DeleteFile 

func (UnimplementedFileServer) DeleteFile(context.Context, *DeleteFileReq) (*DeleteFileResp, error)

func (UnimplementedFileServer) DownloadFile 

func (UnimplementedFileServer) DownloadFile(*DownloadFileReq, grpc.ServerStreamingServer[DownloadFileResp]) error

func (UnimplementedFileServer) GetFileInfo 

func (UnimplementedFileServer) GetFileInfo(context.Context, *GetFileInfoReq) (*GetFileInfoResp, error)

func (UnimplementedFileServer) GetUploadStatus 

func (UnimplementedFileServer) GetUploadStatus(context.Context, *GetUploadStatusReq) (*GetUploadStatusResp, error)

func (UnimplementedFileServer) ListFiles 

func (UnimplementedFileServer) ListFiles(context.Context, *ListFilesReq) (*ListFilesResp, error)

func (UnimplementedFileServer) StartFileUpload 

func (UnimplementedFileServer) StartFileUpload(context.Context, *StartFileUploadReq) (*StartFileUploadResp, error)

func (UnimplementedFileServer) UploadFileChunk 

func (UnimplementedFileServer) UploadFileChunk(context.Context, *UploadFileChunkReq) (*UploadFileChunkResp, error)

type UnimplementedHealthServer 

type UnimplementedHealthServer struct{}

UnimplementedHealthServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHealthServer) GetHealthHistory 

func (UnimplementedHealthServer) GetHealthHistory(context.Context, *GetHealthHistoryReq) (*GetHealthHistoryResp, error)

func (UnimplementedHealthServer) GetHealthStatus 

func (UnimplementedHealthServer) GetHealthStatus(context.Context, *GetHealthStatusReq) (*GetHealthStatusResp, error)

func (UnimplementedHealthServer) ListHealthStatuses 

func (UnimplementedHealthServer) ListHealthStatuses(context.Context, *ListHealthStatusesReq) (*ListHealthStatusesResp, error)

type UnimplementedLuaServer 

type UnimplementedLuaServer struct{}

UnimplementedLuaServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLuaServer) ExecLuaScript 

func (UnimplementedLuaServer) ExecLuaScript(context.Context, *ExecLuaScriptReq) (*ExecLuaScriptResp, error)

type UnimplementedMetricsServer 

type UnimplementedMetricsServer struct{}

UnimplementedMetricsServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMetricsServer) GetApplicationMetrics 

func (UnimplementedMetricsServer) GetApplicationMetrics(context.Context, *GetApplicationMetricsReq) (*GetApplicationMetricsResp, error)

func (UnimplementedMetricsServer) GetMetricsHistory 

func (UnimplementedMetricsServer) GetMetricsHistory(context.Context, *GetMetricsHistoryReq) (*GetMetricsHistoryResp, error)

func (UnimplementedMetricsServer) GetServiceMetrics 

func (UnimplementedMetricsServer) GetServiceMetrics(context.Context, *GetServiceMetricsReq) (*GetServiceMetricsResp, error)

func (UnimplementedMetricsServer) GetSystemMetrics 

func (UnimplementedMetricsServer) GetSystemMetrics(context.Context, *GetSystemMetricsReq) (*GetSystemMetricsResp, error)

func (UnimplementedMetricsServer) ListServiceMetrics 

func (UnimplementedMetricsServer) ListServiceMetrics(context.Context, *ListServiceMetricsReq) (*ListServiceMetricsResp, error)

type UnimplementedPackageServer 

type UnimplementedPackageServer struct{}

UnimplementedPackageServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedPackageServer) ApplyConfigs 

func (UnimplementedPackageServer) ApplyConfigs(context.Context, *ApplyConfigsReq) (*ApplyConfigsResp, error)

func (UnimplementedPackageServer) GetConfigs 

func (UnimplementedPackageServer) GetConfigs(context.Context, *GetConfigsReq) (*GetConfigsResp, error)

func (UnimplementedPackageServer) GetRecentLogs 

func (UnimplementedPackageServer) GetRecentLogs(context.Context, *GetRecentLogsReq) (*GetRecentLogsResp, error)

func (UnimplementedPackageServer) PackageList 

func (UnimplementedPackageServer) PackageList(context.Context, *emptypb.Empty) (*PackageListResp, error)

func (UnimplementedPackageServer) QueryLogs 

func (UnimplementedPackageServer) QueryLogs(context.Context, *QueryLogsReq) (*QueryLogsResp, error)

func (UnimplementedPackageServer) Restart 

func (UnimplementedPackageServer) Restart(context.Context, *RestartReq) (*emptypb.Empty, error)

func (UnimplementedPackageServer) Start 

func (UnimplementedPackageServer) Start(context.Context, *StartReq) (*emptypb.Empty, error)

func (UnimplementedPackageServer) Stop 

func (UnimplementedPackageServer) Stop(context.Context, *StopReq) (*emptypb.Empty, error)

func (UnimplementedPackageServer) StreamLogs 

func (UnimplementedPackageServer) StreamLogs(*StreamLogsReq, grpc.ServerStreamingServer[StreamLogsResp]) error

type UnsafeCollectionTaskServiceServer 

type UnsafeCollectionTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCollectionTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CollectionTaskServiceServer will result in compilation errors.

type UnsafeCommandServer 

type UnsafeCommandServer interface {
	// contains filtered or unexported methods
}

UnsafeCommandServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandServer will result in compilation errors.

type UnsafeFileServer 

type UnsafeFileServer interface {
	// contains filtered or unexported methods
}

UnsafeFileServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileServer will result in compilation errors.

type UnsafeHealthServer 

type UnsafeHealthServer interface {
	// contains filtered or unexported methods
}

UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.

type UnsafeLuaServer 

type UnsafeLuaServer interface {
	// contains filtered or unexported methods
}

UnsafeLuaServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LuaServer will result in compilation errors.

type UnsafeMetricsServer 

type UnsafeMetricsServer interface {
	// contains filtered or unexported methods
}

UnsafeMetricsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServer will result in compilation errors.

type UnsafePackageServer 

type UnsafePackageServer interface {
	// contains filtered or unexported methods
}

UnsafePackageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PackageServer will result in compilation errors.

type UpdateTaskStatusReq 

type UpdateTaskStatusReq struct {
	AgentCode string                 `protobuf:"bytes,1,opt,name=agent_code,json=agentCode,proto3" json:"agent_code,omitempty"`              // Agent标识码
	TaskType  string                 `protobuf:"bytes,2,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`                 // 任务类型
	Status    TaskStatus             `protobuf:"varint,3,opt,name=status,proto3,enum=collection_task_pb.TaskStatus" json:"status,omitempty"` // 任务状态
	Message   string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`                                   // 状态消息（可选）
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`              // 更新时间
	// contains filtered or unexported fields
}

UpdateTaskStatusReq 更新任务状态请求

func (*UpdateTaskStatusReq) Descriptor deprecated 

func (*UpdateTaskStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskStatusReq.ProtoReflect.Descriptor instead.

func (*UpdateTaskStatusReq) GetAgentCode 

func (x *UpdateTaskStatusReq) GetAgentCode() string

func (*UpdateTaskStatusReq) GetMessage 

func (x *UpdateTaskStatusReq) GetMessage() string

func (*UpdateTaskStatusReq) GetStatus 

func (x *UpdateTaskStatusReq) GetStatus() TaskStatus

func (*UpdateTaskStatusReq) GetTaskType 

func (x *UpdateTaskStatusReq) GetTaskType() string

func (*UpdateTaskStatusReq) GetUpdatedAt 

func (x *UpdateTaskStatusReq) GetUpdatedAt() *timestamppb.Timestamp

func (*UpdateTaskStatusReq) ProtoMessage 

func (*UpdateTaskStatusReq) ProtoMessage()

func (*UpdateTaskStatusReq) ProtoReflect 

func (x *UpdateTaskStatusReq) ProtoReflect() protoreflect.Message

func (*UpdateTaskStatusReq) Reset 

func (x *UpdateTaskStatusReq) Reset()

func (*UpdateTaskStatusReq) String 

func (x *UpdateTaskStatusReq) String() string

type UpdateTaskStatusResp 

type UpdateTaskStatusResp struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 是否成功
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`  // 响应消息
	// contains filtered or unexported fields
}

UpdateTaskStatusResp 更新任务状态响应

func (*UpdateTaskStatusResp) Descriptor deprecated 

func (*UpdateTaskStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskStatusResp.ProtoReflect.Descriptor instead.

func (*UpdateTaskStatusResp) GetMessage 

func (x *UpdateTaskStatusResp) GetMessage() string

func (*UpdateTaskStatusResp) GetSuccess 

func (x *UpdateTaskStatusResp) GetSuccess() bool

func (*UpdateTaskStatusResp) ProtoMessage 

func (*UpdateTaskStatusResp) ProtoMessage()

func (*UpdateTaskStatusResp) ProtoReflect 

func (x *UpdateTaskStatusResp) ProtoReflect() protoreflect.Message

func (*UpdateTaskStatusResp) Reset 

func (x *UpdateTaskStatusResp) Reset()

func (*UpdateTaskStatusResp) String 

func (x *UpdateTaskStatusResp) String() string

type UpdatedFileDetail 

type UpdatedFileDetail struct {
	FileName  string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	ByteCount int32  `protobuf:"varint,2,opt,name=byte_count,json=byteCount,proto3" json:"byte_count,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatedFileDetail) Descriptor deprecated 

func (*UpdatedFileDetail) Descriptor() ([]byte, []int)

Deprecated: Use UpdatedFileDetail.ProtoReflect.Descriptor instead.

func (*UpdatedFileDetail) GetByteCount 

func (x *UpdatedFileDetail) GetByteCount() int32

func (*UpdatedFileDetail) GetFileName 

func (x *UpdatedFileDetail) GetFileName() string

func (*UpdatedFileDetail) ProtoMessage 

func (*UpdatedFileDetail) ProtoMessage()

func (*UpdatedFileDetail) ProtoReflect 

func (x *UpdatedFileDetail) ProtoReflect() protoreflect.Message

func (*UpdatedFileDetail) Reset 

func (x *UpdatedFileDetail) Reset()

func (*UpdatedFileDetail) String 

func (x *UpdatedFileDetail) String() string

type UploadFileChunkReq 

type UploadFileChunkReq struct {
	SessionId  string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ChunkIndex int64  `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	Data       []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

UploadFileChunkReq 上传文件块请求

func (*UploadFileChunkReq) Descriptor deprecated 

func (*UploadFileChunkReq) Descriptor() ([]byte, []int)

Deprecated: Use UploadFileChunkReq.ProtoReflect.Descriptor instead.

func (*UploadFileChunkReq) GetChunkIndex 

func (x *UploadFileChunkReq) GetChunkIndex() int64

func (*UploadFileChunkReq) GetData 

func (x *UploadFileChunkReq) GetData() []byte

func (*UploadFileChunkReq) GetSessionId 

func (x *UploadFileChunkReq) GetSessionId() string

func (*UploadFileChunkReq) ProtoMessage 

func (*UploadFileChunkReq) ProtoMessage()

func (*UploadFileChunkReq) ProtoReflect 

func (x *UploadFileChunkReq) ProtoReflect() protoreflect.Message

func (*UploadFileChunkReq) Reset 

func (x *UploadFileChunkReq) Reset()

func (*UploadFileChunkReq) String 

func (x *UploadFileChunkReq) String() string

type UploadFileChunkResp 

type UploadFileChunkResp struct {
	SessionId  string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ChunkIndex int64  `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	Status     string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UploadFileChunkResp 上传文件块响应

func (*UploadFileChunkResp) Descriptor deprecated 

func (*UploadFileChunkResp) Descriptor() ([]byte, []int)

Deprecated: Use UploadFileChunkResp.ProtoReflect.Descriptor instead.

func (*UploadFileChunkResp) GetChunkIndex 

func (x *UploadFileChunkResp) GetChunkIndex() int64

func (*UploadFileChunkResp) GetSessionId 

func (x *UploadFileChunkResp) GetSessionId() string

func (*UploadFileChunkResp) GetStatus 

func (x *UploadFileChunkResp) GetStatus() string

func (*UploadFileChunkResp) ProtoMessage 

func (*UploadFileChunkResp) ProtoMessage()

func (*UploadFileChunkResp) ProtoReflect 

func (x *UploadFileChunkResp) ProtoReflect() protoreflect.Message

func (*UploadFileChunkResp) Reset 

func (x *UploadFileChunkResp) Reset()

func (*UploadFileChunkResp) String 

func (x *UploadFileChunkResp) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.