wscpb

type BatchDispatchRequest struct {
	Items []*DispatchItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // 待投递指令列表 | [EN] Dispatch instructions
	// contains filtered or unexported fields
}

type BatchDispatchResponse struct {
	Results []*DispatchResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // 逐条结果 | [EN] Per-item results
	// contains filtered or unexported fields
}

type BroadcastGroupRequest struct {
	MessageData   []byte `protobuf:"bytes,1,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`        // 序列化后的 HubMessageProto | [EN] Serialized HubMessageProto
	ExcludeSender bool   `protobuf:"varint,2,opt,name=exclude_sender,json=excludeSender,proto3" json:"exclude_sender,omitempty"` // 是否排除发送者 | [EN] Whether to exclude sender
	SenderId      string `protobuf:"bytes,3,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`                 // 发送者用户ID（用于排除） | [EN] Sender user ID (for exclusion)
	// contains filtered or unexported fields
}

type BroadcastGroupResponse struct {
	Delivered int32 `protobuf:"varint,1,opt,name=delivered,proto3" json:"delivered,omitempty"` // 本节点投递数量 | [EN] Delivered count on this node
	// contains filtered or unexported fields
}

type CheckUsersOnlineRequest struct {
	UserIds []string `protobuf:"bytes,1,rep,name=user_ids,json=userIds,proto3" json:"user_ids,omitempty"` // 待检查的用户ID列表 | [EN] User IDs to check
	// contains filtered or unexported fields
}

