executor

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

type ExecutionResult struct {
	Success   bool        `json:"success"`
	Message   string      `json:"message"`
	Data      interface{} `json:"data,omitempty"`
	StartTime int64       `json:"start_time"`
	EndTime   int64       `json:"end_time"`
	Duration  int64       `json:"duration"` // 毫秒
}

type Executor interface {
	// Execute 执行任务
	Execute(ctx context.Context, job domain.CronJob) (*ExecutionResult, error)

	// Validate 校验任务配置是否有效（创建任务时调用）
	Validate(ctx context.Context, job domain.CronJob) error

	// Type 返回执行器类型
	Type() domain.TaskType
}

type ExecutorFactory interface {
	// GetExecutor 根据任务类型获取执行器
	GetExecutor(taskType domain.TaskType) (Executor, error)
	// ValidateTask 校验任务配置是否有效
	ValidateTask(ctx context.Context, job domain.CronJob) error
}

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

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

type GRPCTaskConfig struct {
	Target      string            `json:"target"`       // gRPC服务地址，如 "localhost:50051"
	Service     string            `json:"service"`      // 服务名，如 "helloworld.Greeter"
	Method      string            `json:"method"`       // 方法名，如 "SayHello"
	RequestData string            `json:"request_data"` // 请求数据（JSON格式）
	Metadata    map[string]string `json:"metadata"`     // gRPC元数据
}

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

type HTTPTaskConfig struct {
	URL     string            `json:"url"`
	Method  string            `json:"method"` // GET, POST, PUT, DELETE
	Headers map[string]string `json:"headers"`
	Body    string            `json:"body"`
}

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

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

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