rd-framework/com.jetbrains.rd.framework

Package-level declarations

Types

abstract class AbstractBuffer

AbstractPolymorphic

class AbstractPolymorphic<T>(val declaration: IAbstractDeclaration<T>) : ISerializer<T>

AggregatedMarshallersProvider

class AggregatedMarshallersProvider(val providers: Sequence<MarshallersProvider>) : MarshallersProvider

DelegatedMarshaller

open class DelegatedMarshaller<TFrom : Any, TTo : Any>(marshaller: IMarshaller<TFrom>, type: KClass<*>, to: (TFrom) -> TTo, from: (TTo) -> TFrom) : UniversalMarshaller<TTo>

ExtCreationInfo

data class ExtCreationInfo(val rName: RName, val rdId: RdId?, val hash: Long, val ext: RdExtBase?)

ExtCreationInfoEx

data class ExtCreationInfoEx(val info: ExtCreationInfo, val isLocal: Boolean)

FrameworkMarshallers

object FrameworkMarshallers

IAbstractDeclaration

interface IAbstractDeclaration<T>

class ~~Identities~~(val dynamicKind: IdKind) : IIdentities

Legacy implementation of IIdentities that mixes parent ID into dynamic IDs. This approach can cause ID collisions. Use SequentialIdentities instead.

enum IdKind : Enum<IdKind>

interface IIdentities

Generates unique identifiers for objects in an object graph.

interface IInternRoot<TBase : Any> : IRdReactive

Interns values sent over protocol

interface IMarshaller<T : Any> : ISerializer<T>

A serializer that can participate in polymorphic serialization.

interface IProtocol : IRdDynamic

A root node in an object graph which can be synchronized with its remote copy over a network or a similar connection.

interface IRdCall<in TReq, out TRes>

Represents an API provided by the remote process which can be invoked through the protocol.

interface IRdDynamic

A node in a graph of entities that can be synchronized with its remote copy over a network or a similar connection.

interface IRdEndpoint<TReq, TRes>

Counterpart of IRdCall.

interface IRdTask<out T>

Represents a task that can be asynchronously executed.

interface ISerializer<T>

Supports serializing and deserializing values of a specific type.

interface ISerializers

A registry of known serializers.

IUnknownInstance

interface IUnknownInstance

interface IWire

Sends and receives serialized object data over a network or a similar connection.

IWireWithDelayedDelivery

interface IWireWithDelayedDelivery : IWire

LazyCompanionMarshaller

class LazyCompanionMarshaller<T : Any>(val id: RdId, val classLoader: ClassLoader, val fqn: String) : IMarshaller<T>

MarhallersProviderFromResourcesBase

abstract class MarhallersProviderFromResourcesBase(val resourceName: String) : MarshallersProvider

MarshallersProvider

interface MarshallersProvider

class MessageBroker(queueMessages: Boolean = false) : IPrintable

object Polymorphic : ISerializer<Any?>

class Protocol : IRdDynamic, IProtocol

abstract class RdContext<T : Any>(val key: String, val heavy: Boolean, val serializer: IMarshaller<T>)

Describes a context and provides access to value associated with this context. The associated value is thread-local and synchronized between send/advise pairs on IWire. The associated value will be the same in handler method in IWire.advise as it was in IWire.send. Instances of this class with the same key will share the associated value. Best practice is to declare contexts in toplevel entities in protocol model using Toplevel.threadLocalContext. Manual declaration is also possible.

RdEntitiesRegistrar

class RdEntitiesRegistrar

value class RdId(val hash: Long)

An identifier of the object that participates in the object graph.

object RdIdUtil

Utility object for RdId hash computation operations. This is internal - for ID generation, use IIdentities.mix and IIdentities.next.

class RdMessage(val id: RdId, val istream: AbstractBuffer, val tooBigMessage: String?)

sealed class RdTaskResult<out T>

The result of asynchronously executing a task.

ReflectionMarshaller

class ReflectionMarshaller<T : Any>(val _type: KClass<T>) : IMarshaller<T>

RNameMarshaller

object RNameMarshaller

SequentialIdentities

class SequentialIdentities(val dynamicKind: IdKind) : IIdentities

Recommended implementation of IIdentities that avoids ID collisions.

SerializationCtx

class SerializationCtx(val serializers: ISerializers, val identities: IIdentities, val internRoots: Map<String, IInternRoot<Any>> = emptyMap())

class Serializers(provider: MarshallersProvider) : ISerializers

class SocketWire

ThreadLocalRdContext

