oplog

type Entry struct {
	Time      time.Time     `json:"time"`
	UserID    int64         `json:"user_id"`
	UserEmail string        `json:"user_email"`
	Method    string        `json:"method"`
	Path      string        `json:"path"`
	Status    int           `json:"status"`
	Duration  time.Duration `json:"duration"`
	RequestID string        `json:"request_id"`
	Action    string        `json:"action"`
	Detail    string        `json:"detail"`
}

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

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

type Sink interface {
	// Write 批量写入条目；返回错误时该批条目被丢弃并计入失败计数。
	Write(ctx context.Context, entries []Entry) error
}