Îõģh$”jų      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwx Safe-Inferred Safe-InferredD  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 request1yz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œ Safe-Inferredõ"! #"! # Safe-Inferred''(+*),'(+*), Safe-InferredáHcloudi9Decode Erlang terms within binary data into Haskell typesIcloudi5Encode Haskell types into Erlang terms in binary data0123456789:;<=>?@ABCDEFGHI56789:;<=>?@ABCDEFG12340HI4Noneų RcloudiÝa null trans_id is used to check for a timeout or to get the oldest response with recv_asyncVcloudi%creates an instance of the CloudI APIWcloudi7returns the thread count from the service configurationXcloudi4subscribes to a service name pattern with a callbackYcloudiÅreturns the number of subscriptions for a single service name patternZcloudi-unsubscribes from a service name pattern once[cloudi%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_cloudiÄforwards an asynchronous service request to a different service name`cloudiÂforwards a synchronous service request to a different service nameacloudi(provides a response to a service requestbcloudi6provides a response to an asynchronous service requestccloudi4provides a response to a synchronous service requestdcloudi:blocks to receive an asynchronous service request responseecloudiÁreturns the 0-based index of this process in the service instancefcloudiÄreturns the current process count based on the service configurationgcloudiÓreturns the count_process_dynamic maximum count based on the service configurationhcloudiÓreturns the count_process_dynamic minimum count based on the service configurationicloudiÆreturns the service name pattern prefix from the service configurationjcloudiĘreturns the service initialization timeout from the service configurationkcloudiÝreturns the default asynchronous service request send timeout from the service configurationlcloudiÜreturns the default synchronous service request send timeout from the service configurationmcloudiËreturns the service termination timeout based on the service configurationncloudiŅreturns the default service request send priority from the service configurationocloudi2blocks to process incoming CloudI service requestspcloudi!shutdown the service successfullyqcloudi#simplifies thread creation and join ōConcurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWaitrcloudi0wait for threads to join after being created by qscloudi*decode service request info key/value datatcloudi+encode service response info key/value data3OPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrst3RSTUQPOVWXYZ[\]^_`abcdefghijklmnopqrstž4Ÿ      !"##$%&''()*+,-./0123456789:;<=>?@ABCDEFGHI+JKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstS_`abcdefghuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹‹Œ#cloudi-2.0.4-5bgUIbR2FQbBY8V5PzewzQForeign.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 $fEqError $fShowError$fOrdOtpErlangTerm$fEqOtpErlangTerm$fShowOtpErlangTerm FatalError Exception transIdNullinvalidInputErrormessageDecodingErrorterminateErrorapi threadCount subscribesubscribeCount unsubscribe sendAsyncsendSync mcastAsyncforward_ forwardAsync forwardSyncreturn_ returnAsync returnSync recvAsync processIndex processCountprocessCountMaxprocessCountMinprefixtimeoutInitialize timeoutAsync timeoutSynctimeoutTerminatepriorityDefaultpollshutdown threadCreate threadsWaitinfoKeyValueParseinfoKeyValueNew$fExceptionException$fShowFatalError$fExceptionFatalError$fShowExceptiontimeout bufferSizestateterminateException socketHandle useHeaderinitializationComplete terminate callbacks bufferRecvbufferRecvSize responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>