diff --git a/src/anduril/blobs/v1/blobs_api.pub_connect.d.ts b/src/anduril/blobs/v1/blobs_api.pub_connect.d.ts deleted file mode 100644 index b429f80..0000000 --- a/src/anduril/blobs/v1/blobs_api.pub_connect.d.ts +++ /dev/null @@ -1,74 +0,0 @@ -// @generated by protoc-gen-connect-es v1.4.0 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/blobs_api.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -import { CreateBlobChunkedRequest, CreateBlobChunkedResponse, CreateBlobRequest, CreateBlobResponse, GetBlobRequest, GetBlobResponse, HeadBlobRequest, HeadBlobResponse, StreamBlobMetadataRequest, StreamBlobMetadataResponse } from "./blobs_api.pub_pb.js"; -import { MethodKind } from "@bufbuild/protobuf"; - -/** - * A general purpose blob storage service. - * - * @generated from service anduril.blobs.v1.BlobsAPI - */ -export declare const BlobsAPI: { - readonly typeName: "anduril.blobs.v1.BlobsAPI", - readonly methods: { - /** - * Creates a new blob. This is a simple form for small (<=2MB) blobs with unary atomic API. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.CreateBlob - */ - readonly createBlob: { - readonly name: "CreateBlob", - readonly I: typeof CreateBlobRequest, - readonly O: typeof CreateBlobResponse, - readonly kind: MethodKind.Unary, - }, - /** - * Creates a new blob. This is for creating any sized blob using a client streaming API. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.CreateBlobChunked - */ - readonly createBlobChunked: { - readonly name: "CreateBlobChunked", - readonly I: typeof CreateBlobChunkedRequest, - readonly O: typeof CreateBlobChunkedResponse, - readonly kind: MethodKind.ClientStreaming, - }, - /** - * Gets a blob (streams blob contents). - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.GetBlob - */ - readonly getBlob: { - readonly name: "GetBlob", - readonly I: typeof GetBlobRequest, - readonly O: typeof GetBlobResponse, - readonly kind: MethodKind.ServerStreaming, - }, - /** - * Gets the metadata for a blob, but not the contents. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.HeadBlob - */ - readonly headBlob: { - readonly name: "HeadBlob", - readonly I: typeof HeadBlobRequest, - readonly O: typeof HeadBlobResponse, - readonly kind: MethodKind.Unary, - }, - /** - * Stream blob metadata announcements for the provided clientID. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.StreamBlobMetadata - */ - readonly streamBlobMetadata: { - readonly name: "StreamBlobMetadata", - readonly I: typeof StreamBlobMetadataRequest, - readonly O: typeof StreamBlobMetadataResponse, - readonly kind: MethodKind.ServerStreaming, - }, - } -}; - diff --git a/src/anduril/blobs/v1/blobs_api.pub_connect.js b/src/anduril/blobs/v1/blobs_api.pub_connect.js deleted file mode 100644 index 23ac70d..0000000 --- a/src/anduril/blobs/v1/blobs_api.pub_connect.js +++ /dev/null @@ -1,79 +0,0 @@ -// @generated by protoc-gen-connect-es v1.4.0 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/blobs_api.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); - -const { CreateBlobChunkedRequest, CreateBlobChunkedResponse, CreateBlobRequest, CreateBlobResponse, GetBlobRequest, GetBlobResponse, HeadBlobRequest, HeadBlobResponse, StreamBlobMetadataRequest, StreamBlobMetadataResponse } = require("./blobs_api.pub_pb.js"); -const { MethodKind } = require("@bufbuild/protobuf"); - -/** - * A general purpose blob storage service. - * - * @generated from service anduril.blobs.v1.BlobsAPI - */ -const BlobsAPI = { - typeName: "anduril.blobs.v1.BlobsAPI", - methods: { - /** - * Creates a new blob. This is a simple form for small (<=2MB) blobs with unary atomic API. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.CreateBlob - */ - createBlob: { - name: "CreateBlob", - I: CreateBlobRequest, - O: CreateBlobResponse, - kind: MethodKind.Unary, - }, - /** - * Creates a new blob. This is for creating any sized blob using a client streaming API. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.CreateBlobChunked - */ - createBlobChunked: { - name: "CreateBlobChunked", - I: CreateBlobChunkedRequest, - O: CreateBlobChunkedResponse, - kind: MethodKind.ClientStreaming, - }, - /** - * Gets a blob (streams blob contents). - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.GetBlob - */ - getBlob: { - name: "GetBlob", - I: GetBlobRequest, - O: GetBlobResponse, - kind: MethodKind.ServerStreaming, - }, - /** - * Gets the metadata for a blob, but not the contents. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.HeadBlob - */ - headBlob: { - name: "HeadBlob", - I: HeadBlobRequest, - O: HeadBlobResponse, - kind: MethodKind.Unary, - }, - /** - * Stream blob metadata announcements for the provided clientID. - * - * @generated from rpc anduril.blobs.v1.BlobsAPI.StreamBlobMetadata - */ - streamBlobMetadata: { - name: "StreamBlobMetadata", - I: StreamBlobMetadataRequest, - O: StreamBlobMetadataResponse, - kind: MethodKind.ServerStreaming, - }, - } -}; - - -exports.BlobsAPI = BlobsAPI; diff --git a/src/anduril/blobs/v1/blobs_api.pub_pb.d.ts b/src/anduril/blobs/v1/blobs_api.pub_pb.d.ts deleted file mode 100644 index a959223..0000000 --- a/src/anduril/blobs/v1/blobs_api.pub_pb.d.ts +++ /dev/null @@ -1,413 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/blobs_api.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage, Timestamp } from "@bufbuild/protobuf"; -import { Message, proto3 } from "@bufbuild/protobuf"; -import type { BlobMetadata, BlobProvenance } from "./common.pub_pb.js"; - -/** - * Create and store a new blob (<=2MB). - * - * @generated from message anduril.blobs.v1.CreateBlobRequest - */ -export declare class CreateBlobRequest extends Message { - /** - * blobs created will be namespaced by client_id - * - * @generated from field: string client_id = 1; - */ - clientId: string; - - /** - * unique (per client) key for the blob - * - * @generated from field: string key = 2; - */ - key: string; - - /** - * timestamp after which should no longer retain this blob. required and cannot be > 90 days in the future. - * - * @generated from field: google.protobuf.Timestamp retention_time = 3; - */ - retentionTime?: Timestamp; - - /** - * optional md5 sum/hash of contents. if provided, will be validated against md5 of contents - * - * @generated from field: bytes md5 = 4; - */ - md5: Uint8Array; - - /** - * contents of the entire blob, maximum size is 2MB (2 * 1024 * 1024 bytes) - * - * @generated from field: bytes contents = 5; - */ - contents: Uint8Array; - - /** - * details regarding the blob's origin - aka source and type - * - * @generated from field: anduril.blobs.v1.BlobProvenance provenance = 6; - */ - provenance?: BlobProvenance; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.CreateBlobRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): CreateBlobRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): CreateBlobRequest; - - static fromJsonString(jsonString: string, options?: Partial): CreateBlobRequest; - - static equals(a: CreateBlobRequest | PlainMessage | undefined, b: CreateBlobRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.CreateBlobResponse - */ -export declare class CreateBlobResponse extends Message { - /** - * @generated from field: anduril.blobs.v1.BlobMetadata metadata = 1; - */ - metadata?: BlobMetadata; - - /** - * URL at which the blob can be fetched - * - * @generated from field: string url = 2; - */ - url: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.CreateBlobResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): CreateBlobResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): CreateBlobResponse; - - static fromJsonString(jsonString: string, options?: Partial): CreateBlobResponse; - - static equals(a: CreateBlobResponse | PlainMessage | undefined, b: CreateBlobResponse | PlainMessage | undefined): boolean; -} - -/** - * Create and store a new blob. Only the first 'CreateBlobChunkedRequest' message in the client stream needs - * to contain metadata specific fields (IE: client_id, key, md5 etc.). Metadata fields set on all requests - * ensuing the first request will be ignored. - * - * @generated from message anduril.blobs.v1.CreateBlobChunkedRequest - */ -export declare class CreateBlobChunkedRequest extends Message { - /** - * blobs created will be namespaced by client_id - * - * @generated from field: string client_id = 1; - */ - clientId: string; - - /** - * unique (per client) key for the blob - * - * @generated from field: string key = 2; - */ - key: string; - - /** - * timestamp after which should no longer retain this blob. required and cannot be > 90 days in the future. - * - * @generated from field: google.protobuf.Timestamp retention_time = 3; - */ - retentionTime?: Timestamp; - - /** - * optional md5 sum/hash of contents. if provided, will be validated against the md5 of all contents in aggregate - * - * @generated from field: bytes md5 = 4; - */ - md5: Uint8Array; - - /** - * contents of the blob chunk, maximum size is 2MB per message (2 * 1024 * 1024 bytes) - * - * @generated from field: bytes chunk_contents = 5; - */ - chunkContents: Uint8Array; - - /** - * details regarding the blob's origin - aka source and type - * - * @generated from field: anduril.blobs.v1.BlobProvenance provenance = 6; - */ - provenance?: BlobProvenance; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.CreateBlobChunkedRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): CreateBlobChunkedRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): CreateBlobChunkedRequest; - - static fromJsonString(jsonString: string, options?: Partial): CreateBlobChunkedRequest; - - static equals(a: CreateBlobChunkedRequest | PlainMessage | undefined, b: CreateBlobChunkedRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.CreateBlobChunkedResponse - */ -export declare class CreateBlobChunkedResponse extends Message { - /** - * @generated from field: anduril.blobs.v1.BlobMetadata metadata = 1; - */ - metadata?: BlobMetadata; - - /** - * URL at which the blob can be fetched - * - * @generated from field: string url = 2; - */ - url: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.CreateBlobChunkedResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): CreateBlobChunkedResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): CreateBlobChunkedResponse; - - static fromJsonString(jsonString: string, options?: Partial): CreateBlobChunkedResponse; - - static equals(a: CreateBlobChunkedResponse | PlainMessage | undefined, b: CreateBlobChunkedResponse | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.GetBlobRequest - */ -export declare class GetBlobRequest extends Message { - /** - * @generated from field: string client_id = 1; - */ - clientId: string; - - /** - * @generated from field: string key = 2; - */ - key: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.GetBlobRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): GetBlobRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): GetBlobRequest; - - static fromJsonString(jsonString: string, options?: Partial): GetBlobRequest; - - static equals(a: GetBlobRequest | PlainMessage | undefined, b: GetBlobRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.GetBlobResponse - */ -export declare class GetBlobResponse extends Message { - /** - * contents of the blob, maximum size of each response message contents in stream is capped at 2MB. - * - * @generated from field: bytes contents = 1; - */ - contents: Uint8Array; - - /** - * metadata will only be present in the first stream message - * - * @generated from field: anduril.blobs.v1.BlobMetadata metadata = 2; - */ - metadata?: BlobMetadata; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.GetBlobResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): GetBlobResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): GetBlobResponse; - - static fromJsonString(jsonString: string, options?: Partial): GetBlobResponse; - - static equals(a: GetBlobResponse | PlainMessage | undefined, b: GetBlobResponse | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.HeadBlobRequest - */ -export declare class HeadBlobRequest extends Message { - /** - * @generated from field: string client_id = 1; - */ - clientId: string; - - /** - * @generated from field: string key = 2; - */ - key: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.HeadBlobRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): HeadBlobRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): HeadBlobRequest; - - static fromJsonString(jsonString: string, options?: Partial): HeadBlobRequest; - - static equals(a: HeadBlobRequest | PlainMessage | undefined, b: HeadBlobRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.HeadBlobResponse - */ -export declare class HeadBlobResponse extends Message { - /** - * @generated from field: anduril.blobs.v1.BlobMetadata metadata = 1; - */ - metadata?: BlobMetadata; - - /** - * URL at which the blob can be fetched - * - * @generated from field: string url = 2; - */ - url: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.HeadBlobResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): HeadBlobResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): HeadBlobResponse; - - static fromJsonString(jsonString: string, options?: Partial): HeadBlobResponse; - - static equals(a: HeadBlobResponse | PlainMessage | undefined, b: HeadBlobResponse | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.StreamBlobMetadataRequest - */ -export declare class StreamBlobMetadataRequest extends Message { - /** - * The blob client_id to stream. - * - * @generated from field: string client_id = 1; - */ - clientId: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.StreamBlobMetadataRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): StreamBlobMetadataRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): StreamBlobMetadataRequest; - - static fromJsonString(jsonString: string, options?: Partial): StreamBlobMetadataRequest; - - static equals(a: StreamBlobMetadataRequest | PlainMessage | undefined, b: StreamBlobMetadataRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.StreamBlobMetadataResponse - */ -export declare class StreamBlobMetadataResponse extends Message { - /** - * The set of blob announcement metadata returned from a StreamBlobMetadataResponse. - * - * @generated from field: repeated anduril.blobs.v1.BlobAnnouncement announcements = 1; - */ - announcements: BlobAnnouncement[]; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.StreamBlobMetadataResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): StreamBlobMetadataResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): StreamBlobMetadataResponse; - - static fromJsonString(jsonString: string, options?: Partial): StreamBlobMetadataResponse; - - static equals(a: StreamBlobMetadataResponse | PlainMessage | undefined, b: StreamBlobMetadataResponse | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.BlobAnnouncement - */ -export declare class BlobAnnouncement extends Message { - /** - * The announced blob's specific client-driven namespace. - * - * @generated from field: string client_id = 1; - */ - clientId: string; - - /** - * The announced blob's unique key. - * - * @generated from field: string key = 2; - */ - key: string; - - /** - * The metadata describing the blob's contents. - * - * @generated from field: anduril.blobs.v1.BlobMetadata metadata = 3; - */ - metadata?: BlobMetadata; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.BlobAnnouncement"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): BlobAnnouncement; - - static fromJson(jsonValue: JsonValue, options?: Partial): BlobAnnouncement; - - static fromJsonString(jsonString: string, options?: Partial): BlobAnnouncement; - - static equals(a: BlobAnnouncement | PlainMessage | undefined, b: BlobAnnouncement | PlainMessage | undefined): boolean; -} - diff --git a/src/anduril/blobs/v1/blobs_api.pub_pb.js b/src/anduril/blobs/v1/blobs_api.pub_pb.js deleted file mode 100644 index cbb1f6e..0000000 --- a/src/anduril/blobs/v1/blobs_api.pub_pb.js +++ /dev/null @@ -1,157 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/blobs_api.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); - -const { proto3, Timestamp } = require("@bufbuild/protobuf"); -const { BlobMetadata, BlobProvenance } = require("./common.pub_pb.js"); - -/** - * Create and store a new blob (<=2MB). - * - * @generated from message anduril.blobs.v1.CreateBlobRequest - */ -const CreateBlobRequest = proto3.makeMessageType( - "anduril.blobs.v1.CreateBlobRequest", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 3, name: "retention_time", kind: "message", T: Timestamp }, - { no: 4, name: "md5", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 5, name: "contents", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 6, name: "provenance", kind: "message", T: BlobProvenance }, - ], -); - -/** - * @generated from message anduril.blobs.v1.CreateBlobResponse - */ -const CreateBlobResponse = proto3.makeMessageType( - "anduril.blobs.v1.CreateBlobResponse", - () => [ - { no: 1, name: "metadata", kind: "message", T: BlobMetadata }, - { no: 2, name: "url", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * Create and store a new blob. Only the first 'CreateBlobChunkedRequest' message in the client stream needs - * to contain metadata specific fields (IE: client_id, key, md5 etc.). Metadata fields set on all requests - * ensuing the first request will be ignored. - * - * @generated from message anduril.blobs.v1.CreateBlobChunkedRequest - */ -const CreateBlobChunkedRequest = proto3.makeMessageType( - "anduril.blobs.v1.CreateBlobChunkedRequest", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 3, name: "retention_time", kind: "message", T: Timestamp }, - { no: 4, name: "md5", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 5, name: "chunk_contents", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 6, name: "provenance", kind: "message", T: BlobProvenance }, - ], -); - -/** - * @generated from message anduril.blobs.v1.CreateBlobChunkedResponse - */ -const CreateBlobChunkedResponse = proto3.makeMessageType( - "anduril.blobs.v1.CreateBlobChunkedResponse", - () => [ - { no: 1, name: "metadata", kind: "message", T: BlobMetadata }, - { no: 2, name: "url", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.blobs.v1.GetBlobRequest - */ -const GetBlobRequest = proto3.makeMessageType( - "anduril.blobs.v1.GetBlobRequest", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.blobs.v1.GetBlobResponse - */ -const GetBlobResponse = proto3.makeMessageType( - "anduril.blobs.v1.GetBlobResponse", - () => [ - { no: 1, name: "contents", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 2, name: "metadata", kind: "message", T: BlobMetadata }, - ], -); - -/** - * @generated from message anduril.blobs.v1.HeadBlobRequest - */ -const HeadBlobRequest = proto3.makeMessageType( - "anduril.blobs.v1.HeadBlobRequest", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.blobs.v1.HeadBlobResponse - */ -const HeadBlobResponse = proto3.makeMessageType( - "anduril.blobs.v1.HeadBlobResponse", - () => [ - { no: 1, name: "metadata", kind: "message", T: BlobMetadata }, - { no: 2, name: "url", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.blobs.v1.StreamBlobMetadataRequest - */ -const StreamBlobMetadataRequest = proto3.makeMessageType( - "anduril.blobs.v1.StreamBlobMetadataRequest", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.blobs.v1.StreamBlobMetadataResponse - */ -const StreamBlobMetadataResponse = proto3.makeMessageType( - "anduril.blobs.v1.StreamBlobMetadataResponse", - () => [ - { no: 1, name: "announcements", kind: "message", T: BlobAnnouncement, repeated: true }, - ], -); - -/** - * @generated from message anduril.blobs.v1.BlobAnnouncement - */ -const BlobAnnouncement = proto3.makeMessageType( - "anduril.blobs.v1.BlobAnnouncement", - () => [ - { no: 1, name: "client_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 3, name: "metadata", kind: "message", T: BlobMetadata }, - ], -); - - -exports.CreateBlobRequest = CreateBlobRequest; -exports.CreateBlobResponse = CreateBlobResponse; -exports.CreateBlobChunkedRequest = CreateBlobChunkedRequest; -exports.CreateBlobChunkedResponse = CreateBlobChunkedResponse; -exports.GetBlobRequest = GetBlobRequest; -exports.GetBlobResponse = GetBlobResponse; -exports.HeadBlobRequest = HeadBlobRequest; -exports.HeadBlobResponse = HeadBlobResponse; -exports.StreamBlobMetadataRequest = StreamBlobMetadataRequest; -exports.StreamBlobMetadataResponse = StreamBlobMetadataResponse; -exports.BlobAnnouncement = BlobAnnouncement; diff --git a/src/anduril/blobs/v1/common.pub_pb.d.ts b/src/anduril/blobs/v1/common.pub_pb.d.ts deleted file mode 100644 index d120bc3..0000000 --- a/src/anduril/blobs/v1/common.pub_pb.d.ts +++ /dev/null @@ -1,104 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/common.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage, Timestamp } from "@bufbuild/protobuf"; -import { Message, proto3 } from "@bufbuild/protobuf"; - -/** - * Metadata about the blob. - * - * @generated from message anduril.blobs.v1.BlobMetadata - */ -export declare class BlobMetadata extends Message { - /** - * timestamp of when blob was created - * - * @generated from field: google.protobuf.Timestamp created_time = 1; - */ - createdTime?: Timestamp; - - /** - * timestamp of when this blob will be retained until. - * - * @generated from field: google.protobuf.Timestamp retention_time = 2; - */ - retentionTime?: Timestamp; - - /** - * size of the blob contents in bytes - * - * @generated from field: uint64 size_bytes = 3; - */ - sizeBytes: bigint; - - /** - * md5 sum/hash of blob contents - * - * @generated from field: bytes md5 = 4; - */ - md5: Uint8Array; - - /** - * MIME type of blob contents - * - * @generated from field: string content_type = 5; - */ - contentType: string; - - /** - * details regarding the blob's origin - aka source and type - * - * @generated from field: anduril.blobs.v1.BlobProvenance provenance = 6; - */ - provenance?: BlobProvenance; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.BlobMetadata"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): BlobMetadata; - - static fromJson(jsonValue: JsonValue, options?: Partial): BlobMetadata; - - static fromJsonString(jsonString: string, options?: Partial): BlobMetadata; - - static equals(a: BlobMetadata | PlainMessage | undefined, b: BlobMetadata | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.blobs.v1.BlobProvenance - */ -export declare class BlobProvenance extends Message { - /** - * registered integration_name producing the Blob. - * - * @generated from field: string integration_name = 1; - */ - integrationName: string; - - /** - * data type defines what is inside of the Blob. Must be registered. - * - * @generated from field: string data_type = 2; - */ - dataType: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.BlobProvenance"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): BlobProvenance; - - static fromJson(jsonValue: JsonValue, options?: Partial): BlobProvenance; - - static fromJsonString(jsonString: string, options?: Partial): BlobProvenance; - - static equals(a: BlobProvenance | PlainMessage | undefined, b: BlobProvenance | PlainMessage | undefined): boolean; -} - diff --git a/src/anduril/blobs/v1/common.pub_pb.js b/src/anduril/blobs/v1/common.pub_pb.js deleted file mode 100644 index 06bd2fb..0000000 --- a/src/anduril/blobs/v1/common.pub_pb.js +++ /dev/null @@ -1,41 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/common.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); - -const { proto3, Timestamp } = require("@bufbuild/protobuf"); - -/** - * Metadata about the blob. - * - * @generated from message anduril.blobs.v1.BlobMetadata - */ -const BlobMetadata = proto3.makeMessageType( - "anduril.blobs.v1.BlobMetadata", - () => [ - { no: 1, name: "created_time", kind: "message", T: Timestamp }, - { no: 2, name: "retention_time", kind: "message", T: Timestamp }, - { no: 3, name: "size_bytes", kind: "scalar", T: 4 /* ScalarType.UINT64 */ }, - { no: 4, name: "md5", kind: "scalar", T: 12 /* ScalarType.BYTES */ }, - { no: 5, name: "content_type", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 6, name: "provenance", kind: "message", T: BlobProvenance }, - ], -); - -/** - * @generated from message anduril.blobs.v1.BlobProvenance - */ -const BlobProvenance = proto3.makeMessageType( - "anduril.blobs.v1.BlobProvenance", - () => [ - { no: 1, name: "integration_name", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "data_type", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - - -exports.BlobMetadata = BlobMetadata; -exports.BlobProvenance = BlobProvenance; diff --git a/src/anduril/blobs/v1/filter.pub_pb.d.ts b/src/anduril/blobs/v1/filter.pub_pb.d.ts deleted file mode 100644 index 8e27487..0000000 --- a/src/anduril/blobs/v1/filter.pub_pb.d.ts +++ /dev/null @@ -1,81 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/filter.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage } from "@bufbuild/protobuf"; -import { Message, proto3 } from "@bufbuild/protobuf"; - -/** - * If match and not_match are both populated, both must evaluate to true for Statement to evaluate to true. - * If match is not populated, only not_match is used. If not_match is empty, only match is used. - * If match is not populated and not_match is empty, Statement evaluates to true. - * - * @generated from message anduril.blobs.v1.Statement - */ -export declare class Statement extends Message { - /** - * Positive match fields. - * - * @generated from field: anduril.blobs.v1.FieldMatcher match = 1; - */ - match?: FieldMatcher; - - /** - * Negative match fields. All not_match FieldMatchers must evaluate to false for this to evaluate to true. - * - * @generated from field: repeated anduril.blobs.v1.FieldMatcher not_match = 2; - */ - notMatch: FieldMatcher[]; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.Statement"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): Statement; - - static fromJson(jsonValue: JsonValue, options?: Partial): Statement; - - static fromJsonString(jsonString: string, options?: Partial): Statement; - - static equals(a: Statement | PlainMessage | undefined, b: Statement | PlainMessage | undefined): boolean; -} - -/** - * All populated fields must be an exact match (logical AND). - * - * @generated from message anduril.blobs.v1.FieldMatcher - */ -export declare class FieldMatcher extends Message { - /** - * @generated from field: string integration_name = 1; - */ - integrationName: string; - - /** - * @generated from field: string mime_type = 2; - */ - mimeType: string; - - /** - * @generated from field: string data_type = 3; - */ - dataType: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.blobs.v1.FieldMatcher"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): FieldMatcher; - - static fromJson(jsonValue: JsonValue, options?: Partial): FieldMatcher; - - static fromJsonString(jsonString: string, options?: Partial): FieldMatcher; - - static equals(a: FieldMatcher | PlainMessage | undefined, b: FieldMatcher | PlainMessage | undefined): boolean; -} - diff --git a/src/anduril/blobs/v1/filter.pub_pb.js b/src/anduril/blobs/v1/filter.pub_pb.js deleted file mode 100644 index de8b28b..0000000 --- a/src/anduril/blobs/v1/filter.pub_pb.js +++ /dev/null @@ -1,42 +0,0 @@ -// @generated by protoc-gen-es v1.7.2 with parameter "js_import_style=legacy_commonjs" -// @generated from file anduril/blobs/v1/filter.pub.proto (package anduril.blobs.v1, syntax proto3) -/* eslint-disable */ -// @ts-nocheck - -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); - -const { proto3 } = require("@bufbuild/protobuf"); - -/** - * If match and not_match are both populated, both must evaluate to true for Statement to evaluate to true. - * If match is not populated, only not_match is used. If not_match is empty, only match is used. - * If match is not populated and not_match is empty, Statement evaluates to true. - * - * @generated from message anduril.blobs.v1.Statement - */ -const Statement = proto3.makeMessageType( - "anduril.blobs.v1.Statement", - () => [ - { no: 1, name: "match", kind: "message", T: FieldMatcher }, - { no: 2, name: "not_match", kind: "message", T: FieldMatcher, repeated: true }, - ], -); - -/** - * All populated fields must be an exact match (logical AND). - * - * @generated from message anduril.blobs.v1.FieldMatcher - */ -const FieldMatcher = proto3.makeMessageType( - "anduril.blobs.v1.FieldMatcher", - () => [ - { no: 1, name: "integration_name", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "mime_type", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 3, name: "data_type", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - - -exports.Statement = Statement; -exports.FieldMatcher = FieldMatcher; diff --git a/src/anduril/entitymanager/v1/entity.pub_pb.d.ts b/src/anduril/entitymanager/v1/entity.pub_pb.d.ts index 5600f70..0e7ca8f 100644 --- a/src/anduril/entitymanager/v1/entity.pub_pb.d.ts +++ b/src/anduril/entitymanager/v1/entity.pub_pb.d.ts @@ -597,8 +597,18 @@ export declare class Tracked extends Message { * @generated from message anduril.entitymanager.v1.Provenance */ export declare class Provenance extends Message { + /** + * A feed is a 1:1 or Many:1 mapping between a data type from a specific vendor + * and an output stream of entities. The feed_name identifies the feed definition + * in the Feeds API and must be globally unique per feed. + * + * @generated from field: string feed_name = 7; + */ + feedName: string; + /** * Name of the integration that produced this entity + * To be deprecated soon in favor of feed_name * * @generated from field: string integration_name = 5; */ @@ -606,6 +616,7 @@ export declare class Provenance extends Message { /** * Source data type of this entity. Examples: ADSB, Link16, etc. + * To be deprecated soon in favor of feed_name * * @generated from field: string data_type = 6; */ @@ -626,7 +637,9 @@ export declare class Provenance extends Message { sourceId: string; /** - * Main update timer for the entity with the exception of overrides + * The time, according to the source system, that the data in the entity was last modified. Generally, this should + * be the time that the source-reported time of validity of the data in the entity. This field must be + * updated with every change to the entity or else Entity Manager will discard the update. * * @generated from field: google.protobuf.Timestamp source_update_time = 2; */ diff --git a/src/anduril/entitymanager/v1/entity.pub_pb.js b/src/anduril/entitymanager/v1/entity.pub_pb.js index 0aaaa8a..2c280c8 100644 --- a/src/anduril/entitymanager/v1/entity.pub_pb.js +++ b/src/anduril/entitymanager/v1/entity.pub_pb.js @@ -176,6 +176,7 @@ const Tracked = proto3.makeMessageType( const Provenance = proto3.makeMessageType( "anduril.entitymanager.v1.Provenance", () => [ + { no: 7, name: "feed_name", kind: "scalar", T: 9 /* ScalarType.STRING */ }, { no: 5, name: "integration_name", kind: "scalar", T: 9 /* ScalarType.STRING */ }, { no: 6, name: "data_type", kind: "scalar", T: 9 /* ScalarType.STRING */ }, { no: 1, name: "source", kind: "enum", T: proto3.getEnumType(Source) }, diff --git a/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.d.ts b/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.d.ts index aded08a..3c2036e 100644 --- a/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.d.ts +++ b/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.d.ts @@ -3,11 +3,11 @@ /* eslint-disable */ // @ts-nocheck -import { DeleteEntityRequest, DeleteEntityResponse, GetEntityRequest, GetEntityResponse, OverrideEntityRequest, OverrideEntityResponse, PublishEntitiesRequest, PublishEntitiesResponse, PutEntityRequest, PutEntityResponse, RelateEntityRequest, RelateEntityResponse, RemoveEntityOverrideRequest, RemoveEntityOverrideResponse, StreamEntityComponentsRequest, StreamEntityComponentsResponse, UnrelateEntityRequest, UnrelateEntityResponse } from "./entity_manager_api.pub_pb.js"; +import { GetEntityRequest, GetEntityResponse, OverrideEntityRequest, OverrideEntityResponse, PublishEntitiesRequest, PublishEntitiesResponse, PublishEntityRequest, PublishEntityResponse, RemoveEntityOverrideRequest, RemoveEntityOverrideResponse, StreamEntityComponentsRequest, StreamEntityComponentsResponse } from "./entity_manager_api.pub_pb.js"; import { MethodKind } from "@bufbuild/protobuf"; /** - * The EntityManager provides a UI centric data model for understanding the entities in a battle space. + * The Entity Manager provides a UI centric data model for understanding the entities in a battle space. * * Every object in a battle space is represented as an "Entity". Each Entity is essentially an ID, with a life cycle, * and a collection of data components. Each data component is a separate protobuf message definition. @@ -21,44 +21,22 @@ export declare const EntityManagerAPI: { readonly typeName: "anduril.entitymanager.v1.EntityManagerAPI", readonly methods: { /** - * Get a entity based on an entityId. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.GetEntity - */ - readonly getEntity: { - readonly name: "GetEntity", - readonly I: typeof GetEntityRequest, - readonly O: typeof GetEntityResponse, - readonly kind: MethodKind.Unary, - }, - /** - * Returns a stream of entity with specified components populated. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.StreamEntityComponents - */ - readonly streamEntityComponents: { - readonly name: "StreamEntityComponents", - readonly I: typeof StreamEntityComponentsRequest, - readonly O: typeof StreamEntityComponentsResponse, - readonly kind: MethodKind.ServerStreaming, - }, - /** - * Create or Update an Entity. This should be used by low update rate situations where Entity Manager is - * the source of truth, rather than an aggregator. The canonical example is a manually created entity. - * Entities created in this fashion are stored as a Base entity, overrides on top are still possible. + * Unary RPC to publish an entity for ingest into Entity Manager. This is the preferred RPC to integrate entities + * and should be used by most integrations to publish high- or low-update rate entities. Entities created with this + * method are "owned" by the originator: other sources, such as the UI, may not edit or delete these entities. + * Entities are validated at RPC call time and an error is returned if the entity is invalid. * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PutEntity + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PublishEntity */ - readonly putEntity: { - readonly name: "PutEntity", - readonly I: typeof PutEntityRequest, - readonly O: typeof PutEntityResponse, + readonly publishEntity: { + readonly name: "PublishEntity", + readonly I: typeof PublishEntityRequest, + readonly O: typeof PublishEntityResponse, readonly kind: MethodKind.Unary, }, /** - * Create or Update one or more Entities. This should be used during high update rate situations where the originator - * is both the aggregator and source of truth for the published entities, and the originator does not have - * the ability to directly publish to Flux. + * Create or Update one or more Entities. Prefer PublishEntity instead. The same caveats of PublishEntity apply. + * This RPC does not return error messages for invalid entities or any other feedback from the server. * * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PublishEntities */ @@ -69,7 +47,21 @@ export declare const EntityManagerAPI: { readonly kind: MethodKind.ClientStreaming, }, /** - * Override an Entity Component. Only fields marked with overridable can be overwritten. + * Get a entity based on an entityId. + * + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.GetEntity + */ + readonly getEntity: { + readonly name: "GetEntity", + readonly I: typeof GetEntityRequest, + readonly O: typeof GetEntityResponse, + readonly kind: MethodKind.Unary, + }, + /** + * Override an Entity Component. An override is a definitive change to entity data. Any authorized user of service + * can override overridable components on any entity. Only fields marked with overridable can be overridden. + * When setting an override, the user or service setting the override is asserting that they are certain of the change + * and the truth behind it. * * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.OverrideEntity */ @@ -91,38 +83,15 @@ export declare const EntityManagerAPI: { readonly kind: MethodKind.Unary, }, /** - * Delete an Entity - only works on entities created by PutEntity. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.DeleteEntity - */ - readonly deleteEntity: { - readonly name: "DeleteEntity", - readonly I: typeof DeleteEntityRequest, - readonly O: typeof DeleteEntityResponse, - readonly kind: MethodKind.Unary, - }, - /** - * Creates or Updates relationships on an Entity. All relationships that are being added in the request - * succeed or fail as a batch (i.e. if any one relationship is invalid, the request will fail). - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.RelateEntity - */ - readonly relateEntity: { - readonly name: "RelateEntity", - readonly I: typeof RelateEntityRequest, - readonly O: typeof RelateEntityResponse, - readonly kind: MethodKind.Unary, - }, - /** - * Deletes relationships on an Entity. + * Returns a stream of entity with specified components populated. * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.UnrelateEntity + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.StreamEntityComponents */ - readonly unrelateEntity: { - readonly name: "UnrelateEntity", - readonly I: typeof UnrelateEntityRequest, - readonly O: typeof UnrelateEntityResponse, - readonly kind: MethodKind.Unary, + readonly streamEntityComponents: { + readonly name: "StreamEntityComponents", + readonly I: typeof StreamEntityComponentsRequest, + readonly O: typeof StreamEntityComponentsResponse, + readonly kind: MethodKind.ServerStreaming, }, } }; diff --git a/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.js b/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.js index abc484b..08ddeaf 100644 --- a/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.js +++ b/src/anduril/entitymanager/v1/entity_manager_api.pub_connect.js @@ -6,11 +6,11 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); -const { DeleteEntityRequest, DeleteEntityResponse, GetEntityRequest, GetEntityResponse, OverrideEntityRequest, OverrideEntityResponse, PublishEntitiesRequest, PublishEntitiesResponse, PutEntityRequest, PutEntityResponse, RelateEntityRequest, RelateEntityResponse, RemoveEntityOverrideRequest, RemoveEntityOverrideResponse, StreamEntityComponentsRequest, StreamEntityComponentsResponse, UnrelateEntityRequest, UnrelateEntityResponse } = require("./entity_manager_api.pub_pb.js"); +const { GetEntityRequest, GetEntityResponse, OverrideEntityRequest, OverrideEntityResponse, PublishEntitiesRequest, PublishEntitiesResponse, PublishEntityRequest, PublishEntityResponse, RemoveEntityOverrideRequest, RemoveEntityOverrideResponse, StreamEntityComponentsRequest, StreamEntityComponentsResponse } = require("./entity_manager_api.pub_pb.js"); const { MethodKind } = require("@bufbuild/protobuf"); /** - * The EntityManager provides a UI centric data model for understanding the entities in a battle space. + * The Entity Manager provides a UI centric data model for understanding the entities in a battle space. * * Every object in a battle space is represented as an "Entity". Each Entity is essentially an ID, with a life cycle, * and a collection of data components. Each data component is a separate protobuf message definition. @@ -24,44 +24,22 @@ const EntityManagerAPI = { typeName: "anduril.entitymanager.v1.EntityManagerAPI", methods: { /** - * Get a entity based on an entityId. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.GetEntity - */ - getEntity: { - name: "GetEntity", - I: GetEntityRequest, - O: GetEntityResponse, - kind: MethodKind.Unary, - }, - /** - * Returns a stream of entity with specified components populated. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.StreamEntityComponents - */ - streamEntityComponents: { - name: "StreamEntityComponents", - I: StreamEntityComponentsRequest, - O: StreamEntityComponentsResponse, - kind: MethodKind.ServerStreaming, - }, - /** - * Create or Update an Entity. This should be used by low update rate situations where Entity Manager is - * the source of truth, rather than an aggregator. The canonical example is a manually created entity. - * Entities created in this fashion are stored as a Base entity, overrides on top are still possible. + * Unary RPC to publish an entity for ingest into Entity Manager. This is the preferred RPC to integrate entities + * and should be used by most integrations to publish high- or low-update rate entities. Entities created with this + * method are "owned" by the originator: other sources, such as the UI, may not edit or delete these entities. + * Entities are validated at RPC call time and an error is returned if the entity is invalid. * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PutEntity + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PublishEntity */ - putEntity: { - name: "PutEntity", - I: PutEntityRequest, - O: PutEntityResponse, + publishEntity: { + name: "PublishEntity", + I: PublishEntityRequest, + O: PublishEntityResponse, kind: MethodKind.Unary, }, /** - * Create or Update one or more Entities. This should be used during high update rate situations where the originator - * is both the aggregator and source of truth for the published entities, and the originator does not have - * the ability to directly publish to Flux. + * Create or Update one or more Entities. Prefer PublishEntity instead. The same caveats of PublishEntity apply. + * This RPC does not return error messages for invalid entities or any other feedback from the server. * * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.PublishEntities */ @@ -72,7 +50,21 @@ const EntityManagerAPI = { kind: MethodKind.ClientStreaming, }, /** - * Override an Entity Component. Only fields marked with overridable can be overwritten. + * Get a entity based on an entityId. + * + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.GetEntity + */ + getEntity: { + name: "GetEntity", + I: GetEntityRequest, + O: GetEntityResponse, + kind: MethodKind.Unary, + }, + /** + * Override an Entity Component. An override is a definitive change to entity data. Any authorized user of service + * can override overridable components on any entity. Only fields marked with overridable can be overridden. + * When setting an override, the user or service setting the override is asserting that they are certain of the change + * and the truth behind it. * * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.OverrideEntity */ @@ -94,38 +86,15 @@ const EntityManagerAPI = { kind: MethodKind.Unary, }, /** - * Delete an Entity - only works on entities created by PutEntity. - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.DeleteEntity - */ - deleteEntity: { - name: "DeleteEntity", - I: DeleteEntityRequest, - O: DeleteEntityResponse, - kind: MethodKind.Unary, - }, - /** - * Creates or Updates relationships on an Entity. All relationships that are being added in the request - * succeed or fail as a batch (i.e. if any one relationship is invalid, the request will fail). - * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.RelateEntity - */ - relateEntity: { - name: "RelateEntity", - I: RelateEntityRequest, - O: RelateEntityResponse, - kind: MethodKind.Unary, - }, - /** - * Deletes relationships on an Entity. + * Returns a stream of entity with specified components populated. * - * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.UnrelateEntity + * @generated from rpc anduril.entitymanager.v1.EntityManagerAPI.StreamEntityComponents */ - unrelateEntity: { - name: "UnrelateEntity", - I: UnrelateEntityRequest, - O: UnrelateEntityResponse, - kind: MethodKind.Unary, + streamEntityComponents: { + name: "StreamEntityComponents", + I: StreamEntityComponentsRequest, + O: StreamEntityComponentsResponse, + kind: MethodKind.ServerStreaming, }, } }; diff --git a/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.d.ts b/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.d.ts index 8212b21..e496aad 100644 --- a/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.d.ts +++ b/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.d.ts @@ -6,10 +6,9 @@ import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage, Timestamp } from "@bufbuild/protobuf"; import { Message, proto3 } from "@bufbuild/protobuf"; import type { Entity, Provenance } from "./entity.pub_pb.js"; +import type { OverrideStatus } from "./types.pub_pb.js"; import type { Statement } from "./filter.pub_pb.js"; import type { RateLimit } from "./rate_limit.pub_pb.js"; -import type { OverrideStatus } from "./types.pub_pb.js"; -import type { RelationshipType } from "./relationship.pub_pb.js"; /** * The type of entity event. @@ -59,168 +58,68 @@ export declare enum EventType { } /** - * @generated from message anduril.entitymanager.v1.GetEntityRequest + * @generated from message anduril.entitymanager.v1.PublishEntityRequest */ -export declare class GetEntityRequest extends Message { +export declare class PublishEntityRequest extends Message { /** - * the GUID of this entity to query - * - * @generated from field: string entity_id = 1; - */ - entityId: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.GetEntityRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): GetEntityRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): GetEntityRequest; - - static fromJsonString(jsonString: string, options?: Partial): GetEntityRequest; - - static equals(a: GetEntityRequest | PlainMessage | undefined, b: GetEntityRequest | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.entitymanager.v1.GetEntityResponse - */ -export declare class GetEntityResponse extends Message { - /** - * an Entity object that corresponds with the requested entityId + * Stream of fully formed entities to publish + * Required fields per entity: + * * expiry_time - must be in the future, but less than 30 days from now + * * provenance.data_type [if using deprecated provenance.source, migrate to data_type.] + * * provenance.source_update_time (can be earlier than rpc call if data entered is older) + * * aliases.name + * * ontology.template + * any additional required fields will be determined by template, see com.anduril.entitymanager.v1.Template + * if an entity_id is provided, will treat as update, otherwise create * * @generated from field: anduril.entitymanager.v1.Entity entity = 1; */ entity?: Entity; - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.GetEntityResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): GetEntityResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): GetEntityResponse; - - static fromJsonString(jsonString: string, options?: Partial): GetEntityResponse; - - static equals(a: GetEntityResponse | PlainMessage | undefined, b: GetEntityResponse | PlainMessage | undefined): boolean; -} - -/** - * @generated from message anduril.entitymanager.v1.StreamEntityComponentsRequest - */ -export declare class StreamEntityComponentsRequest extends Message { - /** - * lower_snake_cased component names to include in response events, e.g. location. Only included components will - * populate. - * - * @generated from field: repeated string components_to_include = 1; - */ - componentsToInclude: string[]; - - /** - * subscribe to all components. This should only be used in cases where you want all components (e.g. latticectl) and - * if you're using it for other services please reach out first. Setting both components_to_include and - * include_all_components is invalid and will be rejected. - * - * @generated from field: bool include_all_components = 2; - */ - includeAllComponents: boolean; - - /** - * The root node of a statement filter "tree". - * If provided, only entities matching the filter criteria will be streamed. The filter is applied dynamically so if a - * new entity matches, it will be included, and if an entity updates to no longer match, it will be excluded. - * - * @generated from field: anduril.entitymanager.v1.Statement filter = 3; - */ - filter?: Statement; - - /** - * optional rate-limiting / down-sampling parameters, see RateLimit message for details. - * - * @generated from field: anduril.entitymanager.v1.RateLimit rate_limit = 4; - */ - rateLimit?: RateLimit; - - /** - * The period (in milliseconds) at which a Heartbeat message will be sent on the - * message stream. If this field is set to 0 then no Heartbeat messages are sent. - * - * @generated from field: uint32 heartbeat_period_millis = 5; - */ - heartbeatPeriodMillis: number; - - /** - * subscribe to a finite stream of preexisting events which closes when there are no additional pre-existing events to - * process. Respects the filter specified on the StreamEntityComponentsRequest. - * - * @generated from field: bool preexisting_only = 6; - */ - preexistingOnly: boolean; - - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.StreamEntityComponentsRequest"; + static readonly typeName = "anduril.entitymanager.v1.PublishEntityRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): StreamEntityComponentsRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntityRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): StreamEntityComponentsRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntityRequest; - static fromJsonString(jsonString: string, options?: Partial): StreamEntityComponentsRequest; + static fromJsonString(jsonString: string, options?: Partial): PublishEntityRequest; - static equals(a: StreamEntityComponentsRequest | PlainMessage | undefined, b: StreamEntityComponentsRequest | PlainMessage | undefined): boolean; + static equals(a: PublishEntityRequest | PlainMessage | undefined, b: PublishEntityRequest | PlainMessage | undefined): boolean; } /** - * response stream will be fed all matching pre-existing live entities as CREATED, plus any new events ongoing. - * - * @generated from message anduril.entitymanager.v1.StreamEntityComponentsResponse + * @generated from message anduril.entitymanager.v1.PublishEntityResponse */ -export declare class StreamEntityComponentsResponse extends Message { - /** - * @generated from field: anduril.entitymanager.v1.EntityEvent entity_event = 1; - */ - entityEvent?: EntityEvent; - - /** - * @generated from field: anduril.entitymanager.v1.Heartbeat heartbeat = 2; - */ - heartbeat?: Heartbeat; - - constructor(data?: PartialMessage); +export declare class PublishEntityResponse extends Message { + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.StreamEntityComponentsResponse"; + static readonly typeName = "anduril.entitymanager.v1.PublishEntityResponse"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): StreamEntityComponentsResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntityResponse; - static fromJson(jsonValue: JsonValue, options?: Partial): StreamEntityComponentsResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntityResponse; - static fromJsonString(jsonString: string, options?: Partial): StreamEntityComponentsResponse; + static fromJsonString(jsonString: string, options?: Partial): PublishEntityResponse; - static equals(a: StreamEntityComponentsResponse | PlainMessage | undefined, b: StreamEntityComponentsResponse | PlainMessage | undefined): boolean; + static equals(a: PublishEntityResponse | PlainMessage | undefined, b: PublishEntityResponse | PlainMessage | undefined): boolean; } /** - * @generated from message anduril.entitymanager.v1.PutEntityRequest + * @generated from message anduril.entitymanager.v1.PublishEntitiesRequest */ -export declare class PutEntityRequest extends Message { +export declare class PublishEntitiesRequest extends Message { /** - * The entity to put. * Required fields: * * expiry_time - must be in the future, but less than 30 days from now * * provenance.data_type * * provenance.source_update_time (can be earlier than rpc call if data entered is older) * * aliases.name - * * ontology.template * any additional required fields will be determined by template, see com.anduril.entitymanager.v1.Template * if an entity_id is provided, will treat as update, otherwise create * @@ -228,113 +127,93 @@ export declare class PutEntityRequest extends Message { */ entity?: Entity; - /** - * An optional unique identifier for this entity supplied by integration. - * If provided, EntityId will be determined via consistent hash with provenance.data_type + unique_id - * - * @generated from field: string unique_id = 2; - */ - uniqueId: string; - - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.PutEntityRequest"; + static readonly typeName = "anduril.entitymanager.v1.PublishEntitiesRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): PutEntityRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntitiesRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): PutEntityRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntitiesRequest; - static fromJsonString(jsonString: string, options?: Partial): PutEntityRequest; + static fromJsonString(jsonString: string, options?: Partial): PublishEntitiesRequest; - static equals(a: PutEntityRequest | PlainMessage | undefined, b: PutEntityRequest | PlainMessage | undefined): boolean; + static equals(a: PublishEntitiesRequest | PlainMessage | undefined, b: PublishEntitiesRequest | PlainMessage | undefined): boolean; } /** - * @generated from message anduril.entitymanager.v1.PutEntityResponse + * After the stream is closed the server will return an empty message indicating success. If any streamed message + * caused an error then the stream is immediately terminated and an error code is returned. + * + * @generated from message anduril.entitymanager.v1.PublishEntitiesResponse */ -export declare class PutEntityResponse extends Message { - /** - * The updated entity. - * Automatically updated fields: - * * is_live - always reset to true - * * entity_id - new GUID on create - * * created_time - set on create - * - * @generated from field: anduril.entitymanager.v1.Entity entity = 1; - */ - entity?: Entity; - - constructor(data?: PartialMessage); +export declare class PublishEntitiesResponse extends Message { + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.PutEntityResponse"; + static readonly typeName = "anduril.entitymanager.v1.PublishEntitiesResponse"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): PutEntityResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntitiesResponse; - static fromJson(jsonValue: JsonValue, options?: Partial): PutEntityResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntitiesResponse; - static fromJsonString(jsonString: string, options?: Partial): PutEntityResponse; + static fromJsonString(jsonString: string, options?: Partial): PublishEntitiesResponse; - static equals(a: PutEntityResponse | PlainMessage | undefined, b: PutEntityResponse | PlainMessage | undefined): boolean; + static equals(a: PublishEntitiesResponse | PlainMessage | undefined, b: PublishEntitiesResponse | PlainMessage | undefined): boolean; } /** - * @generated from message anduril.entitymanager.v1.PublishEntitiesRequest + * @generated from message anduril.entitymanager.v1.GetEntityRequest */ -export declare class PublishEntitiesRequest extends Message { +export declare class GetEntityRequest extends Message { /** - * Stream of fully formed entities to publish - * Required fields per entity: - * * expiry_time - must be in the future, but less than 30 days from now - * * provenance.data_type - * * provenance.source_update_time (can be earlier than rpc call if data entered is older) - * * aliases.name - * * ontology.template - * any additional required fields will be determined by template, see com.anduril.entitymanager.v1.Template - * if an entity_id is provided, will treat as update, otherwise create + * the GUID of this entity to query * - * @generated from field: anduril.entitymanager.v1.Entity entity = 1; + * @generated from field: string entity_id = 1; */ - entity?: Entity; + entityId: string; - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.PublishEntitiesRequest"; + static readonly typeName = "anduril.entitymanager.v1.GetEntityRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntitiesRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): GetEntityRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntitiesRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): GetEntityRequest; - static fromJsonString(jsonString: string, options?: Partial): PublishEntitiesRequest; + static fromJsonString(jsonString: string, options?: Partial): GetEntityRequest; - static equals(a: PublishEntitiesRequest | PlainMessage | undefined, b: PublishEntitiesRequest | PlainMessage | undefined): boolean; + static equals(a: GetEntityRequest | PlainMessage | undefined, b: GetEntityRequest | PlainMessage | undefined): boolean; } /** - * After the stream is closed the server will return an empty message indicating success. If any streamed message - * caused an error then the stream is immediately terminated and an error code is returned. - * - * @generated from message anduril.entitymanager.v1.PublishEntitiesResponse + * @generated from message anduril.entitymanager.v1.GetEntityResponse */ -export declare class PublishEntitiesResponse extends Message { - constructor(data?: PartialMessage); +export declare class GetEntityResponse extends Message { + /** + * an Entity object that corresponds with the requested entityId + * + * @generated from field: anduril.entitymanager.v1.Entity entity = 1; + */ + entity?: Entity; + + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.PublishEntitiesResponse"; + static readonly typeName = "anduril.entitymanager.v1.GetEntityResponse"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): PublishEntitiesResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): GetEntityResponse; - static fromJson(jsonValue: JsonValue, options?: Partial): PublishEntitiesResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): GetEntityResponse; - static fromJsonString(jsonString: string, options?: Partial): PublishEntitiesResponse; + static fromJsonString(jsonString: string, options?: Partial): GetEntityResponse; - static equals(a: PublishEntitiesResponse | PlainMessage | undefined, b: PublishEntitiesResponse | PlainMessage | undefined): boolean; + static equals(a: GetEntityResponse | PlainMessage | undefined, b: GetEntityResponse | PlainMessage | undefined): boolean; } /** @@ -460,214 +339,102 @@ export declare class RemoveEntityOverrideResponse extends Message { - /** - * @generated from field: string entity_id = 1; - */ - entityId: string; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.DeleteEntityRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): DeleteEntityRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): DeleteEntityRequest; - - static fromJsonString(jsonString: string, options?: Partial): DeleteEntityRequest; - - static equals(a: DeleteEntityRequest | PlainMessage | undefined, b: DeleteEntityRequest | PlainMessage | undefined): boolean; -} - -/** - * void response but with placeholder for future optional fields. - * - * @generated from message anduril.entitymanager.v1.DeleteEntityResponse - */ -export declare class DeleteEntityResponse extends Message { - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.DeleteEntityResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): DeleteEntityResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): DeleteEntityResponse; - - static fromJsonString(jsonString: string, options?: Partial): DeleteEntityResponse; - - static equals(a: DeleteEntityResponse | PlainMessage | undefined, b: DeleteEntityResponse | PlainMessage | undefined): boolean; -} - -/** - * The set of relationships to add to an entity. Relationships are specified from the primary entity to the - * other entity specified in the relationship request(s). - * - * @generated from message anduril.entitymanager.v1.RelateEntityRequest + * @generated from message anduril.entitymanager.v1.StreamEntityComponentsRequest */ -export declare class RelateEntityRequest extends Message { +export declare class StreamEntityComponentsRequest extends Message { /** - * The entity onto which relationships are being added. + * lower_snake_cased component names to include in response events, e.g. location. Only included components will + * populate. * - * @generated from field: string entity_id = 1; + * @generated from field: repeated string components_to_include = 1; */ - entityId: string; + componentsToInclude: string[]; /** - * The relationships to add to the entity. + * subscribe to all components. This should only be used in cases where you want all components (e.g. latticectl) and + * if you're using it for other services please reach out first. Setting both components_to_include and + * include_all_components is invalid and will be rejected. * - * @generated from field: repeated anduril.entitymanager.v1.RelationshipRequest relationships = 2; + * @generated from field: bool include_all_components = 2; */ - relationships: RelationshipRequest[]; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.RelateEntityRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): RelateEntityRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): RelateEntityRequest; - - static fromJsonString(jsonString: string, options?: Partial): RelateEntityRequest; - - static equals(a: RelateEntityRequest | PlainMessage | undefined, b: RelateEntityRequest | PlainMessage | undefined): boolean; -} + includeAllComponents: boolean; -/** - * A request for a relationship on an entity. Forms a partial of the entitymanager.v1.Relationship message. - * - * @generated from message anduril.entitymanager.v1.RelationshipRequest - */ -export declare class RelationshipRequest extends Message { /** - * The entity ID to which this entity is related. + * The root node of a statement filter "tree". + * If provided, only entities matching the filter criteria will be streamed. The filter is applied dynamically so if a + * new entity matches, it will be included, and if an entity updates to no longer match, it will be excluded. * - * @generated from field: string related_entity_id = 1; + * @generated from field: anduril.entitymanager.v1.Statement filter = 3; */ - relatedEntityId: string; + filter?: Statement; /** - * If RelationshipID is empty, a new relationship is created. Otherwise, the service will attempt - * to update an already existing relationship on the entity. + * optional rate-limiting / down-sampling parameters, see RateLimit message for details. * - * @generated from field: string relationship_id = 2; + * @generated from field: anduril.entitymanager.v1.RateLimit rate_limit = 4; */ - relationshipId: string; + rateLimit?: RateLimit; /** - * The relationship type + * The period (in milliseconds) at which a Heartbeat message will be sent on the + * message stream. If this field is set to 0 then no Heartbeat messages are sent. * - * @generated from field: anduril.entitymanager.v1.RelationshipType relationship_type = 3; + * @generated from field: uint32 heartbeat_period_millis = 5; */ - relationshipType?: RelationshipType; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.RelationshipRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): RelationshipRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): RelationshipRequest; - - static fromJsonString(jsonString: string, options?: Partial): RelationshipRequest; - - static equals(a: RelationshipRequest | PlainMessage | undefined, b: RelationshipRequest | PlainMessage | undefined): boolean; -} + heartbeatPeriodMillis: number; -/** - * @generated from message anduril.entitymanager.v1.RelateEntityResponse - */ -export declare class RelateEntityResponse extends Message { /** - * Newly related entity object with only Relationships component present. + * subscribe to a finite stream of preexisting events which closes when there are no additional pre-existing events to + * process. Respects the filter specified on the StreamEntityComponentsRequest. * - * @generated from field: anduril.entitymanager.v1.Entity entity = 1; + * @generated from field: bool preexisting_only = 6; */ - entity?: Entity; + preexistingOnly: boolean; - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.RelateEntityResponse"; + static readonly typeName = "anduril.entitymanager.v1.StreamEntityComponentsRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): RelateEntityResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): StreamEntityComponentsRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): RelateEntityResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): StreamEntityComponentsRequest; - static fromJsonString(jsonString: string, options?: Partial): RelateEntityResponse; + static fromJsonString(jsonString: string, options?: Partial): StreamEntityComponentsRequest; - static equals(a: RelateEntityResponse | PlainMessage | undefined, b: RelateEntityResponse | PlainMessage | undefined): boolean; + static equals(a: StreamEntityComponentsRequest | PlainMessage | undefined, b: StreamEntityComponentsRequest | PlainMessage | undefined): boolean; } /** - * The relationships to remove from an entity. + * response stream will be fed all matching pre-existing live entities as CREATED, plus any new events ongoing. * - * @generated from message anduril.entitymanager.v1.UnrelateEntityRequest + * @generated from message anduril.entitymanager.v1.StreamEntityComponentsResponse */ -export declare class UnrelateEntityRequest extends Message { - /** - * The entity from which relationships are being removed. - * - * @generated from field: string entity_id = 1; - */ - entityId: string; - +export declare class StreamEntityComponentsResponse extends Message { /** - * The relationships to delete on the entity, specified as relationship id. - * - * @generated from field: repeated string relationship_ids = 2; + * @generated from field: anduril.entitymanager.v1.EntityEvent entity_event = 1; */ - relationshipIds: string[]; - - constructor(data?: PartialMessage); - - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.UnrelateEntityRequest"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): UnrelateEntityRequest; - - static fromJson(jsonValue: JsonValue, options?: Partial): UnrelateEntityRequest; - - static fromJsonString(jsonString: string, options?: Partial): UnrelateEntityRequest; - - static equals(a: UnrelateEntityRequest | PlainMessage | undefined, b: UnrelateEntityRequest | PlainMessage | undefined): boolean; -} + entityEvent?: EntityEvent; -/** - * @generated from message anduril.entitymanager.v1.UnrelateEntityResponse - */ -export declare class UnrelateEntityResponse extends Message { /** - * Updated entity object with only Relationships component present. - * - * @generated from field: anduril.entitymanager.v1.Entity entity = 1; + * @generated from field: anduril.entitymanager.v1.Heartbeat heartbeat = 2; */ - entity?: Entity; + heartbeat?: Heartbeat; - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.entitymanager.v1.UnrelateEntityResponse"; + static readonly typeName = "anduril.entitymanager.v1.StreamEntityComponentsResponse"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): UnrelateEntityResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): StreamEntityComponentsResponse; - static fromJson(jsonValue: JsonValue, options?: Partial): UnrelateEntityResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): StreamEntityComponentsResponse; - static fromJsonString(jsonString: string, options?: Partial): UnrelateEntityResponse; + static fromJsonString(jsonString: string, options?: Partial): StreamEntityComponentsResponse; - static equals(a: UnrelateEntityResponse | PlainMessage | undefined, b: UnrelateEntityResponse | PlainMessage | undefined): boolean; + static equals(a: StreamEntityComponentsResponse | PlainMessage | undefined, b: StreamEntityComponentsResponse | PlainMessage | undefined): boolean; } /** diff --git a/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.js b/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.js index 0d671c4..288ca91 100644 --- a/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.js +++ b/src/anduril/entitymanager/v1/entity_manager_api.pub_pb.js @@ -8,10 +8,9 @@ Object.defineProperty(exports, "__esModule", { value: true }); const { proto3, Timestamp } = require("@bufbuild/protobuf"); const { Entity, Provenance } = require("./entity.pub_pb.js"); +const { OverrideStatus } = require("./types.pub_pb.js"); const { Statement } = require("./filter.pub_pb.js"); const { RateLimit } = require("./rate_limit.pub_pb.js"); -const { OverrideStatus } = require("./types.pub_pb.js"); -const { RelationshipType } = require("./relationship.pub_pb.js"); /** * The type of entity event. @@ -31,95 +30,64 @@ const EventType = proto3.makeEnum( ); /** - * @generated from message anduril.entitymanager.v1.GetEntityRequest + * @generated from message anduril.entitymanager.v1.PublishEntityRequest */ -const GetEntityRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.GetEntityRequest", - () => [ - { no: 1, name: "entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * @generated from message anduril.entitymanager.v1.GetEntityResponse - */ -const GetEntityResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.GetEntityResponse", +const PublishEntityRequest = proto3.makeMessageType( + "anduril.entitymanager.v1.PublishEntityRequest", () => [ { no: 1, name: "entity", kind: "message", T: Entity }, ], ); /** - * @generated from message anduril.entitymanager.v1.StreamEntityComponentsRequest + * @generated from message anduril.entitymanager.v1.PublishEntityResponse */ -const StreamEntityComponentsRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.StreamEntityComponentsRequest", - () => [ - { no: 1, name: "components_to_include", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true }, - { no: 2, name: "include_all_components", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, - { no: 3, name: "filter", kind: "message", T: Statement }, - { no: 4, name: "rate_limit", kind: "message", T: RateLimit }, - { no: 5, name: "heartbeat_period_millis", kind: "scalar", T: 13 /* ScalarType.UINT32 */ }, - { no: 6, name: "preexisting_only", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, - ], +const PublishEntityResponse = proto3.makeMessageType( + "anduril.entitymanager.v1.PublishEntityResponse", + [], ); /** - * response stream will be fed all matching pre-existing live entities as CREATED, plus any new events ongoing. - * - * @generated from message anduril.entitymanager.v1.StreamEntityComponentsResponse + * @generated from message anduril.entitymanager.v1.PublishEntitiesRequest */ -const StreamEntityComponentsResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.StreamEntityComponentsResponse", +const PublishEntitiesRequest = proto3.makeMessageType( + "anduril.entitymanager.v1.PublishEntitiesRequest", () => [ - { no: 1, name: "entity_event", kind: "message", T: EntityEvent }, - { no: 2, name: "heartbeat", kind: "message", T: Heartbeat }, + { no: 1, name: "entity", kind: "message", T: Entity }, ], ); /** - * @generated from message anduril.entitymanager.v1.PutEntityRequest + * After the stream is closed the server will return an empty message indicating success. If any streamed message + * caused an error then the stream is immediately terminated and an error code is returned. + * + * @generated from message anduril.entitymanager.v1.PublishEntitiesResponse */ -const PutEntityRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.PutEntityRequest", - () => [ - { no: 1, name: "entity", kind: "message", T: Entity }, - { no: 2, name: "unique_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], +const PublishEntitiesResponse = proto3.makeMessageType( + "anduril.entitymanager.v1.PublishEntitiesResponse", + [], ); /** - * @generated from message anduril.entitymanager.v1.PutEntityResponse + * @generated from message anduril.entitymanager.v1.GetEntityRequest */ -const PutEntityResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.PutEntityResponse", +const GetEntityRequest = proto3.makeMessageType( + "anduril.entitymanager.v1.GetEntityRequest", () => [ - { no: 1, name: "entity", kind: "message", T: Entity }, + { no: 1, name: "entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, ], ); /** - * @generated from message anduril.entitymanager.v1.PublishEntitiesRequest + * @generated from message anduril.entitymanager.v1.GetEntityResponse */ -const PublishEntitiesRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.PublishEntitiesRequest", +const GetEntityResponse = proto3.makeMessageType( + "anduril.entitymanager.v1.GetEntityResponse", () => [ { no: 1, name: "entity", kind: "message", T: Entity }, ], ); -/** - * After the stream is closed the server will return an empty message indicating success. If any streamed message - * caused an error then the stream is immediately terminated and an error code is returned. - * - * @generated from message anduril.entitymanager.v1.PublishEntitiesResponse - */ -const PublishEntitiesResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.PublishEntitiesResponse", - [], -); - /** * @generated from message anduril.entitymanager.v1.OverrideEntityRequest */ @@ -164,83 +132,30 @@ const RemoveEntityOverrideResponse = proto3.makeMessageType( ); /** - * @generated from message anduril.entitymanager.v1.DeleteEntityRequest - */ -const DeleteEntityRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.DeleteEntityRequest", - () => [ - { no: 1, name: "entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - ], -); - -/** - * void response but with placeholder for future optional fields. - * - * @generated from message anduril.entitymanager.v1.DeleteEntityResponse - */ -const DeleteEntityResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.DeleteEntityResponse", - [], -); - -/** - * The set of relationships to add to an entity. Relationships are specified from the primary entity to the - * other entity specified in the relationship request(s). - * - * @generated from message anduril.entitymanager.v1.RelateEntityRequest - */ -const RelateEntityRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.RelateEntityRequest", - () => [ - { no: 1, name: "entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "relationships", kind: "message", T: RelationshipRequest, repeated: true }, - ], -); - -/** - * A request for a relationship on an entity. Forms a partial of the entitymanager.v1.Relationship message. - * - * @generated from message anduril.entitymanager.v1.RelationshipRequest - */ -const RelationshipRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.RelationshipRequest", - () => [ - { no: 1, name: "related_entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "relationship_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 3, name: "relationship_type", kind: "message", T: RelationshipType }, - ], -); - -/** - * @generated from message anduril.entitymanager.v1.RelateEntityResponse + * @generated from message anduril.entitymanager.v1.StreamEntityComponentsRequest */ -const RelateEntityResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.RelateEntityResponse", +const StreamEntityComponentsRequest = proto3.makeMessageType( + "anduril.entitymanager.v1.StreamEntityComponentsRequest", () => [ - { no: 1, name: "entity", kind: "message", T: Entity }, + { no: 1, name: "components_to_include", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true }, + { no: 2, name: "include_all_components", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, + { no: 3, name: "filter", kind: "message", T: Statement }, + { no: 4, name: "rate_limit", kind: "message", T: RateLimit }, + { no: 5, name: "heartbeat_period_millis", kind: "scalar", T: 13 /* ScalarType.UINT32 */ }, + { no: 6, name: "preexisting_only", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, ], ); /** - * The relationships to remove from an entity. + * response stream will be fed all matching pre-existing live entities as CREATED, plus any new events ongoing. * - * @generated from message anduril.entitymanager.v1.UnrelateEntityRequest - */ -const UnrelateEntityRequest = proto3.makeMessageType( - "anduril.entitymanager.v1.UnrelateEntityRequest", - () => [ - { no: 1, name: "entity_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, - { no: 2, name: "relationship_ids", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true }, - ], -); - -/** - * @generated from message anduril.entitymanager.v1.UnrelateEntityResponse + * @generated from message anduril.entitymanager.v1.StreamEntityComponentsResponse */ -const UnrelateEntityResponse = proto3.makeMessageType( - "anduril.entitymanager.v1.UnrelateEntityResponse", +const StreamEntityComponentsResponse = proto3.makeMessageType( + "anduril.entitymanager.v1.StreamEntityComponentsResponse", () => [ - { no: 1, name: "entity", kind: "message", T: Entity }, + { no: 1, name: "entity_event", kind: "message", T: EntityEvent }, + { no: 2, name: "heartbeat", kind: "message", T: Heartbeat }, ], ); @@ -272,24 +187,17 @@ const Heartbeat = proto3.makeMessageType( exports.EventType = EventType; -exports.GetEntityRequest = GetEntityRequest; -exports.GetEntityResponse = GetEntityResponse; -exports.StreamEntityComponentsRequest = StreamEntityComponentsRequest; -exports.StreamEntityComponentsResponse = StreamEntityComponentsResponse; -exports.PutEntityRequest = PutEntityRequest; -exports.PutEntityResponse = PutEntityResponse; +exports.PublishEntityRequest = PublishEntityRequest; +exports.PublishEntityResponse = PublishEntityResponse; exports.PublishEntitiesRequest = PublishEntitiesRequest; exports.PublishEntitiesResponse = PublishEntitiesResponse; +exports.GetEntityRequest = GetEntityRequest; +exports.GetEntityResponse = GetEntityResponse; exports.OverrideEntityRequest = OverrideEntityRequest; exports.OverrideEntityResponse = OverrideEntityResponse; exports.RemoveEntityOverrideRequest = RemoveEntityOverrideRequest; exports.RemoveEntityOverrideResponse = RemoveEntityOverrideResponse; -exports.DeleteEntityRequest = DeleteEntityRequest; -exports.DeleteEntityResponse = DeleteEntityResponse; -exports.RelateEntityRequest = RelateEntityRequest; -exports.RelationshipRequest = RelationshipRequest; -exports.RelateEntityResponse = RelateEntityResponse; -exports.UnrelateEntityRequest = UnrelateEntityRequest; -exports.UnrelateEntityResponse = UnrelateEntityResponse; +exports.StreamEntityComponentsRequest = StreamEntityComponentsRequest; +exports.StreamEntityComponentsResponse = StreamEntityComponentsResponse; exports.EntityEvent = EntityEvent; exports.Heartbeat = Heartbeat; diff --git a/src/anduril/entitymanager/v1/health_status.pub_pb.d.ts b/src/anduril/entitymanager/v1/health_status.pub_pb.d.ts index 589b59d..7351d12 100644 --- a/src/anduril/entitymanager/v1/health_status.pub_pb.d.ts +++ b/src/anduril/entitymanager/v1/health_status.pub_pb.d.ts @@ -77,6 +77,39 @@ export declare enum HealthStatus { NOT_READY = 5, } +/** + * Alerts are categorized into one of three levels - Warnings, Cautions, and Advisories (WCAs). + * + * @generated from enum anduril.entitymanager.v1.AlertLevel + */ +export declare enum AlertLevel { + /** + * @generated from enum value: ALERT_LEVEL_INVALID = 0; + */ + INVALID = 0, + + /** + * For conditions that require awareness and may require subsequent response. + * + * @generated from enum value: ALERT_LEVEL_ADVISORY = 1; + */ + ADVISORY = 1, + + /** + * For conditions that require immediate awareness and subsequent response. + * + * @generated from enum value: ALERT_LEVEL_CAUTION = 2; + */ + CAUTION = 2, + + /** + * For conditions that require immediate awareness and response. + * + * @generated from enum value: ALERT_LEVEL_WARNING = 3; + */ + WARNING = 3, +} + /** * A message describing the component's health status. * @@ -204,6 +237,18 @@ export declare class Health extends Message { */ updateTime?: Timestamp; + /** + * Active alerts indicate a critical change in system state sent by the asset + * that must be made known to an operator or consumer of the common operating picture. + * Alerts are different from ComponentHealth messages--an active alert does not necessarily + * indicate a component is in an unhealthy state. For example, an asset may trigger + * an active alert based on fuel levels running low. Alerts should be removed from this list when their conditions + * are cleared. In other words, only active alerts should be reported here. + * + * @generated from field: repeated anduril.entitymanager.v1.Alert active_alerts = 5; + */ + activeAlerts: Alert[]; + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; @@ -219,3 +264,101 @@ export declare class Health extends Message { static equals(a: Health | PlainMessage | undefined, b: Health | PlainMessage | undefined): boolean; } +/** + * An alert informs operators of critical events related to system performance and mission + * execution. An alert is produced as a result of one or more alert conditions. + * + * @generated from message anduril.entitymanager.v1.Alert + */ +export declare class Alert extends Message { + /** + * Short, machine-readable code that describes this alert. This code is intended to provide systems off-asset + * with a lookup key to retrieve more detailed information about the alert. + * + * @generated from field: string alert_code = 1; + */ + alertCode: string; + + /** + * Human-readable description of this alert. The description is intended for display in the UI for human + * understanding and should not be used for machine processing. If the description is fixed and the vehicle controller + * provides no dynamic substitutions, then prefer lookup based on alert_code. + * + * @generated from field: string description = 2; + */ + description: string; + + /** + * Alert level (Warning, Caution, or Advisory). + * + * @generated from field: anduril.entitymanager.v1.AlertLevel level = 3; + */ + level: AlertLevel; + + /** + * Time at which this alert was activated. + * + * @generated from field: google.protobuf.Timestamp activated_time = 4; + */ + activatedTime?: Timestamp; + + /** + * Set of conditions which have activated this alert. + * + * @generated from field: repeated anduril.entitymanager.v1.AlertCondition active_conditions = 5; + */ + activeConditions: AlertCondition[]; + + constructor(data?: PartialMessage); + + static readonly runtime: typeof proto3; + static readonly typeName = "anduril.entitymanager.v1.Alert"; + static readonly fields: FieldList; + + static fromBinary(bytes: Uint8Array, options?: Partial): Alert; + + static fromJson(jsonValue: JsonValue, options?: Partial): Alert; + + static fromJsonString(jsonString: string, options?: Partial): Alert; + + static equals(a: Alert | PlainMessage | undefined, b: Alert | PlainMessage | undefined): boolean; +} + +/** + * A condition which may trigger an alert. + * + * @generated from message anduril.entitymanager.v1.AlertCondition + */ +export declare class AlertCondition extends Message { + /** + * Short, machine-readable code that describes this condition. This code is intended to provide systems off-asset + * with a lookup key to retrieve more detailed information about the condition. + * + * @generated from field: string condition_code = 1; + */ + conditionCode: string; + + /** + * Human-readable description of this condition. The description is intended for display in the UI for human + * understanding and should not be used for machine processing. If the description is fixed and the vehicle controller + * provides no dynamic substitutions, then prefer lookup based on condition_code. + * + * @generated from field: string description = 2; + */ + description: string; + + constructor(data?: PartialMessage); + + static readonly runtime: typeof proto3; + static readonly typeName = "anduril.entitymanager.v1.AlertCondition"; + static readonly fields: FieldList; + + static fromBinary(bytes: Uint8Array, options?: Partial): AlertCondition; + + static fromJson(jsonValue: JsonValue, options?: Partial): AlertCondition; + + static fromJsonString(jsonString: string, options?: Partial): AlertCondition; + + static equals(a: AlertCondition | PlainMessage | undefined, b: AlertCondition | PlainMessage | undefined): boolean; +} + diff --git a/src/anduril/entitymanager/v1/health_status.pub_pb.js b/src/anduril/entitymanager/v1/health_status.pub_pb.js index d986097..f38d3ea 100644 --- a/src/anduril/entitymanager/v1/health_status.pub_pb.js +++ b/src/anduril/entitymanager/v1/health_status.pub_pb.js @@ -39,6 +39,21 @@ const HealthStatus = proto3.makeEnum( ], ); +/** + * Alerts are categorized into one of three levels - Warnings, Cautions, and Advisories (WCAs). + * + * @generated from enum anduril.entitymanager.v1.AlertLevel + */ +const AlertLevel = proto3.makeEnum( + "anduril.entitymanager.v1.AlertLevel", + [ + {no: 0, name: "ALERT_LEVEL_INVALID", localName: "INVALID"}, + {no: 1, name: "ALERT_LEVEL_ADVISORY", localName: "ADVISORY"}, + {no: 2, name: "ALERT_LEVEL_CAUTION", localName: "CAUTION"}, + {no: 3, name: "ALERT_LEVEL_WARNING", localName: "WARNING"}, + ], +); + /** * A message describing the component's health status. * @@ -80,12 +95,46 @@ const Health = proto3.makeMessageType( { no: 2, name: "health_status", kind: "enum", T: proto3.getEnumType(HealthStatus) }, { no: 3, name: "components", kind: "message", T: ComponentHealth, repeated: true }, { no: 4, name: "update_time", kind: "message", T: Timestamp }, + { no: 5, name: "active_alerts", kind: "message", T: Alert, repeated: true }, + ], +); + +/** + * An alert informs operators of critical events related to system performance and mission + * execution. An alert is produced as a result of one or more alert conditions. + * + * @generated from message anduril.entitymanager.v1.Alert + */ +const Alert = proto3.makeMessageType( + "anduril.entitymanager.v1.Alert", + () => [ + { no: 1, name: "alert_code", kind: "scalar", T: 9 /* ScalarType.STRING */ }, + { no: 2, name: "description", kind: "scalar", T: 9 /* ScalarType.STRING */ }, + { no: 3, name: "level", kind: "enum", T: proto3.getEnumType(AlertLevel) }, + { no: 4, name: "activated_time", kind: "message", T: Timestamp }, + { no: 5, name: "active_conditions", kind: "message", T: AlertCondition, repeated: true }, + ], +); + +/** + * A condition which may trigger an alert. + * + * @generated from message anduril.entitymanager.v1.AlertCondition + */ +const AlertCondition = proto3.makeMessageType( + "anduril.entitymanager.v1.AlertCondition", + () => [ + { no: 1, name: "condition_code", kind: "scalar", T: 9 /* ScalarType.STRING */ }, + { no: 2, name: "description", kind: "scalar", T: 9 /* ScalarType.STRING */ }, ], ); exports.ConnectionStatus = ConnectionStatus; exports.HealthStatus = HealthStatus; +exports.AlertLevel = AlertLevel; exports.ComponentMessage = ComponentMessage; exports.ComponentHealth = ComponentHealth; exports.Health = Health; +exports.Alert = Alert; +exports.AlertCondition = AlertCondition; diff --git a/src/anduril/entitymanager/v1/types.pub_pb.d.ts b/src/anduril/entitymanager/v1/types.pub_pb.d.ts index 08c62cd..52af1ce 100644 --- a/src/anduril/entitymanager/v1/types.pub_pb.d.ts +++ b/src/anduril/entitymanager/v1/types.pub_pb.d.ts @@ -60,15 +60,14 @@ export declare enum AltIdType { ASSET_ID = 5, /** - * deprecated, do not use + * Use for Link 16 track identifiers for non-JTIDS Unit (JU) entities, such as assets (STN) and tracks (RefTN). Values range from AA000 to ZZ777. * - * @generated from enum value: ALT_ID_TYPE_LINK16_TRACK_NUMBER = 6 [deprecated = true]; - * @deprecated + * @generated from enum value: ALT_ID_TYPE_LINK16_TRACK_NUMBER = 6; */ LINK16_TRACK_NUMBER = 6, /** - * a Link 16 track number. This will allow a link 16 asset (STN) or track (RefTN) to be identified. + * Use for Link 16 JTIDS Unit (JU) identifiers. Applicable to assets representing JUs, with values ranging from 00001 to 77777. * * @generated from enum value: ALT_ID_TYPE_LINK16_JU = 7; */ diff --git a/src/anduril/taskmanager/v1/task_manager_api.pub_connect.d.ts b/src/anduril/taskmanager/v1/task_manager_api.pub_connect.d.ts index b04bc13..370587e 100644 --- a/src/anduril/taskmanager/v1/task_manager_api.pub_connect.d.ts +++ b/src/anduril/taskmanager/v1/task_manager_api.pub_connect.d.ts @@ -3,12 +3,12 @@ /* eslint-disable */ // @ts-nocheck -import { CreateTaskRequest, CreateTaskResponse, GetTaskRequest, GetTaskResponse, ListenAsAgentRequest, ListenAsAgentResponse, StreamTasksRequest, StreamTasksResponse, UpdateStatusRequest, UpdateStatusResponse, UpdateTaskRequest, UpdateTaskResponse } from "./task_manager_api.pub_pb.js"; +import { CreateTaskRequest, CreateTaskResponse, GetTaskRequest, GetTaskResponse, ListenAsAgentRequest, ListenAsAgentResponse, QueryTasksRequest, QueryTasksResponse, UpdateStatusRequest, UpdateStatusResponse } from "./task_manager_api.pub_pb.js"; import { MethodKind } from "@bufbuild/protobuf"; /** * Task Manager is a service that performs state management associated with Tasks, and also the execution of Tasks - * on their designated agents. + * on their designated agents. * * @generated from service anduril.taskmanager.v1.TaskManagerAPI */ @@ -38,18 +38,14 @@ export declare const TaskManagerAPI: { readonly kind: MethodKind.Unary, }, /** - * Update definition of a Task, only works on Tasks that are not DONE or CANCEL_REQUESTED. Notes: - * * send the current task_version in Task, API will increment definition_version, and reset status_version to 1. - * * previous definition_version will have status set to REPLACED. - * * depending on assignee, replacing the definition will either update if capable on backend, - * or cancel previous and issue new. + * Find Tasks that match request criteria. * - * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.UpdateTask + * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.QueryTasks */ - readonly updateTask: { - readonly name: "UpdateTask", - readonly I: typeof UpdateTaskRequest, - readonly O: typeof UpdateTaskResponse, + readonly queryTasks: { + readonly name: "QueryTasks", + readonly I: typeof QueryTasksRequest, + readonly O: typeof QueryTasksResponse, readonly kind: MethodKind.Unary, }, /** @@ -63,18 +59,6 @@ export declare const TaskManagerAPI: { readonly O: typeof UpdateStatusResponse, readonly kind: MethodKind.Unary, }, - /** - * Stream all existing live (not yet done) Tasks and any new updates. - * Intended for clients to gain visibility into real time updates for live Tasks. - * - * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.StreamTasks - */ - readonly streamTasks: { - readonly name: "StreamTasks", - readonly I: typeof StreamTasksRequest, - readonly O: typeof StreamTasksResponse, - readonly kind: MethodKind.ServerStreaming, - }, /** * Stream Tasks ready for RPC Agent execution that match agent selector (ex: entity_ids). * Intended for use by Taskable Agents that need to receive Tasks ready for execution by RPC (no Flux access) diff --git a/src/anduril/taskmanager/v1/task_manager_api.pub_connect.js b/src/anduril/taskmanager/v1/task_manager_api.pub_connect.js index 5fd2d47..9e62dbe 100644 --- a/src/anduril/taskmanager/v1/task_manager_api.pub_connect.js +++ b/src/anduril/taskmanager/v1/task_manager_api.pub_connect.js @@ -6,12 +6,12 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); -const { CreateTaskRequest, CreateTaskResponse, GetTaskRequest, GetTaskResponse, ListenAsAgentRequest, ListenAsAgentResponse, StreamTasksRequest, StreamTasksResponse, UpdateStatusRequest, UpdateStatusResponse, UpdateTaskRequest, UpdateTaskResponse } = require("./task_manager_api.pub_pb.js"); +const { CreateTaskRequest, CreateTaskResponse, GetTaskRequest, GetTaskResponse, ListenAsAgentRequest, ListenAsAgentResponse, QueryTasksRequest, QueryTasksResponse, UpdateStatusRequest, UpdateStatusResponse } = require("./task_manager_api.pub_pb.js"); const { MethodKind } = require("@bufbuild/protobuf"); /** * Task Manager is a service that performs state management associated with Tasks, and also the execution of Tasks - * on their designated agents. + * on their designated agents. * * @generated from service anduril.taskmanager.v1.TaskManagerAPI */ @@ -41,18 +41,14 @@ const TaskManagerAPI = { kind: MethodKind.Unary, }, /** - * Update definition of a Task, only works on Tasks that are not DONE or CANCEL_REQUESTED. Notes: - * * send the current task_version in Task, API will increment definition_version, and reset status_version to 1. - * * previous definition_version will have status set to REPLACED. - * * depending on assignee, replacing the definition will either update if capable on backend, - * or cancel previous and issue new. + * Find Tasks that match request criteria. * - * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.UpdateTask + * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.QueryTasks */ - updateTask: { - name: "UpdateTask", - I: UpdateTaskRequest, - O: UpdateTaskResponse, + queryTasks: { + name: "QueryTasks", + I: QueryTasksRequest, + O: QueryTasksResponse, kind: MethodKind.Unary, }, /** @@ -66,18 +62,6 @@ const TaskManagerAPI = { O: UpdateStatusResponse, kind: MethodKind.Unary, }, - /** - * Stream all existing live (not yet done) Tasks and any new updates. - * Intended for clients to gain visibility into real time updates for live Tasks. - * - * @generated from rpc anduril.taskmanager.v1.TaskManagerAPI.StreamTasks - */ - streamTasks: { - name: "StreamTasks", - I: StreamTasksRequest, - O: StreamTasksResponse, - kind: MethodKind.ServerStreaming, - }, /** * Stream Tasks ready for RPC Agent execution that match agent selector (ex: entity_ids). * Intended for use by Taskable Agents that need to receive Tasks ready for execution by RPC (no Flux access) diff --git a/src/anduril/taskmanager/v1/task_manager_api.pub_pb.d.ts b/src/anduril/taskmanager/v1/task_manager_api.pub_pb.d.ts index 6c0d454..31973e6 100644 --- a/src/anduril/taskmanager/v1/task_manager_api.pub_pb.d.ts +++ b/src/anduril/taskmanager/v1/task_manager_api.pub_pb.d.ts @@ -5,7 +5,7 @@ import type { Any, BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage, Timestamp } from "@bufbuild/protobuf"; import { Message, proto3 } from "@bufbuild/protobuf"; -import type { Principal, Relations, StatusUpdate, Task, TaskEntity, TaskEvent, TaskView } from "./task.pub_pb.js"; +import type { Principal, Relations, Status, StatusUpdate, Task, TaskEntity, TaskView } from "./task.pub_pb.js"; import type { CancelRequest, CompleteRequest, ExecuteRequest } from "./task_api.pub_pb.js"; /** @@ -190,212 +190,245 @@ export declare class GetTaskResponse extends Message { } /** - * Request to update a Task. + * Request to query for Tasks. Returns the each latest Task by Status ID and Version ID by default with no filters. * - * @generated from message anduril.taskmanager.v1.UpdateTaskRequest + * @generated from message anduril.taskmanager.v1.QueryTasksRequest */ -export declare class UpdateTaskRequest extends Message { +export declare class QueryTasksRequest extends Message { /** - * New Task definition. + * If present matches Tasks with this parent Task ID. + * Note: this is mutually exclusive with all other query parameters, i.e., either provide parent Task ID, or + * any of the remaining parameters, but not both. * - * @generated from field: anduril.taskmanager.v1.Task task = 1; + * @generated from field: string parent_task_id = 1; */ - task?: Task; + parentTaskId: string; /** - * If set, execution of this Task is managed elsewhere, not by task-manager. - * In other words, Task Manager will not attempt to update the assigned agent with execution instructions. - * We note that this will also override the existing is_executed_elsewhere value in the Task - * object provided in this request. + * If set, returns results starting from the given page token. * - * @generated from field: bool is_executed_elsewhere = 7; + * @generated from field: string page_token = 3; */ - isExecutedElsewhere: boolean; + pageToken: string; + + /** + * Filters on provided status types in the filter. + * + * @generated from field: anduril.taskmanager.v1.QueryTasksRequest.StatusFilter status_filter = 4; + */ + statusFilter?: QueryTasksRequest_StatusFilter; - constructor(data?: PartialMessage); + /** + * If provided, only provides Tasks updated within the time range. + * + * @generated from field: anduril.taskmanager.v1.QueryTasksRequest.TimeRange update_time_range = 5; + */ + updateTimeRange?: QueryTasksRequest_TimeRange; + + /** + * Optional filter for view of a Task. + * If not set, defaults to TASK_VIEW_MANAGER. + * + * @generated from field: anduril.taskmanager.v1.TaskView view = 6; + */ + view: TaskView; + + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.UpdateTaskRequest"; + static readonly typeName = "anduril.taskmanager.v1.QueryTasksRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): UpdateTaskRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): QueryTasksRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): UpdateTaskRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): QueryTasksRequest; - static fromJsonString(jsonString: string, options?: Partial): UpdateTaskRequest; + static fromJsonString(jsonString: string, options?: Partial): QueryTasksRequest; - static equals(a: UpdateTaskRequest | PlainMessage | undefined, b: UpdateTaskRequest | PlainMessage | undefined): boolean; + static equals(a: QueryTasksRequest | PlainMessage | undefined, b: QueryTasksRequest | PlainMessage | undefined): boolean; } /** - * Response to an Update Task request. + * The type of filter. * - * @generated from message anduril.taskmanager.v1.UpdateTaskResponse + * @generated from enum anduril.taskmanager.v1.QueryTasksRequest.FilterType */ -export declare class UpdateTaskResponse extends Message { +export declare enum QueryTasksRequest_FilterType { /** - * the updated task - * - * @generated from field: anduril.taskmanager.v1.Task task = 1; + * @generated from enum value: FILTER_TYPE_INVALID = 0; */ - task?: Task; - - constructor(data?: PartialMessage); + INVALID = 0, - static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.UpdateTaskResponse"; - static readonly fields: FieldList; - - static fromBinary(bytes: Uint8Array, options?: Partial): UpdateTaskResponse; - - static fromJson(jsonValue: JsonValue, options?: Partial): UpdateTaskResponse; - - static fromJsonString(jsonString: string, options?: Partial): UpdateTaskResponse; + /** + * @generated from enum value: FILTER_TYPE_INCLUSIVE = 1; + */ + INCLUSIVE = 1, - static equals(a: UpdateTaskResponse | PlainMessage | undefined, b: UpdateTaskResponse | PlainMessage | undefined): boolean; + /** + * @generated from enum value: FILTER_TYPE_EXCLUSIVE = 2; + */ + EXCLUSIVE = 2, } /** - * Request to update a Task's status. + * A time range query for Tasks. * - * @generated from message anduril.taskmanager.v1.UpdateStatusRequest + * @generated from message anduril.taskmanager.v1.QueryTasksRequest.TimeRange */ -export declare class UpdateStatusRequest extends Message { +export declare class QueryTasksRequest_TimeRange extends Message { /** - * The updated status. + * If provided, returns Tasks only updated after this time. * - * @generated from field: anduril.taskmanager.v1.StatusUpdate status_update = 1; + * @generated from field: google.protobuf.Timestamp update_start_time = 1; */ - statusUpdate?: StatusUpdate; + updateStartTime?: Timestamp; - constructor(data?: PartialMessage); + /** + * If provided, returns Tasks only updated before this time. + * + * @generated from field: google.protobuf.Timestamp update_end_time = 2; + */ + updateEndTime?: Timestamp; + + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.UpdateStatusRequest"; + static readonly typeName = "anduril.taskmanager.v1.QueryTasksRequest.TimeRange"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): UpdateStatusRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): QueryTasksRequest_TimeRange; - static fromJson(jsonValue: JsonValue, options?: Partial): UpdateStatusRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): QueryTasksRequest_TimeRange; - static fromJsonString(jsonString: string, options?: Partial): UpdateStatusRequest; + static fromJsonString(jsonString: string, options?: Partial): QueryTasksRequest_TimeRange; - static equals(a: UpdateStatusRequest | PlainMessage | undefined, b: UpdateStatusRequest | PlainMessage | undefined): boolean; + static equals(a: QueryTasksRequest_TimeRange | PlainMessage | undefined, b: QueryTasksRequest_TimeRange | PlainMessage | undefined): boolean; } /** - * Response to an Update Status request. + * A filter for statuses. * - * @generated from message anduril.taskmanager.v1.UpdateStatusResponse + * @generated from message anduril.taskmanager.v1.QueryTasksRequest.StatusFilter */ -export declare class UpdateStatusResponse extends Message { +export declare class QueryTasksRequest_StatusFilter extends Message { /** - * The updated Task. + * Statuses to be part of the filter. * - * @generated from field: anduril.taskmanager.v1.Task task = 1; + * @generated from field: repeated anduril.taskmanager.v1.Status status = 1; */ - task?: Task; + status: Status[]; - constructor(data?: PartialMessage); + /** + * The type of filter to apply. + * + * @generated from field: anduril.taskmanager.v1.QueryTasksRequest.FilterType filter_type = 2; + */ + filterType: QueryTasksRequest_FilterType; + + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.UpdateStatusResponse"; + static readonly typeName = "anduril.taskmanager.v1.QueryTasksRequest.StatusFilter"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): UpdateStatusResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): QueryTasksRequest_StatusFilter; - static fromJson(jsonValue: JsonValue, options?: Partial): UpdateStatusResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): QueryTasksRequest_StatusFilter; - static fromJsonString(jsonString: string, options?: Partial): UpdateStatusResponse; + static fromJsonString(jsonString: string, options?: Partial): QueryTasksRequest_StatusFilter; - static equals(a: UpdateStatusResponse | PlainMessage | undefined, b: UpdateStatusResponse | PlainMessage | undefined): boolean; + static equals(a: QueryTasksRequest_StatusFilter | PlainMessage | undefined, b: QueryTasksRequest_StatusFilter | PlainMessage | undefined): boolean; } /** - * Request to Stream Tasks. Returns all live Tasks (aka all not-DONE Tasks). + * Response to a Query Task request. * - * @generated from message anduril.taskmanager.v1.StreamTasksRequest + * @generated from message anduril.taskmanager.v1.QueryTasksResponse */ -export declare class StreamTasksRequest extends Message { +export declare class QueryTasksResponse extends Message { /** - * Optional rate limiting on StreamTasksResponses. + * Tasks matching the Query Task request. * - * @generated from field: anduril.taskmanager.v1.RateLimit rate_limit = 1; + * @generated from field: repeated anduril.taskmanager.v1.Task tasks = 1; */ - rateLimit?: RateLimit; + tasks: Task[]; /** - * Optional additional views of a Task. - * If not set, defaults to TASK_VIEW_MANAGER. + * Page token to the next page of Tasks. * - * @generated from field: repeated anduril.taskmanager.v1.TaskView views = 2; + * @generated from field: string page_token = 2; */ - views: TaskView[]; + pageToken: string; - /** - * Optional period (in milliseconds) at which a Heartbeat message will be sent on the - * message stream. If this field is unset then no Heartbeat messages are sent. - * - * @generated from field: uint32 heartbeat_period_millis = 3; - */ - heartbeatPeriodMillis: number; + constructor(data?: PartialMessage); + static readonly runtime: typeof proto3; + static readonly typeName = "anduril.taskmanager.v1.QueryTasksResponse"; + static readonly fields: FieldList; + + static fromBinary(bytes: Uint8Array, options?: Partial): QueryTasksResponse; + + static fromJson(jsonValue: JsonValue, options?: Partial): QueryTasksResponse; + + static fromJsonString(jsonString: string, options?: Partial): QueryTasksResponse; + + static equals(a: QueryTasksResponse | PlainMessage | undefined, b: QueryTasksResponse | PlainMessage | undefined): boolean; +} + +/** + * Request to update a Task's status. + * + * @generated from message anduril.taskmanager.v1.UpdateStatusRequest + */ +export declare class UpdateStatusRequest extends Message { /** - * Optional flag to only include tasks created or updated after the stream is initiated, and not any previous preexisting tasks. - * If unset, the stream will include any new tasks and task updates, as well as all preexisting tasks. + * The updated status. * - * @generated from field: bool exclude_preexisting_tasks = 4; + * @generated from field: anduril.taskmanager.v1.StatusUpdate status_update = 1; */ - excludePreexistingTasks: boolean; + statusUpdate?: StatusUpdate; - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.StreamTasksRequest"; + static readonly typeName = "anduril.taskmanager.v1.UpdateStatusRequest"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): StreamTasksRequest; + static fromBinary(bytes: Uint8Array, options?: Partial): UpdateStatusRequest; - static fromJson(jsonValue: JsonValue, options?: Partial): StreamTasksRequest; + static fromJson(jsonValue: JsonValue, options?: Partial): UpdateStatusRequest; - static fromJsonString(jsonString: string, options?: Partial): StreamTasksRequest; + static fromJsonString(jsonString: string, options?: Partial): UpdateStatusRequest; - static equals(a: StreamTasksRequest | PlainMessage | undefined, b: StreamTasksRequest | PlainMessage | undefined): boolean; + static equals(a: UpdateStatusRequest | PlainMessage | undefined, b: UpdateStatusRequest | PlainMessage | undefined): boolean; } /** - * Response stream will be fed all matching pre-existing live Tasks, plus any new events ongoing. + * Response to an Update Status request. * - * @generated from message anduril.taskmanager.v1.StreamTasksResponse + * @generated from message anduril.taskmanager.v1.UpdateStatusResponse */ -export declare class StreamTasksResponse extends Message { - /** - * Task event associated with the streaming request. - * - * @generated from field: anduril.taskmanager.v1.TaskEvent task_event = 1; - */ - taskEvent?: TaskEvent; - +export declare class UpdateStatusResponse extends Message { /** - * Heartbeat message signaling liveliness of the stream. + * The updated Task. * - * @generated from field: anduril.taskmanager.v1.Heartbeat heartbeat = 2; + * @generated from field: anduril.taskmanager.v1.Task task = 1; */ - heartbeat?: Heartbeat; + task?: Task; - constructor(data?: PartialMessage); + constructor(data?: PartialMessage); static readonly runtime: typeof proto3; - static readonly typeName = "anduril.taskmanager.v1.StreamTasksResponse"; + static readonly typeName = "anduril.taskmanager.v1.UpdateStatusResponse"; static readonly fields: FieldList; - static fromBinary(bytes: Uint8Array, options?: Partial): StreamTasksResponse; + static fromBinary(bytes: Uint8Array, options?: Partial): UpdateStatusResponse; - static fromJson(jsonValue: JsonValue, options?: Partial): StreamTasksResponse; + static fromJson(jsonValue: JsonValue, options?: Partial): UpdateStatusResponse; - static fromJsonString(jsonString: string, options?: Partial): StreamTasksResponse; + static fromJsonString(jsonString: string, options?: Partial): UpdateStatusResponse; - static equals(a: StreamTasksResponse | PlainMessage | undefined, b: StreamTasksResponse | PlainMessage | undefined): boolean; + static equals(a: UpdateStatusResponse | PlainMessage | undefined, b: UpdateStatusResponse | PlainMessage | undefined): boolean; } /** diff --git a/src/anduril/taskmanager/v1/task_manager_api.pub_pb.js b/src/anduril/taskmanager/v1/task_manager_api.pub_pb.js index c440983..0772a2b 100644 --- a/src/anduril/taskmanager/v1/task_manager_api.pub_pb.js +++ b/src/anduril/taskmanager/v1/task_manager_api.pub_pb.js @@ -7,7 +7,7 @@ Object.defineProperty(exports, "__esModule", { value: true }); const { Any, proto3, Timestamp } = require("@bufbuild/protobuf"); -const { Principal, Relations, StatusUpdate, Task, TaskEntity, TaskEvent, TaskView } = require("./task.pub_pb.js"); +const { Principal, Relations, Status, StatusUpdate, Task, TaskEntity, TaskView } = require("./task.pub_pb.js"); const { CancelRequest, CompleteRequest, ExecuteRequest } = require("./task_api.pub_pb.js"); /** @@ -68,79 +68,97 @@ const GetTaskResponse = proto3.makeMessageType( ); /** - * Request to update a Task. + * Request to query for Tasks. Returns the each latest Task by Status ID and Version ID by default with no filters. * - * @generated from message anduril.taskmanager.v1.UpdateTaskRequest + * @generated from message anduril.taskmanager.v1.QueryTasksRequest */ -const UpdateTaskRequest = proto3.makeMessageType( - "anduril.taskmanager.v1.UpdateTaskRequest", +const QueryTasksRequest = proto3.makeMessageType( + "anduril.taskmanager.v1.QueryTasksRequest", () => [ - { no: 1, name: "task", kind: "message", T: Task }, - { no: 7, name: "is_executed_elsewhere", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, + { no: 1, name: "parent_task_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, + { no: 3, name: "page_token", kind: "scalar", T: 9 /* ScalarType.STRING */ }, + { no: 4, name: "status_filter", kind: "message", T: QueryTasksRequest_StatusFilter }, + { no: 5, name: "update_time_range", kind: "message", T: QueryTasksRequest_TimeRange }, + { no: 6, name: "view", kind: "enum", T: proto3.getEnumType(TaskView) }, + ], +); + +/** + * The type of filter. + * + * @generated from enum anduril.taskmanager.v1.QueryTasksRequest.FilterType + */ +const QueryTasksRequest_FilterType = proto3.makeEnum( + "anduril.taskmanager.v1.QueryTasksRequest.FilterType", + [ + {no: 0, name: "FILTER_TYPE_INVALID", localName: "INVALID"}, + {no: 1, name: "FILTER_TYPE_INCLUSIVE", localName: "INCLUSIVE"}, + {no: 2, name: "FILTER_TYPE_EXCLUSIVE", localName: "EXCLUSIVE"}, ], ); /** - * Response to an Update Task request. + * A time range query for Tasks. * - * @generated from message anduril.taskmanager.v1.UpdateTaskResponse + * @generated from message anduril.taskmanager.v1.QueryTasksRequest.TimeRange */ -const UpdateTaskResponse = proto3.makeMessageType( - "anduril.taskmanager.v1.UpdateTaskResponse", +const QueryTasksRequest_TimeRange = proto3.makeMessageType( + "anduril.taskmanager.v1.QueryTasksRequest.TimeRange", () => [ - { no: 1, name: "task", kind: "message", T: Task }, + { no: 1, name: "update_start_time", kind: "message", T: Timestamp }, + { no: 2, name: "update_end_time", kind: "message", T: Timestamp }, ], + {localName: "QueryTasksRequest_TimeRange"}, ); /** - * Request to update a Task's status. + * A filter for statuses. * - * @generated from message anduril.taskmanager.v1.UpdateStatusRequest + * @generated from message anduril.taskmanager.v1.QueryTasksRequest.StatusFilter */ -const UpdateStatusRequest = proto3.makeMessageType( - "anduril.taskmanager.v1.UpdateStatusRequest", +const QueryTasksRequest_StatusFilter = proto3.makeMessageType( + "anduril.taskmanager.v1.QueryTasksRequest.StatusFilter", () => [ - { no: 1, name: "status_update", kind: "message", T: StatusUpdate }, + { no: 1, name: "status", kind: "enum", T: proto3.getEnumType(Status), repeated: true }, + { no: 2, name: "filter_type", kind: "enum", T: proto3.getEnumType(QueryTasksRequest_FilterType) }, ], + {localName: "QueryTasksRequest_StatusFilter"}, ); /** - * Response to an Update Status request. + * Response to a Query Task request. * - * @generated from message anduril.taskmanager.v1.UpdateStatusResponse + * @generated from message anduril.taskmanager.v1.QueryTasksResponse */ -const UpdateStatusResponse = proto3.makeMessageType( - "anduril.taskmanager.v1.UpdateStatusResponse", +const QueryTasksResponse = proto3.makeMessageType( + "anduril.taskmanager.v1.QueryTasksResponse", () => [ - { no: 1, name: "task", kind: "message", T: Task }, + { no: 1, name: "tasks", kind: "message", T: Task, repeated: true }, + { no: 2, name: "page_token", kind: "scalar", T: 9 /* ScalarType.STRING */ }, ], ); /** - * Request to Stream Tasks. Returns all live Tasks (aka all not-DONE Tasks). + * Request to update a Task's status. * - * @generated from message anduril.taskmanager.v1.StreamTasksRequest + * @generated from message anduril.taskmanager.v1.UpdateStatusRequest */ -const StreamTasksRequest = proto3.makeMessageType( - "anduril.taskmanager.v1.StreamTasksRequest", +const UpdateStatusRequest = proto3.makeMessageType( + "anduril.taskmanager.v1.UpdateStatusRequest", () => [ - { no: 1, name: "rate_limit", kind: "message", T: RateLimit }, - { no: 2, name: "views", kind: "enum", T: proto3.getEnumType(TaskView), repeated: true }, - { no: 3, name: "heartbeat_period_millis", kind: "scalar", T: 13 /* ScalarType.UINT32 */ }, - { no: 4, name: "exclude_preexisting_tasks", kind: "scalar", T: 8 /* ScalarType.BOOL */ }, + { no: 1, name: "status_update", kind: "message", T: StatusUpdate }, ], ); /** - * Response stream will be fed all matching pre-existing live Tasks, plus any new events ongoing. + * Response to an Update Status request. * - * @generated from message anduril.taskmanager.v1.StreamTasksResponse + * @generated from message anduril.taskmanager.v1.UpdateStatusResponse */ -const StreamTasksResponse = proto3.makeMessageType( - "anduril.taskmanager.v1.StreamTasksResponse", +const UpdateStatusResponse = proto3.makeMessageType( + "anduril.taskmanager.v1.UpdateStatusResponse", () => [ - { no: 1, name: "task_event", kind: "message", T: TaskEvent }, - { no: 2, name: "heartbeat", kind: "message", T: Heartbeat }, + { no: 1, name: "task", kind: "message", T: Task }, ], ); @@ -209,12 +227,13 @@ exports.CreateTaskRequest = CreateTaskRequest; exports.CreateTaskResponse = CreateTaskResponse; exports.GetTaskRequest = GetTaskRequest; exports.GetTaskResponse = GetTaskResponse; -exports.UpdateTaskRequest = UpdateTaskRequest; -exports.UpdateTaskResponse = UpdateTaskResponse; +exports.QueryTasksRequest = QueryTasksRequest; +exports.QueryTasksRequest_FilterType = QueryTasksRequest_FilterType; +exports.QueryTasksRequest_TimeRange = QueryTasksRequest_TimeRange; +exports.QueryTasksRequest_StatusFilter = QueryTasksRequest_StatusFilter; +exports.QueryTasksResponse = QueryTasksResponse; exports.UpdateStatusRequest = UpdateStatusRequest; exports.UpdateStatusResponse = UpdateStatusResponse; -exports.StreamTasksRequest = StreamTasksRequest; -exports.StreamTasksResponse = StreamTasksResponse; exports.ListenAsAgentRequest = ListenAsAgentRequest; exports.ListenAsAgentResponse = ListenAsAgentResponse; exports.RateLimit = RateLimit;