Function progressTrackingExample

examples/long-running-tools/main.go:71–103

progressTrackingExample 进度跟踪示例

(ctx context.Context)

// progressTrackingExample 进度跟踪示例
func progressTrackingExample(ctx context.Context) {
	executor := tools.NewLongRunningExecutor()
	tool := NewMockFileUploadTool(executor)

	// 启动任务
	taskID, _ := tool.StartAsync(ctx, map[string]any{
		"file_size":  10000,
		"chunk_size": 1000,
	})

	fmt.Printf("✅ Upload started: %s\n", taskID)

	// 轮询进度
	ticker := time.NewTicker(200 * time.Millisecond)
	defer ticker.Stop()

	for range 10 {
		<-ticker.C

		status, err := executor.GetStatus(ctx, taskID)
		if err != nil {
			log.Fatalf("Failed to get status: %v", err)
		}

		fmt.Printf("   Progress: %.1f%% (%s)\n", status.Progress*100, status.State)

		if status.State.IsTerminal() {
			break
		}
	}

	fmt.Println("✅ Upload completed")
}

// cancellationExample 任务取消示例
func cancellationExample(ctx context.Context) {