Skip to content

Commit b3e9ab7

Browse files
committed
feat(backend): redis-cluster 支持存储访问入口 #7712
1 parent bd4e938 commit b3e9ab7

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

dbm-ui/backend/db_meta/api/cluster/nosqlcomm/detail_cluster.py

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
from django.utils.translation import gettext as _
1414

1515
from backend.db_meta.api.cluster.base.graph import Graphic, Group, LineLabel
16+
from backend.db_meta.enums import ClusterEntryRole
1617
from backend.db_meta.models import Cluster, StorageInstanceTuple
1718

1819
logger = logging.getLogger("root")
@@ -33,7 +34,7 @@ def scan_cluster(cluster: Cluster) -> Graphic:
3334
).filter(receiver__cluster=cluster, ejector__cluster=cluster):
3435
ejector_instance = tr.ejector
3536
receiver_instance = tr.receiver
36-
ejector_instance_node, ejector_instance_grp = graph.add_node(ejector_instance)
37+
ejector_instance_node, ejector_instance_group = graph.add_node(ejector_instance)
3738
receiver_instance_node, receiver_instance_group = graph.add_node(receiver_instance)
3839
graph.add_line(source=ejector_instance_node, target=receiver_instance_node, label=LineLabel.Rep)
3940

@@ -47,8 +48,14 @@ def scan_cluster(cluster: Cluster) -> Graphic:
4748
graph.add_line(source=proxy_instance_group, target=backend_instance_grp, label=LineLabel.Access)
4849

4950
master_bind_entry_group = Group(node_id="master_bind_entry_group", group_name=_("访问入口(主)"))
50-
for be in proxy_instance.bind_entry.all():
51-
dummy_be_node, master_bind_entry_group = graph.add_node(be, to_group=master_bind_entry_group)
51+
for bind_entry in proxy_instance.bind_entry.filter(role=ClusterEntryRole.MASTER_ENTRY.value):
52+
dummy_be_node, master_bind_entry_group = graph.add_node(bind_entry, to_group=master_bind_entry_group)
5253
graph.add_line(source=master_bind_entry_group, target=proxy_instance_group, label=LineLabel.Bind)
5354

55+
# 存储层访问入口
56+
nodes_bind_entry_group = Group(node_id="nodes_bind_entry_group", group_name=_("存储层访问入口"))
57+
for bind_entry in proxy_instance.bind_entry.filter(role=ClusterEntryRole.NODE_ENTRY.value):
58+
dummy_be_node, nodes_bind_entry_group = graph.add_node(bind_entry, to_group=nodes_bind_entry_group)
59+
graph.add_line(source=nodes_bind_entry_group, target=backend_instance_grp, label=LineLabel.Bind)
60+
5461
return graph

0 commit comments

Comments
 (0)