examples

type ComputeParams struct {
	Iterations int     `json:"iterations"` // 计算迭代次数
	Precision  float64 `json:"precision"`  // 计算精度
	Algorithm  string  `json:"algorithm"`  // 计算算法类型
}

type ComputeTask struct {
}

type DatabaseTask struct{}

type DatabaseTaskParams struct {
	ConnectionString string        `json:"connection_string"`
	SQL              string        `json:"sql"`
	Params           []interface{} `json:"params,omitempty"`
	Timeout          int           `json:"timeout_seconds,omitempty"`
	MaxRows          int           `json:"max_rows,omitempty"`
	Operation        string        `json:"operation"` // SELECT, INSERT, UPDATE, DELETE
	BatchSize        int           `json:"batch_size,omitempty"`
}

type DatabaseTaskResult struct {
	Operation    string        `json:"operation"`
	RowsAffected int64         `json:"rows_affected"`
	Duration     time.Duration `json:"duration_ms"`
	Error        string        `json:"error,omitempty"`
	LastInsertID int64         `json:"last_insert_id,omitempty"`
	RowCount     int           `json:"row_count,omitempty"`
}

type EmailService interface {
	SendEmail(ctx context.Context, to, subject, body, from string) error
}

type HTTPRequestParams struct {
	URL     string            `json:"url"`
	Method  string            `json:"method"`
	Headers map[string]string `json:"headers,omitempty"`
	Body    string            `json:"body,omitempty"`
	Timeout int               `json:"timeout,omitempty"` // 超时时间（秒）
}

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

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

type MixedTaskParams struct {
	InputURL       string            `json:"input_url"`       // 输入数据URL
	OutputPath     string            `json:"output_path"`     // 输出文件路径
	ProcessingType string            `json:"processing_type"` // 处理类型：transform, aggregate, analyze
	Filters        map[string]string `json:"filters"`         // 数据过滤条件
	BatchSize      int               `json:"batch_size"`      // 批处理大小
}

type MockEmailService struct{}

type SendEmailParams struct {
	Recipient string `json:"recipient"`
	Subject   string `json:"subject"`
	Body      string `json:"body"`
	From      string `json:"from,omitempty"`
}

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

type ShellCommandParams struct {
	Command     string            `json:"command"`
	Args        []string          `json:"args,omitempty"`
	WorkingDir  string            `json:"working_dir,omitempty"`
	Timeout     int               `json:"timeout_seconds,omitempty"`
	Environment map[string]string `json:"environment,omitempty"`
}

type ShellCommandResult struct {
	Command     string            `json:"command"`
	Args        []string          `json:"args"`
	ExitCode    int               `json:"exit_code"`
	Stdout      string            `json:"stdout"`
	Stderr      string            `json:"stderr"`
	Duration    time.Duration     `json:"duration_ms"`
	WorkingDir  string            `json:"working_dir"`
	Environment map[string]string `json:"environment"`
}

type ShellTask struct{}

type SimpleShellParams struct {
	Command string `json:"command"`
}

type SimpleShellTask struct{}