Merge branch 'vefaas-Java-2024-06-06-online-1034-2025_03_18_18_00_53' into 'integration_2025-03-20_797631155970'

feat: [development task] vefaas-1034-Java (1094078)

See merge request iaasng/volcengine-java-sdk!416

Author: BitsAdmin

volcengine-java-sdk-vefaas/src/main/java/com/volcengine/vefaas/VefaasApi.java

@@ -22,6 +22,7 @@
 import com.volcengine.vefaas.model.EnvForCreateFunctionInput;
 import com.volcengine.vefaas.model.NasStorageForCreateFunctionInput;
 import com.volcengine.vefaas.model.SourceAccessConfigForCreateFunctionInput;
+import com.volcengine.vefaas.model.TagForCreateFunctionInput;
 import com.volcengine.vefaas.model.TlsConfigForCreateFunctionInput;
 import com.volcengine.vefaas.model.TosMountConfigForCreateFunctionInput;
 import com.volcengine.vefaas.model.VpcConfigForCreateFunctionInput;
@@ -89,6 +90,9 @@ public class CreateFunctionRequest {
   @SerializedName("SourceType")
   private String sourceType = null;
 
+  @SerializedName("Tags")
+  private List<TagForCreateFunctionInput> tags = null;
+
   @SerializedName("TlsConfig")
   private TlsConfigForCreateFunctionInput tlsConfig = null;
 
@@ -417,6 +421,33 @@ public void setSourceType(String sourceType) {
     this.sourceType = sourceType;
   }
 
+  public CreateFunctionRequest tags(List<TagForCreateFunctionInput> tags) {
+    this.tags = tags;
+    return this;
+  }
+
+  public CreateFunctionRequest addTagsItem(TagForCreateFunctionInput tagsItem) {
+    if (this.tags == null) {
+      this.tags = new ArrayList<TagForCreateFunctionInput>();
+    }
+    this.tags.add(tagsItem);
+    return this;
+  }
+
+   /**
+   * Get tags
+   * @return tags
+  **/
+  @Valid
+  @Schema(description = "")
+  public List<TagForCreateFunctionInput> getTags() {
+    return tags;
+  }
+
+  public void setTags(List<TagForCreateFunctionInput> tags) {
+    this.tags = tags;
+  }
+
   public CreateFunctionRequest tlsConfig(TlsConfigForCreateFunctionInput tlsConfig) {
     this.tlsConfig = tlsConfig;
     return this;
@@ -501,14 +532,15 @@ public boolean equals(java.lang.Object o) {
         Objects.equals(this.source, createFunctionRequest.source) &&
         Objects.equals(this.sourceAccessConfig, createFunctionRequest.sourceAccessConfig) &&
         Objects.equals(this.sourceType, createFunctionRequest.sourceType) &&
+        Objects.equals(this.tags, createFunctionRequest.tags) &&
         Objects.equals(this.tlsConfig, createFunctionRequest.tlsConfig) &&
         Objects.equals(this.tosMountConfig, createFunctionRequest.tosMountConfig) &&
         Objects.equals(this.vpcConfig, createFunctionRequest.vpcConfig);
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(command, cpuStrategy, description, envs, exclusiveMode, initializerSec, instanceType, maxConcurrency, memoryMB, name, nasStorage, projectName, requestTimeout, runtime, source, sourceAccessConfig, sourceType, tlsConfig, tosMountConfig, vpcConfig);
+    return Objects.hash(command, cpuStrategy, description, envs, exclusiveMode, initializerSec, instanceType, maxConcurrency, memoryMB, name, nasStorage, projectName, requestTimeout, runtime, source, sourceAccessConfig, sourceType, tags, tlsConfig, tosMountConfig, vpcConfig);
   }
 
 
@@ -534,6 +566,7 @@ public String toString() {
     sb.append("    source: ").append(toIndentedString(source)).append("\n");
     sb.append("    sourceAccessConfig: ").append(toIndentedString(sourceAccessConfig)).append("\n");
     sb.append("    sourceType: ").append(toIndentedString(sourceType)).append("\n");
+    sb.append("    tags: ").append(toIndentedString(tags)).append("\n");
     sb.append("    tlsConfig: ").append(toIndentedString(tlsConfig)).append("\n");
     sb.append("    tosMountConfig: ").append(toIndentedString(tosMountConfig)).append("\n");
     sb.append("    vpcConfig: ").append(toIndentedString(vpcConfig)).append("\n");

volcengine-java-sdk-vefaas/src/main/java/com/volcengine/vefaas/model/CreateFunctionRequest.java

@@ -0,0 +1,284 @@
+/*
+ * vefaas
+ * No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen)
+ *
+ * OpenAPI spec version: common-version
+ * 
+ *
+ * NOTE: This class is auto generated by the swagger code generator program.
+ * https://github.com/swagger-api/swagger-codegen.git
+ * Do not edit the class manually.
+ */
+
+package com.volcengine.vefaas.model;
+
+import java.util.Objects;
+import java.util.Arrays;
+import com.google.gson.TypeAdapter;
+import com.google.gson.annotations.JsonAdapter;
+import com.google.gson.annotations.SerializedName;
+import com.google.gson.stream.JsonReader;
+import com.google.gson.stream.JsonWriter;
+import com.volcengine.vefaas.model.KafkaCredentialsForCreateKafkaTriggerInput;
+import io.swagger.v3.oas.annotations.media.Schema;
+import java.io.IOException;
+import javax.validation.constraints.*;
+import javax.validation.Valid;
+/**
+ * CreateKafkaTriggerRequest
+ */
+
+
+
+public class CreateKafkaTriggerRequest {
+  @SerializedName("Description")
+  private String description = null;
+
+  @SerializedName("Enabled")
+  private Boolean enabled = null;
+
+  @SerializedName("FunctionId")
+  private String functionId = null;
+
+  @SerializedName("KafkaCredentials")
+  private KafkaCredentialsForCreateKafkaTriggerInput kafkaCredentials = null;
+
+  @SerializedName("MaximumRetryAttempts")
+  private Integer maximumRetryAttempts = null;
+
+  @SerializedName("MqInstanceId")
+  private String mqInstanceId = null;
+
+  @SerializedName("Name")
+  private String name = null;
+
+  @SerializedName("StartingPosition")
+  private String startingPosition = null;
+
+  @SerializedName("TopicName")
+  private String topicName = null;
+
+  public CreateKafkaTriggerRequest description(String description) {
+    this.description = description;
+    return this;
+  }
+
+   /**
+   * Get description
+   * @return description
+  **/
+  @Schema(description = "")
+  public String getDescription() {
+    return description;
+  }
+
+  public void setDescription(String description) {
+    this.description = description;
+  }
+
+  public CreateKafkaTriggerRequest enabled(Boolean enabled) {
+    this.enabled = enabled;
+    return this;
+  }
+
+   /**
+   * Get enabled
+   * @return enabled
+  **/
+  @Schema(description = "")
+  public Boolean isEnabled() {
+    return enabled;
+  }
+
+  public void setEnabled(Boolean enabled) {
+    this.enabled = enabled;
+  }
+
+  public CreateKafkaTriggerRequest functionId(String functionId) {
+    this.functionId = functionId;
+    return this;
+  }
+
+   /**
+   * Get functionId
+   * @return functionId
+  **/
+  @NotNull
+  @Schema(required = true, description = "")
+  public String getFunctionId() {
+    return functionId;
+  }
+
+  public void setFunctionId(String functionId) {
+    this.functionId = functionId;
+  }
+
+  public CreateKafkaTriggerRequest kafkaCredentials(KafkaCredentialsForCreateKafkaTriggerInput kafkaCredentials) {
+    this.kafkaCredentials = kafkaCredentials;
+    return this;
+  }
+
+   /**
+   * Get kafkaCredentials
+   * @return kafkaCredentials
+  **/
+  @Valid
+  @Schema(description = "")
+  public KafkaCredentialsForCreateKafkaTriggerInput getKafkaCredentials() {
+    return kafkaCredentials;
+  }
+
+  public void setKafkaCredentials(KafkaCredentialsForCreateKafkaTriggerInput kafkaCredentials) {
+    this.kafkaCredentials = kafkaCredentials;
+  }
+
+  public CreateKafkaTriggerRequest maximumRetryAttempts(Integer maximumRetryAttempts) {
+    this.maximumRetryAttempts = maximumRetryAttempts;
+    return this;
+  }
+
+   /**
+   * Get maximumRetryAttempts
+   * @return maximumRetryAttempts
+  **/
+  @Schema(description = "")
+  public Integer getMaximumRetryAttempts() {
+    return maximumRetryAttempts;
+  }
+
+  public void setMaximumRetryAttempts(Integer maximumRetryAttempts) {
+    this.maximumRetryAttempts = maximumRetryAttempts;
+  }
+
+  public CreateKafkaTriggerRequest mqInstanceId(String mqInstanceId) {
+    this.mqInstanceId = mqInstanceId;
+    return this;
+  }
+
+   /**
+   * Get mqInstanceId
+   * @return mqInstanceId
+  **/
+  @NotNull
+  @Schema(required = true, description = "")
+  public String getMqInstanceId() {
+    return mqInstanceId;
+  }
+
+  public void setMqInstanceId(String mqInstanceId) {
+    this.mqInstanceId = mqInstanceId;
+  }
+
+  public CreateKafkaTriggerRequest name(String name) {
+    this.name = name;
+    return this;
+  }
+
+   /**
+   * Get name
+   * @return name
+  **/
+  @NotNull
+  @Schema(required = true, description = "")
+  public String getName() {
+    return name;
+  }
+
+  public void setName(String name) {
+    this.name = name;
+  }
+
+  public CreateKafkaTriggerRequest startingPosition(String startingPosition) {
+    this.startingPosition = startingPosition;
+    return this;
+  }
+
+   /**
+   * Get startingPosition
+   * @return startingPosition
+  **/
+  @Schema(description = "")
+  public String getStartingPosition() {
+    return startingPosition;
+  }
+
+  public void setStartingPosition(String startingPosition) {
+    this.startingPosition = startingPosition;
+  }
+
+  public CreateKafkaTriggerRequest topicName(String topicName) {
+    this.topicName = topicName;
+    return this;
+  }
+
+   /**
+   * Get topicName
+   * @return topicName
+  **/
+  @NotNull
+  @Schema(required = true, description = "")
+  public String getTopicName() {
+    return topicName;
+  }
+
+  public void setTopicName(String topicName) {
+    this.topicName = topicName;
+  }
+
+
+  @Override
+  public boolean equals(java.lang.Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    CreateKafkaTriggerRequest createKafkaTriggerRequest = (CreateKafkaTriggerRequest) o;
+    return Objects.equals(this.description, createKafkaTriggerRequest.description) &&
+        Objects.equals(this.enabled, createKafkaTriggerRequest.enabled) &&
+        Objects.equals(this.functionId, createKafkaTriggerRequest.functionId) &&
+        Objects.equals(this.kafkaCredentials, createKafkaTriggerRequest.kafkaCredentials) &&
+        Objects.equals(this.maximumRetryAttempts, createKafkaTriggerRequest.maximumRetryAttempts) &&
+        Objects.equals(this.mqInstanceId, createKafkaTriggerRequest.mqInstanceId) &&
+        Objects.equals(this.name, createKafkaTriggerRequest.name) &&
+        Objects.equals(this.startingPosition, createKafkaTriggerRequest.startingPosition) &&
+        Objects.equals(this.topicName, createKafkaTriggerRequest.topicName);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(description, enabled, functionId, kafkaCredentials, maximumRetryAttempts, mqInstanceId, name, startingPosition, topicName);
+  }
+
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class CreateKafkaTriggerRequest {\n");
+    
+    sb.append("    description: ").append(toIndentedString(description)).append("\n");
+    sb.append("    enabled: ").append(toIndentedString(enabled)).append("\n");
+    sb.append("    functionId: ").append(toIndentedString(functionId)).append("\n");
+    sb.append("    kafkaCredentials: ").append(toIndentedString(kafkaCredentials)).append("\n");
+    sb.append("    maximumRetryAttempts: ").append(toIndentedString(maximumRetryAttempts)).append("\n");
+    sb.append("    mqInstanceId: ").append(toIndentedString(mqInstanceId)).append("\n");
+    sb.append("    name: ").append(toIndentedString(name)).append("\n");
+    sb.append("    startingPosition: ").append(toIndentedString(startingPosition)).append("\n");
+    sb.append("    topicName: ").append(toIndentedString(topicName)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(java.lang.Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+
+}