Documentation ¶
Overview ¶
Package hadoop_hdfs_namenode is a generated protocol buffer package.
It is generated from these files:
NamenodeProtocol.proto
It has these top-level messages:
GetBlocksRequestProto GetBlocksResponseProto GetBlockKeysRequestProto GetBlockKeysResponseProto GetTransactionIdRequestProto GetTransactionIdResponseProto RollEditLogRequestProto RollEditLogResponseProto GetMostRecentCheckpointTxIdRequestProto GetMostRecentCheckpointTxIdResponseProto ErrorReportRequestProto ErrorReportResponseProto RegisterRequestProto RegisterResponseProto StartCheckpointRequestProto StartCheckpointResponseProto EndCheckpointRequestProto EndCheckpointResponseProto GetEditLogManifestRequestProto GetEditLogManifestResponseProto
Index ¶
- type EndCheckpointRequestProto
- func (m *EndCheckpointRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
- func (m *EndCheckpointRequestProto) GetSignature() *hadoop_hdfs.CheckpointSignatureProto
- func (*EndCheckpointRequestProto) ProtoMessage()
- func (m *EndCheckpointRequestProto) Reset()
- func (m *EndCheckpointRequestProto) String() string
- type EndCheckpointResponseProto
- type ErrorReportRequestProto
- func (m *ErrorReportRequestProto) GetErrorCode() uint32
- func (m *ErrorReportRequestProto) GetMsg() string
- func (m *ErrorReportRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
- func (*ErrorReportRequestProto) ProtoMessage()
- func (m *ErrorReportRequestProto) Reset()
- func (m *ErrorReportRequestProto) String() string
- type ErrorReportResponseProto
- type GetBlockKeysRequestProto
- type GetBlockKeysResponseProto
- type GetBlocksRequestProto
- type GetBlocksResponseProto
- type GetEditLogManifestRequestProto
- type GetEditLogManifestResponseProto
- type GetMostRecentCheckpointTxIdRequestProto
- type GetMostRecentCheckpointTxIdResponseProto
- type GetTransactionIdRequestProto
- type GetTransactionIdResponseProto
- type RegisterRequestProto
- type RegisterResponseProto
- type RollEditLogRequestProto
- type RollEditLogResponseProto
- type StartCheckpointRequestProto
- type StartCheckpointResponseProto
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EndCheckpointRequestProto ¶
type EndCheckpointRequestProto struct { Registration *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"` Signature *hadoop_hdfs.CheckpointSignatureProto `protobuf:"bytes,2,req,name=signature" json:"signature,omitempty"` XXX_unrecognized []byte `json:"-"` }
* End or finalize the previously started checkpoint registration - Namenode that is ending the checkpoint signature - unique token to identify checkpoint transaction,
that was received when checkpoint was started.
func (*EndCheckpointRequestProto) GetRegistration ¶
func (m *EndCheckpointRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
func (*EndCheckpointRequestProto) GetSignature ¶
func (m *EndCheckpointRequestProto) GetSignature() *hadoop_hdfs.CheckpointSignatureProto
func (*EndCheckpointRequestProto) ProtoMessage ¶
func (*EndCheckpointRequestProto) ProtoMessage()
func (*EndCheckpointRequestProto) Reset ¶
func (m *EndCheckpointRequestProto) Reset()
func (*EndCheckpointRequestProto) String ¶
func (m *EndCheckpointRequestProto) String() string
type EndCheckpointResponseProto ¶
type EndCheckpointResponseProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void response
func (*EndCheckpointResponseProto) ProtoMessage ¶
func (*EndCheckpointResponseProto) ProtoMessage()
func (*EndCheckpointResponseProto) Reset ¶
func (m *EndCheckpointResponseProto) Reset()
func (*EndCheckpointResponseProto) String ¶
func (m *EndCheckpointResponseProto) String() string
type ErrorReportRequestProto ¶
type ErrorReportRequestProto struct { Registration *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"` ErrorCode *uint32 `protobuf:"varint,2,req,name=errorCode" json:"errorCode,omitempty"` Msg *string `protobuf:"bytes,3,req,name=msg" json:"msg,omitempty"` XXX_unrecognized []byte `json:"-"` }
* registration - Namenode reporting the error errorCode - error code indicating the error msg - Free text description of the error
func (*ErrorReportRequestProto) GetErrorCode ¶
func (m *ErrorReportRequestProto) GetErrorCode() uint32
func (*ErrorReportRequestProto) GetMsg ¶
func (m *ErrorReportRequestProto) GetMsg() string
func (*ErrorReportRequestProto) GetRegistration ¶
func (m *ErrorReportRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
func (*ErrorReportRequestProto) ProtoMessage ¶
func (*ErrorReportRequestProto) ProtoMessage()
func (*ErrorReportRequestProto) Reset ¶
func (m *ErrorReportRequestProto) Reset()
func (*ErrorReportRequestProto) String ¶
func (m *ErrorReportRequestProto) String() string
type ErrorReportResponseProto ¶
type ErrorReportResponseProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void response
func (*ErrorReportResponseProto) ProtoMessage ¶
func (*ErrorReportResponseProto) ProtoMessage()
func (*ErrorReportResponseProto) Reset ¶
func (m *ErrorReportResponseProto) Reset()
func (*ErrorReportResponseProto) String ¶
func (m *ErrorReportResponseProto) String() string
type GetBlockKeysRequestProto ¶
type GetBlockKeysRequestProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void request
func (*GetBlockKeysRequestProto) ProtoMessage ¶
func (*GetBlockKeysRequestProto) ProtoMessage()
func (*GetBlockKeysRequestProto) Reset ¶
func (m *GetBlockKeysRequestProto) Reset()
func (*GetBlockKeysRequestProto) String ¶
func (m *GetBlockKeysRequestProto) String() string
type GetBlockKeysResponseProto ¶
type GetBlockKeysResponseProto struct { Keys *hadoop_hdfs.ExportedBlockKeysProto `protobuf:"bytes,1,opt,name=keys" json:"keys,omitempty"` XXX_unrecognized []byte `json:"-"` }
* keys - Information about block keys at the active namenode
func (*GetBlockKeysResponseProto) GetKeys ¶
func (m *GetBlockKeysResponseProto) GetKeys() *hadoop_hdfs.ExportedBlockKeysProto
func (*GetBlockKeysResponseProto) ProtoMessage ¶
func (*GetBlockKeysResponseProto) ProtoMessage()
func (*GetBlockKeysResponseProto) Reset ¶
func (m *GetBlockKeysResponseProto) Reset()
func (*GetBlockKeysResponseProto) String ¶
func (m *GetBlockKeysResponseProto) String() string
type GetBlocksRequestProto ¶
type GetBlocksRequestProto struct { Datanode *hadoop_hdfs.DatanodeIDProto `protobuf:"bytes,1,req,name=datanode" json:"datanode,omitempty"` Size *uint64 `protobuf:"varint,2,req,name=size" json:"size,omitempty"` XXX_unrecognized []byte `json:"-"` }
* Get list of blocks for a given datanode with the total length of adding up to given size datanode - Datanode ID to get list of block from size - size to which the block lengths must add up to
func (*GetBlocksRequestProto) GetDatanode ¶
func (m *GetBlocksRequestProto) GetDatanode() *hadoop_hdfs.DatanodeIDProto
func (*GetBlocksRequestProto) GetSize ¶
func (m *GetBlocksRequestProto) GetSize() uint64
func (*GetBlocksRequestProto) ProtoMessage ¶
func (*GetBlocksRequestProto) ProtoMessage()
func (*GetBlocksRequestProto) Reset ¶
func (m *GetBlocksRequestProto) Reset()
func (*GetBlocksRequestProto) String ¶
func (m *GetBlocksRequestProto) String() string
type GetBlocksResponseProto ¶
type GetBlocksResponseProto struct { Blocks *hadoop_hdfs.BlocksWithLocationsProto `protobuf:"bytes,1,req,name=blocks" json:"blocks,omitempty"` XXX_unrecognized []byte `json:"-"` }
* blocks - List of returned blocks
func (*GetBlocksResponseProto) GetBlocks ¶
func (m *GetBlocksResponseProto) GetBlocks() *hadoop_hdfs.BlocksWithLocationsProto
func (*GetBlocksResponseProto) ProtoMessage ¶
func (*GetBlocksResponseProto) ProtoMessage()
func (*GetBlocksResponseProto) Reset ¶
func (m *GetBlocksResponseProto) Reset()
func (*GetBlocksResponseProto) String ¶
func (m *GetBlocksResponseProto) String() string
type GetEditLogManifestRequestProto ¶
type GetEditLogManifestRequestProto struct { SinceTxId *uint64 `protobuf:"varint,1,req,name=sinceTxId" json:"sinceTxId,omitempty"` XXX_unrecognized []byte `json:"-"` }
* sinceTxId - return the editlog information for transactions >= sinceTxId
func (*GetEditLogManifestRequestProto) GetSinceTxId ¶
func (m *GetEditLogManifestRequestProto) GetSinceTxId() uint64
func (*GetEditLogManifestRequestProto) ProtoMessage ¶
func (*GetEditLogManifestRequestProto) ProtoMessage()
func (*GetEditLogManifestRequestProto) Reset ¶
func (m *GetEditLogManifestRequestProto) Reset()
func (*GetEditLogManifestRequestProto) String ¶
func (m *GetEditLogManifestRequestProto) String() string
type GetEditLogManifestResponseProto ¶
type GetEditLogManifestResponseProto struct { Manifest *hadoop_hdfs.RemoteEditLogManifestProto `protobuf:"bytes,1,req,name=manifest" json:"manifest,omitempty"` XXX_unrecognized []byte `json:"-"` }
* manifest - Enumeration of editlogs from namenode for
logs >= sinceTxId in the request
func (*GetEditLogManifestResponseProto) GetManifest ¶
func (m *GetEditLogManifestResponseProto) GetManifest() *hadoop_hdfs.RemoteEditLogManifestProto
func (*GetEditLogManifestResponseProto) ProtoMessage ¶
func (*GetEditLogManifestResponseProto) ProtoMessage()
func (*GetEditLogManifestResponseProto) Reset ¶
func (m *GetEditLogManifestResponseProto) Reset()
func (*GetEditLogManifestResponseProto) String ¶
func (m *GetEditLogManifestResponseProto) String() string
type GetMostRecentCheckpointTxIdRequestProto ¶
type GetMostRecentCheckpointTxIdRequestProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void request
func (*GetMostRecentCheckpointTxIdRequestProto) ProtoMessage ¶
func (*GetMostRecentCheckpointTxIdRequestProto) ProtoMessage()
func (*GetMostRecentCheckpointTxIdRequestProto) Reset ¶
func (m *GetMostRecentCheckpointTxIdRequestProto) Reset()
func (*GetMostRecentCheckpointTxIdRequestProto) String ¶
func (m *GetMostRecentCheckpointTxIdRequestProto) String() string
type GetMostRecentCheckpointTxIdResponseProto ¶
type GetMostRecentCheckpointTxIdResponseProto struct { TxId *uint64 `protobuf:"varint,1,req,name=txId" json:"txId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetMostRecentCheckpointTxIdResponseProto) GetTxId ¶
func (m *GetMostRecentCheckpointTxIdResponseProto) GetTxId() uint64
func (*GetMostRecentCheckpointTxIdResponseProto) ProtoMessage ¶
func (*GetMostRecentCheckpointTxIdResponseProto) ProtoMessage()
func (*GetMostRecentCheckpointTxIdResponseProto) Reset ¶
func (m *GetMostRecentCheckpointTxIdResponseProto) Reset()
func (*GetMostRecentCheckpointTxIdResponseProto) String ¶
func (m *GetMostRecentCheckpointTxIdResponseProto) String() string
type GetTransactionIdRequestProto ¶
type GetTransactionIdRequestProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void request
func (*GetTransactionIdRequestProto) ProtoMessage ¶
func (*GetTransactionIdRequestProto) ProtoMessage()
func (*GetTransactionIdRequestProto) Reset ¶
func (m *GetTransactionIdRequestProto) Reset()
func (*GetTransactionIdRequestProto) String ¶
func (m *GetTransactionIdRequestProto) String() string
type GetTransactionIdResponseProto ¶
type GetTransactionIdResponseProto struct { TxId *uint64 `protobuf:"varint,1,req,name=txId" json:"txId,omitempty"` XXX_unrecognized []byte `json:"-"` }
* txId - Transaction ID of the most recently persisted edit log record
func (*GetTransactionIdResponseProto) GetTxId ¶
func (m *GetTransactionIdResponseProto) GetTxId() uint64
func (*GetTransactionIdResponseProto) ProtoMessage ¶
func (*GetTransactionIdResponseProto) ProtoMessage()
func (*GetTransactionIdResponseProto) Reset ¶
func (m *GetTransactionIdResponseProto) Reset()
func (*GetTransactionIdResponseProto) String ¶
func (m *GetTransactionIdResponseProto) String() string
type RegisterRequestProto ¶
type RegisterRequestProto struct { Registration *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"` XXX_unrecognized []byte `json:"-"` }
* registration - Information of the namenode registering with primary namenode
func (*RegisterRequestProto) GetRegistration ¶
func (m *RegisterRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
func (*RegisterRequestProto) ProtoMessage ¶
func (*RegisterRequestProto) ProtoMessage()
func (*RegisterRequestProto) Reset ¶
func (m *RegisterRequestProto) Reset()
func (*RegisterRequestProto) String ¶
func (m *RegisterRequestProto) String() string
type RegisterResponseProto ¶
type RegisterResponseProto struct { Registration *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"` XXX_unrecognized []byte `json:"-"` }
* registration - Updated registration information of the newly registered
datanode.
func (*RegisterResponseProto) GetRegistration ¶
func (m *RegisterResponseProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
func (*RegisterResponseProto) ProtoMessage ¶
func (*RegisterResponseProto) ProtoMessage()
func (*RegisterResponseProto) Reset ¶
func (m *RegisterResponseProto) Reset()
func (*RegisterResponseProto) String ¶
func (m *RegisterResponseProto) String() string
type RollEditLogRequestProto ¶
type RollEditLogRequestProto struct {
XXX_unrecognized []byte `json:"-"`
}
* void request
func (*RollEditLogRequestProto) ProtoMessage ¶
func (*RollEditLogRequestProto) ProtoMessage()
func (*RollEditLogRequestProto) Reset ¶
func (m *RollEditLogRequestProto) Reset()
func (*RollEditLogRequestProto) String ¶
func (m *RollEditLogRequestProto) String() string
type RollEditLogResponseProto ¶
type RollEditLogResponseProto struct { Signature *hadoop_hdfs.CheckpointSignatureProto `protobuf:"bytes,1,req,name=signature" json:"signature,omitempty"` XXX_unrecognized []byte `json:"-"` }
* signature - A unique token to identify checkpoint transaction
func (*RollEditLogResponseProto) GetSignature ¶
func (m *RollEditLogResponseProto) GetSignature() *hadoop_hdfs.CheckpointSignatureProto
func (*RollEditLogResponseProto) ProtoMessage ¶
func (*RollEditLogResponseProto) ProtoMessage()
func (*RollEditLogResponseProto) Reset ¶
func (m *RollEditLogResponseProto) Reset()
func (*RollEditLogResponseProto) String ¶
func (m *RollEditLogResponseProto) String() string
type StartCheckpointRequestProto ¶
type StartCheckpointRequestProto struct { Registration *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"` XXX_unrecognized []byte `json:"-"` }
* Start checkpoint request registration - Namenode that is starting the checkpoint
func (*StartCheckpointRequestProto) GetRegistration ¶
func (m *StartCheckpointRequestProto) GetRegistration() *hadoop_hdfs.NamenodeRegistrationProto
func (*StartCheckpointRequestProto) ProtoMessage ¶
func (*StartCheckpointRequestProto) ProtoMessage()
func (*StartCheckpointRequestProto) Reset ¶
func (m *StartCheckpointRequestProto) Reset()
func (*StartCheckpointRequestProto) String ¶
func (m *StartCheckpointRequestProto) String() string
type StartCheckpointResponseProto ¶
type StartCheckpointResponseProto struct { Command *hadoop_hdfs.NamenodeCommandProto `protobuf:"bytes,1,req,name=command" json:"command,omitempty"` XXX_unrecognized []byte `json:"-"` }
* command - Command returned by the active namenode to be
be handled by the caller.
func (*StartCheckpointResponseProto) GetCommand ¶
func (m *StartCheckpointResponseProto) GetCommand() *hadoop_hdfs.NamenodeCommandProto
func (*StartCheckpointResponseProto) ProtoMessage ¶
func (*StartCheckpointResponseProto) ProtoMessage()
func (*StartCheckpointResponseProto) Reset ¶
func (m *StartCheckpointResponseProto) Reset()
func (*StartCheckpointResponseProto) String ¶
func (m *StartCheckpointResponseProto) String() string