MarsClient

Undocumented in source.

Constructors

this
this(string id, DatabaseService databaseService)
Undocumented in source.

Members

Functions

authoriseUser
AuthoriseError authoriseUser(string username, string pgpassword)

* Called by the authentication protocol. * * Returns: false if PostgreSQL is offline or user in not authorised, or true.

authorised
bool authorised()
Undocumented in source. Be warned that the author may not have intended to support it.
callServerMethod
string callServerMethod(string method, Json parameters)
Undocumented in source. Be warned that the author may not have intended to support it.
connected
void connected()
Undocumented in source.
discardAuthorisation
void discardAuthorisation()
Undocumented in source. Be warned that the author may not have intended to support it.
disconnected
void disconnected()
Undocumented in source.
id
string id()
Undocumented in source. Be warned that the author may not have intended to support it.
isConnected
bool isConnected()
Undocumented in source. Be warned that the author may not have intended to support it.
pingWebClient
bool pingWebClient()
Undocumented in source. Be warned that the author may not have intended to support it.
receiveReply
auto receiveReply()
Undocumented in source.
reconnections
SysTime[] reconnections()
Undocumented in source. Be warned that the author may not have intended to support it.
sendBroadcast
void sendBroadcast(M msg)

* Push a forward-only message to the client, a reply is not expected.

sendRequest
void sendRequest(M msg)

* Push a new message, from the server to the client. Used by the server to inform clients about events.

socketWired
bool socketWired()

* Returns true if the 'server to client' socket was opened and wired to us.

vueDeleteRecord
immutable(ubyte)[] vueDeleteRecord(int tableIndex, immutable(ubyte)[] record, DeleteError err)
Undocumented in source. Be warned that the author may not have intended to support it.
vueInsertRecord
immutable(ubyte)[][2] vueInsertRecord(int statementIndex, immutable(ubyte)[] record, InsertError err)
Undocumented in source. Be warned that the author may not have intended to support it.
vueSubscribe
auto vueSubscribe(string select, Variant[string] parameters, RequestState state)
Undocumented in source. Be warned that the author may not have intended to support it.
vueUpdateRecord
void vueUpdateRecord(ulong tableIndex, immutable(ubyte)[] keys, immutable(ubyte)[] record, RequestState state)
Undocumented in source. Be warned that the author may not have intended to support it.
wireSocket
void wireSocket(MarsProxyStoC!ResilientWebSocket socket, Task task)

* The Helo protocol will wire the active socket here, and will set this to null when disconnecting.

Variables

db
Database db;
Undocumented in source.
serverSideMethods
typeof(MarsServer.serverSideMethods) serverSideMethods;
Undocumented in source.
stocTask
Task stocTask;
Undocumented in source.

Meta