Class SeqLogger

seq_logger.js:8–288

    const HEADER_FOOTER_BYTES = (new safeGlobalBlob([HEADER])).size + (new safeGlobalBlob([FOOTER])).size;

    class SeqLogger {
        constructor(config) {
            let dflt = {
                serverUrl: 'http://localhost:5341',
                apiKey: null,
                maxBatchingTime: 2000,
                eventSizeLimit: 256 * 1024,
                batchSizeLimit: 1024 * 1024,
                requestTimeout: 30000,
                maxRetries: 5,
                retryDelay: 5000,
                onError: e => {
                    console.error("[seq]", e);
                }
            };
            let cfg = config || dflt;
            var serverUrl = cfg.serverUrl || dflt.serverUrl;
            if (!serverUrl.endsWith('/')) {
                serverUrl += '/';
            }
            this._endpoint = serverUrl + 'api/events/raw';
            this._apiKey = cfg.apiKey || dflt.apiKey;
            this._maxBatchingTime = cfg.maxBatchingTime || dflt.maxBatchingTime;
            this._eventSizeLimit = cfg.eventSizeLimit || dflt.eventSizeLimit;
            this._batchSizeLimit = cfg.batchSizeLimit || dflt.batchSizeLimit;
            this._requestTimeout = cfg.requestTimeout || dflt.requestTimeout;
            this._onError = cfg.onError || dflt.onError;
            this._maxRetries = cfg.maxRetries || dflt.maxRetries;
            this._retryDelay = cfg.retryDelay || dflt.retryDelay;

            this._queue = [];
            this._timer = null;
            this._closed = false;
            this._activeShipper = null;
        }

        /**
         * Flush events queued at the time of the call, and wait for pending writes to complete regardless of configured batching/timers.
         * @returns {Promise<boolean>}
         */
        flush() {
            return this._ship();
        }

        /**
         * Flush then destroy connections, close the logger, destroying timers and other resources.
         * @returns {Promise<void>}
         */
        close() {
            if (this._closed) {
                throw new Error('The logger has already been closed.');
            }

            this._closed = true;
            this._clearTimer();
            return this.flush();
        }