!;3jt      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrsSafe&Safe|  None cloudian instance of the CloudI APIcloudi-service request callback function return typecloudi&a function to handle a service requestcloudi8the Erlang pid that is the source of the service requestcloudi(provided when handling a service request0tuvwxyz{|}~Safe "! #"! #Safe 1'(+*),'(+*),SafeHcloudi9Decode Erlang terms within binary data into Haskell typesIcloudi5Encode Haskell types into Erlang terms in binary data0123456789:;<=>?@ABCDEFGHI56789:;<=>?@ABCDEFG12340HI4None1Qcloudi]a null trans_id is used to check for a timeout or to get the oldest response with recv_asyncUcloudi%creates an instance of the CloudI APIVcloudi7returns the thread count from the service configurationWcloudi4subscribes to a service name pattern with a callbackXcloudiEreturns the number of subscriptions for a single service name patternYcloudi-unsubscribes from a service name pattern onceZcloudi%sends an asynchronous service request[cloudi#sends a synchronous service request\cloudi\sends asynchronous service requests to all subscribers of the matching service name pattern]cloudi6forwards a service request to a different service name^cloudiDforwards an asynchronous service request to a different service name_cloudiBforwards a synchronous service request to a different service name`cloudi(provides a response to a service requestacloudi6provides a response to an asynchronous service requestbcloudi4provides a response to a synchronous service requestccloudi:blocks to receive an asynchronous service request responsedcloudiAreturns the 0-based index of this process in the service instanceecloudiDreturns the current process count based on the service configurationfcloudiSreturns the count_process_dynamic maximum count based on the service configurationgcloudiSreturns the count_process_dynamic minimum count based on the service configurationhcloudiFreturns the service name pattern prefix from the service configurationicloudiJreturns the service initialization timeout from the service configurationjcloudi]returns the default asynchronous service request send timeout from the service configurationkcloudi\returns the default synchronous service request send timeout from the service configurationlcloudiKreturns the service termination timeout based on the service configurationmcloudi2blocks to process incoming CloudI service requestsncloudi!shutdown the service successfullyocloudi#simplifies thread creation and join rConcurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWaitpcloudi0wait for threads to join after being created by oqcloudi+parses "text_pairs" in service request info0OPQRSTUVWXYZ[\]^_`abcdefghijklmnopq0QRSTPOUVWXYZ[\]^_`abcdefghijklmnopq      !"##$%&''()*+,-./0123456789:;<=>?@ABCDEFGHI+JKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnoR^_`abcdefpqrstuvwxyz{|}~#cloudi-1.8.0-JXxnvBkNJDE1X6aJGl26vKForeign.Erlang.FunctionForeign.Erlang.PidForeign.CloudIForeign.Erlang.PortForeign.Erlang.ReferenceForeign.ErlangForeign.CloudI.InstanceFunctiontagvalue $fOrdFunction $fEqFunction$fShowFunctionPidnodeTagnodeidserialcreation$fOrdPid$fEqPid $fShowPidTResponse ResponseInfoForwardForward_Null NullErrorCallbackSource RequestTypeASYNCSYNCPort $fOrdPort$fEqPort $fShowPort Reference$fOrdReference $fEqReference$fShowReferenceResultError InputError OutputError ParseError OtpErlangTermOtpErlangIntegerOtpErlangIntegerBigOtpErlangFloat OtpErlangAtomOtpErlangAtomUTF8OtpErlangAtomCacheRefOtpErlangAtomBoolOtpErlangStringOtpErlangBinaryOtpErlangBinaryBits OtpErlangListOtpErlangListImproperOtpErlangTuple OtpErlangMap OtpErlangPid OtpErlangPortOtpErlangReferenceOtpErlangFunction binaryToTerm termToBinary$fOrdOtpErlangTerm$fEqOtpErlangTerm$fShowOtpErlangTerm $fEqError $fShowError Exception transIdNullinvalidInputErrormessageDecodingErrorterminateErrorapi threadCount subscribesubscribeCount unsubscribe sendAsyncsendSync mcastAsyncforward_ forwardAsync forwardSyncreturn_ returnAsync returnSync recvAsync processIndex processCountprocessCountMaxprocessCountMinprefixtimeoutInitialize timeoutAsync timeoutSynctimeoutTerminatepollshutdown threadCreate threadsWaitinfoKeyValueParse$fExceptionException$fShowExceptiontimeout bufferSizestate socketHandle useHeaderinitializationComplete terminate callbacks bufferRecvbufferRecvSizepriorityDefault responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>