Ξυ³h$συ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrst Safe-Inferred Safe-Inferred4  Nonepcloudian 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 request1uvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜ 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†Qcloudiέ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 callbackXcloudiΕreturns 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^cloudiΔforwards an asynchronous service request to a different service name_cloudiΒforwards 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 responsedcloudiΑreturns the 0-based index of this process in the service instanceecloudiΔreturns the current process count based on the service configurationfcloudiΣreturns the count_process_dynamic maximum count based on the service configurationgcloudiΣreturns the count_process_dynamic minimum count based on the service configurationhcloudiΖreturns the service name pattern prefix from the service configurationicloudiΚreturns 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 configurationlcloudiΛreturns the service termination timeout based on the service configurationmcloudi2blocks to process incoming CloudI service requestsncloudi!shutdown the service successfullyocloudi#simplifies thread creation and join ςConcurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWaitpcloudi0wait for threads to join after being created by oqcloudi*decode service request info key/value datarcloudi+encode service response info key/value data1OPQRSTUVWXYZ[\]^_`abcdefghijklmnopqr1QRSTPOUVWXYZ[\]^_`abcdefghijklmnopqrš4›      !"##$%&''()*+,-./0123456789:;<=>?@ABCDEFGHI+JKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopR^_`abcdefqrstuvwxyz{|}~€‚ƒ„…†‡ˆˆ‰#cloudi-2.0.0-CUEc4cToABl6UdkLePuSlhForeign.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 Exception transIdNullinvalidInputErrormessageDecodingErrorterminateErrorapi threadCount subscribesubscribeCount unsubscribe sendAsyncsendSync mcastAsyncforward_ forwardAsync forwardSyncreturn_ returnAsync returnSync recvAsync processIndex processCountprocessCountMaxprocessCountMinprefixtimeoutInitialize timeoutAsync timeoutSynctimeoutTerminatepollshutdown threadCreate threadsWaitinfoKeyValueParseinfoKeyValueNew$fExceptionException$fShowExceptiontimeout bufferSizestateterminateException socketHandle useHeaderinitializationComplete terminate callbacks bufferRecvbufferRecvSizepriorityDefault responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>