Y      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~   parser support Toshio Ito <debug.ito@gmail.com>None %Common data types for Request objects Toshio Ito <debug.ito@gmail.com>NoneA raw ' encoded to/decoded from a base64 text. instance encodes the raw  to a base64-encoded .  is its inverse.Possible SASL mechanisms. "PLAIN" SASL "GSSAPI" SASLClass of operation objects."processor" field. "op" field.  "args" field.    Request to Gremlin Server Toshio Ito <debug.ito@gmail.com>None"6a)RequestMessage to a Gremlin Server. See  6http://tinkerpop.apache.org/docs/current/dev/provider/. Convert an  object to . Create a  from an  object. The < is generated by the random number generator of the system.    )Operation objects for session OpProcessor Toshio Ito <debug.ito@gmail.com>None"6a$%(&')*+./0,-12345678456783)*+,-./012$%&'($%&'() *+,-./01245678*Operation objects for standard OpProcessor Toshio Ito <debug.ito@gmail.com>None"6aA MNORSTPQUVWXY UVWXYMNOPQRSTMNOPQRSTUVWXYResponse from Gremlin Server Toshio Ito <debug.ito@gmail.com>None6' g1ResponseMessage object from Gremlin Server. See  6http://tinkerpop.apache.org/docs/current/dev/provider/.Type s" is the type of the response data.l"result" field.n "data" field.p"status" field.uResponse status codeReturns  if the u is a terminating code.Returns  if the u is a success.isSuccess SuccessTrueisSuccess UnauthorizedFalseisSuccess ServerErrorFalseReturns  if the u is a client-side failure.isClientSideError SuccessFalseisClientSideError UnauthorizedTrueisClientSideError ServerErrorFalseReturns  if the u is a server-side failure.isServerSideError SuccessFalseisServerSideError UnauthorizedFalseisServerSideError ServerErrorTrue ghijklmnopqsrtuv{wxyz|}~ ghijkpqrstlmnouvwxyz{|}~ghijklmnopqrstu vwxyz{|}~#Encoder/decoder of Request/Response Toshio Ito <debug.ito@gmail.com>None1 Encoder of  and decoder of g, associated with a MIME type.Type s is the body of Response.MIME type sent to the serverRequest encoderResponse decoderMake a request message header. Encode a h into a "binary" format of Gremlin Server. The result includes the message "header" and the "payload".NDecode a message in the "binary" format. This is mainly for testing purposes. MIME type(mimeType, payload) common types for Connection Toshio Ito <debug.ito@gmail.com>NoneChException general to a ). It's not related to specific requests.Server sends a g: with unknown requestId, which is kept in this exception.The U fails to parse a data from the server. The error message is kept in this exception.+A WebSocket connection to a Gremlin Server.Type s is the body of Response, as in g.!Request queue to WS (Mux) thread.~WS (Mux) thread. It keeps the underlying WebSocket connection, watches various types of events and responds to those events. State of the .$Connection is open and ready to use.Connection is closing. It rejects new requests, but keeps receiving responses for pending requests. When there is no pending requests, it goes to .Connection is closed. It rejects requests, and it doesn't expect any responses. It can close the underlying WebSocket connection.gPackage of request data and related stuff. It's passed from the caller thread into WS handling thread.Encoded request data request ID8the output queue for incoming response for this request.+Package of Response data and related stuff.application/json codec Toshio Ito <debug.ito@gmail.com>NoneG  Simple "application/json" codec.VThe encoder uses GraphSON v1 format. The decoder supports all GraphSON v1, v2 and v3. Settings for making Connection Toshio Ito <debug.ito@gmail.com>NoneY;) for making connection to Gremlin Server.You can get the default  by ; function, and customize its fields by accessor functions.Type s is the body of Response.codec for the connection.3Path of the WebSocket endpoint. Default: "/gremlin"An exception handler for . This exception is not fatal, so the connection survives after this handler is called. You don't have to re-throw the exception. Default: print the exception to stderr.Time out (in seconds) for responses. It is the maximum time for which the connection waits for a response to complete after it sends a request. If the response consists of more than one ResponseMessages, the timeout applies to the last of the ResponseMessages. Default: 60Maximum concurrent requests the connection can make to the server. If the client tries to make more concurrent requests than this value, later requests are queued in the connection or the client may be blocked. Default: 4aSize of the internal queue of requests. Usually you don't need to customize the field. See also . Default: 8. with . Common utility Toshio Ito <debug.ito@gmail.com>NoneZ%internal implementation of Connection Toshio Ito <debug.ito@gmail.com>None"avA handle associated in a 7 for a pair of request and response. You can retrieve gs from this object.Type s is the body of the response.Multiplexed event objectL(requestId of pending request) --> (objects related to that pending request)"timer thread to time out response.+An exception related to a specific request.=The connection is already closed before it sends the request.LThe server closed the connection before it sends response for this request.JThe requestId (kept in this object) is already pending in the connection.2The server fails to send ResponseMessages within .TCP port number.Host name or an IP address.Make a  to a Gremlin Server.HIf it fails to connect to the specified server, it throws an exception. Close the .%If there are pending requests in the , 3 function blocks for them to complete or time out.Calling  on a 4 already closed (or waiting to close) does nothing.(A thread taking care of a WS connection./HashTable's mutateIO is available since 1.2.3.0Multiplexer loop.Receiver thread. It keeps receiving data from WS until the connection finishes cleanly. Basically every exception is raised to the caller.Make a  from an  and send it.yUsually this function does not throw any exception. Exceptions about sending requests are reported when you operate on .Like , but you can pass a  directly to this function.Get a g from 5. If you have already got all responses, it returns %. This function may block for a new g to come.:On error, it may throw all sorts of exceptions including . version of .Get all remaining gs from .action to create the new entry. if insertion is successful.-          &WebSocket Connection to Gremlin Server Toshio Ito <debug.ito@gmail.com>Noney9 Options to create a Client Toshio Ito <debug.ito@gmail.com>None<Configuration options to create a client for Gremlin Server.You can get the default  by ; function, and customize its fields by accessor functions.Settings for the underlying  . Default: .2"batchSize" field for "eval" operation. Default: .1"language" field for "eval" operation. Default: ./"aliases" field for "eval" operation. Default: .@"scriptEvaluationTimeout" field for "eval" operation. Default: . Maintainer: Toshio Ito debug.ito@gmail.comNone"FTa\ Exception about " operation and getting its result.The server returns a g with error u.3The client fails to parse the "data" field of the g#. The error message is kept in the  field.RA handle to receive the result of evaluation of a Gremlin script from the server.qA client that establishes a connection to the Gremlin Server. You can send Gremlin expression for evaluation by  function. Create a ' to a Gremlin Server, with the default . Create a  to a Gremlin Server.GClose the connection to the server and release other resources of the .CSubmit a Gremlin script to the server. You can get its results by . The result type v# is determined by the script type g.yUsually this function does not throw any exception. Exceptions about sending requests are reported when you operate on .Less type-safe version of .Get the next value from the *. If you have got all values, it returns 7. This function may block for a new response to come.:On error, it may throw all sorts of exceptions including  and E. For example, if the submitted Gremlin script throws an exception,  throws  with u of ~. version of .Get all remaining results from .Gremlin scriptbindingsGremlin scriptbindings !"#$%&'() #"!$&% &High-level interface to Gremlin Server Toshio Ito <debug.ito@gmail.com>Nonep(Client of Gremlin Server using WebSocket Toshio Ito <debug.ito@gmail.com>None* !"#$%&'(()*+,-./012344567889:;<=>?@ABBCDEFGHIJKLMNOPQRSTUVWXY889:;<=>BBCDEFGHIJKOPQRSTUZZ[\]^^_`aabcdefghijklmnopqrstuvwxyz{|}~                          1greskell-websocket-0.1.0.0-B5MSDMOvrvq7G9hWTH8wEx)Network.Greskell.WebSocket.Request.Common"Network.Greskell.WebSocket.Request*Network.Greskell.WebSocket.Request.Session+Network.Greskell.WebSocket.Request.Standard#Network.Greskell.WebSocket.Response Network.Greskell.WebSocket.Codec%Network.Greskell.WebSocket.Connection%Network.Greskell.WebSocket.Codec.JSON.Network.Greskell.WebSocket.Connection.Settings)Network.Greskell.WebSocket.Client.Options!Network.Greskell.WebSocket.Client(Network.Greskell.WebSocket.Request.Aeson*Network.Greskell.WebSocket.Connection.TypeNetwork.Greskell.WebSocket.Util*Network.Greskell.WebSocket.Connection.Impl&Network.Greskell.WebSocket.Client.ImplNetwork.Greskell.WebSocketBase64unByte64 SASLMechanism SASLPlain SASLGSSAPI Operation opProcessoropNameopArgs$fOperationEither$fFromJSONSASLMechanism$fToJSONSASLMechanism$fFromJSONBase64$fToJSONBase64$fShowSASLMechanism$fEqSASLMechanism$fOrdSASLMechanism$fEnumSASLMechanism$fBoundedSASLMechanism $fShowBase64 $fEqBase64 $fOrdBase64RequestMessage$sel:requestId:RequestMessage$sel:op:RequestMessage$sel:processor:RequestMessage$sel:args:RequestMessagetoRequestMessagemakeRequestMessage$fFromJSONRequestMessage$fToJSONRequestMessage$fShowRequestMessage$fEqRequestMessage$fGenericRequestMessageOpClose$sel:batchSize:OpClose$sel:session:OpClose$sel:force:OpCloseOpEval$sel:batchSize:OpEval$sel:gremlin:OpEval$sel:bindings:OpEval$sel:language:OpEval$sel:aliases:OpEval#$sel:scriptEvaluationTimeout:OpEval$sel:session:OpEval$sel:manageTransaction:OpEval SessionIDOpAuthentication$sel:batchSize:OpAuthentication$sel:sasl:OpAuthentication#$sel:saslMechanism:OpAuthentication$fOperationOpAuthentication$fFromJSONOpAuthentication$fToJSONOpAuthentication$fOperationOpEval$fFromJSONOpEval$fToJSONOpEval$fOperationOpClose$fFromJSONOpClose$fToJSONOpClose$fShowOpAuthentication$fEqOpAuthentication$fOrdOpAuthentication$fGenericOpAuthentication $fShowOpEval $fEqOpEval$fGenericOpEval $fShowOpClose $fEqOpClose $fOrdOpClose$fGenericOpCloseResponseMessage requestIdstatusresultResponseResult resultDatametaResponseStatuscodemessage attributes ResponseCodeSuccess NoContentPartialContent Unauthorized AuthenticateMalformedRequestInvalidRequestArguments ServerErrorScriptEvaluationError ServerTimeoutServerSerializationError codeToInt codeFromInt isTerminating isSuccessisClientSideErrorisServerSideError$fToJSONResponseCode$fFromGraphSONResponseCode$fFromJSONResponseCode$fFromGraphSONResponseStatus$fFromJSONResponseStatus$fFunctorResponseResult$fFromGraphSONResponseResult$fFromJSONResponseResult$fFunctorResponseMessage$fFromGraphSONResponseMessage$fFromJSONResponseMessage$fShowResponseCode$fEqResponseCode$fOrdResponseCode$fEnumResponseCode$fBoundedResponseCode$fShowResponseStatus$fEqResponseStatus$fGenericResponseStatus$fShowResponseResult$fEqResponseResult$fGenericResponseResult$fShowResponseMessage$fEqResponseMessage$fGenericResponseMessageCodecmimeType encodeWith decodeWith messageHeaderencodeBinaryWith decodeBinary$fFunctorCodecGeneralExceptionUnexpectedRequestIdResponseParseFailure Connection jsonCodecSettingscodec endpointPathonGeneralExceptionresponseTimeout concurrencyrequestQueueSize defSettingsdefJSONSettingsResponseHandleRequestException AlreadyClosed ServerClosedDuplicateRequestIdResponseTimeoutPortHostconnectclose sendRequest sendRequest' nextResponsenextResponseSTMslurpResponsesOptionsconnectionSettings batchSizelanguagealiasesscriptEvaluationTimeout defOptionsSubmitException ResponseError ParseError ResultHandleClient connectWithsubmit submitRaw nextResult nextResultSTM slurpResults$aeson-1.2.4.0-H5AjmDBnHfNIj8n3LiLwAGData.Aeson.Types.ToJSONgenericToEncoding genericToJSONData.Aeson.Types.FromJSONgenericParseJSONopttoObjectbytestring-0.10.8.2Data.ByteString.Internal ByteStringToJSON#text-1.2.2.2-EakMpasry3jA6OIwSZhq9MData.Text.InternalTextFromJSONghc-prim GHC.TypesTrueconnQReq connWSThreadConnectionStateConnOpen ConnClosing ConnClosedReqPackreqDatareqId reqOutputResPack connState connCodecReqIDRawResRawReqslurpMuxEventReqPool$sel:rpeTimer:ReqPoolEntry runWSConntryInsertToReqPool runMuxLoop runRxLoopbaseGHC.BaseNothing GHC.Conc.SyncSTM $sel:rhTerminated:ResponseHandle!$sel:rhGetResponse:ResponseHandleEvResponseTimeout EvRxError EvRxFinish EvActiveCloseEvResEvReq ReqPoolEntry$sel:rpeReqId:ReqPoolEntry$sel:rpeOutput:ReqPoolEntryPath flushTBQueuereportToReqPool reportToQReqcleanupReqPoolEntryremoveReqPoolEntrycleanupReqPoolgetAllResponseTimersrunTimerisTerminatingResponseString$sel:rhState:ResultHandle#$sel:rhNextResultIndex:ResultHandle$sel:rhResultCache:ResultHandle$sel:rhParseGValue:ResultHandle$sel:rhResHandle:ResultHandle HandleState HandleError HandleClose HandleOpen$sel:clientConn:Client$sel:clientOpts:Client submitBasegetNextCachedResult loadResponse