|
def | __init__ (self, meta_addrs, timeout=2000, load_period=10, decode_type='utf-8') |
|
def | close (self) |
|
def | __del__ (self) |
|
def | get_all_storage_addrs (self) |
|
def | get_tag_id (self, space_name, tag_name) |
|
def | get_edge_type (self, space_name, edge_name) |
|
def | get_space_id (self, space_name) |
|
def | get_tag_schema (self, space_name, tag_name) |
|
def | get_edge_schema (self, space_name, edge_name) |
|
def | get_part_leader (self, space_name, part_id) |
|
def | get_part_leaders (self, space_name) |
|
def | get_part_alloc (self, space_name) |
|
def | update_storage_leader (self, space_id, part_id, HostAddr address) |
|
Definition at line 252 of file __init__.py.
◆ close()
close the metaClient
:eturn: void
Definition at line 285 of file __init__.py.
◆ get_all_storage_addrs()
def get_all_storage_addrs |
( |
|
self | ) |
|
get all storage address
:return: list[HostAddr]
Definition at line 361 of file __init__.py.
◆ get_edge_schema()
def get_edge_schema |
( |
|
self, |
|
|
|
space_name, |
|
|
|
edge_name |
|
) |
| |
get edge schema
:param space_name:
:param edge_name:
:return: schema
Definition at line 413 of file __init__.py.
◆ get_edge_type()
def get_edge_type |
( |
|
self, |
|
|
|
space_name, |
|
|
|
edge_name |
|
) |
| |
get edge type
:param space_name:
:param edge_name:
:return: edge_type
Definition at line 379 of file __init__.py.
◆ get_part_alloc()
def get_part_alloc |
( |
|
self, |
|
|
|
space_name |
|
) |
| |
get all part info of the space
:param space_name: space name
:eturn: map<PartitionID, list<HostAddr>>
Definition at line 448 of file __init__.py.
◆ get_part_leader()
def get_part_leader |
( |
|
self, |
|
|
|
space_name, |
|
|
|
part_id |
|
) |
| |
:param space_name:
:param part_id:
:return: storage ip port: HostAddr
Definition at line 423 of file __init__.py.
◆ get_part_leaders()
def get_part_leaders |
( |
|
self, |
|
|
|
space_name |
|
) |
| |
get all part leader info of the space
:param space_name: space name
:eturn: map<PartitionID, HostAddr>
Definition at line 435 of file __init__.py.
◆ get_space_id()
def get_space_id |
( |
|
self, |
|
|
|
space_name |
|
) |
| |
get space id
:param space_name:
:return: space_id
Definition at line 390 of file __init__.py.
◆ get_tag_id()
def get_tag_id |
( |
|
self, |
|
|
|
space_name, |
|
|
|
tag_name |
|
) |
| |
get tag id
:param space_name:
:param tag_name:
:return: tag_id
Definition at line 368 of file __init__.py.
◆ get_tag_schema()
def get_tag_schema |
( |
|
self, |
|
|
|
space_name, |
|
|
|
tag_name |
|
) |
| |
get tag schema
:param space_name:
:param tag_name:
:return: schema
Definition at line 403 of file __init__.py.
◆ update_storage_leader()
def update_storage_leader |
( |
|
self, |
|
|
|
space_id, |
|
|
|
part_id, |
|
|
HostAddr |
address |
|
) |
| |
if the storage leader change, storage client need to call this function
:param space_id:
:param part_id:
:param address: HostAddr, if the address is None, it means the leader can't connect,
choose the peer as leader
:return: coid
Definition at line 487 of file __init__.py.
The documentation for this class was generated from the following file: