api

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GolemNodeService_Register_FullMethodName           = "/api.GolemNodeService/Register"
	GolemNodeService_Heartbeat_FullMethodName          = "/api.GolemNodeService/Heartbeat"
	GolemNodeService_Deregister_FullMethodName         = "/api.GolemNodeService/Deregister"
	GolemNodeService_ReportTaskResult_FullMethodName   = "/api.GolemNodeService/ReportTaskResult"
	GolemNodeService_ReportTaskProgress_FullMethodName = "/api.GolemNodeService/ReportTaskProgress"
)
View Source 
const (
	HivemindControlService_DispatchTask_FullMethodName = "/api.HivemindControlService/DispatchTask"
	HivemindControlService_CancelTask_FullMethodName   = "/api.HivemindControlService/CancelTask"
	HivemindControlService_DrainNode_FullMethodName    = "/api.HivemindControlService/DrainNode"
)
View Source 
const (
	HivemindAdminService_ListNodes_FullMethodName    = "/api.HivemindAdminService/ListNodes"
	HivemindAdminService_GetNode_FullMethodName      = "/api.HivemindAdminService/GetNode"
	HivemindAdminService_CordonNode_FullMethodName   = "/api.HivemindAdminService/CordonNode"
	HivemindAdminService_UncordonNode_FullMethodName = "/api.HivemindAdminService/UncordonNode"
)

Variables

View Source 
var (
	HeartbeatAction_name = map[int32]string{
		0: "HEARTBEAT_ACTION_UNSPECIFIED",
		1: "HEARTBEAT_ACTION_NONE",
		2: "HEARTBEAT_ACTION_DRAIN",
		3: "HEARTBEAT_ACTION_SHUTDOWN",
	}
	HeartbeatAction_value = map[string]int32{
		"HEARTBEAT_ACTION_UNSPECIFIED": 0,
		"HEARTBEAT_ACTION_NONE":        1,
		"HEARTBEAT_ACTION_DRAIN":       2,
		"HEARTBEAT_ACTION_SHUTDOWN":    3,
	}
)

Enum value maps for HeartbeatAction.

View Source 
var File_api_api_proto protoreflect.FileDescriptor
View Source 
var GolemNodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.GolemNodeService",
	HandlerType: (*GolemNodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _GolemNodeService_Register_Handler,
		},
		{
			MethodName: "Deregister",
			Handler:    _GolemNodeService_Deregister_Handler,
		},
		{
			MethodName: "ReportTaskResult",
			Handler:    _GolemNodeService_ReportTaskResult_Handler,
		},
		{
			MethodName: "ReportTaskProgress",
			Handler:    _GolemNodeService_ReportTaskProgress_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Heartbeat",
			Handler:       _GolemNodeService_Heartbeat_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/api.proto",
}

GolemNodeService_ServiceDesc is the grpc.ServiceDesc for GolemNodeService 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 HivemindAdminService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.HivemindAdminService",
	HandlerType: (*HivemindAdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListNodes",
			Handler:    _HivemindAdminService_ListNodes_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _HivemindAdminService_GetNode_Handler,
		},
		{
			MethodName: "CordonNode",
			Handler:    _HivemindAdminService_CordonNode_Handler,
		},
		{
			MethodName: "UncordonNode",
			Handler:    _HivemindAdminService_UncordonNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/api.proto",
}

HivemindAdminService_ServiceDesc is the grpc.ServiceDesc for HivemindAdminService 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 HivemindControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.HivemindControlService",
	HandlerType: (*HivemindControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DispatchTask",
			Handler:    _HivemindControlService_DispatchTask_Handler,
		},
		{
			MethodName: "CancelTask",
			Handler:    _HivemindControlService_CancelTask_Handler,
		},
		{
			MethodName: "DrainNode",
			Handler:    _HivemindControlService_DrainNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/api.proto",
}

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

Functions

