taskv1

type CreateTaskRequest struct {
	Name                string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                                             // 任务名称
	Type                TaskType          `protobuf:"varint,2,opt,name=type,proto3,enum=task.v1.TaskType" json:"type,omitempty"`                                      // 任务类型: RECURRING-定时任务, ONE_TIME-一次性任务
	CronExpr            string            `protobuf:"bytes,3,opt,name=cron_expr,json=cronExpr,proto3" json:"cron_expr,omitempty"`                                     // cron 表达式(定时任务必填,一次性任务可选用于定时触发)
	GrpcConfig          *GrpcConfig       `protobuf:"bytes,4,opt,name=grpc_config,json=grpcConfig,proto3" json:"grpc_config,omitempty"`                               // gRPC 配置
	HttpConfig          *HTTPConfig       `protobuf:"bytes,5,opt,name=http_config,json=httpConfig,proto3" json:"http_config,omitempty"`                               // HTTP 配置
	RetryConfig         *RetryConfig      `protobuf:"bytes,6,opt,name=retry_config,json=retryConfig,proto3" json:"retry_config,omitempty"`                            // 重试配置
	MaxExecutionSeconds int64             `protobuf:"varint,7,opt,name=max_execution_seconds,json=maxExecutionSeconds,proto3" json:"max_execution_seconds,omitempty"` // 最大执行秒数,默认24小时
	ScheduleParams      map[string]string ``                                                                                                                          // 调度参数(如分页偏移量、处理进度等)
	/* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateTaskResponse struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // 创建的任务ID
	// contains filtered or unexported fields
}

type DeleteTaskRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // 任务ID
	// contains filtered or unexported fields
}

type DeleteTaskResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 是否成功
	// contains filtered or unexported fields
}

type GetTaskRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // 任务ID
	// contains filtered or unexported fields
}

type GetTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // 任务信息
	// contains filtered or unexported fields
}

type GrpcConfig struct {
	ServiceName string            `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // 服务名称
	AuthToken   string            `protobuf:"bytes,2,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`       // 认证 token
	HandlerName string            `protobuf:"bytes,3,opt,name=handler_name,json=handlerName,proto3" json:"handler_name,omitempty"` // 执行节点支持的方法名称,如 shell、python、demo
	Params      map[string]string ``                                                                                               // 传递参数
	/* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type HTTPConfig struct {
	Endpoint string            `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // HTTP 端点
	Params   map[string]string ``                                                                      // 传递参数
	/* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListTasksRequest struct {
	Page     int32      `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`                             // 页码
	PageSize int32      `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`     // 每页数量
	Status   TaskStatus `protobuf:"varint,3,opt,name=status,proto3,enum=task.v1.TaskStatus" json:"status,omitempty"` // 按状态过滤(可选)
	Type     TaskType   `protobuf:"varint,4,opt,name=type,proto3,enum=task.v1.TaskType" json:"type,omitempty"`       // 按类型过滤(可选)
	// contains filtered or unexported fields
}

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`  // 任务列表
	Total int64   `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` // 总数
	// contains filtered or unexported fields
}

type RetryConfig struct {
	MaxRetries      int32 `protobuf:"varint,1,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`                // 最大重试次数
	InitialInterval int64 `protobuf:"varint,2,opt,name=initial_interval,json=initialInterval,proto3" json:"initial_interval,omitempty"` // 初始重试间隔(毫秒)
	MaxInterval     int64 `protobuf:"varint,3,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`             // 最大重试间隔(毫秒)
	// contains filtered or unexported fields
}

type Task struct {
	Id                  int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                                                // 任务ID
	Name                string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                                             // 任务名称
	Type                TaskType          `protobuf:"varint,3,opt,name=type,proto3,enum=task.v1.TaskType" json:"type,omitempty"`                                      // 任务类型
	CronExpr            string            `protobuf:"bytes,4,opt,name=cron_expr,json=cronExpr,proto3" json:"cron_expr,omitempty"`                                     // cron 表达式(定时任务必填,一次性任务可选用于定时触发)
	GrpcConfig          *GrpcConfig       `protobuf:"bytes,5,opt,name=grpc_config,json=grpcConfig,proto3" json:"grpc_config,omitempty"`                               // gRPC 配置
	HttpConfig          *HTTPConfig       `protobuf:"bytes,6,opt,name=http_config,json=httpConfig,proto3" json:"http_config,omitempty"`                               // HTTP 配置
	RetryConfig         *RetryConfig      `protobuf:"bytes,7,opt,name=retry_config,json=retryConfig,proto3" json:"retry_config,omitempty"`                            // 重试配置
	MaxExecutionSeconds int64             `protobuf:"varint,8,opt,name=max_execution_seconds,json=maxExecutionSeconds,proto3" json:"max_execution_seconds,omitempty"` // 最大执行秒数,默认24小时
	ScheduleNodeId      string            `protobuf:"bytes,9,opt,name=schedule_node_id,json=scheduleNodeId,proto3" json:"schedule_node_id,omitempty"`                 // 调度节点ID
	ScheduleParams      map[string]string ``                                                                                                                          // 调度参数(如分页偏移量、处理进度等)
	/* 178-byte string literal not displayed */
	NextTime int64      `protobuf:"varint,11,opt,name=next_time,json=nextTime,proto3" json:"next_time,omitempty"`     // 下次执行时间戳
	Status   TaskStatus `protobuf:"varint,12,opt,name=status,proto3,enum=task.v1.TaskStatus" json:"status,omitempty"` // 任务状态
	Version  int64      `protobuf:"varint,13,opt,name=version,proto3" json:"version,omitempty"`                       // 版本号,用于乐观锁
	Ctime    int64      `protobuf:"varint,14,opt,name=ctime,proto3" json:"ctime,omitempty"`                           // 创建时间戳
	Utime    int64      `protobuf:"varint,15,opt,name=utime,proto3" json:"utime,omitempty"`                           // 更新时间戳
	// contains filtered or unexported fields
}

