From c75c07a40d1baa0805845b0fa6845907227700df Mon Sep 17 00:00:00 2001 From: Zexi Li Date: Thu, 10 Oct 2024 19:07:51 +0800 Subject: [PATCH] feat(apigateway): add rpc methods of scheduler for apigateway (#21380) --- pkg/mcclient/modules/scheduler/mod_scheduler.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/pkg/mcclient/modules/scheduler/mod_scheduler.go b/pkg/mcclient/modules/scheduler/mod_scheduler.go index 24618a7eb0..a76b0f47e4 100644 --- a/pkg/mcclient/modules/scheduler/mod_scheduler.go +++ b/pkg/mcclient/modules/scheduler/mod_scheduler.go @@ -21,6 +21,7 @@ import ( "yunion.io/x/jsonutils" api "yunion.io/x/onecloud/pkg/apis/scheduler" + "yunion.io/x/onecloud/pkg/httperrors" "yunion.io/x/onecloud/pkg/mcclient" "yunion.io/x/onecloud/pkg/mcclient/auth" "yunion.io/x/onecloud/pkg/mcclient/modulebase" @@ -118,6 +119,18 @@ func (this *SchedulerManager) DoForecast(s *mcclient.ClientSession, params jsonu return obj, err } +func (this *SchedulerManager) DoHistoryList(s *mcclient.ClientSession, params jsonutils.JSONObject) (jsonutils.JSONObject, error) { + return this.HistoryList(s, params) +} + +func (this *SchedulerManager) DoHistoryShow(s *mcclient.ClientSession, params jsonutils.JSONObject) (jsonutils.JSONObject, error) { + sessionId, err := params.GetString("session_id") + if err != nil { + return nil, httperrors.NewNotFoundError("session_id") + } + return this.HistoryShow(s, sessionId, params) +} + func (this *SchedulerManager) Cleanup(s *mcclient.ClientSession, params jsonutils.JSONObject) (jsonutils.JSONObject, error) { url := newSchedURL("cleanup") return modulebase.Post(this.ResourceManager, s, url, params, "")