改进
This commit is contained in:
parent
3b50f77513
commit
089f97ff79
@ -18,7 +18,7 @@ class NodeController extends Controller
|
||||
*
|
||||
* @return View
|
||||
*/
|
||||
public function index()
|
||||
public function index(): View
|
||||
{
|
||||
$nodes = ClusterSupport::nodes();
|
||||
|
||||
@ -32,7 +32,7 @@ public function index()
|
||||
* @param string $node
|
||||
* @return JsonResponse
|
||||
*/
|
||||
public function update(Request $request, string $node)
|
||||
public function update(Request $request, string $node): JsonResponse
|
||||
{
|
||||
$request->validate([
|
||||
'weight' => 'sometimes|integer|min:0|max:100',
|
||||
@ -45,7 +45,7 @@ public function update(Request $request, string $node)
|
||||
return $this->success('Updated');
|
||||
}
|
||||
|
||||
public function event(Request $request)
|
||||
public function event(Request $request): \Illuminate\Http\RedirectResponse
|
||||
{
|
||||
$request->validate([
|
||||
'restart' => 'nullable|string|max:10|in:web,queue',
|
||||
@ -62,7 +62,7 @@ public function event(Request $request)
|
||||
return back()->with('success', '已经向集群广播命令。');
|
||||
}
|
||||
|
||||
public function stream()
|
||||
public function stream(): StreamedResponse
|
||||
{
|
||||
$response = new StreamedResponse(function () {
|
||||
ClusterSupport::publish('monitor.started');
|
||||
|
@ -23,7 +23,7 @@ public function index(Request $request): JsonResponse
|
||||
} catch (EmqxSupportException $e) {
|
||||
Log::error('emqx connect failed.', [$e]);
|
||||
|
||||
return $this->error('unable connectto emqx');
|
||||
return $this->error('unable connect to emqx');
|
||||
}
|
||||
|
||||
return $this->success($clients);
|
||||
|
@ -21,7 +21,7 @@ public function index(): View
|
||||
return view('hosts.index', compact('hosts'));
|
||||
}
|
||||
|
||||
public function renew(Host $host)
|
||||
public function renew(Host $host): RedirectResponse
|
||||
{
|
||||
$price = $host->getRenewPrice();
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user