api

type CancelTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type CancelTaskResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	BaseResp *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type CordonNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type CordonNodeResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	BaseResp *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type DeregisterRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // 注销原因 (e.g. "graceful_shutdown", "maintenance")
	// contains filtered or unexported fields
}

type DeregisterResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	BaseResp *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type DispatchTaskRequest struct {
	Task *golem.Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

type DispatchTaskResponse struct {
	Accepted     bool           `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	RejectReason string         `protobuf:"bytes,2,opt,name=reject_reason,json=rejectReason,proto3" json:"reject_reason,omitempty"`
	BaseResp     *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type DrainNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

type DrainNodeResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	BaseResp *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type GetNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

type GetNodeResponse struct {
	NodeInfo *golem.NodeInfo     `protobuf:"bytes,1,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"`
	LoadInfo *golem.NodeLoadInfo `protobuf:"bytes,2,opt,name=load_info,json=loadInfo,proto3" json:"load_info,omitempty"`
	BaseResp *base.BaseResp      `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type GolemNodeServiceClient interface {
	// Register 注册 Golem 节点到 Hivemind
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Heartbeat 双向流: Golem 定期上报负载, Hivemind 可下发控制指令
	Heartbeat(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[HeartbeatRequest, HeartbeatResponse], error)
	// Deregister 节点主动注销 (graceful shutdown)
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...grpc.CallOption) (*DeregisterResponse, error)
	// ReportTaskResult 上报任务执行结果
	ReportTaskResult(ctx context.Context, in *ReportTaskResultRequest, opts ...grpc.CallOption) (*ReportTaskResultResponse, error)
	// ReportTaskProgress 上报任务执行进度
	ReportTaskProgress(ctx context.Context, in *ReportTaskProgressRequest, opts ...grpc.CallOption) (*ReportTaskProgressResponse, error)
}

type GolemNodeServiceServer interface {
	// Register 注册 Golem 节点到 Hivemind
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Heartbeat 双向流: Golem 定期上报负载, Hivemind 可下发控制指令
	Heartbeat(grpc.BidiStreamingServer[HeartbeatRequest, HeartbeatResponse]) error
	// Deregister 节点主动注销 (graceful shutdown)
	Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)
	// ReportTaskResult 上报任务执行结果
	ReportTaskResult(context.Context, *ReportTaskResultRequest) (*ReportTaskResultResponse, error)
	// ReportTaskProgress 上报任务执行进度
	ReportTaskProgress(context.Context, *ReportTaskProgressRequest) (*ReportTaskProgressResponse, error)
	// contains filtered or unexported methods
}

type GolemNodeService_HeartbeatClient = grpc.BidiStreamingClient[HeartbeatRequest, HeartbeatResponse]

type GolemNodeService_HeartbeatServer = grpc.BidiStreamingServer[HeartbeatRequest, HeartbeatResponse]

type HeartbeatAction int32

type HeartbeatRequest struct {
	NodeId    string                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`       // 节点 ID
	LoadInfo  *golem.NodeLoadInfo    `protobuf:"bytes,2,opt,name=load_info,json=loadInfo,proto3" json:"load_info,omitempty"` // 当前负载
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`               // 心跳时间戳
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	Acknowledged bool            `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`              // 心跳确认
	Action       HeartbeatAction `protobuf:"varint,2,opt,name=action,proto3,enum=api.HeartbeatAction" json:"action,omitempty"` // 控制指令
	// contains filtered or unexported fields
}

type HivemindAdminServiceClient interface {
	// ListNodes 列出所有注册的 Golem 节点
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	// GetNode 获取指定节点详情
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	// CordonNode 隔离节点 (标记为不可调度)
	CordonNode(ctx context.Context, in *CordonNodeRequest, opts ...grpc.CallOption) (*CordonNodeResponse, error)
	// UncordonNode 取消节点隔离
	UncordonNode(ctx context.Context, in *UncordonNodeRequest, opts ...grpc.CallOption) (*UncordonNodeResponse, error)
}

type HivemindAdminServiceServer interface {
	// ListNodes 列出所有注册的 Golem 节点
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	// GetNode 获取指定节点详情
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	// CordonNode 隔离节点 (标记为不可调度)
	CordonNode(context.Context, *CordonNodeRequest) (*CordonNodeResponse, error)
	// UncordonNode 取消节点隔离
	UncordonNode(context.Context, *UncordonNodeRequest) (*UncordonNodeResponse, error)
	// contains filtered or unexported methods
}

type HivemindControlServiceClient interface {
	// DispatchTask 下发任务到 Golem 节点
	DispatchTask(ctx context.Context, in *DispatchTaskRequest, opts ...grpc.CallOption) (*DispatchTaskResponse, error)
	// CancelTask 取消正在执行的任务
	CancelTask(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*CancelTaskResponse, error)
	// DrainNode 排水节点 (停止接受新任务, 等待现有任务完成)
	DrainNode(ctx context.Context, in *DrainNodeRequest, opts ...grpc.CallOption) (*DrainNodeResponse, error)
}

type HivemindControlServiceServer interface {
	// DispatchTask 下发任务到 Golem 节点
	DispatchTask(context.Context, *DispatchTaskRequest) (*DispatchTaskResponse, error)
	// CancelTask 取消正在执行的任务
	CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)
	// DrainNode 排水节点 (停止接受新任务, 等待现有任务完成)
	DrainNode(context.Context, *DrainNodeRequest) (*DrainNodeResponse, error)
	// contains filtered or unexported methods
}

type ListNodesRequest struct {
	StatusFilter golem.NodeStatus `protobuf:"varint,1,opt,name=status_filter,json=statusFilter,proto3,enum=golem.NodeStatus" json:"status_filter,omitempty"` // 可选: 按状态过滤
	PageSize     int32            `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken    string           `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListNodesResponse struct {
	Nodes         []*golem.NodeInfo `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	NextPageToken string            `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalCount    int32             `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	BaseResp      *base.BaseResp    `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type RegisterRequest struct {
	JoinToken string              `protobuf:"bytes,1,opt,name=join_token,json=joinToken,proto3" json:"join_token,omitempty"` // 加入令牌 (由 echoadm 生成)
	NodeInfo  *golem.NodeInfo     `protobuf:"bytes,2,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"`    // 节点信息
	LoadInfo  *golem.NodeLoadInfo `protobuf:"bytes,3,opt,name=load_info,json=loadInfo,proto3" json:"load_info,omitempty"`    // 初始负载信息
	// contains filtered or unexported fields
}

type RegisterResponse struct {
	Accepted     bool           `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`                            // 是否接受注册
	NodeId       string         `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                   // Hivemind 分配/确认的节点 ID
	RejectReason string         `protobuf:"bytes,3,opt,name=reject_reason,json=rejectReason,proto3" json:"reject_reason,omitempty"` // 拒绝原因 (如果不接受)
	BaseResp     *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type ReportTaskProgressRequest struct {
	NodeId       string              `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	TaskProgress *golem.TaskProgress `protobuf:"bytes,2,opt,name=task_progress,json=taskProgress,proto3" json:"task_progress,omitempty"`
	// contains filtered or unexported fields
}

type ReportTaskProgressResponse struct {
	Acknowledged bool           `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	BaseResp     *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type ReportTaskResultRequest struct {
	NodeId     string            `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	TaskResult *golem.TaskResult `protobuf:"bytes,2,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
	// contains filtered or unexported fields
}

type ReportTaskResultResponse struct {
	Acknowledged bool           `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	BaseResp     *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type UncordonNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

type UncordonNodeResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	BaseResp *base.BaseResp `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedGolemNodeServiceServer struct{}

type UnimplementedHivemindAdminServiceServer struct{}

type UnimplementedHivemindControlServiceServer struct{}

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

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

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