feat: Knative API

Author: manusa

apis/knative/build.gradle

@@ -0,0 +1,44 @@
+import com.marcnuri.yack.schema.api.ApiGeneratorTask
+import com.marcnuri.yack.schema.model.ModelGeneratorTask
+
+apply from: rootDir.toPath().resolve('shared.gradle').toFile()
+
+ext {
+  isPublishable = true
+  project.group = project.group + ".apis"
+  pomName = 'Knative Model & API'
+  pomDescription = 'Retrofit2 based Java interfaces to create a declarative REST API client and model files for Knative (Serving & Eventing).'
+}
+
+dependencies {
+  compile  project(':kubernetes-model')
+  compileOnly "org.projectlombok:lombok:$version_projectlombok"
+  annotationProcessor "org.projectlombok:lombok:$version_projectlombok"
+}
+sourceSets.main.java.srcDirs = ['src/api/java', 'src/main/java', 'src/model/java']
+
+
+def templatesDirs = new File(rootProject.projectDir, "schema/templates")
+def schemaDir = new File(projectDir, "schema")
+def availableSchemaNames = Arrays.asList(
+  "knative-0.19.0.json"
+)
+def availableSchemas = availableSchemaNames.stream()
+    .map { s -> new File(schemaDir, s) }
+    .toArray{ i -> new File[i]}
+task generateModel(type: ModelGeneratorTask) {
+  group = 'generators'
+  packageName = 'com.marcnuri.yakc'
+  schemas = availableSchemas
+  templatesDir = templatesDirs
+  outputDirectory = projectDir
+  skipGenerationRegexes = ['^io\\.k8s\\.apimachinery\\.pkg\\..*']
+}
+task generateApi(type: ApiGeneratorTask) {
+  group = 'generators'
+  packageName = 'com.marcnuri.yakc'
+  schemas = availableSchemas
+  templatesDir = templatesDirs
+  outputDirectory = projectDir
+  skipGenerationRegexes = ['^apis$', '^version$']
+}

apis/knative/schema/knative-0.19.0.json

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2020 Marc Nuri
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.marcnuri.yakc.model.dev.knative.eventing.v1;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.marcnuri.yakc.model.Model;
+import com.marcnuri.yakc.model.io.k8s.apimachinery.pkg.apis.meta.v1.ObjectMeta;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+/**
+ * Broker collects a pool of events that are consumable using Triggers. Brokers provide a well-known endpoint for event delivery that senders can use with minimal knowledge of the event routing strategy. Subscribers use Triggers to request delivery of events from a Broker's pool to a specific URL or Addressable endpoint.
+ */
+@SuppressWarnings({"squid:S1192", "WeakerAccess", "unused"})
+@Builder(toBuilder = true, builderClassName = "Builder")
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@ToString
+public class Broker implements Model {
+
+
+  /**
+   * APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources
+   */
+  @JsonProperty("apiVersion")
+  private String apiVersion;
+
+  /**
+   * Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
+   */
+  @JsonProperty("kind")
+  private String kind;
+
+  @JsonProperty("metadata")
+  private ObjectMeta metadata;
+
+  @JsonProperty("spec")
+  private BrokerSpec spec;
+
+  @JsonProperty("status")
+  private BrokerStatus status;
+
+}
+

apis/knative/src/api/java/com/marcnuri/yakc/api/autoscalinginternalknativedev/v1alpha1/AutoscalingInternalKnativeDevV1alpha1Api.java

@@ -0,0 +1,67 @@
+/*
+ * Copyright 2020 Marc Nuri
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.marcnuri.yakc.model.dev.knative.eventing.v1;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.marcnuri.yakc.model.ListModel;
+import com.marcnuri.yakc.model.Model;
+import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.NonNull;
+import lombok.Singular;
+import lombok.ToString;
+
+/**
+ * BrokerList is a list of Broker
+ */
+@SuppressWarnings({"squid:S1192", "WeakerAccess", "unused"})
+@Builder(toBuilder = true, builderClassName = "Builder")
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@ToString
+public class BrokerList implements Model, ListModel<Broker> {
+
+
+  /**
+   * APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources
+   */
+  @JsonProperty("apiVersion")
+  private String apiVersion;
+
+  /**
+   * List of brokers. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md
+   */
+  @NonNull
+  @JsonProperty("items")
+  @Singular(value = "addToItems", ignoreNullCollections = true)
+  private List<Broker> items;
+
+  /**
+   * Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
+   */
+  @JsonProperty("kind")
+  private String kind;
+
+  @JsonProperty("metadata")
+  private BrokerListMetadata metadata;
+
+}
+

