= 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
new file mode 100644
index 0000000..37c6298
--- /dev/null
+++ b/lib/cjs/hermesclient/google/protobuf/struct.js
@@ -0,0 +1,469 @@
+"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("../../../../node_modules/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
new file mode 100644
index 0000000..aa09aa0
--- /dev/null
+++ b/lib/cjs/hermesclient/proto/wsmessages.d.ts
@@ -0,0 +1,4566 @@
+import * as _m0 from "../../../node_modules/protobufjs/minimal";
+import { Observable } from "../../../node_modules/rxjs/dist/types/index";
+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