Documentation
¶
Overview ¶
gen/handler/p2p/p2p_service.go — 设备直传管理面（P2a，2026-10-14 对称节点 spec §7/§8）。hz 首生成桩后本文件转手写（模型引 contracts/gen/p2p， hzmodel 临时目录不落地）。全部端点挂 /admin 组（AdminMiddleware），操作 留审计；数据面=supervisor spawn p2pc 子进程，本层只做编排，不代理文件流量。
p2_ppublic_service.go — 实例间推送邀请收件端点（P3，spec §14）。 hz 首生成桩后转手写（模型引 contracts/gen/p2p）。公开无鉴权（口令即 bearer——邀请体只有口令，资产即权限），归 download 限流桶；入箱幂等去重。
Index ¶
- func AdminP2pCancel(ctx context.Context, c *app.RequestContext)
- func AdminP2pDirectory(ctx context.Context, c *app.RequestContext)
- func AdminP2pInviteAccept(ctx context.Context, c *app.RequestContext)
- func AdminP2pInvitePush(ctx context.Context, c *app.RequestContext)
- func AdminP2pInvites(ctx context.Context, c *app.RequestContext)
- func AdminP2pPublish(ctx context.Context, c *app.RequestContext)
- func AdminP2pRecv(ctx context.Context, c *app.RequestContext)
- func AdminP2pSend(ctx context.Context, c *app.RequestContext)
- func AdminP2pStatus(ctx context.Context, c *app.RequestContext)
- func AdminP2pTasks(ctx context.Context, c *app.RequestContext)
- func PostP2PInvite(ctx context.Context, c *app.RequestContext)
- func SetAuditWriter(fn func(ctx context.Context, action, target string, success bool))
- func SetInviteNotifier(fn func(fromName, code, note string))
- func SetService(s *p2px.Service)
- func SetShareService(s *shareService.Service)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdminP2pCancel ¶
func AdminP2pCancel(ctx context.Context, c *app.RequestContext)
AdminP2pCancel 取消任务。 @router /admin/p2p/cancel [POST]
func AdminP2pDirectory ¶ added in v0.21.0
func AdminP2pDirectory(ctx context.Context, c *app.RequestContext)
AdminP2pDirectory 在线名录透传（2026-10-14 邀请信箱配套:发送卡对端选择器 消费;p2pd 名录零敏感,本层不改写）。 @router /admin/p2p/directory [GET]
func AdminP2pInviteAccept ¶ added in v0.20.0
func AdminP2pInviteAccept(ctx context.Context, c *app.RequestContext)
AdminP2pInviteAccept 认领邀请并发起接收（P3）。 @router /admin/p2p/invites/accept [POST]
func AdminP2pInvitePush ¶ added in v0.20.0
func AdminP2pInvitePush(ctx context.Context, c *app.RequestContext)
AdminP2pInvitePush 把口令推送到目标实例（P3 免口令交接）。 @router /admin/p2p/invite-push [POST]
func AdminP2pInvites ¶ added in v0.20.0
func AdminP2pInvites(ctx context.Context, c *app.RequestContext)
AdminP2pInvites 待收邀请列表（P3）。 @router /admin/p2p/invites [GET]
func AdminP2pPublish ¶
func AdminP2pPublish(ctx context.Context, c *app.RequestContext)
AdminP2pPublish 收件发布为分享（每文件一个分享；复用本地导入铸链）。 @router /admin/p2p/publish [POST]
func AdminP2pRecv ¶
func AdminP2pRecv(ctx context.Context, c *app.RequestContext)
AdminP2pRecv 发起接收。 @router /admin/p2p/recv [POST]
func AdminP2pSend ¶
func AdminP2pSend(ctx context.Context, c *app.RequestContext)
AdminP2pSend 发起发送。 @router /admin/p2p/send [POST]
func AdminP2pStatus ¶
func AdminP2pStatus(ctx context.Context, c *app.RequestContext)
AdminP2pStatus 状态面。 @router /admin/p2p/status [GET]
func AdminP2pTasks ¶
func AdminP2pTasks(ctx context.Context, c *app.RequestContext)
AdminP2pTasks 任务列表。 @router /admin/p2p/tasks [GET]
func PostP2PInvite ¶ added in v0.20.0
func PostP2PInvite(ctx context.Context, c *app.RequestContext)
PostP2PInvite 接收来自其他实例的直传邀请。 @router /api/v1/p2p/invite [POST]
func SetAuditWriter ¶
SetAuditWriter 注入审计写者（wiring 装配）。
func SetInviteNotifier ¶ added in v0.21.0
func SetInviteNotifier(fn func(fromName, code, note string))
SetInviteNotifier 注入邀请到达通知器（bootstrap/wiring 调用）。
func SetShareService ¶
func SetShareService(s *shareService.Service)
SetShareService 注入分享服务（发布为分享复用本地导入铸链）。
Types ¶
This section is empty.
Source Files