disttask: add proto pkg for framework and example

build/nogo_config.json

@@ -375,6 +375,7 @@
       "server/conn_test.go": "server/conn_test.go",
       "planner/core/rule_partition_eliminate.go": "planner/core/rule_partition_eliminate code",
       "distsql/": "ignore distsql code",
+      "disttask": "disttask code",
       "dumpling/export": "dumpling/export code",
       "lock/": "lock file",
       "errno/": "errno code",

disttask/example/BUILD.bazel

@@ -0,0 +1,8 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "example",
+    srcs = ["proto.go"],
+    importpath = "github.com/pingcap/tidb/disttask/example",
+    visibility = ["//visibility:public"],
+)

disttask/example/proto.go

@@ -0,0 +1,35 @@
+// Copyright 2023 PingCAP, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package proto
+
+// TaskStep of Example.
+const (
+	StepOne = iota
+	StepTwo
+)
+
+// TaskType of Example.
+const (
+	TaskTypeExample = "Example"
+)
+
+// TaskExample is the example task.
+type TaskExample struct{}
+
+// SubtaskExample is the example subtask.
+type SubtaskExample struct{}
+
+// MinimalTaskExample is the minimal example task.
+type MinimalTaskExample struct{}

disttask/framework/proto/BUILD.bazel

@@ -0,0 +1,8 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "proto",
+    srcs = ["task.go"],
+    importpath = "github.com/pingcap/tidb/disttask/framework/proto",
+    visibility = ["//visibility:public"],
+)

disttask/framework/proto/task.go

@@ -0,0 +1,77 @@
+// Copyright 2023 PingCAP, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package proto
+
+import (
+	"time"
+)
+
+// task state machine
+//  1. succeed:			pending -> running -> succeed
+//  2. failed:			pending -> running -> reverting -> failed/revert_failed
+//  3. canceled:		pending -> running -> reverting -> canceled/revert_failed
+//  3. pause/resume:	pending -> running -> pausing -> paused -> running
+//
+// subtask state machine
+//  1. succeed/failed:	pending -> running -> succeed/failed
+//  2. canceled:		pending -> running -> canceled
+//  3. rollback:		revert_pending -> reverting -> reverted/revert_failed
+//  4. pause/resume:	pending -> running -> paused -> running
+const (
+	TaskStatePending       = "pending"
+	TaskStateRunning       = "running"
+	TaskStateSucceed       = "succeed"
+	TaskStateReverting     = "reverting"
+	TaskStateFailed        = "failed"
+	TaskStateRevertFailed  = "revert_failed"
+	TaskStateCanceled      = "canceled"
+	TaskStatePausing       = "pausing"
+	TaskStatePaused        = "paused"
+	TaskStateRevertPending = "revert_pending"
+	TaskStateReverted      = "reverted"
+)
+
+// TaskStep is the step of task.
+const (
+	StepInit int64 = -1
+)
+
+// Task represents the task of distribute framework.
+type Task struct {
+	ID           int64
+	Type         string
+	State        string
+	Step         int64
+	DispatcherID string
+	Concurrency  uint64
+	StartTime    time.Time
+	Meta         []byte
+}
+
+// Subtask represents the subtask of distribute framework.
+// Each task is divided into multiple subtasks by dispatcher.
+type Subtask struct {
+	ID          int64
+	Type        string
+	TaskID      int64
+	State       string
+	SchedulerID string
+	StartTime   time.Time
+	Meta        []byte
+}
+
+// MinimalTask is the minimal task of distribute framework.
+// Each subtask is divided into multiple minimal tasks by scheduler.
+type MinimalTask interface{}