UNPKG

513 kBTypeScriptView Raw
1// Copyright 2022 Google LLC
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7// http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15import * as Long from "long";
16import {protobuf as $protobuf} from "google-gax";
17/** Namespace google. */
18export namespace google {
19
20 /** Namespace pubsub. */
21 namespace pubsub {
22
23 /** Namespace v1. */
24 namespace v1 {
25
26 /** Represents a Publisher */
27 class Publisher extends $protobuf.rpc.Service {
28
29 /**
30 * Constructs a new Publisher service.
31 * @param rpcImpl RPC implementation
32 * @param [requestDelimited=false] Whether requests are length-delimited
33 * @param [responseDelimited=false] Whether responses are length-delimited
34 */
35 constructor(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean);
36
37 /**
38 * Creates new Publisher service using the specified rpc implementation.
39 * @param rpcImpl RPC implementation
40 * @param [requestDelimited=false] Whether requests are length-delimited
41 * @param [responseDelimited=false] Whether responses are length-delimited
42 * @returns RPC service. Useful where requests and/or responses are streamed.
43 */
44 public static create(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean): Publisher;
45
46 /**
47 * Calls CreateTopic.
48 * @param request Topic message or plain object
49 * @param callback Node-style callback called with the error, if any, and Topic
50 */
51 public createTopic(request: google.pubsub.v1.ITopic, callback: google.pubsub.v1.Publisher.CreateTopicCallback): void;
52
53 /**
54 * Calls CreateTopic.
55 * @param request Topic message or plain object
56 * @returns Promise
57 */
58 public createTopic(request: google.pubsub.v1.ITopic): Promise<google.pubsub.v1.Topic>;
59
60 /**
61 * Calls UpdateTopic.
62 * @param request UpdateTopicRequest message or plain object
63 * @param callback Node-style callback called with the error, if any, and Topic
64 */
65 public updateTopic(request: google.pubsub.v1.IUpdateTopicRequest, callback: google.pubsub.v1.Publisher.UpdateTopicCallback): void;
66
67 /**
68 * Calls UpdateTopic.
69 * @param request UpdateTopicRequest message or plain object
70 * @returns Promise
71 */
72 public updateTopic(request: google.pubsub.v1.IUpdateTopicRequest): Promise<google.pubsub.v1.Topic>;
73
74 /**
75 * Calls Publish.
76 * @param request PublishRequest message or plain object
77 * @param callback Node-style callback called with the error, if any, and PublishResponse
78 */
79 public publish(request: google.pubsub.v1.IPublishRequest, callback: google.pubsub.v1.Publisher.PublishCallback): void;
80
81 /**
82 * Calls Publish.
83 * @param request PublishRequest message or plain object
84 * @returns Promise
85 */
86 public publish(request: google.pubsub.v1.IPublishRequest): Promise<google.pubsub.v1.PublishResponse>;
87
88 /**
89 * Calls GetTopic.
90 * @param request GetTopicRequest message or plain object
91 * @param callback Node-style callback called with the error, if any, and Topic
92 */
93 public getTopic(request: google.pubsub.v1.IGetTopicRequest, callback: google.pubsub.v1.Publisher.GetTopicCallback): void;
94
95 /**
96 * Calls GetTopic.
97 * @param request GetTopicRequest message or plain object
98 * @returns Promise
99 */
100 public getTopic(request: google.pubsub.v1.IGetTopicRequest): Promise<google.pubsub.v1.Topic>;
101
102 /**
103 * Calls ListTopics.
104 * @param request ListTopicsRequest message or plain object
105 * @param callback Node-style callback called with the error, if any, and ListTopicsResponse
106 */
107 public listTopics(request: google.pubsub.v1.IListTopicsRequest, callback: google.pubsub.v1.Publisher.ListTopicsCallback): void;
108
109 /**
110 * Calls ListTopics.
111 * @param request ListTopicsRequest message or plain object
112 * @returns Promise
113 */
114 public listTopics(request: google.pubsub.v1.IListTopicsRequest): Promise<google.pubsub.v1.ListTopicsResponse>;
115
116 /**
117 * Calls ListTopicSubscriptions.
118 * @param request ListTopicSubscriptionsRequest message or plain object
119 * @param callback Node-style callback called with the error, if any, and ListTopicSubscriptionsResponse
120 */
121 public listTopicSubscriptions(request: google.pubsub.v1.IListTopicSubscriptionsRequest, callback: google.pubsub.v1.Publisher.ListTopicSubscriptionsCallback): void;
122
123 /**
124 * Calls ListTopicSubscriptions.
125 * @param request ListTopicSubscriptionsRequest message or plain object
126 * @returns Promise
127 */
128 public listTopicSubscriptions(request: google.pubsub.v1.IListTopicSubscriptionsRequest): Promise<google.pubsub.v1.ListTopicSubscriptionsResponse>;
129
130 /**
131 * Calls ListTopicSnapshots.
132 * @param request ListTopicSnapshotsRequest message or plain object
133 * @param callback Node-style callback called with the error, if any, and ListTopicSnapshotsResponse
134 */
135 public listTopicSnapshots(request: google.pubsub.v1.IListTopicSnapshotsRequest, callback: google.pubsub.v1.Publisher.ListTopicSnapshotsCallback): void;
136
137 /**
138 * Calls ListTopicSnapshots.
139 * @param request ListTopicSnapshotsRequest message or plain object
140 * @returns Promise
141 */
142 public listTopicSnapshots(request: google.pubsub.v1.IListTopicSnapshotsRequest): Promise<google.pubsub.v1.ListTopicSnapshotsResponse>;
143
144 /**
145 * Calls DeleteTopic.
146 * @param request DeleteTopicRequest message or plain object
147 * @param callback Node-style callback called with the error, if any, and Empty
148 */
149 public deleteTopic(request: google.pubsub.v1.IDeleteTopicRequest, callback: google.pubsub.v1.Publisher.DeleteTopicCallback): void;
150
151 /**
152 * Calls DeleteTopic.
153 * @param request DeleteTopicRequest message or plain object
154 * @returns Promise
155 */
156 public deleteTopic(request: google.pubsub.v1.IDeleteTopicRequest): Promise<google.protobuf.Empty>;
157
158 /**
159 * Calls DetachSubscription.
160 * @param request DetachSubscriptionRequest message or plain object
161 * @param callback Node-style callback called with the error, if any, and DetachSubscriptionResponse
162 */
163 public detachSubscription(request: google.pubsub.v1.IDetachSubscriptionRequest, callback: google.pubsub.v1.Publisher.DetachSubscriptionCallback): void;
164
165 /**
166 * Calls DetachSubscription.
167 * @param request DetachSubscriptionRequest message or plain object
168 * @returns Promise
169 */
170 public detachSubscription(request: google.pubsub.v1.IDetachSubscriptionRequest): Promise<google.pubsub.v1.DetachSubscriptionResponse>;
171 }
172
173 namespace Publisher {
174
175 /**
176 * Callback as used by {@link google.pubsub.v1.Publisher|createTopic}.
177 * @param error Error, if any
178 * @param [response] Topic
179 */
180 type CreateTopicCallback = (error: (Error|null), response?: google.pubsub.v1.Topic) => void;
181
182 /**
183 * Callback as used by {@link google.pubsub.v1.Publisher|updateTopic}.
184 * @param error Error, if any
185 * @param [response] Topic
186 */
187 type UpdateTopicCallback = (error: (Error|null), response?: google.pubsub.v1.Topic) => void;
188
189 /**
190 * Callback as used by {@link google.pubsub.v1.Publisher|publish}.
191 * @param error Error, if any
192 * @param [response] PublishResponse
193 */
194 type PublishCallback = (error: (Error|null), response?: google.pubsub.v1.PublishResponse) => void;
195
196 /**
197 * Callback as used by {@link google.pubsub.v1.Publisher|getTopic}.
198 * @param error Error, if any
199 * @param [response] Topic
200 */
201 type GetTopicCallback = (error: (Error|null), response?: google.pubsub.v1.Topic) => void;
202
203 /**
204 * Callback as used by {@link google.pubsub.v1.Publisher|listTopics}.
205 * @param error Error, if any
206 * @param [response] ListTopicsResponse
207 */
208 type ListTopicsCallback = (error: (Error|null), response?: google.pubsub.v1.ListTopicsResponse) => void;
209
210 /**
211 * Callback as used by {@link google.pubsub.v1.Publisher|listTopicSubscriptions}.
212 * @param error Error, if any
213 * @param [response] ListTopicSubscriptionsResponse
214 */
215 type ListTopicSubscriptionsCallback = (error: (Error|null), response?: google.pubsub.v1.ListTopicSubscriptionsResponse) => void;
216
217 /**
218 * Callback as used by {@link google.pubsub.v1.Publisher|listTopicSnapshots}.
219 * @param error Error, if any
220 * @param [response] ListTopicSnapshotsResponse
221 */
222 type ListTopicSnapshotsCallback = (error: (Error|null), response?: google.pubsub.v1.ListTopicSnapshotsResponse) => void;
223
224 /**
225 * Callback as used by {@link google.pubsub.v1.Publisher|deleteTopic}.
226 * @param error Error, if any
227 * @param [response] Empty
228 */
229 type DeleteTopicCallback = (error: (Error|null), response?: google.protobuf.Empty) => void;
230
231 /**
232 * Callback as used by {@link google.pubsub.v1.Publisher|detachSubscription}.
233 * @param error Error, if any
234 * @param [response] DetachSubscriptionResponse
235 */
236 type DetachSubscriptionCallback = (error: (Error|null), response?: google.pubsub.v1.DetachSubscriptionResponse) => void;
237 }
238
239 /** Properties of a MessageStoragePolicy. */
240 interface IMessageStoragePolicy {
241
242 /** MessageStoragePolicy allowedPersistenceRegions */
243 allowedPersistenceRegions?: (string[]|null);
244 }
245
246 /** Represents a MessageStoragePolicy. */
247 class MessageStoragePolicy implements IMessageStoragePolicy {
248
249 /**
250 * Constructs a new MessageStoragePolicy.
251 * @param [properties] Properties to set
252 */
253 constructor(properties?: google.pubsub.v1.IMessageStoragePolicy);
254
255 /** MessageStoragePolicy allowedPersistenceRegions. */
256 public allowedPersistenceRegions: string[];
257
258 /**
259 * Creates a new MessageStoragePolicy instance using the specified properties.
260 * @param [properties] Properties to set
261 * @returns MessageStoragePolicy instance
262 */
263 public static create(properties?: google.pubsub.v1.IMessageStoragePolicy): google.pubsub.v1.MessageStoragePolicy;
264
265 /**
266 * Encodes the specified MessageStoragePolicy message. Does not implicitly {@link google.pubsub.v1.MessageStoragePolicy.verify|verify} messages.
267 * @param message MessageStoragePolicy message or plain object to encode
268 * @param [writer] Writer to encode to
269 * @returns Writer
270 */
271 public static encode(message: google.pubsub.v1.IMessageStoragePolicy, writer?: $protobuf.Writer): $protobuf.Writer;
272
273 /**
274 * Encodes the specified MessageStoragePolicy message, length delimited. Does not implicitly {@link google.pubsub.v1.MessageStoragePolicy.verify|verify} messages.
275 * @param message MessageStoragePolicy message or plain object to encode
276 * @param [writer] Writer to encode to
277 * @returns Writer
278 */
279 public static encodeDelimited(message: google.pubsub.v1.IMessageStoragePolicy, writer?: $protobuf.Writer): $protobuf.Writer;
280
281 /**
282 * Decodes a MessageStoragePolicy message from the specified reader or buffer.
283 * @param reader Reader or buffer to decode from
284 * @param [length] Message length if known beforehand
285 * @returns MessageStoragePolicy
286 * @throws {Error} If the payload is not a reader or valid buffer
287 * @throws {$protobuf.util.ProtocolError} If required fields are missing
288 */
289 public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.pubsub.v1.MessageStoragePolicy;
290
291 /**
292 * Decodes a MessageStoragePolicy message from the specified reader or buffer, length delimited.
293 * @param reader Reader or buffer to decode from
294 * @returns MessageStoragePolicy
295 * @throws {Error} If the payload is not a reader or valid buffer
296 * @throws {$protobuf.util.ProtocolError} If required fields are missing
297 */
298 public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.pubsub.v1.MessageStoragePolicy;
299
300 /**
301 * Verifies a MessageStoragePolicy message.
302 * @param message Plain object to verify
303 * @returns `null` if valid, otherwise the reason why it is not
304 */
305 public static verify(message: { [k: string]: any }): (string|null);
306
307 /**
308 * Creates a MessageStoragePolicy message from a plain object. Also converts values to their respective internal types.
309 * @param object Plain object
310 * @returns MessageStoragePolicy
311 */
312 public static fromObject(object: { [k: string]: any }): google.pubsub.v1.MessageStoragePolicy;
313
314 /**
315 * Creates a plain object from a MessageStoragePolicy message. Also converts values to other types if specified.
316 * @param message MessageStoragePolicy
317 * @param [options] Conversion options
318 * @returns Plain object
319 */
320 public static toObject(message: google.pubsub.v1.MessageStoragePolicy, options?: $protobuf.IConversionOptions): { [k: string]: any };
321
322 /**
323 * Converts this MessageStoragePolicy to JSON.
324 * @returns JSON object
325 */
326 public toJSON(): { [k: string]: any };
327 }
328
329 /** Properties of a SchemaSettings. */
330 interface ISchemaSettings {
331
332 /** SchemaSettings schema */
333 schema?: (string|null);
334
335 /** SchemaSettings encoding */
336 encoding?: (google.pubsub.v1.Encoding|keyof typeof google.pubsub.v1.Encoding|null);
337 }
338
339 /** Represents a SchemaSettings. */
340 class SchemaSettings implements ISchemaSettings {
341
342 /**
343 * Constructs a new SchemaSettings.
344 * @param [properties] Properties to set
345 */
346 constructor(properties?: google.pubsub.v1.ISchemaSettings);
347
348 /** SchemaSettings schema. */
349 public schema: string;
350
351 /** SchemaSettings encoding. */
352 public encoding: (google.pubsub.v1.Encoding|keyof typeof google.pubsub.v1.Encoding);
353
354 /**
355 * Creates a new SchemaSettings instance using the specified properties.
356 * @param [properties] Properties to set
357 * @returns SchemaSettings instance
358 */
359 public static create(properties?: google.pubsub.v1.ISchemaSettings): google.pubsub.v1.SchemaSettings;
360
361 /**
362 * Encodes the specified SchemaSettings message. Does not implicitly {@link google.pubsub.v1.SchemaSettings.verify|verify} messages.
363 * @param message SchemaSettings message or plain object to encode
364 * @param [writer] Writer to encode to
365 * @returns Writer
366 */
367 public static encode(message: google.pubsub.v1.ISchemaSettings, writer?: $protobuf.Writer): $protobuf.Writer;
368
369 /**
370 * Encodes the specified SchemaSettings message, length delimited. Does not implicitly {@link google.pubsub.v1.SchemaSettings.verify|verify} messages.
371 * @param message SchemaSettings message or plain object to encode
372 * @param [writer] Writer to encode to
373 * @returns Writer
374 */
375 public static encodeDelimited(message: google.pubsub.v1.ISchemaSettings, writer?: $protobuf.Writer): $protobuf.Writer;
376
377 /**
378 * Decodes a SchemaSettings message from the specified reader or buffer.
379 * @param reader Reader or buffer to decode from
380 * @param [length] Message length if known beforehand
381 * @returns SchemaSettings
382 * @throws {Error} If the payload is not a reader or valid buffer
383 * @throws {$protobuf.util.ProtocolError} If required fields are missing
384 */
385 public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.pubsub.v1.SchemaSettings;
386
387 /**
388 * Decodes a SchemaSettings message from the specified reader or buffer, length delimited.
389 * @param reader Reader or buffer to decode from
390 * @returns SchemaSettings
391 * @throws {Error} If the payload is not a reader or valid buffer
392 * @throws {$protobuf.util.ProtocolError} If required fields are missing
393 */
394 public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.pubsub.v1.SchemaSettings;
395
396 /**
397 * Verifies a SchemaSettings message.
398 * @param message Plain object to verify
399 * @returns `null` if valid, otherwise the reason why it is not
400 */
401 public static verify(message: { [k: string]: any }): (string|null);
402
403 /**
404 * Creates a SchemaSettings message from a plain object. Also converts values to their respective internal types.
405 * @param object Plain object
406 * @returns SchemaSettings
407 */
408 public static fromObject(object: { [k: string]: any }): google.pubsub.v1.SchemaSettings;
409
410 /**
411 * Creates a plain object from a SchemaSettings message. Also converts values to other types if specified.
412 * @param message SchemaSettings
413 * @param [options] Conversion options
414 * @returns Plain object
415 */
416 public static toObject(message: google.pubsub.v1.SchemaSettings, options?: $protobuf.IConversionOptions): { [k: string]: any };
417
418 /**
419 * Converts this SchemaSettings to JSON.
420 * @returns JSON object
421 */
422 public toJSON(): { [k: string]: any };
423 }
424
425 /** Properties of a Topic. */
426 interface ITopic {
427
428 /** Topic name */
429 name?: (string|null);
430
431 /** Topic labels */
432 labels?: ({ [k: string]: string }|null);
433
434 /** Topic messageStoragePolicy */
435 messageStoragePolicy?: (google.pubsub.v1.IMessageStoragePolicy|null);
436
437 /** Topic kmsKeyName */
438 kmsKeyName?: (string|null);
439
440 /** Topic schemaSettings */
441 schemaSettings?: (google.pubsub.v1.ISchemaSettings|null);
442
443 /** Topic satisfiesPzs */
444 satisfiesPzs?: (boolean|null);
445
446 /** Topic messageRetentionDuration */
447 messageRetentionDuration?: (google.protobuf.IDuration|null);
448 }
449
450 /** Represents a Topic. */
451 class Topic implements ITopic {
452
453 /**
454 * Constructs a new Topic.
455 * @param [properties] Properties to set
456 */
457 constructor(properties?: google.pubsub.v1.ITopic);
458
459 /** Topic name. */
460 public name: string;
461
462 /** Topic labels. */
463 public labels: { [k: string]: string };
464
465 /** Topic messageStoragePolicy. */
466 public messageStoragePolicy?: (google.pubsub.v1.IMessageStoragePolicy|null);
467
468 /** Topic kmsKeyName. */
469 public kmsKeyName: string;
470
471 /** Topic schemaSettings. */
472 public schemaSettings?: (google.pubsub.v1.ISchemaSettings|null);
473
474 /** Topic satisfiesPzs. */
475 public satisfiesPzs: boolean;
476
477 /** Topic messageRetentionDuration. */
478 public messageRetentionDuration?: (google.protobuf.IDuration|null);
479
480 /**
481 * Creates a new Topic instance using the specified properties.
482 * @param [properties] Properties to set
483 * @returns Topic instance
484 */
485 public static create(properties?: google.pubsub.v1.ITopic): google.pubsub.v1.Topic;
486
487 /**
488 * Encodes the specified Topic message. Does not implicitly {@link google.pubsub.v1.Topic.verify|verify} messages.
489 * @param message Topic message or plain object to encode
490 * @param [writer] Writer to encode to
491 * @returns Writer
492 */
493 public static encode(message: google.pubsub.v1.ITopic, writer?: $protobuf.Writer): $protobuf.Writer;
494
495 /**
496 * Encodes the specified Topic message, length delimited. Does not implicitly {@link google.pubsub.v1.Topic.verify|verify} messages.
497 * @param message Topic message or plain object to encode
498 * @param [writer] Writer to encode to
499 * @returns Writer
500 */
501 public static encodeDelimited(message: google.pubsub.v1.ITopic, writer?: $protobuf.Writer): $protobuf.Writer;
502
503 /**
504 * Decodes a Topic message from the specified reader or buffer.
505 * @param reader Reader or buffer to decode from
506 * @param [length] Message length if known beforehand
507 * @returns Topic
508 * @throws {Error} If the payload is not a reader or valid buffer
509 * @throws {$protobuf.util.ProtocolError} If required fields are missing
510 */
511 public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.pubsub.v1.Topic;
512
513 /**
514 * Decodes a Topic message from the specified reader or buffer, length delimited.
515 * @param reader Reader or buffer to decode from
516 * @returns Topic
517 * @throws {Error} If the payload is not a reader or valid buffer
518 * @throws {$protobuf.util.ProtocolError} If required fields are missing
519 */
520 public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.pubsub.v1.Topic;
521
522 /**
523 * Verifies a Topic message.
524 * @param message Plain object to verify
525 * @returns `null` if valid, otherwise the reason why it is not
526 */
527 public static verify(message: { [k: string]: any }): (string|null);
528
529 /**
530 * Creates a Topic message from a plain object. Also converts values to their respective internal types.
531 * @param object Plain object
532 * @returns Topic
533 */
534 public static fromObject(object: { [k: string]: any }): google.pubsub.v1.Topic;
535
536 /**
537 * Creates a plain object from a Topic message. Also converts values to other types if specified.
538 * @param message Topic
539 * @param [options] Conversion options
540 * @returns Plain object
541 */
542 public static toObject(message: google.pubsub.v1.Topic, options?: $protobuf.IConversionOptions): { [k: string]: any };
543
544 /**
545 * Converts this Topic to JSON.
546 * @returns JSON object
547 */
548 public toJSON(): { [k: string]: any };
549 }
550
551 /** Properties of a PubsubMessage. */
552 interface IPubsubMessage {
553
554 /** PubsubMessage data */
555 data?: (Uint8Array|string|null);
556
557 /** PubsubMessage attributes */
558 attributes?: ({ [k: string]: string }|null);
559
560 /** PubsubMessage messageId */
561 messageId?: (string|null);
562
563 /** PubsubMessage publishTime */
564 publishTime?: (google.protobuf.ITimestamp|null);
565
566 /** PubsubMessage orderingKey */
567 orderingKey?: (string|null);
568 }
569
570 /** Represents a PubsubMessage. */
571 class PubsubMessage implements IPubsubMessage {
572
573 /**
574 * Constructs a new PubsubMessage.
575 * @param [properties] Properties to set
576 */
577 constructor(properties?: google.pubsub.v1.IPubsubMessage);
578
579 /** PubsubMessage data. */
580 public data: (Uint8Array|string);
581
582 /** PubsubMessage attributes. */
583 public attributes: { [k: string]: string };
584
585 /** PubsubMessage messageId. */
586 public messageId: string;
587
588 /** PubsubMessage publishTime. */
589 public publishTime?: (google.protobuf.ITimestamp|null);
590
591 /** PubsubMessage orderingKey. */
592 public orderingKey: string;
593
594 /**
595 * Creates a new PubsubMessage instance using the specified properties.
596 * @param [properties] Properties to set
597 * @returns PubsubMessage instance
598 */
599 public static create(properties?: google.pubsub.v1.IPubsubMessage): google.pubsub.v1.PubsubMessage;
600
601 /**
602 * Encodes the specified PubsubMessage message. Does not implicitly {@link google.pubsub.v1.PubsubMessage.verify|verify} messages.
603 * @param message PubsubMessage message or plain object to encode
604 * @param [writer] Writer to encode to
605 * @returns Writer
606 */
607 public static encode(message: google.pubsub.v1.IPubsubMessage, writer?: $protobuf.Writer): $protobuf.Writer;
608
609 /**
610 * Encodes the specified PubsubMessage message, length delimited. Does not implicitly {@link google.pubsub.v1.PubsubMessage.verify|verify} messages.
611 * @param message PubsubMessage message or plain object to encode
612 * @param [writer] Writer to encode to
613 * @returns Writer
614 */
615 public static encodeDelimited(message: google.pubsub.v1.IPubsubMessage, writer?: $protobuf.Writer): $protobuf.Writer;
616
617 /**
618 * Decodes a PubsubMessage message from the specified reader or buffer.
619 * @param reader Reader or buffer to decode from
620 * @param [length] Message length if known beforehand
621 * @returns PubsubMessage
622 * @throws {Error} If the payload is not a reader or valid buffer
623 * @throws {$protobuf.util.ProtocolError} If required fields are missing
624 */
625 public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.pubsub.v1.PubsubMessage;
626
627 /**
628 * Decodes a PubsubMessage message from the specified reader or buffer, length delimited.
629 * @param reader Reader or buffer to decode from
630 * @returns PubsubMessage
631 * @throws {Error} If the payload is not a reader or valid buffer
632 * @throws {$protobuf.util.ProtocolError} If required fields are missing
633 */
634 public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.pubsub.v1.PubsubMessage;
635
636 /**
637 * Verifies a PubsubMessage message.
638 * @param message Plain object to verify
639 * @returns `null` if valid, otherwise the reason why it is not
640 */
641 public static verify(message: { [k: string]: any }): (string|null);
642
643 /**
644 * Creates a PubsubMessage message from a plain object. Also converts values to their respective internal types.
645 * @param object Plain object
646 * @returns PubsubMessage
647 */
648 public static fromObject(object: { [k: string]: any }): google.pubsub.v1.PubsubMessage;
649
650 /**
651 * Creates a plain object from a PubsubMessage message. Also converts values to other types if specified.
652 * @param message PubsubMessage
653 * @param [options] Conversion options
654 * @returns Plain object
655 */