type CheckUsersOnlineResponse struct {
	OnlineUsers map[string]bool `` // userID → 是否在本节点在线 | [EN] userID → online on this node
	/* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DispatchItem struct {
	Operation     DispatchOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=wscpb.DispatchOperation" json:"operation,omitempty"` // 操作类型 | [EN] Operation type
	AppId         string            `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`                          // 路由信封 appID（最上层隔离维度）| [EN] Routing envelope appID
	Namespace     string            `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`                               // 路由信封 namespace（空=全局/通配）| [EN] Routing envelope namespace
	GroupIds      []string          `protobuf:"bytes,4,rep,name=group_ids,json=groupIds,proto3" json:"group_ids,omitempty"`                 // 路由信封 groupIDs（群组维度）| [EN] Routing envelope group IDs
	TargetUserId  string            `protobuf:"bytes,5,opt,name=target_user_id,json=targetUserId,proto3" json:"target_user_id,omitempty"`   // 目标用户（send_message/kick_user 使用）| [EN] Target user ID
	Reason        string            `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`                                     // 辅助信息（kick_user 踢人原因）| [EN] Auxiliary info (kick reason)
	MessageData   []byte            `protobuf:"bytes,7,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`        // 序列化后的 HubMessageProto | [EN] Serialized HubMessageProto
	ExcludeSender bool              `protobuf:"varint,8,opt,name=exclude_sender,json=excludeSender,proto3" json:"exclude_sender,omitempty"` // 群组广播是否排除发送者 | [EN] Whether to exclude sender
	SenderId      string            `protobuf:"bytes,9,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`                 // 发送者用户ID（用于排除）| [EN] Sender user ID (for exclusion)
	TraceId       string            `protobuf:"bytes,10,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                   // 全链路追踪ID（每条 item 各自携带，跨节点串联日志）| [EN] Trace ID for full-link correlation
	// contains filtered or unexported fields
}

type DispatchOperation int32

type DispatchResult struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                         // send_message: 是否投递成功; kick_user: 是否成功 | [EN] Whether succeeded
	UserOnline bool   `protobuf:"varint,2,opt,name=user_online,json=userOnline,proto3" json:"user_online,omitempty"` // send_message 专用: 用户是否在线 | [EN] Whether user online (send only)
	Count      int32  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`                             // 投递数/踢出连接数/通知数 | [EN] delivered/kicked/notified count
	Error      string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`                              // 失败原因（成功时为空）| [EN] Failure reason (empty on success)
	// contains filtered or unexported fields
}

type DistributedMessageProto struct {
	Type          string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`                                          // 操作类型 | [EN] Operation Type
	NodeId        string                 `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                        // 源节点ID | [EN] Source Node ID
	TargetId      string                 `protobuf:"bytes,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`                  // 目标ID（用户ID、节点ID等） | [EN] Target ID
	TraceId       string                 `protobuf:"bytes,9,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                     // 全链路追踪ID | [EN] Trace ID
	Message       *HubMessageProto       `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`                                    // 消息数据 | [EN] Message Data
	Reason        string                 `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`                                      // 原因 | [EN] Reason
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                // 时间戳 | [EN] Timestamp
	Namespace     string                 `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`                                // 命名空间ID（路由信封携带，空=全命名空间广播） | [EN] Namespace ID
	GroupIds      []string               `protobuf:"bytes,8,rep,name=group_ids,json=groupIds,proto3" json:"group_ids,omitempty"`                  // 群组ID列表（支持多群组，观察者可订阅多个组） | [EN] Group IDs
	ExcludeSender bool                   `protobuf:"varint,10,opt,name=exclude_sender,json=excludeSender,proto3" json:"exclude_sender,omitempty"` // 是否排除发送者（跨节点群组广播 PubSub 兜底携带，与 gRPC BroadcastGroupRequest 对齐） | [EN] Exclude Sender
	SenderId      string                 `protobuf:"bytes,11,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`                 // 发送者ID（排除发送者时用，跨节点 PubSub 兜底场景） | [EN] Sender ID
	// contains filtered or unexported fields
}

type HubMessageProto struct {
	Id                  string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                                  // 消息ID | [EN] Message ID
	TraceId             string                 `protobuf:"bytes,26,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                                        // 全链路追踪ID | [EN] Trace ID
	MessageType         string                 `protobuf:"bytes,2,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`                             // 消息类型 | [EN] Message Type
	Sender              string                 `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`                                                          // 发送者 | [EN] Sender
	SenderName          string                 `protobuf:"bytes,4,opt,name=sender_name,json=senderName,proto3" json:"sender_name,omitempty"`                                // 发送者名称 | [EN] Sender Name
	SenderType          string                 `protobuf:"bytes,5,opt,name=sender_type,json=senderType,proto3" json:"sender_type,omitempty"`                                // 发送者类型 | [EN] Sender Type
	SenderClient        string                 `protobuf:"bytes,6,opt,name=sender_client,json=senderClient,proto3" json:"sender_client,omitempty"`                          // 发送者客户端 | [EN] Sender Client
	Receiver            string                 `protobuf:"bytes,7,opt,name=receiver,proto3" json:"receiver,omitempty"`                                                      // 接收者 | [EN] Receiver
	ReceiverName        string                 `protobuf:"bytes,8,opt,name=receiver_name,json=receiverName,proto3" json:"receiver_name,omitempty"`                          // 接收者名称 | [EN] Receiver Name
	ReceiverType        string                 `protobuf:"bytes,9,opt,name=receiver_type,json=receiverType,proto3" json:"receiver_type,omitempty"`                          // 接收者类型 | [EN] Receiver Type
	ReceiverClient      string                 `protobuf:"bytes,10,opt,name=receiver_client,json=receiverClient,proto3" json:"receiver_client,omitempty"`                   // 接收者客户端 | [EN] Receiver Client
	ReceiverNode        string                 `protobuf:"bytes,11,opt,name=receiver_node,json=receiverNode,proto3" json:"receiver_node,omitempty"`                         // 接收者节点 | [EN] Receiver Node
	SessionId           string                 `protobuf:"bytes,12,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`                                  // 会话ID | [EN] Session ID
	Content             string                 `protobuf:"bytes,13,opt,name=content,proto3" json:"content,omitempty"`                                                       // 消息内容 | [EN] Content
	Data                *structpb.Struct       `protobuf:"bytes,14,opt,name=data,proto3" json:"data,omitempty"`                                                             // 数据 | [EN] Data
	CreateAt            *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`                                     // 创建时间 | [EN] Create At
	MessageId           string                 `protobuf:"bytes,16,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`                                  // 消息ID | [EN] Message ID
	SeqNo               int64                  `protobuf:"varint,17,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`                                             // 序列号 | [EN] Seq No
	Priority            string                 `protobuf:"bytes,18,opt,name=priority,proto3" json:"priority,omitempty"`                                                     // 优先级 | [EN] Priority
	ReplyToMsgId        string                 `protobuf:"bytes,19,opt,name=reply_to_msg_id,json=replyToMsgId,proto3" json:"reply_to_msg_id,omitempty"`                     // 回复消息ID | [EN] Reply To Msg ID
	RequireAck          bool                   `protobuf:"varint,20,opt,name=require_ack,json=requireAck,proto3" json:"require_ack,omitempty"`                              // 是否需要确认 | [EN] Require Ack
	Source              string                 `protobuf:"bytes,21,opt,name=source,proto3" json:"source,omitempty"`                                                         // 源节点ID | [EN] Source Node ID
	PushType            string                 `protobuf:"bytes,22,opt,name=push_type,json=pushType,proto3" json:"push_type,omitempty"`                                     // 推送类型 | [EN] Push Type
	BroadcastType       string                 `protobuf:"bytes,23,opt,name=broadcast_type,json=broadcastType,proto3" json:"broadcast_type,omitempty"`                      // 广播类型 | [EN] Broadcast Type
	SkipDatabaseStorage bool                   `protobuf:"varint,24,opt,name=skip_database_storage,json=skipDatabaseStorage,proto3" json:"skip_database_storage,omitempty"` // 是否跳过数据库存储 | [EN] Skip Database Storage
	SkipSendToClient    bool                   `protobuf:"varint,25,opt,name=skip_send_to_client,json=skipSendToClient,proto3" json:"skip_send_to_client,omitempty"`        // 是否跳过发送到客户端 | [EN] Skip Send To Client
	Namespace           string                 `protobuf:"bytes,27,opt,name=namespace,proto3" json:"namespace,omitempty"`                                                   // 命名空间ID（路由信封，投递精确隔离用） | [EN] Namespace (routing envelope)
	GroupIds            []string               `protobuf:"bytes,28,rep,name=group_ids,json=groupIds,proto3" json:"group_ids,omitempty"`                                     // 群组ID列表（路由信封，P2P为空） | [EN] Group IDs (routing envelope)
	// contains filtered or unexported fields
}

type KickUserRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // 目标用户ID | [EN] Target user ID
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`               // 踢出原因 | [EN] Kick reason
	// contains filtered or unexported fields
}

type KickUserResponse struct {
	Success           bool  `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                                              // 是否成功 | [EN] Whether kick succeeded
	KickedConnections int32 `protobuf:"varint,2,opt,name=kicked_connections,json=kickedConnections,proto3" json:"kicked_connections,omitempty"` // 踢出的连接数 | [EN] Kicked connection count
	// contains filtered or unexported fields
}

type NodeInfoProto struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                  // 节点ID | [EN] Node ID
	IpAddress   string                 `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`   // IP地址 | [EN] IP Address
	Port        int32                  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`                             // 端口号 | [EN] Port
	Status      string                 `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`                          // 状态 | [EN] Status
	LoadScore   float64                `protobuf:"fixed64,5,opt,name=load_score,json=loadScore,proto3" json:"load_score,omitempty"` // 负载分数 | [EN] Load Score
	LastSeen    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`      // 最后一次看到时间 | [EN] Last Seen
	Connections int64                  `protobuf:"varint,7,opt,name=connections,proto3" json:"connections,omitempty"`               // 连接数 | [EN] Connections
	// contains filtered or unexported fields
}

type NodeServiceClient interface {
	// SendToUser 向本节点的指定用户发送消息（点对点投递）
	// [EN] Send message to a specific user on this node
	SendToUser(ctx context.Context, in *SendToUserRequest, opts ...grpc.CallOption) (*SendToUserResponse, error)
	// CheckUsersOnline 批量检查用户是否在本节点在线（路由探测）
	// [EN] Batch check if users are online on this node
	CheckUsersOnline(ctx context.Context, in *CheckUsersOnlineRequest, opts ...grpc.CallOption) (*CheckUsersOnlineResponse, error)
	// BroadcastGroup 向本节点的群组成员广播消息
	// [EN] Broadcast message to group members on this node
	BroadcastGroup(ctx context.Context, in *BroadcastGroupRequest, opts ...grpc.CallOption) (*BroadcastGroupResponse, error)
	// NotifyObservers 通知本节点的观察者
	// [EN] Notify observers on this node
	NotifyObservers(ctx context.Context, in *NotifyObserversRequest, opts ...grpc.CallOption) (*NotifyObserversResponse, error)
	// KickUser 踢出本节点上的用户
	// [EN] Kick user on this node
	KickUser(ctx context.Context, in *KickUserRequest, opts ...grpc.CallOption) (*KickUserResponse, error)
	// Ping 节点健康检查
	// [EN] Node health check
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// BatchDispatch 跨节点微批合帧投递（多条指令合并为单次 RPC）
	// [EN] Micro-batch dispatch of multiple inter-node delivery instructions in a single RPC
	BatchDispatch(ctx context.Context, in *BatchDispatchRequest, opts ...grpc.CallOption) (*BatchDispatchResponse, error)
}

type NodeServiceServer interface {
	// SendToUser 向本节点的指定用户发送消息（点对点投递）
	// [EN] Send message to a specific user on this node
	SendToUser(context.Context, *SendToUserRequest) (*SendToUserResponse, error)
	// CheckUsersOnline 批量检查用户是否在本节点在线（路由探测）
	// [EN] Batch check if users are online on this node
	CheckUsersOnline(context.Context, *CheckUsersOnlineRequest) (*CheckUsersOnlineResponse, error)
	// BroadcastGroup 向本节点的群组成员广播消息
	// [EN] Broadcast message to group members on this node
	BroadcastGroup(context.Context, *BroadcastGroupRequest) (*BroadcastGroupResponse, error)
	// NotifyObservers 通知本节点的观察者
	// [EN] Notify observers on this node
	NotifyObservers(context.Context, *NotifyObserversRequest) (*NotifyObserversResponse, error)
	// KickUser 踢出本节点上的用户
	// [EN] Kick user on this node
	KickUser(context.Context, *KickUserRequest) (*KickUserResponse, error)
	// Ping 节点健康检查
	// [EN] Node health check
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// BatchDispatch 跨节点微批合帧投递（多条指令合并为单次 RPC）
	// [EN] Micro-batch dispatch of multiple inter-node delivery instructions in a single RPC
	BatchDispatch(context.Context, *BatchDispatchRequest) (*BatchDispatchResponse, error)
	// contains filtered or unexported methods
}

type NotifyObserversRequest struct {
	MessageData []byte `protobuf:"bytes,1,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"` // 序列化后的 HubMessageProto | [EN] Serialized HubMessageProto
	// contains filtered or unexported fields
}

type NotifyObserversResponse struct {
	Notified int32 `protobuf:"varint,1,opt,name=notified,proto3" json:"notified,omitempty"` // 本节点通知数量 | [EN] Notified count on this node
	// contains filtered or unexported fields
}

type PingRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // 发起方节点ID | [EN] Source node ID
	// contains filtered or unexported fields
}

type PingResponse struct {
	NodeId            string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                                   // 响应方节点ID | [EN] Responder node ID
	ActiveConnections int64  `protobuf:"varint,2,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"` // 活跃连接数 | [EN] Active connection count
	Healthy           bool   `protobuf:"varint,3,opt,name=healthy,proto3" json:"healthy,omitempty"`                                              // 节点是否健康 | [EN] Whether node is healthy
	// contains filtered or unexported fields
}

type SendToUserRequest struct {
	UserId      string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`                // 目标用户ID | [EN] Target user ID
	MessageData []byte `protobuf:"bytes,2,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"` // 序列化后的 HubMessageProto | [EN] Serialized HubMessageProto
	// contains filtered or unexported fields
}

type SendToUserResponse struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                         // 是否投递成功 | [EN] Whether delivery succeeded
	Error      string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`                              // 失败原因（成功时为空） | [EN] Failure reason (empty on success)
	UserOnline bool   `protobuf:"varint,3,opt,name=user_online,json=userOnline,proto3" json:"user_online,omitempty"` // 用户是否在本节点在线 | [EN] Whether user is online on this node
	// contains filtered or unexported fields
}

type UnimplementedNodeServiceServer struct{}

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