jobstore

type Delivery struct {
	// ID 全局唯一，同时作为回调里的 X-OFD-Delivery，供接收方去重。
	ID string `json:"id"`
	// JobID 关联的转换任务，仅供排障时串联。
	JobID string `json:"job_id,omitempty"`
	// Target 是预注册的通知目标名，不是 URL——URL 与密钥都在服务端侧配置，
	// 调用方碰不到，避免被当作伪造回调的凭据。
	Target string `json:"target"`
	// Event 为 "succeeded" 或 "failed"。
	Event string `json:"event"`
	// Payload 是回调请求体，已序列化好的 JSON。
	Payload json.RawMessage `json:"payload"`
	// Attempts 已经尝试的次数。
	Attempts int `json:"attempts"`
	// MaxAttempts 超过后转为 abandoned。
	MaxAttempts int `json:"max_attempts"`
	// DueAt 下次尝试时间；重试时按退避往后推。
	DueAt time.Time `json:"due_at"`
	// State 见 DeliveryState。
	State DeliveryState `json:"state"`
	// LastError 最近一次失败原因。
	LastError string `json:"last_error,omitempty"`
}

type DeliveryState string

type Job struct {
	ID    string `json:"id"`
	State State  `json:"state"`
	Lane  Lane   `json:"lane"`
	Order Order  `json:"order"`
	// From 是提交时调用方声明的输入格式，可能为空——大多数请求靠服务端
	// 按魔数与文件名推断，声明值只是覆盖手段。
	From string `json:"from"`
	// FromActual 是服务端实际判定的输入格式，成功后回写。
	//
	// 不能拿 From 当统计口径：README 里写明输入格式由服务端解析、不采信
	// 调用方的文件名，而 From 恰好就是那个声明值。一个 OFD 内容配了
	// .html 名字、按 html 导入器转换的任务，在 From 里会记成 ofd→pdf。
	// 空表示尚未判定（任务失败或仍在排队）。
	FromActual string `json:"from_actual,omitempty"`
	To         string `json:"to"`
	// InputBytes 是输入字节数。
	//
	// 提交时先记已收到的部分（上传的字节，URL 输入为 0），转换成功后用
	// 实际落盘的尺寸覆盖，所以 URL 输入失败时这一项是 0——不是漏记，
	// 是那时确实没有拿到完整内容。
	InputBytes int64 `json:"input_bytes,omitempty"`
	// Request 是提交时的原始请求 JSON。
	Request json.RawMessage `json:"request,omitempty"`
	// Output 是终态时的结果位置。
	Output Output `json:"output,omitempty"`
	// Error 是失败原因，终态时对调用方可见。
	Error     string    `json:"error,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	// DueAt 是任务最早可被取走的时刻。为零表示立即可取；重试时用它实现退避，
	// 靠把它塞进 delayed 队列实现，而不是靠 sleep——sleep 会占住一个 worker。
	DueAt        time.Time `json:"due_at,omitempty"`
	StartedAt    time.Time `json:"started_at,omitempty"`
	FinishedAt   time.Time `json:"finished_at,omitempty"`
	Attempt      int       `json:"attempt"`
	NotifyTarget string    `json:"notify_target,omitempty"`
	// NotifyEvents 限定要通知的事件，空表示用目标的默认集合。
	NotifyEvents []string `json:"notify_events,omitempty"`
}

type Lane string

type Order int

type Output struct {
	Kind   string `json:"kind"`
	Path   string `json:"path,omitempty"`
	Bucket string `json:"bucket,omitempty"`
	Key    string `json:"key,omitempty"`
	URL    string `json:"url,omitempty"`
	Size   int64  `json:"size"`
	// Files 是产物的文件名清单，逐页输出会有多项。
	//
	// 单有这个字段是不够的：调用方能指定 output.filename，但产物名由格式扩展名
	// 决定，逐页输出还会带页号（thumb-0001.png）。只报目录等于让调用方还得去
	// 猜文件名或者列目录——那正是"不然用户如何知道"要解决的问题。
	Files []string `json:"files,omitempty"`
}

type State string

type StatsPair struct {
	From string
	To   string
}

type StatsSnapshot struct {
	// Since 是第一次记账的时间。没有转换发生过时为零值。
	//
	// 没有它，调用方只看到一个总数却不知道该按什么时间跨度算速率——
	// "1234 次转换"在一周和一年里是完全不同的两件事。
	Since time.Time `json:"since"`
	// Jobs 按 输入格式 -> 输出格式 -> 状态 索引的转换次数。
	Jobs map[StatsTriple]uint64
	// InputBytes 按输入格式索引的输入字节总量。
	InputBytes map[string]uint64
	// OutputBytes 按 输入格式 -> 输出格式 索引的输出字节总量。
	OutputBytes map[StatsPair]uint64
}

type StatsTriple struct {
	From  string
	To    string
	State string
}

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