DistributedConnection class

Inheritance

• Object
• IEventHandler
• IDestructible
• NetworkConnection
• DistributedConnection

Mixed in types

• IStore

Constructors

DistributedConnection()

Create a new distributed connection.

Properties

autoReconnect ↔ bool

getter/setter pair

hashCode → int

The hash code for this object.

no setter, inherited

instance ↔ Instance?

IResource interface.

getter/setter pair, override

isConnected → bool

no setter, inherited

jitter ↔ int

getter/setter pair

keepAliveInterval ↔ int

getter/setter pair

keepAliveTime ↔ int

getter/setter pair

lastAction → DateTime

no setter, inherited

localEndPoint → IPEndPoint?

no setter, inherited

localUsername → String

Local username to authenticate ourselves.

no setter

properyModified → Stream<PropertyModificationInfo>

no setter, inherited

reconnectInterval ↔ int

getter/setter pair

remoteEndPoint → IPEndPoint?

no setter, inherited

remoteUsername → String

Peer's username.

no setter

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

server ↔ DistributedServer?

getter/setter pair

session → Session?

Working domain.

no setter

socket → ISocket?

no setter, inherited

status ↔ ConnectionStatus

getter/setter pair

template → TemplateDescriber

no setter, override

variables → KeyList<String, dynamic>

KeyList to store user variables related to this connection.

final

Methods

assign(ISocket socket) → void

Assign a socket to the connection.

override

call(String procedureCall, [List? parameters = null]) → AsyncReply

callArgs(String procedureCall, Map<UInt8, dynamic> parameters) → AsyncReply

close() → void

inherited

connect({AuthenticationMethod method = AuthenticationMethod.None, ISocket? socket, String? hostname, int? port, String? username, int? tokenIndex, DC? passwordOrToken, String? domain, bool useWebsocket = false, bool secureWebSocket = false}) → AsyncReply<bool>

connected() → void

inherited

create(IStore store, IResource parent, String className, List parameters, Map<String, dynamic> attributes, Map<String, dynamic> values) → AsyncReply<DistributedResource?>

Create a new resource.

dataReceived(NetworkBuffer data) → void

override

destroy() → void

inherited

detachResource(int instanceId) → void

disconnected() → void

override

emitArgs(String event, List arguments) → bool

inherited

emitProperty(PropertyModificationInfo event) → void

inherited

fetch(int id, List<int>? requestSequence) → AsyncReply<DistributedResource>

Fetch a resource from the other end

get(String path) → AsyncReply<IResource?>

Get a resource by its path.

override

getAttributes(IResource resource, [List<String>? attributes = null]) → AsyncReply<Map<String, dynamic>>

getChildren(IResource resource) → AsyncReply<List<IResource?>>

getLinkTemplates(String link) → AsyncReply<List<TypeTemplate>>

getParents(IResource resource) → AsyncReply<List<IResource?>>

getProperty(String name) → dynamic

override

getRecord(IResource resource, DateTime fromDate, DateTime toDate) → AsyncReply<KeyList<PropertyTemplate, List<PropertyValue>>?>

Get resource history.

override

getTemplate(Guid classId) → AsyncReply<TypeTemplate?>

Get the TypeTemplate for a given class Id.

getTemplateByClassName(String className) → AsyncReply<TypeTemplate?>

iipEventAttributesUpdated(int resourceId, DC attributes) → void

iipEventChildAdded(int resourceId, int childId) → void

iipEventChildRemoved(int resourceId, int childId) → void

iipEventEventOccurred(int resourceId, int index, TransmissionType dataType, DC data) → void

iipEventPropertyUpdated(int resourceId, int index, TransmissionType dataType, DC data) → void

iipEventRenamed(int resourceId, String name) → void

iipEventResourceDestroyed(int resourceId) → void

iipEventResourceReassigned(int resourceId, int newResourceId) → void

iipReply(int callbackId, [List? results = null]) → void

iipReplyInvoke(int callbackId, TransmissionType dataType, DC data) → void

iipReportChunk(int callbackId, TransmissionType dataType, DC data) → void

iipReportError(int callbackId, ErrorType errorType, int errorCode, String? errorMessage) → void

iipReportProgress(int callbackId, ProgressType type, int value, int max) → void

