MCPcopy Create free account
hub / github.com/53AI/53AIHub / GetBatch

Method GetBatch

api/service/batch_upload_manager.go:264–284  ·  view source on GitHub ↗

GetBatch 获取批量上传会话

(batchID string)

Source from the content-addressed store, hash-verified

262
263// GetBatch 获取批量上传会话
264func (m *BatchUploadManager) GetBatch(batchID string) (*BatchUpload, error) {
265 m.mu.RLock()
266 batch, exists := m.batches[batchID]
267 m.mu.RUnlock()
268
269 if exists {
270 return batch, nil
271 }
272
273 // 从Redis加载
274 batch, err := m.progressStorage.LoadBatch(batchID)
275 if err != nil {
276 return nil, fmt.Errorf("批次不存在: %s", batchID)
277 }
278
279 m.mu.Lock()
280 m.batches[batchID] = batch
281 m.mu.Unlock()
282
283 return batch, nil
284}
285
286// ValidateUploadToken 验证上传令牌
287func (m *BatchUploadManager) ValidateUploadToken(batchID, token string) bool {

Callers 12

ValidateUploadTokenMethod · 0.95
processUploadTaskMethod · 0.95
CancelBatchMethod · 0.95
CompleteBatchMethod · 0.95
UploadFileMethod · 0.80
GetProgressMethod · 0.80
GetBatchByIDMethod · 0.80
updateBatchProgressMethod · 0.80
cleanupFileRecordMethod · 0.80
resetFileForReuploadMethod · 0.80
CleanupFailedBatchMethod · 0.80

Calls 3

LoadBatchMethod · 0.80
ErrorfMethod · 0.80
UnlockMethod · 0.65

Tested by

no test coverage detected