dis+/node_modules/@google-cloud/pubsub/build/src/v1/subscriber_client.js
/**
     * Seeks an existing subscription to a point in time or to a given snapshot,
     * whichever is provided in the request. Snapshots are used in [Seek]
     * (https://cloud.google.com/pubsub/docs/replay-overview) operations, which
     * allow you to manage message acknowledgments in bulk. That is, you can set
     * the acknowledgment state of messages in an existing subscription to the
     * state captured by a snapshot. Note that both the subscription and the
     * snapshot must be on the same topic.
     *
     * @param {Object} request
     *   The request object that will be sent.
     * @param {string} request.subscription
     *   Required. The subscription to affect.
     * @param {google.protobuf.Timestamp} request.time
     *   The time to seek to.
     *   Messages retained in the subscription that were published before this
     *   time are marked as acknowledged, and messages retained in the
     *   subscription that were published after this time are marked as
     *   unacknowledged. Note that this operation affects only those messages
     *   retained in the subscription (configured by the combination of
     *   `message_retention_duration` and `retain_acked_messages`). For example,
     *   if `time` corresponds to a point before the message retention
     *   window (or to a point before the system's notion of the subscription
     *   creation time), only retained messages will be marked as unacknowledged,
     *   and already-expunged messages will not be restored.
     * @param {string} request.snapshot
     *   The snapshot to seek to. The snapshot's topic must be the same as that of
     *   the provided subscription.
     *   Format is `projects/{project}/snapshots/{snap}`.
     * @param {object} [options]
     *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
     * @returns {Promise} - The promise which resolves to an array.
     *   The first element of the array is an object representing [SeekResponse]{@link google.pubsub.v1.SeekResponse}.
     *   Please see the
     *   [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
     *   for more details and examples.
     * @example
     * const [response] = await client.seek(request);
     */
Seeks an existing subscription to a point in time or to a given snapshot,
whichever is provided in the request. Snapshots are used in [Seek]
operations, which
allow you to manage message acknowledgments in bulk. That is, you can set
the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot. Note that both the subscription and the
snapshot must be on the same topic.

@param {Object} request
The request object that will be sent.
Seeks an existing subscription to a point in time or to a given snapshot whichever is provided in the request . Snapshots are used in [ Seek ] operations which allow you to manage message acknowledgments in bulk . That is you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot . Note that both the subscription and the snapshot must be on the same topic . @param { Object } request The request object that will be sent .
seek(request, optionsOrCallback, callback) {
        request = request || {};
        let options;
        if (typeof optionsOrCallback === 'function' && callback === undefined) {
            callback = optionsOrCallback;
            options = {};
        }
        else {
            options = optionsOrCallback;
        }
        options = options || {};
        options.otherArgs = options.otherArgs || {};
        options.otherArgs.headers = options.otherArgs.headers || {};
        options.otherArgs.headers['x-goog-request-params'] =
            gax.routingHeader.fromParams({
                subscription: request.subscription || '',
            });
        this.initialize();
        return this.innerApiCalls.seek(request, options, callback);
    }
seek ( request , optionsOrCallback , callback ) { request = request || { } ; let options ; if ( typeof optionsOrCallback === 'function' && callback === undefined ) { callback = optionsOrCallback ; options = { } ; } else { options = optionsOrCallback ; } options = options || { } ; options . otherArgs = options . otherArgs || { } ; options . otherArgs . headers = options . otherArgs . headers || { } ; options . otherArgs . headers [ 'x-goog-request-params' ] = gax . routingHeader . fromParams ( { subscription : request . subscription || '' , } ) ; this . initialize ( ) ; return this . innerApiCalls . seek ( request , options , callback ) ; }
Seeks an existing subscription to a point in time or to a given snapshot,
 whichever is provided in the request.
Seeks an existing subscription to a point in time or to a given snapshot whichever is provided in the request .