type TaskServiceClient interface {
	// 创建任务
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	// 获取任务
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)
	// 更新任务
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)
	// 删除任务
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskResponse, error)
	// 列出任务
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
}

type TaskServiceServer interface {
	// 创建任务
	CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
	// 获取任务
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
	// 更新任务
	UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)
	// 删除任务
	DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error)
	// 列出任务
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	// contains filtered or unexported methods
}

type TaskStatus int32

type TaskType int32

type UnimplementedTaskServiceServer struct{}

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateTaskRequest struct {
	Id                  int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                                                // 任务ID
	Name                string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                                             // 任务名称
	Type                TaskType          `protobuf:"varint,3,opt,name=type,proto3,enum=task.v1.TaskType" json:"type,omitempty"`                                      // 任务类型
	CronExpr            string            `protobuf:"bytes,4,opt,name=cron_expr,json=cronExpr,proto3" json:"cron_expr,omitempty"`                                     // cron 表达式
	GrpcConfig          *GrpcConfig       `protobuf:"bytes,5,opt,name=grpc_config,json=grpcConfig,proto3" json:"grpc_config,omitempty"`                               // gRPC 配置
	HttpConfig          *HTTPConfig       `protobuf:"bytes,6,opt,name=http_config,json=httpConfig,proto3" json:"http_config,omitempty"`                               // HTTP 配置
	RetryConfig         *RetryConfig      `protobuf:"bytes,7,opt,name=retry_config,json=retryConfig,proto3" json:"retry_config,omitempty"`                            // 重试配置
	MaxExecutionSeconds int64             `protobuf:"varint,8,opt,name=max_execution_seconds,json=maxExecutionSeconds,proto3" json:"max_execution_seconds,omitempty"` // 最大执行秒数
	ScheduleParams      map[string]string ``                                                                                                                          // 调度参数
	/* 177-byte string literal not displayed */
	Status TaskStatus `protobuf:"varint,10,opt,name=status,proto3,enum=task.v1.TaskStatus" json:"status,omitempty"` // 任务状态
	// contains filtered or unexported fields
}

type UpdateTaskResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 是否成功
	// contains filtered or unexported fields
}