Respond

Worker returns this as query result

struct Respond {

this(QueryException e, IConnection conn);

bool collect(InputRange!(shared IPGresult) results, IConnection conn, bool oneRowConstraint, size_t queryId);

bool onRowConstaintFailed;

size_t constraintFailQueryId;

string exception;

immutable(Bson)[] result;

immutable(string)[] msgs;

}

Constructors

this this(QueryException e, IConnection conn): The constructor is used when pool detects problem at its own level. collect method handles other cases.

Members

Functions

collect bool collect(InputRange!(shared IPGresult) results, IConnection conn, bool oneRowConstraint, size_t queryId): Transforms raw result from data base into BSON format. Also handles errors that was raised in the connection.

Variables

constraintFailQueryId size_t constraintFailQueryId;: Undocumented in source.
exception string exception;: Error stored in string
failed bool failed;: Flag to distinct error case from normal respond
msgs immutable(string)[] msgs;: Additional messages
onRowConstaintFailed bool onRowConstaintFailed;: Undocumented in source.
result immutable(Bson)[] result;: Collected result

Meta

Source

See Implementation

pgator db async respond structs

Respond