hadoop-rpc-0.1.1.1: Use the Hadoop RPC interface from Haskell.

Safe HaskellNone
LanguageHaskell2010

Data.Hadoop.Protobuf.Headers

Synopsis

Documentation

data UserInformation Source

User information beyond what can be determined as part of the security handshake at connection time (kerberos, tokens, etc)

data IpcConnectionContext Source

The connection context is sent as part of the connection establishment. It establishes the context for ALL Rpc calls within the connection.

Constructors

IpcConnectionContext 

Fields

ctxUserInfo :: Optional 2 (Message UserInformation)
 
ctxProtocol :: Optional 3 (Value Text)

Name of the next RPC layer.

data RpcKind Source

Determines the RPC Engine and the serialization of the RPC request.

Constructors

Builtin

Used for built-in calls by tests

Writable

Use WritableRpcEngine

ProtocolBuffer

Use ProtobufRpcEngine

data RpcOperation Source

Constructors

FinalPacket

The final RPC packet

ContinuationPacket

Not implemented yet

CloseConnection

Close the RPC connection

data RpcRequest Source

This message is used for Protobuf RPC Engine. The message is used to marshal a RPC request from RPC client to the RPC server. The response to the RPC call (including errors) are handled as part of the standard RPC response.

Constructors

RpcRequest 

Fields

reqMethodName :: Required 1 (Value Text)

Name of the RPC method

reqBytes :: Optional 2 (Value ByteString)

Bytes corresponding to the client protobuf request

reqProtocolName :: Required 3 (Value Text)

Protocol name of class declaring the called method

reqProtocolVersion :: Required 4 (Value Word64)

Protocol version of class declaring the called method

data RpcStatus Source

Success or failure. The reponse header's error detail, exception class name and error message contains further details on the error.

Constructors

Success

Succeeded

Error

Non-fatal error, connection left open

Fatal

Fatal error, connection closed

data RpcResponseHeader Source

Note that RPC response header is also used when connection setup fails. (i.e. the response looks like an RPC response with a fake callId)

For v7: - If successfull then the Respose follows after this header - length (4 byte int), followed by the response - If error or fatal - the exception info follow - length (4 byte int) Class name of exception - UTF-8 string - length (4 byte int) Stacktrace - UTF-8 string - if the strings are null then the length is -1

In case of Fatal error then the respose contains the Serverside's IPC version.

Constructors

RpcResponseHeader 

Fields

rspCallId :: Required 1 (Value Word32)

Call ID used in request

rspStatus :: Required 2 (Enumeration RpcStatus)
 
rspServerIpcVersion :: Optional 3 (Value Word32)

v7: Sent if fatal v9: Sent if success or fail