func RegisterGolemNodeServiceServer 

func RegisterGolemNodeServiceServer(s grpc.ServiceRegistrar, srv GolemNodeServiceServer)

func RegisterHivemindAdminServiceServer 

func RegisterHivemindAdminServiceServer(s grpc.ServiceRegistrar, srv HivemindAdminServiceServer)

func RegisterHivemindControlServiceServer 

func RegisterHivemindControlServiceServer(s grpc.ServiceRegistrar, srv HivemindControlServiceServer)

Types

type CancelTaskRequest 

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
}

func (*CancelTaskRequest) Descriptor deprecated 

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

Deprecated: Use CancelTaskRequest.ProtoReflect.Descriptor instead.

func (*CancelTaskRequest) GetReason 

func (x *CancelTaskRequest) GetReason() string

func (*CancelTaskRequest) GetTaskId 

func (x *CancelTaskRequest) GetTaskId() string

func (*CancelTaskRequest) ProtoMessage 

func (*CancelTaskRequest) ProtoMessage()

func (*CancelTaskRequest) ProtoReflect 

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

func (*CancelTaskRequest) Reset 

func (x *CancelTaskRequest) Reset()

func (*CancelTaskRequest) String 

func (x *CancelTaskRequest) String() string

type CancelTaskResponse 

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
}

func (*CancelTaskResponse) Descriptor deprecated 

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

Deprecated: Use CancelTaskResponse.ProtoReflect.Descriptor instead.

func (*CancelTaskResponse) GetBaseResp 

func (x *CancelTaskResponse) GetBaseResp() *base.BaseResp

func (*CancelTaskResponse) GetSuccess 

func (x *CancelTaskResponse) GetSuccess() bool

func (*CancelTaskResponse) ProtoMessage 

func (*CancelTaskResponse) ProtoMessage()

func (*CancelTaskResponse) ProtoReflect 

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

func (*CancelTaskResponse) Reset 

func (x *CancelTaskResponse) Reset()

func (*CancelTaskResponse) String 

func (x *CancelTaskResponse) String() string

type CordonNodeRequest 

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
}

func (*CordonNodeRequest) Descriptor deprecated 

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

Deprecated: Use CordonNodeRequest.ProtoReflect.Descriptor instead.

func (*CordonNodeRequest) GetNodeId 

func (x *CordonNodeRequest) GetNodeId() string

func (*CordonNodeRequest) GetReason 

func (x *CordonNodeRequest) GetReason() string

func (*CordonNodeRequest) ProtoMessage 

func (*CordonNodeRequest) ProtoMessage()

func (*CordonNodeRequest) ProtoReflect 

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

func (*CordonNodeRequest) Reset 

func (x *CordonNodeRequest) Reset()

func (*CordonNodeRequest) String 

func (x *CordonNodeRequest) String() string

type CordonNodeResponse 

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
}

func (*CordonNodeResponse) Descriptor deprecated 

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

Deprecated: Use CordonNodeResponse.ProtoReflect.Descriptor instead.

func (*CordonNodeResponse) GetBaseResp 

func (x *CordonNodeResponse) GetBaseResp() *base.BaseResp

func (*CordonNodeResponse) GetSuccess 

func (x *CordonNodeResponse) GetSuccess() bool

func (*CordonNodeResponse) ProtoMessage 

func (*CordonNodeResponse) ProtoMessage()

func (*CordonNodeResponse) ProtoReflect 

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

func (*CordonNodeResponse) Reset 

func (x *CordonNodeResponse) Reset()

func (*CordonNodeResponse) String 

func (x *CordonNodeResponse) String() string

type DeregisterRequest 

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
}

func (*DeregisterRequest) Descriptor deprecated 

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

Deprecated: Use DeregisterRequest.ProtoReflect.Descriptor instead.

func (*DeregisterRequest) GetNodeId 

func (x *DeregisterRequest) GetNodeId() string

