yorkie/dev.yorkie.document/Document

Document

class Document(key: String, options: Document.Options = Options()) : Closeable, Attachable

A CRDT-based data type. We can represent the model of the application and edit it even while offline.

A single-threaded, Closeable is used as default. Therefore you need to close the document, when the document is no longer needed. If you provide your own dispatcher, it is up to you to decide close is needed or not. snapshotDispatcher can be set differently from dispatcher, as snapshot operation can be much heavier than other operations.

Constructors

constructor(key: String, options: Document.Options = Options())

Types

BroadcastOptions

data class BroadcastOptions(val maxRetries: Int = Int.MAX_VALUE)

BroadcastOptions are the options to create a new broadcast.

sealed interface Event : ResourceEvent

data class Options(val disableGC: Boolean = false)

Properties

@VisibleForTesting

var changeID: ChangeID

val events: SharedFlow<Document.Event>

@VisibleForTesting

val garbageLength: Int

val myPresence: P

val presences: StateFlow<Presences>

Functions

open override fun applyStatus(status: ResourceStatus)

open override fun close()

fun events(targetPath: String): Flow<Document.Event>

Subscribes to events on the document with the specific targetPath.

@VisibleForTesting

fun garbageCollect(minSyncedVersionVector: VersionVector): Int

Deletes elements that were removed before the given time.

fun getDocSize(): DocSize

getDocSize returns the size of this document.

open override fun getKey(): String

getKey returns the key of this document.

getMaxSizePerDocument

fun getMaxSizePerDocument(): Int

getMaxSizePerDocument gets the maximum size of this document.

suspend fun getRoot(): JsonObject

Returns a new proxy of cloned root.

fun getSchemaRules(): List<Rule>

getSchemaRules gets the schema rules of this document.

open override fun getStatus(): ResourceStatus

getStatus returns the status of this document.

suspend fun getValueByPath(path: String): JsonElement?

Returns the JsonElement corresponding to the path.

getVersionVector

fun getVersionVector(): VersionVector

getVersionVector returns the version vector of document

hasLocalChanges

open override fun hasLocalChanges(): Boolean

hasLocalChanges returns whether this document has local changes or not.

open override fun publish(event: ResourceEvent)

publish publishes an event to notify observers about changes in this resource.

suspend fun publishEvent(event: Document.Event)

open override fun setActor(actorID: ActorID)

Sets actorID into this document. This is also applied in the localChanges the document has.

setMaxSizePerDocument

fun setMaxSizePerDocument(size: Int)

setMaxSizePerDocument sets the maximum size of this document.

fun setSchemaRules(rules: List<Rule>)

setSchemaRules sets the schema rules of this document.

fun toJson(): String

fun updateAsync(message: String? = null, updater: suspend (root: JsonObject, presence: DocPresence) -> Unit): Deferred<OperationResult>

Executes the given updater to update this document.