iipRequestAddChild(int callback, int parentId, int childId) → void

iipRequestAttachResource(int callback, int resourceId) → void

iipRequestClearAttributes(int callback, int resourceId, DC attributes, [bool all = false]) → void

iipRequestCreateResource(int callback, int storeId, int parentId, DC content) → void

iipRequestDeleteResource(int callback, int resourceId) → void

iipRequestDetachResource(int callback, int resourceId) → void

iipRequestGetAttributes(int callback, int resourceId, DC attributes, [bool all = false]) → void

iipRequestInquireResourceHistory(int callback, int resourceId, DateTime fromDate, DateTime toDate) → void

iipRequestInvokeFunction(int callback, int resourceId, int index, TransmissionType dataType, DC data) → void

iipRequestKeepAlive(int callbackId, DateTime peerTime, int interval) → void

iipRequestLinkTemplates(int callback, String resourceLink) → void

iipRequestListen(int callback, int resourceId, int index) → void

iipRequestProcedureCall(int callback, String procedureCall, TransmissionType transmissionType, DC content) → void

iipRequestQueryResources(int callback, String resourceLink) → void

iipRequestReattachResource(int callback, int resourceId, int resourceAge) → void

iipRequestRemoveChild(int callback, int parentId, int childId) → void

iipRequestRenameResource(int callback, int resourceId, String name) → void

iipRequestResourceAttribute(int callback, int resourceId) → void

iipRequestResourceChildren(int callback, int resourceId) → void

iipRequestResourceParents(int callback, int resourceId) → void

iipRequestSetProperty(int callback, int resourceId, int index, TransmissionType dataType, DC data) → void

iipRequestStaticCall(int callback, Guid classId, int index, TransmissionType transmissionType, DC content) → void

iipRequestTemplateFromClassId(int callback, Guid classId) → void

iipRequestTemplateFromClassName(int callback, String className) → void

iipRequestTemplateFromResourceId(int callback, int resourceId) → void

iipRequestUnlisten(int callback, int resourceId, int index) → void

iipRequestUpdateAttributes(int callback, int resourceId, DC attributes, [bool clearAttributes = false]) → void

init() → void

invoke(String name, List arguments) → dynamic

override

link(IResource resource) → String?

override

modify(IResource resource, String propertyName, dynamic value, int? age, DateTime? dateTime) → bool

override

networkClose(ISocket sender) → void

inherited

networkConnect(ISocket sender) → void

inherited

networkReceive(ISocket sender, NetworkBuffer buffer) → void

inherited

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

off(String event, Function? callback) → void

inherited

on(String event, Function callback) → void

inherited

processPacket(DC msg, int offset, int ends, NetworkBuffer data, int chunkId) → int

put(IResource resource) → AsyncReply<bool>

Resource interface

override

query(String path) → AsyncReply<List<IResource?>>

Query resources at specific link.

reconnect() → Future<bool>

record(IResource resource, String propertyName, dynamic value, int? age, DateTime? dateTime) → bool

override

register(String event) → void

inherited

remove(IResource resource) → bool

Distributed server responsible for this connection, usually for incoming connections.

override

removeAttributes(IResource resource, [List<String>? attributes = null]) → AsyncReply<bool>

send(DC data) → void

Send raw data through the connection.

override

sendChunk(int callbackId, dynamic chunk) → void

sendEvent(int evt) → SendList

sendInvoke(int instanceId, int index, Map<UInt8, dynamic> parameters) → AsyncReply

sendListenRequest(int instanceId, int index) → AsyncReply

sendProgress(int callbackId, int value, int max) → void

sendRequest(int action) → SendList

Send IIP request.

sendString(String data) → void

inherited

sendUnlistenRequest(int instanceId, int index) → AsyncReply

setAttributes(IResource resource, Map<String, dynamic> attributes, [bool clearAttributes = false]) → AsyncReply<bool>

setProperty(String name, dynamic value) → dynamic

override

staticCall(Guid classId, int index, Map<UInt8, dynamic> parameters) → AsyncReply

toString() → String

A string representation of this object.

inherited

trigger(ResourceTrigger trigger) → AsyncReply<bool>

override

unassign() → ISocket?

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited