= T extends T ? keyof T : never;
-export type Exact = P extends Builtin ? P : P & {
- [K in keyof P]: Exact
;
-} & {
- [K in Exclude>]: never;
-};
-export {};
diff --git a/lib/cjs/hermesclient/google/protobuf/struct.js b/lib/cjs/hermesclient/google/protobuf/struct.js
deleted file mode 100644
index adbdc91..0000000
--- a/lib/cjs/hermesclient/google/protobuf/struct.js
+++ /dev/null
@@ -1,469 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
- if (k2 === undefined) k2 = k;
- var desc = Object.getOwnPropertyDescriptor(m, k);
- if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
- desc = { enumerable: true, get: function() { return m[k]; } };
- }
- Object.defineProperty(o, k2, desc);
-}) : (function(o, m, k, k2) {
- if (k2 === undefined) k2 = k;
- o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
- Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
- o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
- if (mod && mod.__esModule) return mod;
- var result = {};
- if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
- __setModuleDefault(result, mod);
- return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ListValue = exports.Value = exports.Struct_FieldsEntry = exports.Struct = exports.nullValueToJSON = exports.nullValueFromJSON = exports.NullValue = exports.protobufPackage = void 0;
-/* eslint-disable */
-const _m0 = __importStar(require("protobufjs/minimal"));
-exports.protobufPackage = "google.protobuf";
-/**
- * `NullValue` is a singleton enumeration to represent the null value for the
- * `Value` type union.
- *
- * The JSON representation for `NullValue` is JSON `null`.
- */
-var NullValue;
-(function (NullValue) {
- /** NULL_VALUE - Null value. */
- NullValue[NullValue["NULL_VALUE"] = 0] = "NULL_VALUE";
- NullValue[NullValue["UNRECOGNIZED"] = -1] = "UNRECOGNIZED";
-})(NullValue || (exports.NullValue = NullValue = {}));
-function nullValueFromJSON(object) {
- switch (object) {
- case 0:
- case "NULL_VALUE":
- return NullValue.NULL_VALUE;
- case -1:
- case "UNRECOGNIZED":
- default:
- return NullValue.UNRECOGNIZED;
- }
-}
-exports.nullValueFromJSON = nullValueFromJSON;
-function nullValueToJSON(object) {
- switch (object) {
- case NullValue.NULL_VALUE:
- return "NULL_VALUE";
- case NullValue.UNRECOGNIZED:
- default:
- return "UNRECOGNIZED";
- }
-}
-exports.nullValueToJSON = nullValueToJSON;
-function createBaseStruct() {
- return { fields: {} };
-}
-exports.Struct = {
- encode(message, writer = _m0.Writer.create()) {
- Object.entries(message.fields).forEach(([key, value]) => {
- if (value !== undefined) {
- exports.Struct_FieldsEntry.encode({ key: key, value }, writer.uint32(10).fork()).ldelim();
- }
- });
- return writer;
- },
- decode(input, length) {
- const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
- let end = length === undefined ? reader.len : reader.pos + length;
- const message = createBaseStruct();
- while (reader.pos < end) {
- const tag = reader.uint32();
- switch (tag >>> 3) {
- case 1:
- if (tag !== 10) {
- break;
- }
- const entry1 = exports.Struct_FieldsEntry.decode(reader, reader.uint32());
- if (entry1.value !== undefined) {
- message.fields[entry1.key] = entry1.value;
- }
- continue;
- }
- if ((tag & 7) === 4 || tag === 0) {
- break;
- }
- reader.skipType(tag & 7);
- }
- return message;
- },
- fromJSON(object) {
- return {
- fields: isObject(object.fields)
- ? Object.entries(object.fields).reduce((acc, [key, value]) => {
- acc[key] = value;
- return acc;
- }, {})
- : {},
- };
- },
- toJSON(message) {
- const obj = {};
- if (message.fields) {
- const entries = Object.entries(message.fields);
- if (entries.length > 0) {
- obj.fields = {};
- entries.forEach(([k, v]) => {
- obj.fields[k] = v;
- });
- }
- }
- return obj;
- },
- create(base) {
- return exports.Struct.fromPartial(base !== null && base !== void 0 ? base : {});
- },
- fromPartial(object) {
- var _a;
- const message = createBaseStruct();
- message.fields = Object.entries((_a = object.fields) !== null && _a !== void 0 ? _a : {}).reduce((acc, [key, value]) => {
- if (value !== undefined) {
- acc[key] = value;
- }
- return acc;
- }, {});
- return message;
- },
- wrap(object) {
- const struct = createBaseStruct();
- if (object !== undefined) {
- Object.keys(object).forEach((key) => {
- struct.fields[key] = object[key];
- });
- }
- return struct;
- },
- unwrap(message) {
- const object = {};
- if (message.fields) {
- Object.keys(message.fields).forEach((key) => {
- object[key] = message.fields[key];
- });
- }
- return object;
- },
-};
-function createBaseStruct_FieldsEntry() {
- return { key: "", value: undefined };
-}
-exports.Struct_FieldsEntry = {
- encode(message, writer = _m0.Writer.create()) {
- if (message.key !== "") {
- writer.uint32(10).string(message.key);
- }
- if (message.value !== undefined) {
- exports.Value.encode(exports.Value.wrap(message.value), writer.uint32(18).fork()).ldelim();
- }
- return writer;
- },
- decode(input, length) {
- const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
- let end = length === undefined ? reader.len : reader.pos + length;
- const message = createBaseStruct_FieldsEntry();
- while (reader.pos < end) {
- const tag = reader.uint32();
- switch (tag >>> 3) {
- case 1:
- if (tag !== 10) {
- break;
- }
- message.key = reader.string();
- continue;
- case 2:
- if (tag !== 18) {
- break;
- }
- message.value = exports.Value.unwrap(exports.Value.decode(reader, reader.uint32()));
- continue;
- }
- if ((tag & 7) === 4 || tag === 0) {
- break;
- }
- reader.skipType(tag & 7);
- }
- return message;
- },
- fromJSON(object) {
- return {
- key: isSet(object.key) ? globalThis.String(object.key) : "",
- value: isSet(object === null || object === void 0 ? void 0 : object.value) ? object.value : undefined,
- };
- },
- toJSON(message) {
- const obj = {};
- if (message.key !== "") {
- obj.key = message.key;
- }
- if (message.value !== undefined) {
- obj.value = message.value;
- }
- return obj;
- },
- create(base) {
- return exports.Struct_FieldsEntry.fromPartial(base !== null && base !== void 0 ? base : {});
- },
- fromPartial(object) {
- var _a, _b;
- const message = createBaseStruct_FieldsEntry();
- message.key = (_a = object.key) !== null && _a !== void 0 ? _a : "";
- message.value = (_b = object.value) !== null && _b !== void 0 ? _b : undefined;
- return message;
- },
-};
-function createBaseValue() {
- return {
- nullValue: undefined,
- numberValue: undefined,
- stringValue: undefined,
- boolValue: undefined,
- structValue: undefined,
- listValue: undefined,
- };
-}
-exports.Value = {
- encode(message, writer = _m0.Writer.create()) {
- if (message.nullValue !== undefined) {
- writer.uint32(8).int32(message.nullValue);
- }
- if (message.numberValue !== undefined) {
- writer.uint32(17).double(message.numberValue);
- }
- if (message.stringValue !== undefined) {
- writer.uint32(26).string(message.stringValue);
- }
- if (message.boolValue !== undefined) {
- writer.uint32(32).bool(message.boolValue);
- }
- if (message.structValue !== undefined) {
- exports.Struct.encode(exports.Struct.wrap(message.structValue), writer.uint32(42).fork()).ldelim();
- }
- if (message.listValue !== undefined) {
- exports.ListValue.encode(exports.ListValue.wrap(message.listValue), writer.uint32(50).fork()).ldelim();
- }
- return writer;
- },
- decode(input, length) {
- const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
- let end = length === undefined ? reader.len : reader.pos + length;
- const message = createBaseValue();
- while (reader.pos < end) {
- const tag = reader.uint32();
- switch (tag >>> 3) {
- case 1:
- if (tag !== 8) {
- break;
- }
- message.nullValue = reader.int32();
- continue;
- case 2:
- if (tag !== 17) {
- break;
- }
- message.numberValue = reader.double();
- continue;
- case 3:
- if (tag !== 26) {
- break;
- }
- message.stringValue = reader.string();
- continue;
- case 4:
- if (tag !== 32) {
- break;
- }
- message.boolValue = reader.bool();
- continue;
- case 5:
- if (tag !== 42) {
- break;
- }
- message.structValue = exports.Struct.unwrap(exports.Struct.decode(reader, reader.uint32()));
- continue;
- case 6:
- if (tag !== 50) {
- break;
- }
- message.listValue = exports.ListValue.unwrap(exports.ListValue.decode(reader, reader.uint32()));
- continue;
- }
- if ((tag & 7) === 4 || tag === 0) {
- break;
- }
- reader.skipType(tag & 7);
- }
- return message;
- },
- fromJSON(object) {
- return {
- nullValue: isSet(object.nullValue) ? nullValueFromJSON(object.nullValue) : undefined,
- numberValue: isSet(object.numberValue) ? globalThis.Number(object.numberValue) : undefined,
- stringValue: isSet(object.stringValue) ? globalThis.String(object.stringValue) : undefined,
- boolValue: isSet(object.boolValue) ? globalThis.Boolean(object.boolValue) : undefined,
- structValue: isObject(object.structValue) ? object.structValue : undefined,
- listValue: globalThis.Array.isArray(object.listValue) ? [...object.listValue] : undefined,
- };
- },
- toJSON(message) {
- const obj = {};
- if (message.nullValue !== undefined) {
- obj.nullValue = nullValueToJSON(message.nullValue);
- }
- if (message.numberValue !== undefined) {
- obj.numberValue = message.numberValue;
- }
- if (message.stringValue !== undefined) {
- obj.stringValue = message.stringValue;
- }
- if (message.boolValue !== undefined) {
- obj.boolValue = message.boolValue;
- }
- if (message.structValue !== undefined) {
- obj.structValue = message.structValue;
- }
- if (message.listValue !== undefined) {
- obj.listValue = message.listValue;
- }
- return obj;
- },
- create(base) {
- return exports.Value.fromPartial(base !== null && base !== void 0 ? base : {});
- },
- fromPartial(object) {
- var _a, _b, _c, _d, _e, _f;
- const message = createBaseValue();
- message.nullValue = (_a = object.nullValue) !== null && _a !== void 0 ? _a : undefined;
- message.numberValue = (_b = object.numberValue) !== null && _b !== void 0 ? _b : undefined;
- message.stringValue = (_c = object.stringValue) !== null && _c !== void 0 ? _c : undefined;
- message.boolValue = (_d = object.boolValue) !== null && _d !== void 0 ? _d : undefined;
- message.structValue = (_e = object.structValue) !== null && _e !== void 0 ? _e : undefined;
- message.listValue = (_f = object.listValue) !== null && _f !== void 0 ? _f : undefined;
- return message;
- },
- wrap(value) {
- const result = createBaseValue();
- if (value === null) {
- result.nullValue = NullValue.NULL_VALUE;
- }
- else if (typeof value === "boolean") {
- result.boolValue = value;
- }
- else if (typeof value === "number") {
- result.numberValue = value;
- }
- else if (typeof value === "string") {
- result.stringValue = value;
- }
- else if (globalThis.Array.isArray(value)) {
- result.listValue = value;
- }
- else if (typeof value === "object") {
- result.structValue = value;
- }
- else if (typeof value !== "undefined") {
- throw new globalThis.Error("Unsupported any value type: " + typeof value);
- }
- return result;
- },
- unwrap(message) {
- if (message.stringValue !== undefined) {
- return message.stringValue;
- }
- else if ((message === null || message === void 0 ? void 0 : message.numberValue) !== undefined) {
- return message.numberValue;
- }
- else if ((message === null || message === void 0 ? void 0 : message.boolValue) !== undefined) {
- return message.boolValue;
- }
- else if ((message === null || message === void 0 ? void 0 : message.structValue) !== undefined) {
- return message.structValue;
- }
- else if ((message === null || message === void 0 ? void 0 : message.listValue) !== undefined) {
- return message.listValue;
- }
- else if ((message === null || message === void 0 ? void 0 : message.nullValue) !== undefined) {
- return null;
- }
- return undefined;
- },
-};
-function createBaseListValue() {
- return { values: [] };
-}
-exports.ListValue = {
- encode(message, writer = _m0.Writer.create()) {
- for (const v of message.values) {
- exports.Value.encode(exports.Value.wrap(v), writer.uint32(10).fork()).ldelim();
- }
- return writer;
- },
- decode(input, length) {
- const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
- let end = length === undefined ? reader.len : reader.pos + length;
- const message = createBaseListValue();
- while (reader.pos < end) {
- const tag = reader.uint32();
- switch (tag >>> 3) {
- case 1:
- if (tag !== 10) {
- break;
- }
- message.values.push(exports.Value.unwrap(exports.Value.decode(reader, reader.uint32())));
- continue;
- }
- if ((tag & 7) === 4 || tag === 0) {
- break;
- }
- reader.skipType(tag & 7);
- }
- return message;
- },
- fromJSON(object) {
- return { values: globalThis.Array.isArray(object === null || object === void 0 ? void 0 : object.values) ? [...object.values] : [] };
- },
- toJSON(message) {
- var _a;
- const obj = {};
- if ((_a = message.values) === null || _a === void 0 ? void 0 : _a.length) {
- obj.values = message.values;
- }
- return obj;
- },
- create(base) {
- return exports.ListValue.fromPartial(base !== null && base !== void 0 ? base : {});
- },
- fromPartial(object) {
- var _a;
- const message = createBaseListValue();
- message.values = ((_a = object.values) === null || _a === void 0 ? void 0 : _a.map((e) => e)) || [];
- return message;
- },
- wrap(array) {
- const result = createBaseListValue();
- result.values = array !== null && array !== void 0 ? array : [];
- return result;
- },
- unwrap(message) {
- if ((message === null || message === void 0 ? void 0 : message.hasOwnProperty("values")) && globalThis.Array.isArray(message.values)) {
- return message.values;
- }
- else {
- return message;
- }
- },
-};
-function isObject(value) {
- return typeof value === "object" && value !== null;
-}
-function isSet(value) {
- return value !== null && value !== undefined;
-}
diff --git a/lib/cjs/hermesclient/proto/wsmessages.d.ts b/lib/cjs/hermesclient/proto/wsmessages.d.ts
deleted file mode 100644
index 7cc1789..0000000
--- a/lib/cjs/hermesclient/proto/wsmessages.d.ts
+++ /dev/null
@@ -1,4566 +0,0 @@
-import * as _m0 from "protobufjs/minimal";
-import { Observable } from "rxjs";
-export declare const protobufPackage = "hermes";
-export declare enum RpcFrameType {
- UnspecifiedRFT = 0,
- Request = 1,
- SuccessResponse = 2,
- ErrorResponse = 3,
- UNRECOGNIZED = -1
-}
-export declare function rpcFrameTypeFromJSON(object: any): RpcFrameType;
-export declare function rpcFrameTypeToJSON(object: RpcFrameType): string;
-export declare enum ContentType {
- UnspecifiedCT = 0,
- Protobuf = 1,
- Json = 2,
- Binary = 3,
- Text = 4,
- UNRECOGNIZED = -1
-}
-export declare function contentTypeFromJSON(object: any): ContentType;
-export declare function contentTypeToJSON(object: ContentType): string;
-export interface MessageFromClient {
- sendMessageRequest?: SendMessageRequest | undefined;
- firstMessage?: FirstMessage | undefined;
- ping?: Ping | undefined;
- pong?: Pong | undefined;
- notification?: Notification | undefined;
- subscribeRequest?: SubscribeRequest | undefined;
-}
-export interface Notification {
- message?: string | undefined;
-}
-export interface MessageToClient {
- messageEnvelope?: MessageEnvelope | undefined;
- sendMessageResponse?: SendMessageResponse | undefined;
- ping?: Ping | undefined;
- pong?: Pong | undefined;
- notification?: Notification | undefined;
- subscribeResponse?: SubscribeResponse | undefined;
-}
-export interface Ping {
- payload?: Uint8Array | undefined;
-}
-export interface Pong {
- payload?: Uint8Array | undefined;
-}
-export interface MessageHeader {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: RpcHeader | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: KeyValPair[] | undefined;
-}
-export interface SenderEnvelope {
- created?: number | undefined;
-}
-export interface ServerEnvelope {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
-}
-export interface KeyValPair {
- key?: string | undefined;
- val?: string | undefined;
-}
-export interface RpcHeader {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: RpcErrorInfo | undefined;
-}
-export interface RpcErrorInfo {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
-}
-export interface Message {
- header?: MessageHeader | undefined;
- senderEnvelope?: SenderEnvelope | undefined;
- serverEnvelope?: ServerEnvelope | undefined;
- data?: Uint8Array | undefined;
-}
-export interface MessageEnvelope {
- messageBytes?: Uint8Array | undefined;
- serverEnvelope?: ServerEnvelope | undefined;
-}
-export interface SendMessageRequest {
- to?: string[] | undefined;
- message?: Message | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
-}
-export interface SendMessageResponse {
- errors?: SendMessageError[] | undefined;
- duplicates?: string[] | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
-}
-export interface SendReceipt {
- request?: SendMessageRequest | undefined;
- response?: SendMessageResponse | undefined;
- serverEnvelope?: ServerEnvelope | undefined;
-}
-export interface SendMessageError {
- message?: string | undefined;
- to?: string | undefined;
-}
-export interface FirstMessage {
- senderInfo?: SenderInfo | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: Subscription[] | undefined;
-}
-export interface SenderInfo {
- readerKey?: string | undefined;
- address?: string | undefined;
-}
-export interface SubscribeRequest {
- subscriptions?: Subscription[] | undefined;
-}
-export interface SubscribeResponse {
- succeeded?: string[] | undefined;
- errors?: SubscribeError[] | undefined;
-}
-export interface SubscribeError {
- state?: string | undefined;
- message?: string | undefined;
-}
-export interface Subscription {
- mailbox?: MailboxSubscription | undefined;
- nefario?: NefarioSubscription | undefined;
- changeDataCapture?: ChangeDataCaptureSubscription | undefined;
- unsubscribe?: Unsubscribe | undefined;
-}
-export interface MailboxSubscription {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
-}
-export interface ChangeDataCaptureSubscription {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: RecordMatcher[] | undefined;
- startSeq?: string | undefined;
-}
-export interface RecordMatcher {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
-}
-export interface NefarioSubscription {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
-}
-export interface Unsubscribe {
- id?: string | undefined;
-}
-export interface CreateMailboxRequest {
- channels?: string[] | undefined;
- privateMetadata?: {
- [key: string]: any;
- } | undefined;
- publicMetadata?: {
- [key: string]: any;
- } | undefined;
- purgeTimeoutInMillis?: number | undefined;
- closeTimeoutInMillis?: number | undefined;
- extraData?: {
- [key: string]: any;
- } | undefined;
-}
-export interface CreateMailboxResponse {
- adminKey?: string | undefined;
- address?: string | undefined;
- readerKey?: string | undefined;
- channels?: string[] | undefined;
-}
-export interface AddChannelRequest {
- adminKey?: string | undefined;
- channels?: string[] | undefined;
-}
-export interface AddChannelResponse {
-}
-export declare const MessageFromClient: {
- encode(message: MessageFromClient, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): MessageFromClient;
- fromJSON(object: any): MessageFromClient;
- toJSON(message: MessageFromClient): unknown;
- create]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- } & { [K_2 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_3 in Exclude]: never; })[] & { [K_4 in Exclude]: never; }) | undefined;
- } & { [K_5 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_7 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_8 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_9 in Exclude]: never; }) | undefined;
- firstMessage?: ({
- senderInfo?: {
- readerKey?: string | undefined;
- address?: string | undefined;
- } | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: {
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] | undefined;
- } & {
- senderInfo?: ({
- readerKey?: string | undefined;
- address?: string | undefined;
- } & {
- readerKey?: string | undefined;
- address?: string | undefined;
- } & { [K_10 in Exclude]: never; }) | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] & ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- } & {
- mailbox?: ({
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_11 in Exclude]: never; }) | undefined;
- nefario?: ({
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_12 in Exclude]: never; }) | undefined;
- changeDataCapture?: ({
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] & ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- } & {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: (any[] & any[] & { [K_13 in Exclude]: never; }) | undefined;
- } & { [K_14 in Exclude]: never; })[] & { [K_15 in Exclude]: never; }) | undefined;
- startSeq?: string | undefined;
- } & { [K_16 in Exclude]: never; }) | undefined;
- unsubscribe?: ({
- id?: string | undefined;
- } & {
- id?: string | undefined;
- } & { [K_17 in Exclude]: never; }) | undefined;
- } & { [K_18 in Exclude]: never; })[] & { [K_19 in Exclude]: never; }) | undefined;
- } & { [K_20 in Exclude]: never; }) | undefined;
- ping?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_21 in Exclude]: never; }) | undefined;
- pong?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_22 in Exclude]: never; }) | undefined;
- notification?: ({
- message?: string | undefined;
- } & {
- message?: string | undefined;
- } & { [K_23 in Exclude]: never; }) | undefined;
- subscribeRequest?: ({
- subscriptions?: {
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] | undefined;
- } & {
- subscriptions?: ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] & ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- } & {
- mailbox?: ({
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_24 in Exclude]: never; }) | undefined;
- nefario?: ({
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_25 in Exclude]: never; }) | undefined;
- changeDataCapture?: ({
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] & ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- } & {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: (any[] & any[] & { [K_26 in Exclude]: never; }) | undefined;
- } & { [K_27 in Exclude]: never; })[] & { [K_28 in Exclude]: never; }) | undefined;
- startSeq?: string | undefined;
- } & { [K_29 in Exclude]: never; }) | undefined;
- unsubscribe?: ({
- id?: string | undefined;
- } & {
- id?: string | undefined;
- } & { [K_30 in Exclude]: never; }) | undefined;
- } & { [K_31 in Exclude]: never; })[] & { [K_32 in Exclude]: never; }) | undefined;
- } & { [K_33 in Exclude]: never; }) | undefined;
- } & { [K_34 in Exclude]: never; }>(base?: I): MessageFromClient;
- fromPartial]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_36 in Exclude]: never; }) | undefined;
- } & { [K_37 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_38 in Exclude]: never; })[] & { [K_39 in Exclude]: never; }) | undefined;
- } & { [K_40 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_41 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_42 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_43 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_44 in Exclude]: never; }) | undefined;
- firstMessage?: ({
- senderInfo?: {
- readerKey?: string | undefined;
- address?: string | undefined;
- } | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: {
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] | undefined;
- } & {
- senderInfo?: ({
- readerKey?: string | undefined;
- address?: string | undefined;
- } & {
- readerKey?: string | undefined;
- address?: string | undefined;
- } & { [K_45 in Exclude]: never; }) | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] & ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- } & {
- mailbox?: ({
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_46 in Exclude]: never; }) | undefined;
- nefario?: ({
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_47 in Exclude]: never; }) | undefined;
- changeDataCapture?: ({
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] & ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- } & {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: (any[] & any[] & { [K_48 in Exclude]: never; }) | undefined;
- } & { [K_49 in Exclude]: never; })[] & { [K_50 in Exclude]: never; }) | undefined;
- startSeq?: string | undefined;
- } & { [K_51 in Exclude]: never; }) | undefined;
- unsubscribe?: ({
- id?: string | undefined;
- } & {
- id?: string | undefined;
- } & { [K_52 in Exclude]: never; }) | undefined;
- } & { [K_53 in Exclude]: never; })[] & { [K_54 in Exclude]: never; }) | undefined;
- } & { [K_55 in Exclude]: never; }) | undefined;
- ping?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_56 in Exclude]: never; }) | undefined;
- pong?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_57 in Exclude]: never; }) | undefined;
- notification?: ({
- message?: string | undefined;
- } & {
- message?: string | undefined;
- } & { [K_58 in Exclude]: never; }) | undefined;
- subscribeRequest?: ({
- subscriptions?: {
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] | undefined;
- } & {
- subscriptions?: ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] & ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- } & {
- mailbox?: ({
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_59 in Exclude]: never; }) | undefined;
- nefario?: ({
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_60 in Exclude]: never; }) | undefined;
- changeDataCapture?: ({
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] & ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- } & {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: (any[] & any[] & { [K_61 in Exclude]: never; }) | undefined;
- } & { [K_62 in Exclude]: never; })[] & { [K_63 in Exclude]: never; }) | undefined;
- startSeq?: string | undefined;
- } & { [K_64 in Exclude]: never; }) | undefined;
- unsubscribe?: ({
- id?: string | undefined;
- } & {
- id?: string | undefined;
- } & { [K_65 in Exclude]: never; }) | undefined;
- } & { [K_66 in Exclude]: never; })[] & { [K_67 in Exclude]: never; }) | undefined;
- } & { [K_68 in Exclude]: never; }) | undefined;
- } & { [K_69 in Exclude]: never; }>(object: I_1): MessageFromClient;
-};
-export declare const Notification: {
- encode(message: Notification, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): Notification;
- fromJSON(object: any): Notification;
- toJSON(message: Notification): unknown;
- create]: never; }>(base?: I): Notification;
- fromPartial]: never; }>(object: I_1): Notification;
-};
-export declare const MessageToClient: {
- encode(message: MessageToClient, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): MessageToClient;
- fromJSON(object: any): MessageToClient;
- toJSON(message: MessageToClient): unknown;
- create]: never; }) | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- sendMessageResponse?: ({
- errors?: {
- message?: string | undefined;
- to?: string | undefined;
- }[] | undefined;
- duplicates?: string[] | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & {
- errors?: ({
- message?: string | undefined;
- to?: string | undefined;
- }[] & ({
- message?: string | undefined;
- to?: string | undefined;
- } & {
- message?: string | undefined;
- to?: string | undefined;
- } & { [K_2 in Exclude]: never; })[] & { [K_3 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_4 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_5 in Exclude]: never; }) | undefined;
- ping?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- pong?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_7 in Exclude]: never; }) | undefined;
- notification?: ({
- message?: string | undefined;
- } & {
- message?: string | undefined;
- } & { [K_8 in Exclude]: never; }) | undefined;
- subscribeResponse?: ({
- succeeded?: string[] | undefined;
- errors?: {
- state?: string | undefined;
- message?: string | undefined;
- }[] | undefined;
- } & {
- succeeded?: (string[] & string[] & { [K_9 in Exclude]: never; }) | undefined;
- errors?: ({
- state?: string | undefined;
- message?: string | undefined;
- }[] & ({
- state?: string | undefined;
- message?: string | undefined;
- } & {
- state?: string | undefined;
- message?: string | undefined;
- } & { [K_10 in Exclude]: never; })[] & { [K_11 in Exclude]: never; }) | undefined;
- } & { [K_12 in Exclude]: never; }) | undefined;
- } & { [K_13 in Exclude]: never; }>(base?: I): MessageToClient;
- fromPartial]: never; }) | undefined;
- } & { [K_15 in Exclude]: never; }) | undefined;
- sendMessageResponse?: ({
- errors?: {
- message?: string | undefined;
- to?: string | undefined;
- }[] | undefined;
- duplicates?: string[] | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & {
- errors?: ({
- message?: string | undefined;
- to?: string | undefined;
- }[] & ({
- message?: string | undefined;
- to?: string | undefined;
- } & {
- message?: string | undefined;
- to?: string | undefined;
- } & { [K_16 in Exclude]: never; })[] & { [K_17 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_18 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_19 in Exclude]: never; }) | undefined;
- ping?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_20 in Exclude]: never; }) | undefined;
- pong?: ({
- payload?: Uint8Array | undefined;
- } & {
- payload?: Uint8Array | undefined;
- } & { [K_21 in Exclude]: never; }) | undefined;
- notification?: ({
- message?: string | undefined;
- } & {
- message?: string | undefined;
- } & { [K_22 in Exclude]: never; }) | undefined;
- subscribeResponse?: ({
- succeeded?: string[] | undefined;
- errors?: {
- state?: string | undefined;
- message?: string | undefined;
- }[] | undefined;
- } & {
- succeeded?: (string[] & string[] & { [K_23 in Exclude]: never; }) | undefined;
- errors?: ({
- state?: string | undefined;
- message?: string | undefined;
- }[] & ({
- state?: string | undefined;
- message?: string | undefined;
- } & {
- state?: string | undefined;
- message?: string | undefined;
- } & { [K_24 in Exclude]: never; })[] & { [K_25 in Exclude]: never; }) | undefined;
- } & { [K_26 in Exclude]: never; }) | undefined;
- } & { [K_27 in Exclude]: never; }>(object: I_1): MessageToClient;
-};
-export declare const Ping: {
- encode(message: Ping, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): Ping;
- fromJSON(object: any): Ping;
- toJSON(message: Ping): unknown;
- create]: never; }>(base?: I): Ping;
- fromPartial]: never; }>(object: I_1): Ping;
-};
-export declare const Pong: {
- encode(message: Pong, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): Pong;
- fromJSON(object: any): Pong;
- toJSON(message: Pong): unknown;
- create]: never; }>(base?: I): Pong;
- fromPartial]: never; }>(object: I_1): Pong;
-};
-export declare const MessageHeader: {
- encode(message: MessageHeader, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): MessageHeader;
- fromJSON(object: any): MessageHeader;
- toJSON(message: MessageHeader): unknown;
- create]: never; }) | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_2 in Exclude]: never; })[] & { [K_3 in Exclude]: never; }) | undefined;
- } & { [K_4 in Exclude]: never; }>(base?: I): MessageHeader;
- fromPartial]: never; }) | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_7 in Exclude]: never; })[] & { [K_8 in Exclude]: never; }) | undefined;
- } & { [K_9 in Exclude]: never; }>(object: I_1): MessageHeader;
-};
-export declare const SenderEnvelope: {
- encode(message: SenderEnvelope, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): SenderEnvelope;
- fromJSON(object: any): SenderEnvelope;
- toJSON(message: SenderEnvelope): unknown;
- create]: never; }>(base?: I): SenderEnvelope;
- fromPartial]: never; }>(object: I_1): SenderEnvelope;
-};
-export declare const ServerEnvelope: {
- encode(message: ServerEnvelope, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): ServerEnvelope;
- fromJSON(object: any): ServerEnvelope;
- toJSON(message: ServerEnvelope): unknown;
- create]: never; }>(base?: I): ServerEnvelope;
- fromPartial]: never; }>(object: I_1): ServerEnvelope;
-};
-export declare const KeyValPair: {
- encode(message: KeyValPair, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): KeyValPair;
- fromJSON(object: any): KeyValPair;
- toJSON(message: KeyValPair): unknown;
- create]: never; }>(base?: I): KeyValPair;
- fromPartial]: never; }>(object: I_1): KeyValPair;
-};
-export declare const RpcHeader: {
- encode(message: RpcHeader, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): RpcHeader;
- fromJSON(object: any): RpcHeader;
- toJSON(message: RpcHeader): unknown;
- create]: never; }) | undefined;
- } & { [K_1 in Exclude]: never; }>(base?: I): RpcHeader;
- fromPartial]: never; }) | undefined;
- } & { [K_3 in Exclude]: never; }>(object: I_1): RpcHeader;
-};
-export declare const RpcErrorInfo: {
- encode(message: RpcErrorInfo, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): RpcErrorInfo;
- fromJSON(object: any): RpcErrorInfo;
- toJSON(message: RpcErrorInfo): unknown;
- create]: never; }>(base?: I): RpcErrorInfo;
- fromPartial]: never; }>(object: I_1): RpcErrorInfo;
-};
-export declare const Message: {
- encode(message: Message, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): Message;
- fromJSON(object: any): Message;
- toJSON(message: Message): unknown;
- create]: never; }) | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_2 in Exclude]: never; })[] & { [K_3 in Exclude]: never; }) | undefined;
- } & { [K_4 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_5 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_7 in Exclude]: never; }>(base?: I): Message;
- fromPartial]: never; }) | undefined;
- } & { [K_9 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_10 in Exclude]: never; })[] & { [K_11 in Exclude]: never; }) | undefined;
- } & { [K_12 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_13 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_14 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_15 in Exclude]: never; }>(object: I_1): Message;
-};
-export declare const MessageEnvelope: {
- encode(message: MessageEnvelope, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): MessageEnvelope;
- fromJSON(object: any): MessageEnvelope;
- toJSON(message: MessageEnvelope): unknown;
- create]: never; }) | undefined;
- } & { [K_1 in Exclude]: never; }>(base?: I): MessageEnvelope;
- fromPartial]: never; }) | undefined;
- } & { [K_3 in Exclude]: never; }>(object: I_1): MessageEnvelope;
-};
-export declare const SendMessageRequest: {
- encode(message: SendMessageRequest, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): SendMessageRequest;
- fromJSON(object: any): SendMessageRequest;
- toJSON(message: SendMessageRequest): unknown;
- create]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- } & { [K_2 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_3 in Exclude]: never; })[] & { [K_4 in Exclude]: never; }) | undefined;
- } & { [K_5 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_7 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_8 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_9 in Exclude]: never; }>(base?: I): SendMessageRequest;
- fromPartial]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_11 in Exclude]: never; }) | undefined;
- } & { [K_12 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_13 in Exclude]: never; })[] & { [K_14 in Exclude]: never; }) | undefined;
- } & { [K_15 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_16 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_17 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_18 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_19 in Exclude]: never; }>(object: I_1): SendMessageRequest;
-};
-export declare const SendMessageResponse: {
- encode(message: SendMessageResponse, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): SendMessageResponse;
- fromJSON(object: any): SendMessageResponse;
- toJSON(message: SendMessageResponse): unknown;
- create]: never; })[] & { [K_1 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_2 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_3 in Exclude]: never; }>(base?: I): SendMessageResponse;
- fromPartial]: never; })[] & { [K_5 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_6 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_7 in Exclude]: never; }>(object: I_1): SendMessageResponse;
-};
-export declare const SendReceipt: {
- encode(message: SendReceipt, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): SendReceipt;
- fromJSON(object: any): SendReceipt;
- toJSON(message: SendReceipt): unknown;
- create]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- } & { [K_2 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_3 in Exclude]: never; })[] & { [K_4 in Exclude]: never; }) | undefined;
- } & { [K_5 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_7 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_8 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_9 in Exclude]: never; }) | undefined;
- response?: ({
- errors?: {
- message?: string | undefined;
- to?: string | undefined;
- }[] | undefined;
- duplicates?: string[] | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & {
- errors?: ({
- message?: string | undefined;
- to?: string | undefined;
- }[] & ({
- message?: string | undefined;
- to?: string | undefined;
- } & {
- message?: string | undefined;
- to?: string | undefined;
- } & { [K_10 in Exclude]: never; })[] & { [K_11 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_12 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_13 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_14 in Exclude]: never; }) | undefined;
- } & { [K_15 in Exclude]: never; }>(base?: I): SendReceipt;
- fromPartial]: never; }) | undefined;
- message?: ({
- header?: {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } | undefined;
- senderEnvelope?: {
- created?: number | undefined;
- } | undefined;
- serverEnvelope?: {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } | undefined;
- data?: Uint8Array | undefined;
- } & {
- header?: ({
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: {
- key?: string | undefined;
- val?: string | undefined;
- }[] | undefined;
- } & {
- sender?: string | undefined;
- contentType?: ContentType | undefined;
- rpcHeader?: ({
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } | undefined;
- } & {
- correlationId?: string | undefined;
- endPoint?: string | undefined;
- frameType?: RpcFrameType | undefined;
- errorInfo?: ({
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & {
- errorCode?: number | undefined;
- message?: string | undefined;
- stackTrace?: string | undefined;
- } & { [K_17 in Exclude]: never; }) | undefined;
- } & { [K_18 in Exclude]: never; }) | undefined;
- senderSequence?: number | undefined;
- extraHeaders?: ({
- key?: string | undefined;
- val?: string | undefined;
- }[] & ({
- key?: string | undefined;
- val?: string | undefined;
- } & {
- key?: string | undefined;
- val?: string | undefined;
- } & { [K_19 in Exclude]: never; })[] & { [K_20 in Exclude]: never; }) | undefined;
- } & { [K_21 in Exclude]: never; }) | undefined;
- senderEnvelope?: ({
- created?: number | undefined;
- } & {
- created?: number | undefined;
- } & { [K_22 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_23 in Exclude]: never; }) | undefined;
- data?: Uint8Array | undefined;
- } & { [K_24 in Exclude]: never; }) | undefined;
- channel?: string | undefined;
- idempotentId?: string | undefined;
- } & { [K_25 in Exclude]: never; }) | undefined;
- response?: ({
- errors?: {
- message?: string | undefined;
- to?: string | undefined;
- }[] | undefined;
- duplicates?: string[] | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & {
- errors?: ({
- message?: string | undefined;
- to?: string | undefined;
- }[] & ({
- message?: string | undefined;
- to?: string | undefined;
- } & {
- message?: string | undefined;
- to?: string | undefined;
- } & { [K_26 in Exclude]: never; })[] & { [K_27 in Exclude]: never; }) | undefined;
- duplicates?: (string[] & string[] & { [K_28 in Exclude]: never; }) | undefined;
- idempotentId?: string | undefined;
- correlationId?: string | undefined;
- } & { [K_29 in Exclude]: never; }) | undefined;
- serverEnvelope?: ({
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & {
- sequence?: number | undefined;
- created?: number | undefined;
- channel?: string | undefined;
- subscriptionId?: string | undefined;
- } & { [K_30 in Exclude]: never; }) | undefined;
- } & { [K_31 in Exclude]: never; }>(object: I_1): SendReceipt;
-};
-export declare const SendMessageError: {
- encode(message: SendMessageError, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): SendMessageError;
- fromJSON(object: any): SendMessageError;
- toJSON(message: SendMessageError): unknown;
- create]: never; }>(base?: I): SendMessageError;
- fromPartial]: never; }>(object: I_1): SendMessageError;
-};
-export declare const FirstMessage: {
- encode(message: FirstMessage, writer?: _m0.Writer): _m0.Writer;
- decode(input: _m0.Reader | Uint8Array, length?: number): FirstMessage;
- fromJSON(object: any): FirstMessage;
- toJSON(message: FirstMessage): unknown;
- create]: never; }) | undefined;
- mailboxTimeoutInMs?: number | undefined;
- subscriptions?: ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- }[] & ({
- mailbox?: {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- nefario?: {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } | undefined;
- changeDataCapture?: {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } | undefined;
- unsubscribe?: {
- id?: string | undefined;
- } | undefined;
- } & {
- mailbox?: ({
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- readerKey?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_1 in Exclude]: never; }) | undefined;
- nefario?: ({
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- processUid?: string | undefined;
- channel?: string | undefined;
- startSeq?: string | undefined;
- } & { [K_2 in Exclude]: never; }) | undefined;
- changeDataCapture?: ({
- id?: string | undefined;
- state?: string | undefined;
- matchers?: {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] | undefined;
- startSeq?: string | undefined;
- } & {
- id?: string | undefined;
- state?: string | undefined;
- matchers?: ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- }[] & ({
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: any[] | undefined;
- } & {
- database?: string | undefined;
- table?: string | undefined;
- primaryKeys?: (any[] & any[] & { [K_3 in Exclude]: never; }) | undefined;
- } & { [K_4 in Exclude]: never; })[] & { [K_5 in Exclude]: never; }) | undefined;
- startSeq?: string | undefined;
- } & { [K_6 in Exclude]: never; }) | undefined;
- unsubscribe?: ({
- id?: string | undefined;
- } & {
- id?: string | undefined;
- } & { [K_7 in Exclude]: never; }) | undefined;
- } & { [K_8 in Exclude]: never; })[] & { [K_9 in Exclude