func (*DeregisterRequest) GetReason 

func (x *DeregisterRequest) GetReason() string

func (*DeregisterRequest) ProtoMessage 

func (*DeregisterRequest) ProtoMessage()

func (*DeregisterRequest) ProtoReflect 

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

func (*DeregisterRequest) Reset 

func (x *DeregisterRequest) Reset()

func (*DeregisterRequest) String 

func (x *DeregisterRequest) String() string

type DeregisterResponse 

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
}

func (*DeregisterResponse) Descriptor deprecated 

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

Deprecated: Use DeregisterResponse.ProtoReflect.Descriptor instead.

func (*DeregisterResponse) GetBaseResp 

func (x *DeregisterResponse) GetBaseResp() *base.BaseResp

func (*DeregisterResponse) GetSuccess 

func (x *DeregisterResponse) GetSuccess() bool

func (*DeregisterResponse) ProtoMessage 

func (*DeregisterResponse) ProtoMessage()

func (*DeregisterResponse) ProtoReflect 

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

func (*DeregisterResponse) Reset 

func (x *DeregisterResponse) Reset()

func (*DeregisterResponse) String 

func (x *DeregisterResponse) String() string

type DispatchTaskRequest 

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

func (*DispatchTaskRequest) Descriptor deprecated 

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

Deprecated: Use DispatchTaskRequest.ProtoReflect.Descriptor instead.

func (*DispatchTaskRequest) GetTask 

func (x *DispatchTaskRequest) GetTask() *golem.Task

func (*DispatchTaskRequest) ProtoMessage 

func (*DispatchTaskRequest) ProtoMessage()

func (*DispatchTaskRequest) ProtoReflect 

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

func (*DispatchTaskRequest) Reset 

func (x *DispatchTaskRequest) Reset()

func (*DispatchTaskRequest) String 

func (x *DispatchTaskRequest) String() string

type DispatchTaskResponse 

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
}

func (*DispatchTaskResponse) Descriptor deprecated 

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

Deprecated: Use DispatchTaskResponse.ProtoReflect.Descriptor instead.

func (*DispatchTaskResponse) GetAccepted 

func (x *DispatchTaskResponse) GetAccepted() bool

func (*DispatchTaskResponse) GetBaseResp 

func (x *DispatchTaskResponse) GetBaseResp() *base.BaseResp

func (*DispatchTaskResponse) GetRejectReason 

func (x *DispatchTaskResponse) GetRejectReason() string

func (*DispatchTaskResponse) ProtoMessage 

func (*DispatchTaskResponse) ProtoMessage()

func (*DispatchTaskResponse) ProtoReflect 

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

func (*DispatchTaskResponse) Reset 

func (x *DispatchTaskResponse) Reset()

func (*DispatchTaskResponse) String 

func (x *DispatchTaskResponse) String() string

type DrainNodeRequest 

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

func (*DrainNodeRequest) Descriptor deprecated 

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

Deprecated: Use DrainNodeRequest.ProtoReflect.Descriptor instead.

func (*DrainNodeRequest) GetNodeId 

func (x *DrainNodeRequest) GetNodeId() string

func (*DrainNodeRequest) ProtoMessage 

func (*DrainNodeRequest) ProtoMessage()

func (*DrainNodeRequest) ProtoReflect 

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

func (*DrainNodeRequest) Reset 

func (x *DrainNodeRequest) Reset()

func (*DrainNodeRequest) String 

func (x *DrainNodeRequest) String() string

type DrainNodeResponse 

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
}

func (*DrainNodeResponse) Descriptor deprecated 

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

Deprecated: Use DrainNodeResponse.ProtoReflect.Descriptor instead.

func (*DrainNodeResponse) GetBaseResp 

func (x *DrainNodeResponse) GetBaseResp() *base.BaseResp

func (*DrainNodeResponse) GetSuccess 

