v2boardpb

type BaseConfig struct {
	PushInterval int32 `protobuf:"varint,1,opt,name=push_interval,json=pushInterval,proto3" json:"push_interval,omitempty"` // 流量上报间隔(秒)
	PullInterval int32 `protobuf:"varint,2,opt,name=pull_interval,json=pullInterval,proto3" json:"pull_interval,omitempty"` // 配置拉取间隔(秒)
	// contains filtered or unexported fields
}

type ConfigChangeNotification struct {
	Type      ConfigChangeNotification_ChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=v2board.ConfigChangeNotification_ChangeType" json:"type,omitempty"`
	NodeId    uint32                              `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Timestamp int64                               `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Payload   []byte                              `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` // 变更内容(JSON)
	// contains filtered or unexported fields
}

type ConfigChangeNotification_ChangeType int32

type ConfigSyncRequest struct {
	NodeId       uint32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	LastSyncTime int64  `protobuf:"varint,2,opt,name=last_sync_time,json=lastSyncTime,proto3" json:"last_sync_time,omitempty"` // 上次同步时间
	// contains filtered or unexported fields
}

type ConfigSyncResponse struct {
	HasChanges bool                `protobuf:"varint,1,opt,name=has_changes,json=hasChanges,proto3" json:"has_changes,omitempty"`
	Config     *NodeConfigResponse `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`                      // 如果有变更
	Users      []*UserInfo         `protobuf:"bytes,3,rep,name=users,proto3" json:"users,omitempty"`                        // 用户列表(全量或增量)
	SyncTime   int64               `protobuf:"varint,4,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"` // 当前同步时间
	// contains filtered or unexported fields
}

type ConfigSyncServiceClient interface {
	// 请求配置同步
	SyncConfig(ctx context.Context, in *ConfigSyncRequest, opts ...grpc.CallOption) (*ConfigSyncResponse, error)
	// 双向流：配置变更实时推送
	// 面板推送变更，节点确认接收
	ConfigChanges(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ConfigChangeNotification, StatusResponse], error)
	// 全量同步 (节点启动时)
	FullSync(ctx context.Context, in *ConfigSyncRequest, opts ...grpc.CallOption) (*ConfigSyncResponse, error)
}

type ConfigSyncServiceServer interface {
	// 请求配置同步
	SyncConfig(context.Context, *ConfigSyncRequest) (*ConfigSyncResponse, error)
	// 双向流：配置变更实时推送
	// 面板推送变更，节点确认接收
	ConfigChanges(grpc.BidiStreamingServer[ConfigChangeNotification, StatusResponse]) error
	// 全量同步 (节点启动时)
	FullSync(context.Context, *ConfigSyncRequest) (*ConfigSyncResponse, error)
	// contains filtered or unexported methods
}

type ConfigSyncService_ConfigChangesClient = grpc.BidiStreamingClient[ConfigChangeNotification, StatusResponse]

type ConfigSyncService_ConfigChangesServer = grpc.BidiStreamingServer[ConfigChangeNotification, StatusResponse]

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

