Variable create

Type Declaration

• • (
        options: any,
    ): {
        acquireLease: (
            name: any,
            nodeId: any,
            ttlMs: any,
        ) => Promise<{ expiresAt: number; held: boolean; token: number }>;
        adoptOrigin: (opts: any) => any;
        advanceCounter: (scope: any, realmId: any, key: any, value: any) => any;
        agreeFingerprint: (nodeId: any, fingerprint: any) => Promise<any>;
        bridgeConnection: () => any;
        changeCeiling: () => any;
        changeRowsWritten: () => number;
        changesAt: (seqs: any) => any;
        changesSince: (afterSeq: any, limit: any) => any;
        claimHeld: (scope: any, realmId: any, key: any) => any;
        claimOnce: (scope: any, realmId: any, key: any, opts: any) => any;
        claimUsedAssertion: (row: any, opts: any) => any;
        clearWindow: (scope: any, realmId: any, key: any) => any;
        close: () => any;
        clusterClock: () => any;
        clusterState: () => Promise<{ leases: any; nodes: any; now: number }>;
        countAllSealed: () => any;
        countSealed: (dekIds: any) => Promise<any>;
        countWindow: (scope: any, realmId: any, key: any, windowMs: any) => any;
        deleteKeys: (realmId: any) => Promise<void>;
        directoryQuery: (name: any, args: any) => any;
        ensureSharedSecret: (name: any, material: any) => any;
        entryCodec: () => {
            index: (
                attrs: any,
            ) => {
                attrNames: any[];
                classKeys: any[];
                mailKeys: any[];
                nameKeys: any[];
                uuidKeys: any[];
                valueKeys: any[];
            };
            openAttributes: (dnKey: any, stored: any) => any;
            sealAttributes: (realmId: any, dnKey: any, attrs: any) => any;
            tier: string;
        };
        findUsedAssertion: (realm: any, key: any, nowMs: any) => any;
        heartbeat: (
            nodeId: any,
            ttlMs: any,
            info: any,
        ) => Promise<{ alive: boolean; leases: any }>;
        joinCluster: (node: any) => Promise<any>;
        latestBlockingChangeSeq: () => any;
        latestChangeSeq: () => any;
        leaveChangeReader: () => any;
        leaveCluster: (nodeId: any) => Promise<boolean>;
        listUsedAssertions: (
            realm: any,
            opts: any,
        ) => Promise<{ live: number; rows: any; total: number }>;
        livenessStatus: () => { open: boolean } & {
            connects: number;
            drops: number;
            queries: number;
            viaPool: number;
        };
        loadDirectory: () => any;
        loadKey: (realmId: any) => any;
        loadKeys: () => any;
        loadMinted: (filter: any) => any;
        loadOverrides: () => any;
        loadRealms: () => any;
        mergeKeys: (realmId: any, ciphertext: any, merge: any) => Promise<any>;
        metrics: (options: any) => any;
        name: string;
        nodeSnapshots: () => Promise<{ now: number; rows: any }>;
        open: () => Promise<void>;
        origin: () => string;
        peekWindow: (scope: any, realmId: any, key: any) => any;
        purgeBudgets: (scope: any, realmId: any) => any;
        purgeChangeLog: (opts: any) => any;
        purgeChanges: (beforeSeq: any) => any;
        purgeClaims: () => any;
        purgeExpiredMinted: (kind: any, options: any) => any;
        purgeMinted: (beforeMs: any) => any;
        purgeNodeSnapshots: (olderThanMs: any, keepNames: any) => any;
        purgeTombstones: (beforeMs: any) => any;
        purgeUsedAssertions: (nowMs: any) => any;
        purgeWindows: () => any;
        putNodeSnapshot: (name: any, nodeId: any, body: any) => any;
        readEntry: (realmId: any, dnKey: any) => any;
        readMinted: (handle: any, realmId: any, key: any) => any;
        readMintedMany: (refs: any) => any;
        refundBudget: (
            scope: any,
            realmId: any,
            key: any,
            period: any,
            amount: any,
            count: any,
        ) => any;
        releaseClaim: (scope: any, realmId: any, key: any, reservation: any) => any;
        releaseLease: (name: any, nodeId: any, token: any) => Promise<boolean>;
        releaseOrigin: () => any;
        removeUsedAssertions: (realm: any) => any;
        renewOrigin: (ttlMs: any) => Promise<any>;
        replicaLagMs: () => any;
        reportChangeReader: (applied: any, nodeId: any) => any;
        resealSealed: (dekIds: any, reseal: any, options: any) => any;
        riskAbandonStalled: (before: any, at: any, why: any, code: any) => any;
        riskActivate: (
            realm: any,
            dataset: any,
            kind: any,
            version: any,
            now: any,
        ) => Promise<any>;
        riskAssessmentMetrics: (
            realm: any,
            opts: any,
        ) => Promise<
            {
                groups: any;
                quantiles: {};
                series: any;
                totals: {
                    bots: number;
                    maxScore: number;
                    meanScore: number;
                    subjects: number;
                    total: number;
                };
            },
        >;
        riskBeginVersion: (v: any) => any;
        riskClaimAction: (
            realm: any,
            subject: any,
            reaction: any,
            assessmentId: any,
        ) => any;
        riskDeleteRows: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            limit: any,
        ) => any;
        riskDistinctValues: (
            realm: any,
            subject: any,
            feature: any,
            prefix: any,
        ) => any;
        riskFeatureCounts: (realm: any, subject: any, pairs: any) => any;
        riskFinishVersion: (
            realm: any,
            dataset: any,
            version: any,
            patch: any,
        ) => any;
        riskGeography: (realm: any, opts: any) => any;
        riskIncrementCounts: (realm: any, rows: any, at: any) => any;
        riskInsertRows: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            rows: any,
        ) => any;
        riskListAcceptances: () => any;
        riskListAssessments: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListDatasets: () => any;
        riskListFailures: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListSubjects: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListVersions: (realm: any, dataset: any) => any;
        riskLookupFido: (dataset: any, version: any, keyKind: any, key: any) => any;
        riskLookupRange: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            address: any,
        ) => any;
        riskMarkRowsDeleted: (
            realm: any,
            dataset: any,
            version: any,
            now: any,
        ) => any;
        riskPurgeFailures: (beforeMs: any, limit: any) => any;
        riskPurgeHistory: (table: any, beforeMs: any, limit: any) => any;
        riskRecordAcceptance: (a: any) => any;
        riskRecordAssessment: (a: any) => any;
        riskRecordFailure: (row: any) => any;
        riskSetFeedback: (
            realm: any,
            id: any,
            subject: any,
            feedback: any,
            at: any,
        ) => any;
        riskSettleAssessment: (a: any) => any;
        riskSubjectLevels: (realm: any) => any;
        riskSubjectOf: (realm: any, subject: any) => any;
        riskTouchVersion: (
            realm: any,
            dataset: any,
            version: any,
            at: any,
            rows: any,
        ) => any;
        riskUpsertSessionContext: (c: any) => any;
        riskUpsertSubject: (s: any) => any;
        routeClaim: (realmId: any, kind: any, digest: any, cell: any) => any;
        routeCounts: () => any;
        routeLookup: (realmId: any, kind: any, digest: any) => any;
        routeMove: (
            realmId: any,
            kind: any,
            digest: any,
            fromCell: any,
            toCell: any,
        ) => any;
        routeRelease: (realmId: any, kind: any, digest: any, cell: any) => any;
        routeRemoveRealm: (realmId: any) => any;
        routeRowsOf: (realmId: any, cell: any) => any;
        saveDirectory: (change: any) => Promise<{ outcomes: any[] }>;
        saveKeys: (realmId: any, ciphertext: any) => Promise<void>;
        saveMinted: (
            upserts: any,
            deletes: any,
        ) => Promise<{ merged: any[]; refused: any[] }>;
        saveOverrides: (map: any, delta: any) => Promise<void>;
        saveRealms: (rows: any, delta: any) => Promise<void>;
        setFence: (provider: any, whenFenced: any) => void;
        setOriginLost: (fn: any) => void;
        settleUsedAssertion: (
            realm: any,
            key: any,
            reservation: any,
            spent: any,
            at: any,
        ) => any;
        spendBudget: (
            scope: any,
            realmId: any,
            key: any,
            period: any,
            amount: any,
            count: any,
            limitAmount: any,
            limitCount: any,
            expiresAtMs: any,
        ) => any;
        watchChanges: (onNudge: any) => () => void;
    }

  • Creates the postgres persistence driver.

    A connection pool, a transaction per flush, the change log that several processes coordinate through, and the minted, key, cluster and risk tables. TLS is used when the connection string's sslmode asks for it.

    Parameters

    • options: any

      url, the connection string; log, the logger; verifyTls, whether the server certificate is verified; and poolMax, the pool size

    Returns {
        acquireLease: (
            name: any,
            nodeId: any,
            ttlMs: any,
        ) => Promise<{ expiresAt: number; held: boolean; token: number }>;
        adoptOrigin: (opts: any) => any;
        advanceCounter: (scope: any, realmId: any, key: any, value: any) => any;
        agreeFingerprint: (nodeId: any, fingerprint: any) => Promise<any>;
        bridgeConnection: () => any;
        changeCeiling: () => any;
        changeRowsWritten: () => number;
        changesAt: (seqs: any) => any;
        changesSince: (afterSeq: any, limit: any) => any;
        claimHeld: (scope: any, realmId: any, key: any) => any;
        claimOnce: (scope: any, realmId: any, key: any, opts: any) => any;
        claimUsedAssertion: (row: any, opts: any) => any;
        clearWindow: (scope: any, realmId: any, key: any) => any;
        close: () => any;
        clusterClock: () => any;
        clusterState: () => Promise<{ leases: any; nodes: any; now: number }>;
        countAllSealed: () => any;
        countSealed: (dekIds: any) => Promise<any>;
        countWindow: (scope: any, realmId: any, key: any, windowMs: any) => any;
        deleteKeys: (realmId: any) => Promise<void>;
        directoryQuery: (name: any, args: any) => any;
        ensureSharedSecret: (name: any, material: any) => any;
        entryCodec: () => {
            index: (
                attrs: any,
            ) => {
                attrNames: any[];
                classKeys: any[];
                mailKeys: any[];
                nameKeys: any[];
                uuidKeys: any[];
                valueKeys: any[];
            };
            openAttributes: (dnKey: any, stored: any) => any;
            sealAttributes: (realmId: any, dnKey: any, attrs: any) => any;
            tier: string;
        };
        findUsedAssertion: (realm: any, key: any, nowMs: any) => any;
        heartbeat: (
            nodeId: any,
            ttlMs: any,
            info: any,
        ) => Promise<{ alive: boolean; leases: any }>;
        joinCluster: (node: any) => Promise<any>;
        latestBlockingChangeSeq: () => any;
        latestChangeSeq: () => any;
        leaveChangeReader: () => any;
        leaveCluster: (nodeId: any) => Promise<boolean>;
        listUsedAssertions: (
            realm: any,
            opts: any,
        ) => Promise<{ live: number; rows: any; total: number }>;
        livenessStatus: () => { open: boolean } & {
            connects: number;
            drops: number;
            queries: number;
            viaPool: number;
        };
        loadDirectory: () => any;
        loadKey: (realmId: any) => any;
        loadKeys: () => any;
        loadMinted: (filter: any) => any;
        loadOverrides: () => any;
        loadRealms: () => any;
        mergeKeys: (realmId: any, ciphertext: any, merge: any) => Promise<any>;
        metrics: (options: any) => any;
        name: string;
        nodeSnapshots: () => Promise<{ now: number; rows: any }>;
        open: () => Promise<void>;
        origin: () => string;
        peekWindow: (scope: any, realmId: any, key: any) => any;
        purgeBudgets: (scope: any, realmId: any) => any;
        purgeChangeLog: (opts: any) => any;
        purgeChanges: (beforeSeq: any) => any;
        purgeClaims: () => any;
        purgeExpiredMinted: (kind: any, options: any) => any;
        purgeMinted: (beforeMs: any) => any;
        purgeNodeSnapshots: (olderThanMs: any, keepNames: any) => any;
        purgeTombstones: (beforeMs: any) => any;
        purgeUsedAssertions: (nowMs: any) => any;
        purgeWindows: () => any;
        putNodeSnapshot: (name: any, nodeId: any, body: any) => any;
        readEntry: (realmId: any, dnKey: any) => any;
        readMinted: (handle: any, realmId: any, key: any) => any;
        readMintedMany: (refs: any) => any;
        refundBudget: (
            scope: any,
            realmId: any,
            key: any,
            period: any,
            amount: any,
            count: any,
        ) => any;
        releaseClaim: (scope: any, realmId: any, key: any, reservation: any) => any;
        releaseLease: (name: any, nodeId: any, token: any) => Promise<boolean>;
        releaseOrigin: () => any;
        removeUsedAssertions: (realm: any) => any;
        renewOrigin: (ttlMs: any) => Promise<any>;
        replicaLagMs: () => any;
        reportChangeReader: (applied: any, nodeId: any) => any;
        resealSealed: (dekIds: any, reseal: any, options: any) => any;
        riskAbandonStalled: (before: any, at: any, why: any, code: any) => any;
        riskActivate: (
            realm: any,
            dataset: any,
            kind: any,
            version: any,
            now: any,
        ) => Promise<any>;
        riskAssessmentMetrics: (
            realm: any,
            opts: any,
        ) => Promise<
            {
                groups: any;
                quantiles: {};
                series: any;
                totals: {
                    bots: number;
                    maxScore: number;
                    meanScore: number;
                    subjects: number;
                    total: number;
                };
            },
        >;
        riskBeginVersion: (v: any) => any;
        riskClaimAction: (
            realm: any,
            subject: any,
            reaction: any,
            assessmentId: any,
        ) => any;
        riskDeleteRows: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            limit: any,
        ) => any;
        riskDistinctValues: (
            realm: any,
            subject: any,
            feature: any,
            prefix: any,
        ) => any;
        riskFeatureCounts: (realm: any, subject: any, pairs: any) => any;
        riskFinishVersion: (
            realm: any,
            dataset: any,
            version: any,
            patch: any,
        ) => any;
        riskGeography: (realm: any, opts: any) => any;
        riskIncrementCounts: (realm: any, rows: any, at: any) => any;
        riskInsertRows: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            rows: any,
        ) => any;
        riskListAcceptances: () => any;
        riskListAssessments: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListDatasets: () => any;
        riskListFailures: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListSubjects: (
            realm: any,
            opts: any,
        ) => Promise<{ rows: any; total: number }>;
        riskListVersions: (realm: any, dataset: any) => any;
        riskLookupFido: (dataset: any, version: any, keyKind: any, key: any) => any;
        riskLookupRange: (
            kind: any,
            realm: any,
            dataset: any,
            version: any,
            address: any,
        ) => any;
        riskMarkRowsDeleted: (
            realm: any,
            dataset: any,
            version: any,
            now: any,
        ) => any;
        riskPurgeFailures: (beforeMs: any, limit: any) => any;
        riskPurgeHistory: (table: any, beforeMs: any, limit: any) => any;
        riskRecordAcceptance: (a: any) => any;
        riskRecordAssessment: (a: any) => any;
        riskRecordFailure: (row: any) => any;
        riskSetFeedback: (
            realm: any,
            id: any,
            subject: any,
            feedback: any,
            at: any,
        ) => any;
        riskSettleAssessment: (a: any) => any;
        riskSubjectLevels: (realm: any) => any;
        riskSubjectOf: (realm: any, subject: any) => any;
        riskTouchVersion: (
            realm: any,
            dataset: any,
            version: any,
            at: any,
            rows: any,
        ) => any;
        riskUpsertSessionContext: (c: any) => any;
        riskUpsertSubject: (s: any) => any;
        routeClaim: (realmId: any, kind: any, digest: any, cell: any) => any;
        routeCounts: () => any;
        routeLookup: (realmId: any, kind: any, digest: any) => any;
        routeMove: (
            realmId: any,
            kind: any,
            digest: any,
            fromCell: any,
            toCell: any,
        ) => any;
        routeRelease: (realmId: any, kind: any, digest: any, cell: any) => any;
        routeRemoveRealm: (realmId: any) => any;
        routeRowsOf: (realmId: any, cell: any) => any;
        saveDirectory: (change: any) => Promise<{ outcomes: any[] }>;
        saveKeys: (realmId: any, ciphertext: any) => Promise<void>;
        saveMinted: (
            upserts: any,
            deletes: any,
        ) => Promise<{ merged: any[]; refused: any[] }>;
        saveOverrides: (map: any, delta: any) => Promise<void>;
        saveRealms: (rows: any, delta: any) => Promise<void>;
        setFence: (provider: any, whenFenced: any) => void;
        setOriginLost: (fn: any) => void;
        settleUsedAssertion: (
            realm: any,
            key: any,
            reservation: any,
            spent: any,
            at: any,
        ) => any;
        spendBudget: (
            scope: any,
            realmId: any,
            key: any,
            period: any,
            amount: any,
            count: any,
            limitAmount: any,
            limitCount: any,
            expiresAtMs: any,
        ) => any;
        watchChanges: (onNudge: any) => () => void;
    }

    the driver object, with the methods the persistence contract names