func (x *DrainNodeResponse) GetSuccess() bool

func (*DrainNodeResponse) ProtoMessage 

func (*DrainNodeResponse) ProtoMessage()

func (*DrainNodeResponse) ProtoReflect 

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

func (*DrainNodeResponse) Reset 

func (x *DrainNodeResponse) Reset()

func (*DrainNodeResponse) String 

func (x *DrainNodeResponse) String() string

type GetNodeRequest 

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

func (*GetNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetNodeId 

func (x *GetNodeRequest) GetNodeId() string

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect 

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

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type GetNodeResponse 

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
}

func (*GetNodeResponse) Descriptor deprecated 

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

Deprecated: Use GetNodeResponse.ProtoReflect.Descriptor instead.

func (*GetNodeResponse) GetBaseResp 

func (x *GetNodeResponse) GetBaseResp() *base.BaseResp

func (*GetNodeResponse) GetLoadInfo 

func (x *GetNodeResponse) GetLoadInfo() *golem.NodeLoadInfo

func (*GetNodeResponse) GetNodeInfo 

func (x *GetNodeResponse) GetNodeInfo() *golem.NodeInfo

func (*GetNodeResponse) ProtoMessage 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) ProtoReflect 

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

func (*GetNodeResponse) Reset 

func (x *GetNodeResponse) Reset()

func (*GetNodeResponse) String 

func (x *GetNodeResponse) String() string

type GolemNodeServiceClient 

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

GolemNodeServiceClient is the client API for GolemNodeService 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.

========================================================================== GolemNodeService — Golem 节点向 Hivemind 注册 / 心跳 / 上报结果 由 Golem 调用, Hivemind 作为 gRPC Server 端 ==========================================================================

func NewGolemNodeServiceClient 

func NewGolemNodeServiceClient(cc grpc.ClientConnInterface) GolemNodeServiceClient

type GolemNodeServiceServer 

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
}

GolemNodeServiceServer is the server API for GolemNodeService service. All implementations must embed UnimplementedGolemNodeServiceServer for forward compatibility.

========================================================================== GolemNodeService — Golem 节点向 Hivemind 注册 / 心跳 / 上报结果 由 Golem 调用, Hivemind 作为 gRPC Server 端 ==========================================================================

type GolemNodeService_HeartbeatClient 

type GolemNodeService_HeartbeatClient = grpc.BidiStreamingClient[HeartbeatRequest, HeartbeatResponse]

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

type GolemNodeService_HeartbeatServer 

type GolemNodeService_HeartbeatServer = grpc.BidiStreamingServer[HeartbeatRequest, HeartbeatResponse]

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

type HeartbeatAction 

type HeartbeatAction int32

HeartbeatAction 心跳响应中 Hivemind 可下发的控制指令 

const (
	HeartbeatAction_HEARTBEAT_ACTION_UNSPECIFIED HeartbeatAction = 0
	HeartbeatAction_HEARTBEAT_ACTION_NONE        HeartbeatAction = 1 // 无操作
	HeartbeatAction_HEARTBEAT_ACTION_DRAIN       HeartbeatAction = 2 // 开始排水
	HeartbeatAction_HEARTBEAT_ACTION_SHUTDOWN    HeartbeatAction = 3 // 要求关闭
)

func (HeartbeatAction) Descriptor 

func (HeartbeatAction) Descriptor() protoreflect.EnumDescriptor

func (HeartbeatAction) Enum 

func (x HeartbeatAction) Enum() *HeartbeatAction

func (HeartbeatAction) EnumDescriptor deprecated 

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

Deprecated: Use HeartbeatAction.Descriptor instead.

func (HeartbeatAction) Number 

func (x HeartbeatAction) Number() protoreflect.EnumNumber

func (HeartbeatAction) String 

func (x HeartbeatAction) String() string

func (HeartbeatAction) Type 

func (HeartbeatAction) Type() protoreflect.EnumType

