Replicator
public final class Replicator
A replicator for replicating document changes between a local database and a target database. The replicator can be bidirectional or either push or pull. The replicator can also be one-short or continuous. The replicator runs asynchronously, so observe the status property to be notified of progress.
-
Activity level of a replicator.
- stopped: The replicator is finished or hit a fatal error.
- offline: The replicator is offline as the remote host is unreachable.
- connecting: The replicator is connecting to the remote host.
- idle: The replicator is inactive waiting for changes or offline.
- busy: The replicator is actively transferring data.
Declaration
Swift
public enum ActivityLevel : UInt8
-
Progress of a replicator. If
See moretotal
is zero, the progress is indeterminate; otherwise, dividing the two will produce a fraction that can be used to draw a progress bar.Declaration
Swift
public struct Progress
-
Combined activity level and progress of a replicator.
See moreDeclaration
Swift
public struct Status
-
Initializes a replicator with the given configuration.
Declaration
Swift
public init(config: ReplicatorConfiguration)
Parameters
config
The configuration.
-
The replicator’s configuration.
Declaration
Swift
public var config: ReplicatorConfiguration
-
The replicator’s current status: its activity level and progress. Observable.
Declaration
Swift
public var status: Status
-
Starts the replicator. This method returns immediately; the replicator runs asynchronously and will report its progress throuh the replicator change notification.
Declaration
Swift
public func start()
-
Stops a running replicator. This method returns immediately; when the replicator actually stops, the replicator will change its status’s activity level to
.stopped
and the replicator change notification will be notified accordingly.Declaration
Swift
public func stop()
-
Resets the local checkpoint of the replicator, meaning that it will read all changes since the beginning of time from the remote database. This can only be called when the replicator is in a stopped state.
Declaration
Swift
public func resetCheckpoint()
-
Adds a replicator change listener. Changes will be posted on the main queue.
Declaration
Swift
@discardableResult public func addChangeListener( _ listener: @escaping (ReplicatorChange) -> Void) -> ListenerToken
Parameters
listener
The listener to post changes.
Return Value
An opaque listener token object for removing the listener.
-
Adds a replicator change listener with the dispatch queue on which changes will be posted. If the dispatch queue is not specified, the changes will be posted on the main queue.
Declaration
Swift
@discardableResult public func addChangeListener(withQueue queue: DispatchQueue?, _ listener: @escaping (ReplicatorChange) -> Void) -> ListenerToken
Parameters
queue
The dispatch queue.
listener
The listener to post changes.
Return Value
An opaque listener token object for removing the listener.
-
Removes a change listener with the given listener token.
Declaration
Swift
public func removeChangeListener(withToken token: ListenerToken)
Parameters
token
The listener token.