type HealthCheckRequest struct {
	NodeId  uint32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckResponse struct {
	Status        HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=v2board.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	ServerVersion string                            `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	Timestamp     int64                             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckResponse_ServingStatus int32

type HealthServiceClient interface {
	// 简单健康检查
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// 双向流：持续健康检查
	Watch(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[HealthCheckRequest, HealthCheckResponse], error)
}

type HealthServiceServer interface {
	// 简单健康检查
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// 双向流：持续健康检查
	Watch(grpc.BidiStreamingServer[HealthCheckRequest, HealthCheckResponse]) error
	// contains filtered or unexported methods
}

type HealthService_WatchClient = grpc.BidiStreamingClient[HealthCheckRequest, HealthCheckResponse]

type HealthService_WatchServer = grpc.BidiStreamingServer[HealthCheckRequest, HealthCheckResponse]

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

type NodeConfigResponse struct {
	NodeType        string            `protobuf:"bytes,1,opt,name=node_type,json=nodeType,proto3" json:"node_type,omitempty"`
	Type            string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // 与 node_type 一致
	Host            string            `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	ServerPort      int32             `protobuf:"varint,4,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	ServerName      string            `protobuf:"bytes,5,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	Tls             int32             `protobuf:"varint,6,opt,name=tls,proto3" json:"tls,omitempty"`                              // 0=无, 1=TLS, 2=Reality
	TlsSettings     map[string]string ``                                                                                          /* 168-byte string literal not displayed */
	Network         string            `protobuf:"bytes,8,opt,name=network,proto3" json:"network,omitempty"`                       // tcp, ws, grpc, etc.
	NetworkSettings map[string]string ``                                                                                          /* 180-byte string literal not displayed */
	Cipher          string            `protobuf:"bytes,10,opt,name=cipher,proto3" json:"cipher,omitempty"`                        // SS加密方式
	Flow            string            `protobuf:"bytes,11,opt,name=flow,proto3" json:"flow,omitempty"`                            // VLESS flow
	ServerKey       string            `protobuf:"bytes,12,opt,name=server_key,json=serverKey,proto3" json:"server_key,omitempty"` // SS2022服务器密钥
	BaseConfig      *BaseConfig       `protobuf:"bytes,13,opt,name=base_config,json=baseConfig,proto3" json:"base_config,omitempty"`
	Routes          []*Route          `protobuf:"bytes,14,rep,name=routes,proto3" json:"routes,omitempty"`
	SendThrough     string            `protobuf:"bytes,15,opt,name=send_through,json=sendThrough,proto3" json:"send_through,omitempty"`
	Extra           map[string]string `` // 扩展配置
	/* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NodeLogBatchRequest struct {
	NodeId uint32          `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Logs   []*NodeLogEntry `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

type NodeLogEntry struct {
	Level      string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`                             // debug/info/warning/error
	Source     string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`                           // 模块/组件名称
	Message    string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`                         // 日志正文
	Timestamp  int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                    // Unix 时间戳（秒，或毫秒也兼容）
	FieldsJson string `protobuf:"bytes,5,opt,name=fields_json,json=fieldsJson,proto3" json:"fields_json,omitempty"` // 结构化附加字段（JSON字符串）
	TraceId    string `protobuf:"bytes,6,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`          // 关联追踪ID
	// contains filtered or unexported fields
}

type NodeLogServiceClient interface {
	// 批量上报节点运行日志
	ReportLogs(ctx context.Context, in *NodeLogBatchRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

type NodeLogServiceServer interface {
	// 批量上报节点运行日志
	ReportLogs(context.Context, *NodeLogBatchRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

type NodeRegisterRequest struct {
	AuthKey            string   `protobuf:"bytes,1,opt,name=auth_key,json=authKey,proto3" json:"auth_key,omitempty"`                                  // 授权密钥
	Name               string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                                       // 节点名称
	Host               string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`                                                       // 节点地址
	Port               int32    `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`                                                      // API端口
	ServerVersion      string   `protobuf:"bytes,5,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`                // 节点版本
	ServerOs           string   `protobuf:"bytes,6,opt,name=server_os,json=serverOs,proto3" json:"server_os,omitempty"`                               // 操作系统
	SupportedProtocols []string `protobuf:"bytes,7,rep,name=supported_protocols,json=supportedProtocols,proto3" json:"supported_protocols,omitempty"` // 支持的协议列表
	// contains filtered or unexported fields
}

type NodeRegisterResponse struct {
	NodeId  uint32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // 节点ID
	ApiKey  string `protobuf:"bytes,2,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`  // API密钥
	Secret  string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`                // 共享密钥
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type NodeServiceClient interface {
	// 节点注册
	Register(ctx context.Context, in *NodeRegisterRequest, opts ...grpc.CallOption) (*NodeRegisterResponse, error)
	// 获取节点配置
	GetConfig(ctx context.Context, in *NodeConfigRequest, opts ...grpc.CallOption) (*NodeConfigResponse, error)
	// 上报节点状态 (替代心跳)
	ReportStatus(ctx context.Context, in *NodeStatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// 双向流：节点状态实时通信
	StatusStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[NodeStatusRequest, NodeConfigResponse], error)
}

type NodeServiceServer interface {
	// 节点注册
	Register(context.Context, *NodeRegisterRequest) (*NodeRegisterResponse, error)
	// 获取节点配置
	GetConfig(context.Context, *NodeConfigRequest) (*NodeConfigResponse, error)
	// 上报节点状态 (替代心跳)
	ReportStatus(context.Context, *NodeStatusRequest) (*StatusResponse, error)
	// 双向流：节点状态实时通信
	StatusStream(grpc.BidiStreamingServer[NodeStatusRequest, NodeConfigResponse]) error
	// contains filtered or unexported methods
}

type NodeService_StatusStreamClient = grpc.BidiStreamingClient[NodeStatusRequest, NodeConfigResponse]

type NodeService_StatusStreamServer = grpc.BidiStreamingServer[NodeStatusRequest, NodeConfigResponse]

type NodeStatusRequest struct {
	NodeId      uint32  `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	CpuUsage    float64 `protobuf:"fixed64,2,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	MemoryUsage float64 `protobuf:"fixed64,3,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
	DiskUsage   float64 `protobuf:"fixed64,4,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	Uptime      int64   `protobuf:"varint,5,opt,name=uptime,proto3" json:"uptime,omitempty"`
	OnlineUsers int32   `protobuf:"varint,6,opt,name=online_users,json=onlineUsers,proto3" json:"online_users,omitempty"`
	Upload      int64   `protobuf:"varint,7,opt,name=upload,proto3" json:"upload,omitempty"`     // 本次上报的上传流量增量
	Download    int64   `protobuf:"varint,8,opt,name=download,proto3" json:"download,omitempty"` // 本次上报的下载流量增量
	// contains filtered or unexported fields
}

type OnlineData struct {
	Ips       []string `protobuf:"bytes,1,rep,name=ips,proto3" json:"ips,omitempty"`              // 在线IP列表
	Timestamp int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // 时间戳
	// contains filtered or unexported fields
}

type OnlineReportRequest struct {
	NodeId uint32                 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Online map[uint32]*OnlineData `` // 用户ID -> 在线数据
	/* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Route struct {
	Match  string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse 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"`
	Code    int32  `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

type TrafficData struct {
	Upload   int64 `protobuf:"varint,1,opt,name=upload,proto3" json:"upload,omitempty"`     // 上传流量 (bytes)
	Download int64 `protobuf:"varint,2,opt,name=download,proto3" json:"download,omitempty"` // 下载流量 (bytes)
	// contains filtered or unexported fields
}

type TrafficReportRequest struct {
	NodeId   uint32                  `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Traffics map[uint32]*TrafficData `` // 用户ID -> 流量数据
	/* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type TrafficReportResponse 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"`
	Balances map[uint32]int64 `` // 用户ID -> 更新后的余额(可选)
	/* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

type TrafficServiceClient interface {
	// 批量上报流量
	ReportTraffic(ctx context.Context, in *TrafficReportRequest, opts ...grpc.CallOption) (*TrafficReportResponse, error)
	// 上报在线状态
	ReportOnline(ctx context.Context, in *OnlineReportRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// 双向流：实时流量上报
	// 节点持续上报，面板实时响应
	TrafficStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TrafficReportRequest, TrafficReportResponse], error)
	// 双向流：实时在线状态
	OnlineStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[OnlineReportRequest, StatusResponse], error)
}

type TrafficServiceServer interface {
	// 批量上报流量
	ReportTraffic(context.Context, *TrafficReportRequest) (*TrafficReportResponse, error)
	// 上报在线状态
	ReportOnline(context.Context, *OnlineReportRequest) (*StatusResponse, error)
	// 双向流：实时流量上报
	// 节点持续上报，面板实时响应
	TrafficStream(grpc.BidiStreamingServer[TrafficReportRequest, TrafficReportResponse]) error
	// 双向流：实时在线状态
	OnlineStream(grpc.BidiStreamingServer[OnlineReportRequest, StatusResponse]) error
	// contains filtered or unexported methods
}

type TrafficService_OnlineStreamClient = grpc.BidiStreamingClient[OnlineReportRequest, StatusResponse]

type TrafficService_OnlineStreamServer = grpc.BidiStreamingServer[OnlineReportRequest, StatusResponse]

type TrafficService_TrafficStreamClient = grpc.BidiStreamingClient[TrafficReportRequest, TrafficReportResponse]

type TrafficService_TrafficStreamServer = grpc.BidiStreamingServer[TrafficReportRequest, TrafficReportResponse]

type UnimplementedConfigSyncServiceServer struct{}

type UnimplementedHealthServiceServer struct{}

type UnimplementedNodeLogServiceServer struct{}

type UnimplementedNodeServiceServer struct{}

type UnimplementedTrafficServiceServer struct{}

type UnimplementedUserServiceServer struct{}

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

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

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

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

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

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

type UserChangeNotification struct {
	Type      UserChangeNotification_ChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=v2board.UserChangeNotification_ChangeType" json:"type,omitempty"`
	User      *UserInfo                         `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Timestamp int64                             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type UserChangeNotification_ChangeType int32

type UserInfo struct {
	Id             uint32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid           string            `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	SpeedLimit     int64             `protobuf:"varint,3,opt,name=speed_limit,json=speedLimit,proto3" json:"speed_limit,omitempty"`             // 速度限制 (bytes/s)
	DeviceLimit    int32             `protobuf:"varint,4,opt,name=device_limit,json=deviceLimit,proto3" json:"device_limit,omitempty"`          // 设备限制
	ExpiredAt      int64             `protobuf:"varint,5,opt,name=expired_at,json=expiredAt,proto3" json:"expired_at,omitempty"`                // 过期时间
	TransferEnable int64             `protobuf:"varint,6,opt,name=transfer_enable,json=transferEnable,proto3" json:"transfer_enable,omitempty"` // 总流量
	UsedUpload     int64             `protobuf:"varint,7,opt,name=used_upload,json=usedUpload,proto3" json:"used_upload,omitempty"`             // 已用上传
	UsedDownload   int64             `protobuf:"varint,8,opt,name=used_download,json=usedDownload,proto3" json:"used_download,omitempty"`       // 已用下载
	Extra          map[string]string ``                                                                                                         // 扩展信息
	/* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UserListRequest struct {
	NodeId   uint32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Page     int32  `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

type UserListResponse struct {
	Users     []*UserInfo `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	Total     int64       `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	UpdatedAt int64       `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // 数据更新时间
	// contains filtered or unexported fields
}

type UserServiceClient interface {
	// 获取用户列表
	GetUsers(ctx context.Context, in *UserListRequest, opts ...grpc.CallOption) (*UserListResponse, error)
	// 双向流：用户变更实时推送
	// 面板推送用户变更，节点确认接收
	UserChanges(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[UserChangeNotification, StatusResponse], error)
}

type UserServiceServer interface {
	// 获取用户列表
	GetUsers(context.Context, *UserListRequest) (*UserListResponse, error)
	// 双向流：用户变更实时推送
	// 面板推送用户变更，节点确认接收
	UserChanges(grpc.BidiStreamingServer[UserChangeNotification, StatusResponse]) error
	// contains filtered or unexported methods
}

type UserService_UserChangesClient = grpc.BidiStreamingClient[UserChangeNotification, StatusResponse]

type UserService_UserChangesServer = grpc.BidiStreamingServer[UserChangeNotification, StatusResponse]