Help us shape the future of Go! Take the 2026 Go Developer Survey

transfer

package
v0.32.41 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package transfer 提供传输日志（上传/下载）的异步记录。

背景：TransferLog 模型/DAO/前端页面早已存在，但全库无任何写入方， 传输日志页与趋势统计的下载序列一直是空数据——本包是写入侧的唯一收口。 记录失败只记运行日志，绝不影响主流程。

落盘能力经 Sink 注入（bootstrap 以 dao 仓储桥接）：pkg 是最底层共享库， 不直接依赖 repo 层。

Index

Constants

View Source 
const (
	OpUpload   = "upload"
	OpDownload = "download"
)

操作类型常量（与 model.TransferLog.Operation 语义一致）

Variables

This section is empty.

Functions

func Flush 

func Flush(d time.Duration)

Flush 等待在飞日志落盘，至多等待 d。优雅停机与测试清理用—— 异步 goroutine 持有 DB/文件句柄写盘，调用方（如测试的 TempDir 清理） 必须先排水再释放底层资源，否则出现"readonly database/目录非空"竞争。

func Record 

func Record(e Entry)

Record 异步记录一次传输（GoSafe 兜底 panic，不影响主流程）。

func SetSink 

func SetSink(s Sink)

SetSink 注入落盘实现（bootstrap 装配调用；须先于任何服务流量）。

Types

type Entry 

type Entry struct {
	Operation  string // upload | download
	FileCodeID uint
	Code       string
	FileName   string
	FileSize   int64
	UserID     *uint
	APIKeyID   *uint // 非 nil 表示该操作经用户级 API Key 认证（泄露排查归因用）
	Username   string
	IP         string
	DurationMs int64
}

Entry 一次传输的归因信息。UserID/APIKeyID 为 nil 表示匿名/JWT 认证。

type Sink 

type Sink interface {
	Create(ctx context.Context, e Entry) error
}

Sink 传输日志落盘能力（repo/db/dao 的仓储实现，bootstrap 装配注入）。

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.