Safe Haskell | None |
---|---|
Language | Haskell2010 |
This module contains protocol buffers that are used to transfer data to and from the datanode, as well as between datanodes.
- data DataTransferEncryptorStatus
- data DataTransferEncryptorMessage = DataTransferEncryptorMessage {
- dtesStatus :: Required 1 (Enumeration DataTransferEncryptorStatus)
- dtesPayload :: Optional 2 (Value ByteString)
- dtesData :: Optional 3 (Value Text)
- data BaseHeader = BaseHeader {}
- data ClientOperationHeader = ClientOperationHeader {
- cohBaseHeader :: Required 1 (Message BaseHeader)
- cohClientName :: Required 2 (Value Text)
- data CachingStrategy = CachingStrategy {
- csDropBehind :: Optional 1 (Value Bool)
- csReadahead :: Optional 2 (Value Int64)
- data OpReadBlock = OpReadBlock {
- orbHeader :: Required 1 (Message ClientOperationHeader)
- orbOffset :: Required 2 (Value Word64)
- orbLen :: Required 3 (Value Word64)
- orbSendChecksums :: Optional 4 (Value Bool)
- orbCachingStrategy :: Optional 5 (Message CachingStrategy)
- data Checksum = Checksum {
- csType :: Required 1 (Message ChecksumType)
- csBytesPerChecksum :: Required 2 (Value Word32)
- data BlockConstructionStage
- data OpWriteBlock = OpWriteBlock {
- owbHeader :: Required 1 (Message ClientOperationHeader)
- owbTargets :: Repeated 2 (Message DataNodeInfo)
- owbSource :: Optional 3 (Message DataNodeInfo)
- owbStage :: Required 4 (Enumeration BlockConstructionStage)
- owbPipelineSize :: Required 5 (Value Word32)
- owbMinBytesRcvd :: Required 6 (Value Word64)
- owbMaxBytesRcvd :: Required 7 (Value Word64)
- owbLatestGenerationStamp :: Required 8 (Value Word64)
- owbRequestedChecksum :: Required 9 (Message Checksum)
- owbCachingStrategy :: Optional 10 (Message CachingStrategy)
- data OpTransferBlock = OpTransferBlock {}
- data OpReplaceBlock = OpReplaceBlock {
- orpHeader :: Required 1 (Message BaseHeader)
- orpDelHint :: Required 2 (Value Text)
- orpSource :: Required 3 (Message DataNodeInfo)
- data OpCopyBlock = OpCopyBlock {
- ocbHeader :: Required 1 (Message BaseHeader)
- data OpBlockChecksum = OpBlockChecksum {
- obcHeader :: Required 1 (Message BaseHeader)
- data OpRequestShortCircuitAccess = OpRequestShortCircuitAccess {
- orscHeader :: Required 1 (Message BaseHeader)
- orscMaxVersion :: Required 2 (Value Word32)
- data PacketHeader = PacketHeader {}
- data DataTransferStatus
- data PipelineAck = PipelineAck {
- psSeqno :: Required 1 (Value (Signed Int64))
- paStatus :: Optional 2 (Enumeration DataTransferStatus)
- paDownstreamAckTimeNanos :: Optional 3 (Value Word64)
- data ReadOpChecksumInfo = ReadOpChecksumInfo {
- rociChecksum :: Required 1 (Message Checksum)
- rociChunkOffset :: Required 2 (Value Word64)
- data BlockOpResponse = BlockOpResponse {
- borStatus :: Required 1 (Enumeration DataTransferStatus)
- borFirstBadLink :: Optional 2 (Value String)
- borChecksumResponse :: Optional 3 (Message OpBlockChecksumResponse)
- borReadOpChecksumInfo :: Optional 4 (Message ReadOpChecksumInfo)
- borData :: Optional 5 (Value Text)
- borShortCircuitAccessVersion :: Optional 6 (Value Word32)
- data ClientReadStatus = ClientReadStatus {}
- data DNTransferAck = DNTransferAck {}
- data OpBlockChecksumResponse = OpBlockChecksumResponse {
- obcrBytesPerCrc :: Required 1 (Value Word32)
- obcrCrcPerBlock :: Required 2 (Value Word64)
- obcrMd5 :: Required 3 (Value ByteString)
- obcrCrcType :: Optional 4 (Message ChecksumType)
Documentation
data CachingStrategy Source
CachingStrategy | |
|
data OpReadBlock Source
OpReadBlock | |
|
Checksum | |
|
data BlockConstructionStage Source
BCS_PIPELINE_SETUP_APPEND | |
BCS_PIPELINE_SETUP_APPEND_RECOVERY | pipeline set up for failed PIPELINE_SETUP_APPEND recovery |
BCS_DATA_STREAMING | data streaming |
BCS_PIPELINE_SETUP_STREAMING_RECOVERY | pipeline setup for failed data streaming recovery |
BCS_PIPELINE_CLOSE | close the block and pipeline |
BCS_PIPELINE_CLOSE_RECOVERY | Recover a failed PIPELINE_CLOSE |
BCS_PIPELINE_SETUP_CREATE | pipeline set up for block creation |
BCS_TRANSFER_RBW | transfer RBW for adding datanodes |
BCS_TRANSFER_FINALIZED | transfer Finalized for adding datanodes |
data OpWriteBlock Source
OpWriteBlock | |
|
data OpTransferBlock Source
data OpReplaceBlock Source
OpReplaceBlock | |
|
data OpCopyBlock Source
data OpBlockChecksum Source
data OpRequestShortCircuitAccess Source
OpRequestShortCircuitAccess | |
|
data DataTransferStatus Source
data PipelineAck Source
PipelineAck | |
|
data ReadOpChecksumInfo Source
Sent as part of the BlockOpResponse for READ_BLOCK and COPY_BLOCK operations.
ReadOpChecksumInfo | |
|
data BlockOpResponse Source
BlockOpResponse | |
|
data ClientReadStatus Source
Message sent from the client to the DN after reading the entire read request.
data DNTransferAck Source
data OpBlockChecksumResponse Source
OpBlockChecksumResponse | |
|