Documentation ¶
Index ¶
- type DataNodeData
- type DataNodeDeleteRequest
- type DataNodeGetRequest
- type DataNodeInstance
- type DataNodePutRequest
- type DataNodeReNameRequest
- type DataNodeReplyStatus
- type NameNodePingRequest
- type NameNodePingResponse
- type Service
- func (dataNode *Service) DeleteFile(request *DataNodeDeleteRequest, reply *DataNodeReplyStatus) error
- func (dataNode *Service) DeletePath(request *DataNodeDeleteRequest, reply *DataNodeReplyStatus) error
- func (dataNode *Service) GetData(request *DataNodeGetRequest, reply *DataNodeData) error
- func (dataNode *Service) Heartbeat(request bool, response *bool) error
- func (dataNode *Service) MakeDir(request string, reply *DataNodeReplyStatus) error
- func (dataNode *Service) Ping(request *NameNodePingRequest, reply *NameNodePingResponse) error
- func (dataNode *Service) PutData(request *DataNodePutRequest, reply *DataNodeReplyStatus) error
- func (dataNode *Service) ReNameDir(request *DataNodeReNameRequest, reply *DataNodeReplyStatus) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataNodeData ¶
type DataNodeData struct {
Data string
}
type DataNodeDeleteRequest ¶
type DataNodeGetRequest ¶
type DataNodeInstance ¶
type DataNodePutRequest ¶
type DataNodePutRequest struct { RemoteFilePath string BlockId string Data string ReplicationNodes []DataNodeInstance }
type DataNodeReNameRequest ¶
type DataNodeReplyStatus ¶
type DataNodeReplyStatus struct {
Status bool
}
type NameNodePingRequest ¶
type NameNodePingResponse ¶
type NameNodePingResponse struct {
Ack bool
}
type Service ¶
type Service struct { DataDirectory string ServicePort uint16 NameNodeHost string NameNodePort uint16 }
func (*Service) DeleteFile ¶
func (dataNode *Service) DeleteFile(request *DataNodeDeleteRequest, reply *DataNodeReplyStatus) error
DeleteFile 删除远端文件 输入:相对路径+BlockId 返回:执行成功与否
func (*Service) DeletePath ¶
func (dataNode *Service) DeletePath(request *DataNodeDeleteRequest, reply *DataNodeReplyStatus) error
DeletePath 删除远端文件目录 输入:相对路径 返回:执行成功与否
func (*Service) GetData ¶
func (dataNode *Service) GetData(request *DataNodeGetRequest, reply *DataNodeData) error
GetData 获取blockId对应的数据内容 读取请求:FilePath+BlockId
func (*Service) MakeDir ¶
func (dataNode *Service) MakeDir(request string, reply *DataNodeReplyStatus) error
MakeDir 创建datanode节点文件目录
func (*Service) Ping ¶
func (dataNode *Service) Ping(request *NameNodePingRequest, reply *NameNodePingResponse) error
Ping 维护dataNode的元数据信息:NameNodeHost,NameNodePort,同时测试调用rpc方法消息的应答
func (*Service) PutData ¶
func (dataNode *Service) PutData(request *DataNodePutRequest, reply *DataNodeReplyStatus) error
PutData 将BlockSize大小的数据写入datanode节点对应的路径 文件写入请求:路径,BlockId,实际数据,备份的节点信息 reply:是否写入成功
func (*Service) ReNameDir ¶
func (dataNode *Service) ReNameDir(request *DataNodeReNameRequest, reply *DataNodeReplyStatus) error
ReNameDir 重命名文件目录
Click to show internal directories.
Click to hide internal directories.