test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-12-03 04:07:51 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

[ADD] add test function

Browse Source
This commit is contained in:
zhoujunhao 2018-06-14 16:32:21 +08:00
parent 8d6c38d246
commit 5c3eef42d2
2 changed files with 56 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
appruntimesync/clean/clean.go
View File

@ -137,7 +137,7 @@ func (t *tenantServiceResource) Type() string {
return "tenantService"
}
func queryTenantServiceResource(m *Manager) []Resource {
func QueryTenantServiceResource(m *Manager) []Resource {
TenantServiceList := make([]Resource, 0, 100)
now := time.Now()
create_time := now.AddDate(0, 0, -7)
@ -196,7 +196,7 @@ func (k *k8sServiceResource) Type() string {
return "k8sService"
}
func queryK8sServiceResource(m *Manager) []Resource {
func QueryK8sServiceResource(m *Manager) []Resource {
ServivesMap := make(map[string][]string)
serviceList := make([]Resource, 0, 100)
@ -275,7 +275,7 @@ func (d *deploymentResource) Type() string {
return "deployment"
}
func queryDeploymentResource(m *Manager) []Resource {
func QueryDeploymentResource(m *Manager) []Resource {
DeploymentMap := make(map[string][]string)
DeploymentDelList := make([]Resource, 0, 100)
DeleteList, err := db.GetManager().K8sDeployReplicationDao().GetK8sDeployReplicationByIsDelete("deployment", true)
@ -354,7 +354,7 @@ func (s *statefulResource) Type() string {
return "statefulset"
}
func queryStatefulResource(m *Manager) []Resource {
func QueryStatefulResource(m *Manager) []Resource {
StatefulSetsMap := make(map[string][]string)
StatefulSetList := make([]Resource, 0, 100)
DeleteList, err := db.GetManager().K8sDeployReplicationDao().GetK8sDeployReplicationByIsDelete("statefulset", true)
@ -430,7 +430,7 @@ func (n *nameSpacesResource) Type() string {
return "namespaces"
}
func queryNameSpacesResource(m *Manager) []Resource {
func QueryNameSpacesResource(m *Manager) []Resource {
nameList := make([]string, 0, 200)
allList := make([]string, 0, 300)
NamespacesList := make([]Resource, 0, 100)
@ -505,7 +505,7 @@ func (r *rcResource) Type() string {
return "replicationcontroller"
}
func queryRcResource(m *Manager) []Resource {
func QueryRcResource(m *Manager) []Resource {
ReplicationControllersMap := make(map[string][]string)
RcList := make([]Resource, 0, 100)
DeleteList, err := db.GetManager().K8sDeployReplicationDao().GetK8sDeployReplicationByIsDelete("replicationcontroller", true)
@ -525,10 +525,14 @@ func queryRcResource(m *Manager) []Resource {
if err != nil {
logrus.Error(err)
}
fmt.Println("ReplicationControllersMap",ReplicationControllersMap)
for _, v := range ReplicationControllersList.Items {
val, ok := ReplicationControllersMap[v.Namespace]
if ok {
fmt.Println("ok:",v.Namespace)
if InSlice(v.Name, val) {
fmt.Println("存在：", v.Name)
s := &rcResource{
manager: m,
namespaces: v.Namespace,
@ -536,7 +540,11 @@ func queryRcResource(m *Manager) []Resource {
createTime: time.Now(),
}
RcList = append(RcList, s)
}else {
fmt.Println("不存在：",v.Name)
}
}else {
fmt.Println("no",v.Namespace)
}
}
@ -560,12 +568,12 @@ func NewManager(ctx context.Context, kubeclient *kubernetes.Clientset) (*Manager
kubeclient: kubeclient,
}
queryResource := []func(*Manager) []Resource{
queryRcResource,
queryNameSpacesResource,
queryStatefulResource,
queryDeploymentResource,
queryK8sServiceResource,
queryTenantServiceResource,
QueryRcResource,
QueryNameSpacesResource,
QueryStatefulResource,
QueryDeploymentResource,
QueryK8sServiceResource,
QueryTenantServiceResource,
}
m.queryResource = queryResource
dclient, err := client.NewEnvClient()
@ -622,10 +630,7 @@ func (m *Manager) PerformTasks() {
if res.IsTimeout() {
if res.IsClean() {
if err := res.DeleteResources(); err != nil {
logrus.Error("failed to delete：", err.Error())
}else {
fmt.Println("成功")
break
logrus.Error("failed to delete:", err)
}
}
m.l.Remove(rs)

35
appruntimesync/clean/clean_test.go Normal file
View File

@ -0,0 +1,35 @@
package clean
//type TestManager struct {
// ctx context.Context
// kubeclient *kubernetes.Clientset
// waiting []Resource
// queryResource []func(*Manager) []Resource
// cancel context.CancelFunc
// //l list.List
// //dclient *client.Client
//}
//func TestNewManager(t *testing.T) (*Manager, error) {
// c, err := clientcmd.BuildConfigFromFlags("", "../../../test/admin.kubeconfig")
// if err != nil {
// logrus.Error("read kube config file error.", err)
// return nil,err
// }
// clientset, err := kubernetes.NewForConfig(c)
// if err != nil {
// logrus.Error("create kube api client error", err)
// return nil,err
// }
// ctx, cancel := context.WithCancel(context.Background())
// defer cancel()
// m := &Manager{
// ctx: ctx,
// kubeclient: clientset,
// cancel: cancel,
//
// }
// m.CollectingTasks()
// return m,nil
//}