Types
RpcSocketServer = ref object of RpcServer
- Source Edit
Procs
proc addStreamServer(server: RpcSocketServer; address: string) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Create new server and assign it to addresses addresses. Source Edit
proc addStreamServer(server: RpcSocketServer; address: string; port: Port) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Source Edit
proc addStreamServer(server: RpcSocketServer; address: TransportAddress) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Source Edit
proc addStreamServers(server: RpcSocketServer; addresses: openArray[string]) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Source Edit
proc addStreamServers(server: RpcSocketServer; addresses: openArray[TransportAddress]) {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Source Edit
proc close(server: RpcSocketServer) {....raises: [], gcsafe, tags: [], forbids: [].}
- Cleanup resources of RPC server. Source Edit
proc closeWait(server: RpcSocketServer): InternalRaisesFuture[void, void] {. ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Cleanup resources of RPC server. Source Edit
proc localAddress(server: RpcSocketServer): seq[TransportAddress] {....raises: [], gcsafe, tags: [], forbids: [].}
- Source Edit
proc newRpcSocketServer(address: string; port: Port = Port(8545); framing = Framing.newLine()): RpcSocketServer {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Source Edit
proc newRpcSocketServer(addresses: openArray[string]; framing = Framing.newLine()): RpcSocketServer {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Create new server and assign it to addresses addresses. Source Edit
proc newRpcSocketServer(addresses: openArray[TransportAddress]; framing = Framing.newLine()): RpcSocketServer {. ...raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Create new server and assign it to addresses addresses. Source Edit
proc newRpcSocketServer(maxMessageSize = defaultMaxMessageSize; framing = Framing.newLine()): RpcSocketServer {. ...raises: [], gcsafe, tags: [], forbids: [].}
- Source Edit
proc newRpcSocketServer(processClientHook: StreamCallback2; framing = Framing.newLine()): RpcSocketServer {. ...raises: [], gcsafe, tags: [], forbids: [].}
- Create new server with custom processClientHook. Source Edit
proc start(server: RpcSocketServer) {....raises: [JsonRpcError], raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Start the RPC server. Source Edit
proc stop(server: RpcSocketServer) {....raises: [], gcsafe, tags: [RootEffect, WriteIOEffect], forbids: [].}
- Stop the RPC server. Source Edit
Exports
-
JsonRpcError, RpcAddressUnresolvableError, RpcPostError, FailedHttpResponse, ApplicationError, ErrorResponse, InvalidResponse, RequestDecodeError, RpcTransportError, RpcBindError, InvalidRequest, automaticBuiltinSerialization, METHOD_NOT_FOUND, call, json_rpc_workaround_24844_future_string, hash, flavorSkipNullFields, ResponseRx, readValue, RpcRouter, ==, writeRequest, readValue, RpcServer, mimeType, JrpcSys, writeValue, call, processsSingleResponse, new, rpc, flavorRequiresAllFields, automaticPrimitivesSerialization, ResponseError, RpcBatchResponse, createRpcSigsFromNim, hash, call, typeAutoSerialize, flavorEnumRep, executeMethod, RequestTx, prepareBatch, withPendingFut, executeMethod, JSON_PARSE_ERROR, ResponseRx2, decode, RpcBatchItem, createSingleRpcSig, readValue, INTERNAL_ERROR, flavorOmitsOptionalFields, readValue, flavorOmitsOptionalFields, readValue, automaticSerialization, wrapError, typeClassOrMemberAutoSerialize, GetJsonRpcRequestHeaders, route, automaticBuiltinSerialization, RequestParamsTx, Reader, send, Writer, RequestParamKind, RequestId, RpcClient, ResponseKind, createRpcSigsFromNim, defaultMaxMessageSize, ParamDescRx, RequestRx2, flavorAllowsUnknownFields, JrpcConv, writeValue, ResponseFut, typeAutoSerialize, executeMethod, Writer, writeValue, hasMethod, createRpcSigsFromString, close, RequestParamsRx, RpcRouterCallback, rpc, flavorRequiresAllFields, notify, decode, readValue, PreferredOutputType, $, createSingleRpcSig, mimeType, flavorEnumRep, clear, readValue, callBatch, clearPending, route, ParamDescNamed, processMessage, writeValue, flavorSkipNullFields, ResponseTx, hasMethod, writeNotification, readValue, PreferredOutputType, register, readValue, RpcBatchCallRef, unRegisterAll, JsonRPC2, flavorUsesAutomaticObjectSerialization, flavorEnumRep, shouldWriteObjectField, writeValue, flavorUsesAutomaticObjectSerialization, Reader, createRpcSigsFromString, flavorEnumRep, createRpcSigs, callOnProcessMessage, readValue, rpc, automaticSerialization, writeValue, ReqRespHeader, executeMethod, automaticPrimitivesSerialization, meth, notify, route, INVALID_PARAMS, INVALID_REQUEST, RequestRx, createRpcSigs, toTx, RequestIdKind, typeClassOrMemberAutoSerialize, rpc, RpcProc, ReBatchKind, register, readValue, writeValue, withWriter, route, flavorAllowsUnknownFields, RequestBatchRx, rpc, init, isFieldExpected, SERVER_ERROR, JSON_ENCODE_ERROR, RpcConnection, route, rpc, Framing, lengthHeaderBE32, httpHeader