Schema Registry API

.github/workflows/tests.yml

@@ -1,93 +1,96 @@
-name: Tests
-
-on:
-  workflow_call:
-    inputs:
-      runtime:
-        required: true
-        type: string
-
-      registry:
-        description: "When in QA mode, the Docker registry to use"
-        type: string
-        required: false
-
-      image:
-        description: "When in QA mode, the Docker image to use"
-        type: string
-        required: false
-
-      tag:
-        description: "When in QA mode, the Docker image tag to use"
-        type: string
-        required: false
-
-jobs:
-  load_configuration:
-    uses: ./.github/workflows/load-configuration.yml
-    with:
-      runtime: ${{ inputs.runtime }}
-      registry: ${{ inputs.registry }}
-      image: ${{ inputs.image }}
-      tag: ${{ inputs.tag }}
-
-  test:
-    needs: load_configuration
-    timeout-minutes: 10
-    name: "${{ matrix.group.name }}"
-    strategy:
-      fail-fast: false
-      matrix:
-        group:
-          - name: samples
-            path: ./src/samples
-
-          - name: connection
-            path: ./src/connection
-
-          - name: extra
-            path: ./src/extra
-
-          - name: persistentSubscription
-            path: ./src/persistentSubscription
-
-          - name: projections
-            path: ./src/projections
-
-          - name: streams
-            path: ./src/streams
-
-          - name: opentelemetry
-            path: ./src/opentelemetry
-
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Login to Cloudsmith
-        uses: docker/login-action@v3
-        with:
-          registry: ${{ needs.load_configuration.outputs.registry }}
-          username: ${{ secrets.CLOUDSMITH_CICD_USER }}
-          password: ${{ secrets.CLOUDSMITH_CICD_TOKEN }}
-
-      - uses: actions/setup-node@v4
-        with:
-          node-version-file: .github/files/.nvmrc
-
-      - name: NodeJS version
-        run: node -v
-
-      - name: Corepack
-        run: corepack enable
-
-      - name: Install
-        run: yarn
-
-      - name: Build
-        run: yarn build
-
-      - name: Run Tests
-        run: yarn test ${{ matrix.group.path }} --ci --run-in-band --forceExit
-        env:
-          KURRENT_IMAGE: "${{ needs.load_configuration.outputs.registry }}/${{ needs.load_configuration.outputs.image }}:${{ needs.load_configuration.outputs.tag }}"
+name: Tests
+
+on:
+  workflow_call:
+    inputs:
+      runtime:
+        required: true
+        type: string
+
+      registry:
+        description: "When in QA mode, the Docker registry to use"
+        type: string
+        required: false
+
+      image:
+        description: "When in QA mode, the Docker image to use"
+        type: string
+        required: false
+
+      tag:
+        description: "When in QA mode, the Docker image tag to use"
+        type: string
+        required: false
+
+jobs:
+  load_configuration:
+    uses: ./.github/workflows/load-configuration.yml
+    with:
+      runtime: ${{ inputs.runtime }}
+      registry: ${{ inputs.registry }}
+      image: ${{ inputs.image }}
+      tag: ${{ inputs.tag }}
+
+  test:
+    needs: load_configuration
+    timeout-minutes: 10
+    name: "${{ matrix.group.name }}"
+    strategy:
+      fail-fast: false
+      matrix:
+        group:
+          # - name: samples
+          #   path: ./src/samples
+
+          # - name: connection
+          #   path: ./src/connection
+
+          # - name: extra
+          #   path: ./src/extra
+
+          # - name: persistentSubscription
+          #   path: ./src/persistentSubscription
+
+          # - name: projections
+          #   path: ./src/projections
+
+          # - name: streams
+          #   path: ./src/streams
+
+          # - name: opentelemetry
+          #   path: ./src/opentelemetry
+
+          - name: schemaRegistry
+            path: ./src/schemaRegistry
+
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Login to Cloudsmith
+        uses: docker/login-action@v3
+        with:
+          registry: ${{ needs.load_configuration.outputs.registry }}
+          username: ${{ secrets.CLOUDSMITH_CICD_USER }}
+          password: ${{ secrets.CLOUDSMITH_CICD_TOKEN }}
+
+      - uses: actions/setup-node@v4
+        with:
+          node-version-file: .github/files/.nvmrc
+
+      - name: NodeJS version
+        run: node -v
+
+      - name: Corepack
+        run: corepack enable
+
+      - name: Install
+        run: yarn
+
+      - name: Build
+        run: yarn build
+
+      - name: Run Tests
+        run: yarn test ${{ matrix.group.path }} --ci --run-in-band --forceExit
+        env:
+          KURRENT_IMAGE: "${{ needs.load_configuration.outputs.registry }}/${{ needs.load_configuration.outputs.image }}:${{ needs.load_configuration.outputs.tag }}"

