mirror of
https://gitee.com/rainbond/Rainbond.git
synced 2024-12-02 19:57:42 +08:00
93 lines
3.4 KiB
Go
93 lines
3.4 KiB
Go
// Copyright (C) 2nilfmt.Errorf("a")4-2nilfmt.Errorf("a")8 Goodrain Co., Ltd.
|
|
// RAINBOND, Application Management Platform
|
|
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version. For any non-GPL usage of Rainbond,
|
|
// one or multiple Commercial Licenses authorized by Goodrain Co., Ltd.
|
|
// must be obtained first.
|
|
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
package gc
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path"
|
|
|
|
"github.com/Sirupsen/logrus"
|
|
eventutil "github.com/goodrain/rainbond/eventlog/util"
|
|
"github.com/goodrain/rainbond/worker/discover/model"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/client-go/kubernetes"
|
|
)
|
|
|
|
// GarbageCollector -
|
|
type GarbageCollector struct {
|
|
clientset kubernetes.Interface
|
|
}
|
|
|
|
// NewGarbageCollector -
|
|
func NewGarbageCollector(clientset kubernetes.Interface) *GarbageCollector {
|
|
gcr := &GarbageCollector{
|
|
clientset: clientset,
|
|
}
|
|
return gcr
|
|
}
|
|
|
|
// DelLogFile deletes persistent data related to the service based on serviceID.
|
|
func (g *GarbageCollector) DelLogFile(serviceGCReq model.ServiceGCTaskBody) {
|
|
logrus.Infof("service id: %s; delete log file.", serviceGCReq.ServiceID)
|
|
// log generated during service running
|
|
logPath := "/grdata/logs"
|
|
dockerLogPath := eventutil.DockerLogFilePath(logPath, serviceGCReq.ServiceID)
|
|
if err := os.RemoveAll(dockerLogPath); err != nil {
|
|
logrus.Warningf("remove docker log files: %v", err)
|
|
}
|
|
// log generated by the service event
|
|
eventLogPath := eventutil.EventLogFilePath(logPath)
|
|
for _, eventID := range serviceGCReq.EventIDs {
|
|
eventLogFileName := eventutil.EventLogFileName(eventLogPath, eventID)
|
|
logrus.Debugf("remove event log file: %s", eventLogFileName)
|
|
if err := os.RemoveAll(eventLogFileName); err != nil {
|
|
logrus.Warningf("file: %s; remove event log file: %v", eventLogFileName, err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// DelVolumeData -
|
|
func (g *GarbageCollector) DelVolumeData(serviceGCReq model.ServiceGCTaskBody) {
|
|
f := func(prefix string) {
|
|
dir := path.Join(prefix, fmt.Sprintf("tenant/%s/service/%s", serviceGCReq.TenantID, serviceGCReq.ServiceID))
|
|
logrus.Infof("volume data. delete %s", dir)
|
|
if err := os.RemoveAll(dir); err != nil {
|
|
logrus.Warningf("dir: %s; remove volume data: %v", dir, err)
|
|
}
|
|
}
|
|
f("/grdata")
|
|
}
|
|
|
|
// DelPvPvcByServiceID -
|
|
func (g *GarbageCollector) DelPvPvcByServiceID(serviceGCReq model.ServiceGCTaskBody) {
|
|
logrus.Infof("service_id: %s", serviceGCReq.ServiceID)
|
|
deleteOpts := &metav1.DeleteOptions{}
|
|
listOpts := metav1.ListOptions{
|
|
LabelSelector: fmt.Sprintf("service_id=%s", serviceGCReq.ServiceID),
|
|
}
|
|
if err := g.clientset.CoreV1().PersistentVolumes().DeleteCollection(deleteOpts, listOpts); err != nil {
|
|
logrus.Warningf("service id: %s; delete a collection fo PV: %v", serviceGCReq.ServiceID, err)
|
|
}
|
|
|
|
if err := g.clientset.CoreV1().PersistentVolumeClaims(serviceGCReq.TenantID).DeleteCollection(deleteOpts, listOpts); err != nil {
|
|
logrus.Warningf("service id: %s; delete a collection fo PVC: %v", serviceGCReq.ServiceID, err)
|
|
}
|
|
}
|