ivampiresp/Lae
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加 节点类型选择

Browse Source
This commit is contained in:
iVampireSP.com 2023-02-09 19:08:54 +08:00
parent bf60034518
commit 75a0449ae8
No known key found for this signature in database
GPG Key ID: 2F7B001CA27A8132
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/Support/ClusterSupport.php
View File

@ -84,6 +84,7 @@ public static function hset($key, $value, $data = []): void
* @param string|array $events 事件名称 * @param string|array $events 事件名称
* @param $callback callable 回调函数，接收一个参数，为事件数据。 * @param $callback callable 回调函数，接收一个参数，为事件数据。
* @param $ignore_self bool 是否忽略此节点的消息。 * @param $ignore_self bool 是否忽略此节点的消息。
*
* @return void * @return void
*/ */
public static function listen(string|array $events, callable $callback, bool $ignore_self = true): void public static function listen(string|array $events, callable $callback, bool $ignore_self = true): void
@ -143,7 +144,7 @@ public static function hget($key, $hashKey, $default = []): string|array|null
return $value ?: $default; return $value ?: $default;
} }
public static function nodes($hide_ip = false): array public static function nodes($hide_ip = false, $type = 'all'): array
{ {
$nodes = self::hgetAll('nodes'); $nodes = self::hgetAll('nodes');
@ -156,6 +157,10 @@ public static function nodes($hide_ip = false): array
unset($nodes[$key]['ip']); unset($nodes[$key]['ip']);
} }
if ($type !== 'all' && $nodes[$key]['type'] !== $type) {
continue;
}
$append_nodes[] = $nodes[$key]; $append_nodes[] = $nodes[$key];
} }