RDFS
The Rice Comp413 2017 class' continuation on the work of the 2016 RDFS.
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator Friends Pages
zkclient::ZkNnClient Member List

This is the complete list of members for zkclient::ZkNnClient, including all inherited members.

abandon_block(AbandonBlockRequestProto &req, AbandonBlockResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
add_block(AddBlockRequestProto &req, AddBlockResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
add_block(const std::string &fileName, u_int64_t &block_id, std::vector< std::string > &dataNodes, uint32_t replication_factor)zkclient::ZkNnClient
add_block_group(const std::string &filePath, u_int64_t &block_group_id, std::vector< std::string > &dataNodes, std::vector< char > &blockIndices, uint32_t total_num_storage_blocks)zkclient::ZkNnClient
append_file(AppendRequestProto &req, AppendResponseProto &res)zkclient::ZkNnClient
BLOCK_GROUP_LOCATIONS (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
BLOCK_LOCATIONS (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
BLOCKS (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
BLOCKS_TREE (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
cache_contains(const std::string &path) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
cache_size() (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
check_acks()zkclient::ZkNnClient
check_lease(std::string client_name, std::string file_path) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
CLASS_NAME (defined in zkclient::ZkNnClient)zkclient::ZkNnClientstatic
CLIENTS (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
complete(CompleteRequestProto &req, CompleteResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
create_file(CreateRequestProto &request, CreateResponseProto &response)zkclient::ZkNnClient
CreateResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
current_time_ms()zkclient::ZkNnClient
DEFAULT_DATA_UNITS (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_EC_CELLSIZE (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_EC_CODEC_NAME (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_EC_ID (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_EC_POLICY (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_EC_SCHEMA (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_PARITY_UNITS (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DEFAULT_STORAGE_ID (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
DELETE_QUEUES (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
DELETE_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
DeleteResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
destroy(DeleteRequestProto &req, DeleteResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
EC_RECOVER_QUEUES (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
EC_RECOVER_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
EC_REPLICATION (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
ErasureCodingPoliciesResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
ErasureCodingPolicyResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
file_exists(const std::string &path)zkclient::ZkNnClient
find_all_datanodes_with_block(const uint64_t &block_uuid, std::vector< std::string > &rdatanodes, int &error_code) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
find_datanode_for_block(std::vector< std::string > &datanodes, std::vector< std::string > &excluded_dns, const u_int64_t blockId, uint32_t replication_factor, uint64_t blocksize) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
find_live_datanodes(const uint64_t blockId, int error_code, std::vector< std::string > &live_data_nodes) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
find_parent(const std::string &path)zkclient::ZkNnClient
generate_block_group_id()zkclient::ZkNnClient
generate_storage_block_id(uint64_t block_group_id, uint64_t index_within_group)zkclient::ZkNnClient
get_block_group_id(u_int64_t storage_block_id)zkclient::ZkNnClient
get_block_locations(GetBlockLocationsRequestProto &req, GetBlockLocationsResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
get_block_locations(const std::string &src, google::protobuf::uint64 offset, google::protobuf::uint64 length, LocatedBlocksProto *blocks, std::string client_name="default") (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
get_block_metadata_path(u_int64_t block_or_block_group_id)zkclient::ZkClientCommon
get_block_size(const u_int64_t &block_id, uint64_t &blocksize)zkclient::ZkNnClient
get_client_lease_timestamp(std::string client_name)zkclient::ZkNnClient
get_content(GetContentSummaryRequestProto &req, GetContentSummaryResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
get_erasure_coding_policies(GetErasureCodingPoliciesRequestProto &req, GetErasureCodingPoliciesResponseProto &res)zkclient::ZkNnClient
get_erasure_coding_policy_of_path(GetErasureCodingPolicyRequestProto &req, GetErasureCodingPolicyResponseProto &res)zkclient::ZkNnClient
get_index_within_block_group(u_int64_t storage_block_id)zkclient::ZkNnClient
get_info(GetFileInfoRequestProto &req, GetFileInfoResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
get_listing(GetListingRequestProto &req, GetListingResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
get_node_policy() (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
get_primary_block_info(std::string file_path, AppendRequestProto &req, AppendResponseProto &res) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
get_total_num_storage_blocks(const std::string &fileName, u_int64_t &block_group_id)zkclient::ZkNnClient
GetFileInfoResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
HEALTH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
HEALTH_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
HEARTBEAT (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
init() (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommon
is_ec_block(u_int64_t block_id)zkclient::ZkClientCommonstatic
LEASES (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
ListingResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
mkdir(MkdirsRequestProto &req, MkdirsResponseProto &res)zkclient::ZkNnClient
MkdirResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
NAMESPACE_PATH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
policy (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
previousBlockComplete(uint64_t prev_id) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
process_request(std::string client_name, std::string file_path, AppendRequestProto &req) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
read_file_znode(FileZNode &znode_data, const std::string &path)zkclient::ZkNnClient
recover_lease(RecoverLeaseRequestProto &req, RecoverLeaseResponseProto &res) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
register_watches() (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
rename(RenameRequestProto &req, RenameResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
rename_ops_for_dir(const std::string &src, const std::string &dst, std::vector< std::shared_ptr< ZooOp >> &ops) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
rename_ops_for_file(const std::string &src, const std::string &dst, std::vector< std::shared_ptr< ZooOp >> &ops)zkclient::ZkNnClient
RenameResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
renew_lease(RenewLeaseRequestProto &req, RenewLeaseResponseProto &res)zkclient::ZkNnClient
REPLICATE_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
REPLICATE_QUEUES (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
REPLICATE_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
REPLICATION_1_2_SCHEMA (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
REPLICATION_EC_ID (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
REPLICATION_PROTO (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
REPLICATION_STORAGE_ID (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
RS_SOLOMON_PROTO (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
set_erasure_coding_policy_of_path(SetErasureCodingPolicyRequestProto &req, SetErasureCodingPolicyResponseProto &res)zkclient::ZkNnClient
set_file_info_content(ContentSummaryProto *status, const std::string &path, FileZNode &znode_data)zkclient::ZkNnClient
set_node_policy(char policy) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
set_owner(SetOwnerRequestProto &req, SetOwnerResponseProto &res, std::string client_name="default")zkclient::ZkNnClient
set_owner(SetOwnerRequestProto &req, SetOwnerResponseProto &res) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
set_permission(SetPermissionRequestProto &req, SetPermissionResponseProto &res)zkclient::ZkNnClient
SetErasureCodingPolicyResponse enum name (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
STATS (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
update_block_for_pipeline(UpdateBlockForPipelineRequestProto &req, UpdateBlockForPipelineResponseProto &res) (defined in zkclient::ZkNnClient)zkclient::ZkNnClient
WAIT_FOR_ACK (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
WAIT_FOR_ACK_BACKSLASH (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
WORK_QUEUES (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonstatic
zk (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommon
ZkClientCommon(std::string hostAndIp) (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonexplicit
ZkClientCommon(std::shared_ptr< ZKWrapper > zk) (defined in zkclient::ZkClientCommon)zkclient::ZkClientCommonexplicit
ZkNnClient(std::string zkIpAndAddress) (defined in zkclient::ZkNnClient)zkclient::ZkNnClientinlineexplicit
ZkNnClient(std::shared_ptr< ZKWrapper > zk_in, bool secureMode=false)zkclient::ZkNnClientinlineexplicit