h$Q      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|} Safe-Inferred* Safe-InferredX  Nonecloudian 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-InferredB'(+*),'(+*), Safe-InferredHcloudi9Decode Erlang terms within binary data into Haskell typesIcloudi5Encode Haskell types into Erlang terms in binary data0123456789:;<=>?@ABCDEFGHI56789:;<=>?@ABCDEFG12340HI4None%Rcloudia 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 0-based index of this process in the service instancegcloudireturns the current process count based on the service configurationhcloudireturns the count_process_dynamic maximum count based on the service configurationicloudireturns the count_process_dynamic maximum count based on the service configurationjcloudireturns the count_process_dynamic minimum count based on the service configurationkcloudireturns the count_process_dynamic minimum count based on the service configurationlcloudireturns the service name pattern prefix from the service configurationmcloudireturns the service initialization timeout from the service configurationncloudireturns the service initialization timeout from the service configurationocloudireturns the default asynchronous service request send timeout from the service configurationpcloudireturns the default synchronous service request send timeout from the service configurationqcloudireturns the service termination timeout based on the service configurationrcloudireturns the service termination timeout based on the service configurationscloudireturns 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 data8OPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy8RSTUQPOVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy4      !"##$%&''()*+,-./0123456789:;<=>?@ABCDEFGHI+JKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyS_abdfgijkmz{|}~"cloudi-2.0.6-GserKnsPX1cCMQcuCbGv1Foreign.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 processIndex_ processCountprocessCountMaxprocessCountMax_processCountMinprocessCountMin_prefixtimeoutInitializetimeoutInitialize_ timeoutAsync timeoutSynctimeoutTerminatetimeoutTerminate_priorityDefaultpollshutdown threadCreate threadsWaitinfoKeyValueParseinfoKeyValueNew$fExceptionException$fShowFatalError$fExceptionFatalError$fShowExceptiontimeout bufferSizestateterminateException socketHandle useHeaderinitializationCompletefatalExceptions terminate callbacks bufferRecvbufferRecvSize responseInforesponsetransIdtransIdsmakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove<>