abstract class ThreadLocalRdContext<T : Any>(key: String, heavy: Boolean, serializer: IMarshaller<T>) : RdContext<T>

Describes an RdContext which uses ThreadLocal as internal storage for values

UniversalMarshaller

open class UniversalMarshaller<T : Any>(val _type: KClass<*>, val reader: (SerializationCtx, AbstractBuffer) -> T, val writer: (SerializationCtx, AbstractBuffer, T) -> Unit, val predefinedId: Int? = null) : IMarshaller<T>

class UnsafeBuffer : AbstractBuffer, Closeable

Properties

val IMarshaller<*>.fqn: String

val <T> IRdTask<T>.isCanceled: Boolean

val <T> IRdTask<T>.isFaulted: Boolean

val <T> IRdTask<T>.isSucceeded: Boolean

protocolOrThrow

val IRdDynamic.protocolOrThrow: IProtocol

val IWire.serverPort: Int

Functions

inline fun <T> ISerializer<T>.array(): ISerializer<Array<T>>

createAbstractBuffer

fun createAbstractBuffer(): AbstractBuffer

fun createAbstractBuffer(bytes: ByteArray): AbstractBuffer

createBackgroundScheduler

fun createBackgroundScheduler(lifetime: Lifetime, name: String): IScheduler

getPlatformIndependentHash

fun Int.~~getPlatformIndependentHash~~(initial: Long = 19): Long

fun Long.~~getPlatformIndependentHash~~(initial: Long = 19): Long

fun String?.~~getPlatformIndependentHash~~(initial: Long = 19): Long

fun <T : Any> ISerializer<T>.interned(internKey: String): ISerializer<T>

fun <T> ISerializer<T>.list(): ISerializer<List<T>>

fun <T : Any> ISerializer<T>.nullable(): ISerializer<T?>

inline fun <T> AbstractBuffer.readArray(inner: () -> T): Array<T>

fun AbstractBuffer.readBool(): Boolean

fun AbstractBuffer.readDateTime(): Date

inline fun <T : Enum<T>> AbstractBuffer.readEnum(): T

inline fun <T : Enum<T>> AbstractBuffer.readEnumSet(): EnumSet<T>

fun AbstractBuffer.readGuid(): UUID

inline fun <T : Any> SerializationCtx.readInterned(stream: AbstractBuffer, internKey: String, readValueDelegate: (SerializationCtx, AbstractBuffer) -> T): T

inline fun <T> AbstractBuffer.readList(inner: () -> T): List<T>

inline fun <T : Any> AbstractBuffer.readNullable(inner: () -> T): T?

fun AbstractBuffer.readRdId(): RdId

readSecureString

fun AbstractBuffer.readSecureString(): RdSecureString

fun AbstractBuffer.readTimeSpan(): Duration

fun AbstractBuffer.readUri(): URI

fun AbstractBuffer.readUuid(): UUID

fun AbstractBuffer.readVoid()

inline fun <T> IRdTask<T>.wait(timeoutMs: Long, pump: () -> Unit): Boolean

withInternRootsHere

fun SerializationCtx.withInternRootsHere(owner: RdBindableBase, vararg newRoots: String): SerializationCtx

fun <T> AbstractBuffer.writeArray(value: Array<T>, elemWriter: (T) -> Unit)

fun AbstractBuffer.writeBool(value: Boolean)

fun AbstractBuffer.writeDateTime(value: Date)

inline fun <T : Enum<T>> AbstractBuffer.writeEnum(value: Enum<T>)

inline fun <T : Enum<T>> AbstractBuffer.writeEnumSet(set: EnumSet<T>)

fun AbstractBuffer.writeGuid(value: UUID)

inline fun <T : Any> SerializationCtx.writeInterned(stream: AbstractBuffer, value: T, internKey: String, writeValueDelegate: (SerializationCtx, AbstractBuffer, T) -> Unit)

inline fun <T> AbstractBuffer.writeList(value: List<T>, elemWriter: (T) -> Unit)

fun <T : Any> AbstractBuffer.writeNullable(value: T?, elemWriter: (T) -> Unit)

fun AbstractBuffer.writeRdId(value: RdId)

writeSecureString

fun AbstractBuffer.writeSecureString(string: RdSecureString)

fun AbstractBuffer.writeTimeSpan(value: Duration)

fun AbstractBuffer.writeUri(value: URI)

fun AbstractBuffer.writeUuid(value: UUID)

fun AbstractBuffer.writeVoid(void: Unit)