feat(core): add outputs and ID to log shippers

core/src/main/java/io/kestra/core/models/tasks/logs/LogShipper.java

@@ -1,14 +1,31 @@
 package io.kestra.core.models.tasks.logs;
 
 import io.kestra.core.models.annotations.Plugin;
+import io.kestra.core.models.tasks.Output;
+import io.kestra.core.models.tasks.runners.TaskRunnerDetailResult;
 import io.kestra.core.runners.RunContext;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Pattern;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
 import reactor.core.publisher.Flux;
 
 @Plugin
-public abstract class LogShipper implements io.kestra.core.models.Plugin {
+@SuperBuilder(toBuilder = true)
+@Getter
+@NoArgsConstructor
+public abstract class LogShipper<T extends Output>  implements io.kestra.core.models.Plugin {
+    @NotNull
+    @NotBlank
+    @Pattern(regexp="^[a-zA-Z0-9][a-zA-Z0-9_-]*")
+    protected String id;
 
+    @NotBlank
+    @Pattern(regexp="\\p{javaJavaIdentifierStart}\\p{javaJavaIdentifierPart}*(\\.\\p{javaJavaIdentifierStart}\\p{javaJavaIdentifierPart}*)*")
     protected String type;
 
-    public abstract void sendLogs(RunContext runContext, Flux<LogRecord> logRecord);
+    public abstract T sendLogs(RunContext runContext, Flux<LogRecord> logRecord) throws Exception;
 
 }

core/src/test/java/io/kestra/core/docs/JsonSchemaGeneratorTest.java

@@ -354,9 +354,11 @@ public static class BetaTask extends Task {
         private String beta;
     }
 
-    public static class TestLogShipper extends LogShipper {
+    public static class TestLogShipper extends LogShipper<VoidOutput> {
 
         @Override
-        public void sendLogs(RunContext runContext, Flux<LogRecord> logRecord) {}
+        public VoidOutput sendLogs(RunContext runContext, Flux<LogRecord> logRecord) throws Exception {
+            return null;
+        }
     }
 }