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, hash, ResponseRx, RpcRouter, automaticBuiltinSerialization, RpcParseError, writeRequest, readValue, RpcServer, mimeType, JrpcSys, flavorRequiresAllFields, writeValue, call, flavorSkipNullFields, RequestDecodeError, flavorUsesAutomaticObjectSerialization, ApplicationError, processsSingleResponse, rpc, automaticPrimitivesSerialization, ResponseError, RpcBatchResponse, createRpcSigsFromNim, RpcOrigin, hash, call, typeAutoSerialize, executeMethod, $, RequestTx, prepareBatch, ParamsMismatchError, 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, withPendingFut, defaultMaxMessageSize, ParamDescRx, RequestRx2, automaticSerialization, RpcTransportError, JrpcConv, writeValue, ResponseFut, executeMethod, flavorEnumRep, typeClassOrMemberAutoSerialize, close, Writer, writeValue, hasMethod, RpcInvalidRequestError, createRpcSigsFromString, RequestParamsRx, JsonRpcError, typeClassOrMemberAutoSerialize, RpcInternalError, send, 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, 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