apis/knative/src/api/java/com/marcnuri/yakc/api/cachinginternalknativedev/v1alpha1/CachingInternalKnativeDevV1alpha1Api.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright 2020 Marc Nuri
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.marcnuri.yakc.model.dev.knative.eventing.v1;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.marcnuri.yakc.model.Model;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+/**
+ * ListMeta describes metadata that synthetic resources must have, including lists and various status objects. A resource may have only one of {ObjectMeta, ListMeta}.
+ */
+@SuppressWarnings({"squid:S1192", "WeakerAccess", "unused"})
+@Builder(toBuilder = true, builderClassName = "Builder")
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@ToString
+public class BrokerListMetadata implements Model {
+
+
+  /**
+   * continue may be set if the user set a limit on the number of items returned, and indicates that the server has more data available. The value is opaque and may be used to issue another request to the endpoint that served this list to retrieve the next set of available objects. Continuing a consistent list may not be possible if the server configuration has changed or more than a few minutes have passed. The resourceVersion field returned when using this continue value will be identical to the value in the first response, unless you have received this token from an error message.
+   */
+  @JsonProperty("continue")
+  private String continues;
+
+  /**
+   * remainingItemCount is the number of subsequent items in the list which are not included in this list response. If the list request contained label or field selectors, then the number of remaining items is unknown and the field will be left unset and omitted during serialization. If the list is complete (either because it is not chunking or because this is the last chunk), then there are no more remaining items and this field will be left unset and omitted during serialization. Servers older than v1.15 do not set this field. The intended use of the remainingItemCount is *estimating* the size of a collection. Clients should not rely on the remainingItemCount to be set or to be exact.
+   */
+  @JsonProperty("remainingItemCount")
+  private Number remainingItemCount;
+
+  /**
+   * String that identifies the server's internal version of this object that can be used by clients to determine when objects have changed. Value must be treated as opaque by clients and passed unmodified back to the server. Populated by the system. Read-only. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#concurrency-control-and-consistency
+   */
+  @JsonProperty("resourceVersion")
+  private String resourceVersion;
+
+  /**
+   * selfLink is a URL representing this object. Populated by the system. Read-only.<br><p> <br><p> DEPRECATED Kubernetes will stop propagating this field in 1.20 release and the field is planned to be removed in 1.21 release.
+   */
+  @JsonProperty("selfLink")
+  private String selfLink;
+
+}
+

apis/knative/src/api/java/com/marcnuri/yakc/api/eventingknativedev/v1/EventingKnativeDevV1Api.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright 2020 Marc Nuri
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.marcnuri.yakc.model.dev.knative.eventing.v1;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.marcnuri.yakc.model.Model;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+/**
+ * Spec defines the desired state of the Broker.
+ */
+@SuppressWarnings({"squid:S1192", "WeakerAccess", "unused"})
+@Builder(toBuilder = true, builderClassName = "Builder")
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@ToString
+public class BrokerSpec implements Model {
+
+
+  @JsonProperty("config")
+  private BrokerSpecConfig config;
+
+  @JsonProperty("delivery")
+  private BrokerSpecDelivery delivery;
+
+}
+

apis/knative/src/api/java/com/marcnuri/yakc/api/eventingknativedev/v1beta1/EventingKnativeDevV1beta1Api.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright 2020 Marc Nuri
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.marcnuri.yakc.model.dev.knative.eventing.v1;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.marcnuri.yakc.model.Model;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+/**
+ * Config is a KReference to the configuration that specifies configuration options for this Broker. For example, this could be a pointer to a ConfigMap.
+ */
+@SuppressWarnings({"squid:S1192", "WeakerAccess", "unused"})
+@Builder(toBuilder = true, builderClassName = "Builder")
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@ToString
+public class BrokerSpecConfig implements Model {
+
+
+  /**
+   * API version of the referent.
+   */
+  @JsonProperty("apiVersion")
+  private String apiVersion;
+
+  /**
+   * Kind of the referent. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
+   */
+  @JsonProperty("kind")
+  private String kind;
+
+  /**
+   * Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names
+   */
+  @JsonProperty("name")
+  private String name;
+
+  /**
+   * Namespace of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/namespaces/ This is optional field, it gets defaulted to the object holding it if left out.
+   */
+  @JsonProperty("namespace")
+  private String namespace;
+
+}
+