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_health_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 采集任务服务

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 (*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) Enum

func (ExecCommandSignalType) EnumDescriptor deprecated

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

Deprecated: Use ExecCommandSignalType.Descriptor instead.

func (ExecCommandSignalType) Number

func (ExecCommandSignalType) String

func (x ExecCommandSignalType) String() string

func (ExecCommandSignalType) Type

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 (*GetApplicationMetricsResp) GetServices

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

func (*GetApplicationMetricsResp) ProtoMessage

func (*GetApplicationMetricsResp) ProtoMessage()

func (*GetApplicationMetricsResp) ProtoReflect

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) Enum

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated

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

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number

func (HealthStatus) String

func (x HealthStatus) String() string

func (HealthStatus) Type

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) Enum

func (x OutputFormat) Enum() *OutputFormat

func (OutputFormat) EnumDescriptor deprecated

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

Deprecated: Use OutputFormat.Descriptor instead.

func (OutputFormat) Number

func (OutputFormat) String

func (x OutputFormat) String() string

func (OutputFormat) Type

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

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) GetTaskStatus

func (UnimplementedCollectionTaskServiceServer) GetTasks

func (UnimplementedCollectionTaskServiceServer) UpdateTaskStatus

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) ExecCommandSignal

func (UnimplementedCommandServer) GetCommandStatus

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) DeleteFile

func (UnimplementedFileServer) GetFileInfo

func (UnimplementedFileServer) GetUploadStatus

func (UnimplementedFileServer) ListFiles

func (UnimplementedFileServer) StartFileUpload

func (UnimplementedFileServer) UploadFileChunk

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) GetHealthStatus

func (UnimplementedHealthServer) ListHealthStatuses

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

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) GetMetricsHistory

func (UnimplementedMetricsServer) GetServiceMetrics

func (UnimplementedMetricsServer) GetSystemMetrics

func (UnimplementedMetricsServer) ListServiceMetrics

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) GetConfigs

func (UnimplementedPackageServer) GetRecentLogs

func (UnimplementedPackageServer) PackageList

func (UnimplementedPackageServer) QueryLogs

func (UnimplementedPackageServer) Restart

func (UnimplementedPackageServer) Start

func (UnimplementedPackageServer) Stop

func (UnimplementedPackageServer) StreamLogs

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL