json_rpc/servers/socketserver

Source   Edit  

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

ParamsMismatchError, RpcResponseError, RpcInvalidRequestError, RequestDecodeError, ResultDecodeError, new, RpcMethodNotFoundError, RpcInternalError, FailedHttpResponse, RpcServerError, ApplicationError, JsonRpcError, RpcParseError, RpcApplicationError, RpcOrigin, RpcTransportError, InvalidRequest, RpcAddressUnresolvableError, RpcPostError, ErrorResponse, InvalidResponse, RpcInvalidParamsError, RpcBindError, ResponseBatchRx, InvalidResponse, automaticBuiltinSerialization, new, METHOD_NOT_FOUND, call, json_rpc_workaround_24844_future_string, hash, ResponseRx, RpcRouter, automaticBuiltinSerialization, RpcParseError, writeRequest, readValue, RpcServer, mimeType, JrpcSys, flavorRequiresAllFields, writeValue, call, flavorSkipNullFields, RequestDecodeError, ApplicationError, processsSingleResponse, rpc, automaticPrimitivesSerialization, ResponseError, RpcBatchResponse, createRpcSigsFromNim, RpcOrigin, hash, call, typeAutoSerialize, executeMethod, RequestTx, prepareBatch, ParamsMismatchError, withPendingFut, RpcInvalidParamsError, executeMethod, JSON_PARSE_ERROR, BidiMessageRequestError, ResponseRx2, RpcBatchItem, createSingleRpcSig, meth, readValue, INTERNAL_ERROR, flavorOmitsOptionalFields, toJsonError, readValue, flavorOmitsOptionalFields, readValue, automaticSerialization, INVALID_REQUEST, parseResponse, automaticPrimitivesSerialization, wrapError, GetJsonRpcRequestHeaders, FailedHttpResponse, RpcPostError, route, RpcServerError, RequestParamsTx, Reader, send, Writer, readValue, RequestParamKind, RequestId, RpcClient, BidiMessage, ResponseKind, createRpcSigsFromNim, defaultMaxMessageSize, ParamDescRx, RequestRx2, automaticSerialization, RpcTransportError, JrpcConv, writeValue, ResponseFut, executeMethod, flavorEnumRep, typeClassOrMemberAutoSerialize, close, Writer, writeValue, hasMethod, RpcInvalidRequestError, createRpcSigsFromString, RequestParamsRx, JsonRpcError, typeClassOrMemberAutoSerialize, RpcInternalError, RpcRouterCallback, flavorSkipNullFields, rpc, flavorRequiresAllFields, notify, decode, readValue, PreferredOutputType, $, createSingleRpcSig, mimeType, flavorEnumRep, clear, RpcMethodNotFoundError, readValue, clearPending, route, ParamDescNamed, readValue, processMessage, writeValue, ResponseTx, hasMethod, ResultDecodeError, writeNotification, readValue, PreferredOutputType, InvalidRequestSysError, register, readValue, RpcBatchCallRef, unRegisterAll, JsonRPC2, flavorUsesAutomaticObjectSerialization, flavorUsesAutomaticObjectSerialization, shouldWriteObjectField, writeValue, Reader, createRpcSigsFromString, createRpcSigs, new, callOnProcessMessage, readValue, rpc, BidiMessageResponseError, RpcApplicationError, writeValue, ReqRespHeader, RpcResponseError, executeMethod, meth, notify, decode, readValue, route, flavorAllowsUnknownFields, ==, typeAutoSerialize, INVALID_PARAMS, flavorEnumRep, RequestRx, createRpcSigs, toTx, RequestIdKind, rpc, RpcAddressUnresolvableError, RpcProc, ReBatchKind, BidiMessageKind, register, readValue, flavorEnumRep, writeValue, InvalidRequest, init, ErrorResponse, withWriter, route, flavorAllowsUnknownFields, RequestBatchRx, rpc, RpcBindError, isFieldExpected, SERVER_ERROR, JSON_ENCODE_ERROR, RpcConnection, route, rpc, httpHeader, FramingRecvMsg, lengthHeaderBE32, init, FramingSendMsg, Framing, newLine