packages/db-client/generated/kurrentdb/protocols/v2/registry/errors_grpc_pb.js

@@ -0,0 +1 @@
+// GENERATED CODE -- NO SERVICES IN PROTO

packages/db-client/generated/kurrentdb/protocols/v2/registry/errors_pb.d.ts

@@ -0,0 +1,75 @@
+// package: kurrentdb.protocol.v2.registry.errors
+// file: kurrentdb/protocols/v2/registry/errors.proto
+
+/* tslint:disable */
+/* eslint-disable */
+
+import * as jspb from "google-protobuf";
+import * as kurrentdb_protocols_v2_rpc_pb from "../../../../kurrentdb/protocols/v2/rpc_pb";
+
+export class SchemaNotFoundErrorDetails extends jspb.Message { 
+    getSchema(): string;
+    setSchema(value: string): SchemaNotFoundErrorDetails;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): SchemaNotFoundErrorDetails.AsObject;
+    static toObject(includeInstance: boolean, msg: SchemaNotFoundErrorDetails): SchemaNotFoundErrorDetails.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: SchemaNotFoundErrorDetails, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): SchemaNotFoundErrorDetails;
+    static deserializeBinaryFromReader(message: SchemaNotFoundErrorDetails, reader: jspb.BinaryReader): SchemaNotFoundErrorDetails;
+}
+
+export namespace SchemaNotFoundErrorDetails {
+    export type AsObject = {
+        schema: string,
+    }
+}
+
+export class SchemaAlreadyExistsErrorDetails extends jspb.Message { 
+    getSchema(): string;
+    setSchema(value: string): SchemaAlreadyExistsErrorDetails;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): SchemaAlreadyExistsErrorDetails.AsObject;
+    static toObject(includeInstance: boolean, msg: SchemaAlreadyExistsErrorDetails): SchemaAlreadyExistsErrorDetails.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: SchemaAlreadyExistsErrorDetails, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): SchemaAlreadyExistsErrorDetails;
+    static deserializeBinaryFromReader(message: SchemaAlreadyExistsErrorDetails, reader: jspb.BinaryReader): SchemaAlreadyExistsErrorDetails;
+}
+
+export namespace SchemaAlreadyExistsErrorDetails {
+    export type AsObject = {
+        schema: string,
+    }
+}
+
+export class SchemaDeletedErrorDetails extends jspb.Message { 
+    getSchema(): string;
+    setSchema(value: string): SchemaDeletedErrorDetails;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): SchemaDeletedErrorDetails.AsObject;
+    static toObject(includeInstance: boolean, msg: SchemaDeletedErrorDetails): SchemaDeletedErrorDetails.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: SchemaDeletedErrorDetails, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): SchemaDeletedErrorDetails;
+    static deserializeBinaryFromReader(message: SchemaDeletedErrorDetails, reader: jspb.BinaryReader): SchemaDeletedErrorDetails;
+}
+
+export namespace SchemaDeletedErrorDetails {
+    export type AsObject = {
+        schema: string,
+    }
+}
+
+export enum RegistryError {
+    UNSPECIFIED = 0,
+    SCHEMA_NOT_FOUND = 1,
+    SCHEMA_ALREADY_EXISTS = 2,
+    SCHEMA_DELETED = 3,
+}