h$)      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvw Safe-Inferred Safe-Inferred@  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 request1xyz{|}~ Safe-Inferred"! #"! # Safe-Inferred"'(+*),'(+*), Safe-InferredHcloudi9Decode Erlang terms within binary data into Haskell typesIcloudi5Encode Haskell types into Erlang terms in binary data0123456789:;<=>?@ABCDEFGHI56789:;<=>?@ABCDEFG12340HI4NoneRcloudia 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 callbackYcloudireturns 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]cloudisends asynchronous service requests to all subscribers of the matching service name pattern^cloudi6forwards a service request to a different service name_cloudiforwards an asynchronous service request to a different service name`cloudiforwards 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 responseecloudireturns the 0-based index of this process in the service instancefcloudireturns the current process count based on the service configurationgcloudireturns the count_process_dynamic maximum count based on the service configurationhcloudireturns the count_process_dynamic minimum count based on the service configurationicloudireturns the service name pattern prefix from the service configurationjcloudireturns the service initialization timeout from the service configurationkcloudireturns the default asynchronous service request send timeout from the service configurationlcloudireturns the default synchronous service request send timeout from the service configurationmcloudireturns the service termination timeout based on the service configurationncloudi2blocks to process incoming CloudI service requestsocloudi!shutdown the service successfullypcloudi#simplifies thread creation and join Concurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWaitqcloudi0wait for threads to join after being created by prcloudi*decode service request info key/value datascloudi+encode service response info key/value data2OPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrs2RSTUQPOVWXYZ[\]^_`abcdefghijklmnopqrs4      !"##$%&''()*+,-./0123456789:;<=>?@ABCDEFGHI+JKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrsS_`abcdefgtuvwxyz{|}~#cloudi-2.0.1-Bl9MCkR11gdJgSNIwnxKedForeign.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 timeoutSynctimeoutTerminatepollshutdown threadCreate threadsWaitinfoKeyValueParseinfoKeyValueNew$fExceptionException$fShowFatalError$fExceptionFatalError$fShowExceptiontimeout bufferSizestateterminateException socketHandle useHeaderinitializationComplete terminate callbacks bufferRecvbufferRecvSizepriorityDefault responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>