type HeartbeatRequest 

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
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetLoadInfo 

func (x *HeartbeatRequest) GetLoadInfo() *golem.NodeLoadInfo

func (*HeartbeatRequest) GetNodeId 

func (x *HeartbeatRequest) GetNodeId() string

func (*HeartbeatRequest) GetTimestamp 

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

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

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
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetAcknowledged 

func (x *HeartbeatResponse) GetAcknowledged() bool

func (*HeartbeatResponse) GetAction 

func (x *HeartbeatResponse) GetAction() HeartbeatAction

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type HivemindAdminServiceClient 

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

HivemindAdminServiceClient is the client API for HivemindAdminService 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.

========================================================================== HivemindAdminService — 管理面 API, 供 echoctl / echadm 使用 ==========================================================================

func NewHivemindAdminServiceClient 

func NewHivemindAdminServiceClient(cc grpc.ClientConnInterface) HivemindAdminServiceClient

type HivemindAdminServiceServer 

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
}

HivemindAdminServiceServer is the server API for HivemindAdminService service. All implementations must embed UnimplementedHivemindAdminServiceServer for forward compatibility.

========================================================================== HivemindAdminService — 管理面 API, 供 echoctl / echadm 使用 ==========================================================================

type HivemindControlServiceClient 

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

HivemindControlServiceClient is the client API for HivemindControlService 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.

========================================================================== HivemindControlService — Hivemind 向 Golem 下发任务和管控指令 由 Hivemind 调用, Golem 作为 gRPC Server 端 (或通过双向流实现) ==========================================================================

func NewHivemindControlServiceClient 

func NewHivemindControlServiceClient(cc grpc.ClientConnInterface) HivemindControlServiceClient

type HivemindControlServiceServer 

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
}

HivemindControlServiceServer is the server API for HivemindControlService service. All implementations must embed UnimplementedHivemindControlServiceServer for forward compatibility.

========================================================================== HivemindControlService — Hivemind 向 Golem 下发任务和管控指令 由 Hivemind 调用, Golem 作为 gRPC Server 端 (或通过双向流实现) ==========================================================================

type ListNodesRequest 

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
}

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetPageSize 

func (x *ListNodesRequest) GetPageSize() int32

func (*ListNodesRequest) GetPageToken 

func (x *ListNodesRequest) GetPageToken() string

func (*ListNodesRequest) GetStatusFilter 

func (x *ListNodesRequest) GetStatusFilter() golem.NodeStatus

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListNodesResponse 

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
}

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetBaseResp 

func (x *ListNodesResponse) GetBaseResp() *base.BaseResp

func (*ListNodesResponse) GetNextPageToken 

func (x *ListNodesResponse) GetNextPageToken() string

func (*ListNodesResponse) GetNodes 

func (x *ListNodesResponse) GetNodes() []*golem.NodeInfo

func (*ListNodesResponse) GetTotalCount 

func (x *ListNodesResponse) GetTotalCount() int32

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type RegisterRequest 

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
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetJoinToken 

func (x *RegisterRequest) GetJoinToken() string

func (*RegisterRequest) GetLoadInfo 

func (x *RegisterRequest) GetLoadInfo() *golem.NodeLoadInfo

func (*RegisterRequest) GetNodeInfo 

func (x *RegisterRequest) GetNodeInfo() *golem.NodeInfo

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

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
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetAccepted 

func (x *RegisterResponse) GetAccepted() bool

func (*RegisterResponse) GetBaseResp 

func (x *RegisterResponse) GetBaseResp() *base.BaseResp

func (*RegisterResponse) GetNodeId 

func (x *RegisterResponse) GetNodeId() string

func (*RegisterResponse) GetRejectReason 

func (x *RegisterResponse) GetRejectReason() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type ReportTaskProgressRequest 

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
}

func (*ReportTaskProgressRequest) Descriptor deprecated 

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

