Variable createReplication

Type Declaration

• • (
        label: any,
    ): {
        contribute: (
            handle: any,
            realmId: any,
            key: any,
            origin: any,
            value: any,
        ) => void;
        origins: () => any[];
        pull: () => any;
        purgeOnce: () => Promise<any>;
        remoteKeys: (handle: any, realmId: any) => any[];
        remoteRows: (handle: any, realmId: any, key: any) => any[];
        remoteSegmentedRows: (handle: any, realmId: any) => any[];
        reportPosition: (force: any) => Promise<any>;
        reset: () => void;
        start: (theDriver: any, theAppliers: any) => any;
        status: () => {
            appliedSeq: number;
            byKind: {};
            coordinating: boolean;
            failures: number;
            highestSeq: number;
            holes: number;
            holesAbandoned: number;
            lastError: string;
            lastPullAt: any;
            note: string;
            nudges: number;
            otherProcesses: number;
            pollIntervalMs: number;
            pulls: number;
            retention: {
                declaredGoneAt: any;
                lastTrim: any;
                readerTtlS: number;
                reportedAt: string;
                reportError: string;
                retentionS: number;
                trimming: boolean;
            };
            rowsApplied: number;
            startedAt: any;
            supported: boolean;
        };
        stop: () => Promise<any>;
        supports: (theDriver: any) => boolean;
        syncNow: () => any;
        wake: () => void;
    }

  • Builds a follower of one store's change log.

    Parameters

    • label: any

      '' for the process's main log, or a name ('global') that the jobs and the log lines of this instance carry

    Returns {
        contribute: (
            handle: any,
            realmId: any,
            key: any,
            origin: any,
            value: any,
        ) => void;
        origins: () => any[];
        pull: () => any;
        purgeOnce: () => Promise<any>;
        remoteKeys: (handle: any, realmId: any) => any[];
        remoteRows: (handle: any, realmId: any, key: any) => any[];
        remoteSegmentedRows: (handle: any, realmId: any) => any[];
        reportPosition: (force: any) => Promise<any>;
        reset: () => void;
        start: (theDriver: any, theAppliers: any) => any;
        status: () => {
            appliedSeq: number;
            byKind: {};
            coordinating: boolean;
            failures: number;
            highestSeq: number;
            holes: number;
            holesAbandoned: number;
            lastError: string;
            lastPullAt: any;
            note: string;
            nudges: number;
            otherProcesses: number;
            pollIntervalMs: number;
            pulls: number;
            retention: {
                declaredGoneAt: any;
                lastTrim: any;
                readerTtlS: number;
                reportedAt: string;
                reportError: string;
                retentionS: number;
                trimming: boolean;
            };
            rowsApplied: number;
            startedAt: any;
            supported: boolean;
        };
        stop: () => Promise<any>;
        supports: (theDriver: any) => boolean;
        syncNow: () => any;
        wake: () => void;
    }

    the instance: start, stop, syncNow, pull, wake, status and the rest of the module's interface

    • contribute: (handle: any, realmId: any, key: any, origin: any, value: any) => void

    • origins: () => any[]

    • pull: () => any

    • purgeOnce: () => Promise<any>

    • remoteKeys: (handle: any, realmId: any) => any[]

    • remoteRows: (handle: any, realmId: any, key: any) => any[]

    • remoteSegmentedRows: (handle: any, realmId: any) => any[]

    • reportPosition: (force: any) => Promise<any>

    • reset: () => void

    • start: (theDriver: any, theAppliers: any) => any

    • status: () => {
          appliedSeq: number;
          byKind: {};
          coordinating: boolean;
          failures: number;
          highestSeq: number;
          holes: number;
          holesAbandoned: number;
          lastError: string;
          lastPullAt: any;
          note: string;
          nudges: number;
          otherProcesses: number;
          pollIntervalMs: number;
          pulls: number;
          retention: {
              declaredGoneAt: any;
              lastTrim: any;
              readerTtlS: number;
              reportedAt: string;
              reportError: string;
              retentionS: number;
              trimming: boolean;
          };
          rowsApplied: number;
          startedAt: any;
          supported: boolean;
      }

    • stop: () => Promise<any>

    • supports: (theDriver: any) => boolean

    • syncNow: () => any

    • wake: () => void