E7`      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_Safe`a`aSafe bc   bcSafe de    deSafe fgfgNonean instance of the CloudI API-service request callback function return type&a function to handle a service request 8the Erlang pid that is the source of the service request!(provided when handling a service request<hijklmnopqrstuvwxyz{|}~ !"#0hijklmnopqrstuvwxyz{|}~ !"#hijklmnopqrstuvwxyz{|}~ !"#Safe<9Decode Erlang terms within binary data into Haskell types=5Encode Haskell types into Erlang terms in binary dataX$%&'()*+,-./0123456789:;<=$%&'()*+,-./0123456789:;<=)*+,-./0123456789:;%&'($<=C$%&'()*+,-./0123456789:;<=None@]a null trans_id is used to check for a timeout or to get the oldest response with recv_asyncD%creates an instance of the CloudI APIE7returns the thread count from the service configurationF4subscribes to a service name pattern with a callbackGEreturns the number of subscriptions for a single service name patternH-unsubscribes from a service name pattern onceI%sends an asynchronous service requestJ#sends a synchronous service requestK\sends asynchronous service requests to all subscribers of the matching service name patternL6forwards a service request to a different service nameMDforwards an asynchronous service request to a different service nameNBforwards a synchronous service request to a different service nameO(provides a response to a service requestP6provides a response to an asynchronous service requestQ4provides a response to a synchronous service requestR:blocks to receive an asynchronous service request responseSAreturns the 0-based index of this process in the service instanceTDreturns the current process count based on the service configurationUSreturns the count_process_dynamic maximum count based on the service configurationVSreturns the count_process_dynamic minimum count based on the service configurationWFreturns the service name pattern prefix from the service configurationXJreturns the service initialization timeout from the service configurationY]returns the default asynchronous service request send timeout from the service configurationZ\returns the default synchronous service request send timeout from the service configuration[Kreturns the service termination timeout based on the service configuration\2blocks to process incoming CloudI service requests]#simplifies thread creation and join rConcurrent.setNumCapabilities threadCount mapM_ (CloudI.threadCreate task) [0..threadCount - 1] CloudI.threadsWait^0wait for threads to join after being created by ]_+parses "text_pairs" in service request info\>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\   ] ^ _/ !"#>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_/!"# @ABC?>DEFGHIJKLMNOPQRSTUVWXYZ[\]^_S>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\   ] ^ _           !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[Z[Z[Z[\]^_`abcdeMNOPQRSTUfghijAklmnop[qrstuvwxyz{|}~ kZn[qknp[qrcloud_3b7PGGrCO6DCsx3qQuYc1SForeign.Erlang.FunctionForeign.Erlang.ReferenceForeign.Erlang.PortForeign.Erlang.PidForeign.CloudIForeign.ErlangForeign.CloudI.InstanceFunctiontagvalue ReferencenodeTagnodeidcreationPortPidserialTResponse ResponseInfoForwardForward_Null NullErrorCallbackSource RequestTypeASYNCSYNCResultError InputError OutputError ParseError OtpErlangTermOtpErlangIntegerOtpErlangIntegerBigOtpErlangFloat OtpErlangAtomOtpErlangAtomUTF8OtpErlangAtomCacheRefOtpErlangAtomBoolOtpErlangStringOtpErlangBinaryOtpErlangBinaryBits OtpErlangListOtpErlangListImproperOtpErlangTuple OtpErlangMap OtpErlangPid OtpErlangPortOtpErlangReferenceOtpErlangFunction binaryToTerm termToBinary Exception transIdNullinvalidInputErrormessageDecodingErrorterminateErrorapi threadCount subscribesubscribeCount unsubscribe sendAsyncsendSync mcastAsyncforward_ forwardAsync forwardSyncreturn_ returnAsync returnSync recvAsync processIndex processCountprocessCountMaxprocessCountMinprefixtimeoutInitialize timeoutAsync timeoutSynctimeoutTerminatepoll threadCreate threadsWaitinfoKeyValueParseWord8 ByteStringstate socketHandle useHeaderinitializationComplete terminatetimeout callbacks bufferSize bufferRecvbufferRecvSizepriorityDefault responseInforesponsetransIdtransIdsWord32SocketSeqMapInt8HandleBuilderArray makeSocketmakeSocketHandlemakeinitreinit setResponse setTransId setTransIdssetSubscribeCount callbacksAddcallbacksRemove$fShowTWord16Int32LazyByteStringGet tagVersiontagCompressedZlibtagNewFloatExttagBitBinaryExttagAtomCacheReftagSmallIntegerExt tagIntegerExt tagFloatExt tagAtomExttagReferenceExt tagPortExt tagPidExttagSmallTupleExttagLargeTupleExt tagNilExt tagStringExt tagListExt tagBinaryExttagSmallBigExttagLargeBigExt tagNewFunExt tagExportExttagNewReferenceExttagSmallAtomExt tagMapExt tagFunExttagAtomUtf8ExttagSmallAtomUtf8Extok errorTypegetUnsignedInt8getUnsignedInt16getUnsignedInt32getSignedInt32getUnsignedInt8or32boolTrue boolFalse<> binaryToTermsbinaryToTermSequencebinaryToMapPairbinaryToExportSizebinaryToFunSizebinaryToInteger binaryToPid binaryToAtom termsToBinarytermSequenceToBinarymapPairToBinaryCallbackResultReturnIForwardIFinished ReturnSync ReturnAsync ForwardSync ForwardAsyncMessage MessageSendMessageKeepaliveThreadId SomeException messageInitmessageSendAsyncmessageSendSyncmessageRecvAsyncmessageReturnAsyncmessageReturnSyncmessageReturnsAsyncmessageKeepalive messageReinitmessageSubscribeCount messageTermprintException printError forwardAsyncI forwardSyncI returnAsyncI returnSyncI nullResponsecallback handleEventspollRequestDataGetpollRequestDataProcesspollRequestDatapollRequestLooppollRequestLoopBegin pollRequestsend recvBuffer recvBufferAllrecvtimeoutAdjustmentPoll threadListthreadCreateForktextKeyValueParse$fExceptionException