Îõŗh)šjū      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}2.0.7 Safe-Inferred1 Safe-Inferred_   Safe-Inferred¤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 request2~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ Ąĸ Safe-Inferred "! #"! # Safe-InferredR'(+*),'(+*), Safe-Inferred Hcloudi9Decode Erlang terms within binary data into Haskell typesIcloudi5Encode Haskell types into Erlang terms in binary data56789:;<=>?@ABCDEFG12340HI56789:;<=>?@ABCDEFG12340HIŖ4 Safe-Inferredī%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 0-based index of this process in the service instancegcloudiÄreturns the current process count based on the service configurationhcloudiĶreturns the count_process_dynamic maximum count based on the service configurationicloudiĶreturns the count_process_dynamic maximum count based on the service configurationjcloudiĶreturns the count_process_dynamic minimum count based on the service configurationkcloudiĶreturns the count_process_dynamic minimum count based on the service configurationlcloudiÆreturns the service name pattern prefix from the service configurationmcloudiĘreturns the service initialization timeout from the service configurationncloudiĘreturns the service initialization timeout from the service configurationocloudiŨreturns the default asynchronous service request send timeout from the service configurationpcloudiÜreturns the default synchronous service request send timeout from the service configurationqcloudiËreturns the service termination timeout based on the service configurationrcloudiËreturns the service termination timeout based on the service configurationscloudiŅreturns the default service request send priority from the service configurationtcloudi2blocks to process incoming CloudI service requestsucloudi!shutdown the service successfullyvcloudi#simplifies thread creation and join ōConcurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWaitwcloudi0wait for threads to join after being created by vxcloudi*decode service request info key/value dataycloudi+encode service response info key/value data8RSTUQPOVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy8RSTUQPOVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy¤4Ĩ       !"#$$%&'(()*+,-./0123456789:;<=>?@ABCDEFGHIJ,KLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyzT`bceghjkln{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’’“cloudi-2.0.7-inplaceForeign.Erlang.FunctionForeign.Erlang.PidForeign.CloudIForeign.Erlang.PortForeign.Erlang.ReferenceForeign.ErlangcloudiForeign.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 processIndex_ processCountprocessCountMaxprocessCountMax_processCountMinprocessCountMin_prefixtimeoutInitializetimeoutInitialize_ timeoutAsync timeoutSynctimeoutTerminatetimeoutTerminate_priorityDefaultpollshutdown threadCreate threadsWaitinfoKeyValueParseinfoKeyValueNew$fExceptionException$fShowFatalError$fExceptionFatalError$fShowExceptiontimeout bufferSizestateterminateException socketHandle useHeaderinitializationCompletefatalExceptions terminate callbacks bufferRecvbufferRecvSize responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>