Deprecated: Use ReportTaskProgressRequest.ProtoReflect.Descriptor instead.

func (*ReportTaskProgressRequest) GetNodeId 

func (x *ReportTaskProgressRequest) GetNodeId() string

func (*ReportTaskProgressRequest) GetTaskProgress 

func (x *ReportTaskProgressRequest) GetTaskProgress() *golem.TaskProgress

func (*ReportTaskProgressRequest) ProtoMessage 

func (*ReportTaskProgressRequest) ProtoMessage()

func (*ReportTaskProgressRequest) ProtoReflect 

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

func (*ReportTaskProgressRequest) Reset 

func (x *ReportTaskProgressRequest) Reset()

func (*ReportTaskProgressRequest) String 

func (x *ReportTaskProgressRequest) String() string

type ReportTaskProgressResponse 

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
}

func (*ReportTaskProgressResponse) Descriptor deprecated 

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

Deprecated: Use ReportTaskProgressResponse.ProtoReflect.Descriptor instead.

func (*ReportTaskProgressResponse) GetAcknowledged 

func (x *ReportTaskProgressResponse) GetAcknowledged() bool

func (*ReportTaskProgressResponse) GetBaseResp 

func (x *ReportTaskProgressResponse) GetBaseResp() *base.BaseResp

func (*ReportTaskProgressResponse) ProtoMessage 

func (*ReportTaskProgressResponse) ProtoMessage()

func (*ReportTaskProgressResponse) ProtoReflect 

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

func (*ReportTaskProgressResponse) Reset 

func (x *ReportTaskProgressResponse) Reset()

func (*ReportTaskProgressResponse) String 

func (x *ReportTaskProgressResponse) String() string

type ReportTaskResultRequest 

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
}

func (*ReportTaskResultRequest) Descriptor deprecated 

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

Deprecated: Use ReportTaskResultRequest.ProtoReflect.Descriptor instead.

func (*ReportTaskResultRequest) GetNodeId 

func (x *ReportTaskResultRequest) GetNodeId() string

func (*ReportTaskResultRequest) GetTaskResult 

func (x *ReportTaskResultRequest) GetTaskResult() *golem.TaskResult

func (*ReportTaskResultRequest) ProtoMessage 

func (*ReportTaskResultRequest) ProtoMessage()

func (*ReportTaskResultRequest) ProtoReflect 

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

func (*ReportTaskResultRequest) Reset 

func (x *ReportTaskResultRequest) Reset()

func (*ReportTaskResultRequest) String 

func (x *ReportTaskResultRequest) String() string

type ReportTaskResultResponse 

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
}

func (*ReportTaskResultResponse) Descriptor deprecated 

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

Deprecated: Use ReportTaskResultResponse.ProtoReflect.Descriptor instead.

func (*ReportTaskResultResponse) GetAcknowledged 

func (x *ReportTaskResultResponse) GetAcknowledged() bool

func (*ReportTaskResultResponse) GetBaseResp 

func (x *ReportTaskResultResponse) GetBaseResp() *base.BaseResp

func (*ReportTaskResultResponse) ProtoMessage 

func (*ReportTaskResultResponse) ProtoMessage()

func (*ReportTaskResultResponse) ProtoReflect 

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

func (*ReportTaskResultResponse) Reset 

func (x *ReportTaskResultResponse) Reset()

func (*ReportTaskResultResponse) String 

func (x *ReportTaskResultResponse) String() string

type UncordonNodeRequest 

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

func (*UncordonNodeRequest) Descriptor deprecated 

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

Deprecated: Use UncordonNodeRequest.ProtoReflect.Descriptor instead.

func (*UncordonNodeRequest) GetNodeId 

func (x *UncordonNodeRequest) GetNodeId() string

func (*UncordonNodeRequest) ProtoMessage 

func (*UncordonNodeRequest) ProtoMessage()

