Factory

@SerialName(value = "!InMemory")
@Serializable
data class Factory(var instantSource: InstantSource = InstantSource.system(), var epoch: Int = 0) : Log.Factory

Constructors

Link copied to clipboard
constructor(instantSource: InstantSource = InstantSource.system(), epoch: Int = 0)

Properties

Link copied to clipboard
var epoch: Int
Link copied to clipboard

Functions

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun openReadOnlyReplicaLog(remotes: Map<RemoteAlias, Remote>, partitions: Int = 1): ReadOnlyLog<ReplicaMessage>
Link copied to clipboard
open override fun openReadOnlySourceLog(remotes: Map<RemoteAlias, Remote>, partitions: Int = 1): ReadOnlyLog<SourceMessage>
Link copied to clipboard
open override fun openReplicaLog(remotes: Map<RemoteAlias, Remote>, partitions: Int = 1): InMemoryLog<ReplicaMessage>
Link copied to clipboard
open override fun openSourceLog(remotes: Map<RemoteAlias, Remote>, partitions: Int = 1): InMemoryLog<SourceMessage>
Link copied to clipboard
open override fun writeTo(dbConfig: DatabaseConfig.Builder)