func (*UncordonNodeRequest) ProtoReflect 

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

func (*UncordonNodeRequest) Reset 

func (x *UncordonNodeRequest) Reset()

func (*UncordonNodeRequest) String 

func (x *UncordonNodeRequest) String() string

type UncordonNodeResponse 

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
}

func (*UncordonNodeResponse) Descriptor deprecated 

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

Deprecated: Use UncordonNodeResponse.ProtoReflect.Descriptor instead.

func (*UncordonNodeResponse) GetBaseResp 

func (x *UncordonNodeResponse) GetBaseResp() *base.BaseResp

func (*UncordonNodeResponse) GetSuccess 

func (x *UncordonNodeResponse) GetSuccess() bool

func (*UncordonNodeResponse) ProtoMessage 

func (*UncordonNodeResponse) ProtoMessage()

func (*UncordonNodeResponse) ProtoReflect 

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

func (*UncordonNodeResponse) Reset 

func (x *UncordonNodeResponse) Reset()

func (*UncordonNodeResponse) String 

func (x *UncordonNodeResponse) String() string

type UnimplementedGolemNodeServiceServer 

type UnimplementedGolemNodeServiceServer struct{}

UnimplementedGolemNodeServiceServer 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 (UnimplementedGolemNodeServiceServer) Deregister 

func (UnimplementedGolemNodeServiceServer) Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)

func (UnimplementedGolemNodeServiceServer) Heartbeat 

func (UnimplementedGolemNodeServiceServer) Heartbeat(grpc.BidiStreamingServer[HeartbeatRequest, HeartbeatResponse]) error

func (UnimplementedGolemNodeServiceServer) Register 

func (UnimplementedGolemNodeServiceServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedGolemNodeServiceServer) ReportTaskProgress 

func (UnimplementedGolemNodeServiceServer) ReportTaskProgress(context.Context, *ReportTaskProgressRequest) (*ReportTaskProgressResponse, error)

func (UnimplementedGolemNodeServiceServer) ReportTaskResult 

func (UnimplementedGolemNodeServiceServer) ReportTaskResult(context.Context, *ReportTaskResultRequest) (*ReportTaskResultResponse, error)

type UnimplementedHivemindAdminServiceServer 

type UnimplementedHivemindAdminServiceServer struct{}

UnimplementedHivemindAdminServiceServer 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 (UnimplementedHivemindAdminServiceServer) CordonNode 

func (UnimplementedHivemindAdminServiceServer) CordonNode(context.Context, *CordonNodeRequest) (*CordonNodeResponse, error)

func (UnimplementedHivemindAdminServiceServer) GetNode 

func (UnimplementedHivemindAdminServiceServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)

func (UnimplementedHivemindAdminServiceServer) ListNodes 

func (UnimplementedHivemindAdminServiceServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)

func (UnimplementedHivemindAdminServiceServer) UncordonNode 

func (UnimplementedHivemindAdminServiceServer) UncordonNode(context.Context, *UncordonNodeRequest) (*UncordonNodeResponse, error)

type UnimplementedHivemindControlServiceServer 

type UnimplementedHivemindControlServiceServer struct{}

UnimplementedHivemindControlServiceServer 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 (UnimplementedHivemindControlServiceServer) CancelTask 

func (UnimplementedHivemindControlServiceServer) CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)

func (UnimplementedHivemindControlServiceServer) DispatchTask 

func (UnimplementedHivemindControlServiceServer) DispatchTask(context.Context, *DispatchTaskRequest) (*DispatchTaskResponse, error)

func (UnimplementedHivemindControlServiceServer) DrainNode 

func (UnimplementedHivemindControlServiceServer) DrainNode(context.Context, *DrainNodeRequest) (*DrainNodeResponse, error)

type UnsafeGolemNodeServiceServer 

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

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

type UnsafeHivemindAdminServiceServer 

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

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

type UnsafeHivemindControlServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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