-
Notifications
You must be signed in to change notification settings - Fork 102
/
cluster.go
107 lines (90 loc) · 3.26 KB
/
cluster.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
/*
Copyright 2021 The KubeVela Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package model
import (
"time"
"github.com/oam-dev/kubevela/pkg/multicluster"
)
func init() {
RegisterModel(&Cluster{})
}
// ProviderInfo describes the information from provider API
type ProviderInfo struct {
Provider string `json:"provider"`
ClusterID string `json:"clusterID"`
ClusterName string `json:"clusterName,omitempty"`
Zone string `json:"zone,omitempty"`
ZoneID string `json:"zoneID,omitempty"`
RegionID string `json:"regionID,omitempty"`
VpcID string `json:"vpcID,omitempty"`
Labels map[string]string `json:"labels"`
}
const (
// ClusterStatusHealthy healthy cluster
ClusterStatusHealthy = "Healthy"
// ClusterStatusUnhealthy unhealthy cluster
ClusterStatusUnhealthy = "Unhealthy"
)
var (
// LocalClusterCreatedTime create time for local cluster, set to late date in order to ensure it is sorted to first
LocalClusterCreatedTime = time.Date(2999, 1, 1, 0, 0, 0, 0, time.UTC)
)
// Cluster describes the model of cluster in apiserver
type Cluster struct {
BaseModel
Name string `json:"name" gorm:"primaryKey"`
Alias string `json:"alias"`
Description string `json:"description"`
Icon string `json:"icon"`
Labels map[string]string `json:"labels" gorm:"serializer:json"`
Status string `json:"status"`
Reason string `json:"reason"`
Provider ProviderInfo `json:"provider" gorm:"serializer:json"`
APIServerURL string `json:"apiServerURL"`
DashboardURL string `json:"dashboardURL"`
KubeConfig string `json:"kubeConfig"`
KubeConfigSecret string `json:"kubeConfigSecret"`
}
// SetCreateTime for local cluster, create time is set to a large date which ensures the order of list
func (c *Cluster) SetCreateTime(t time.Time) {
if c.Name == multicluster.ClusterLocalName {
c.CreateTime = LocalClusterCreatedTime
c.SetUpdateTime(t)
} else {
c.CreateTime = t
}
}
// TableName table name for datastore
func (c *Cluster) TableName() string {
return tableNamePrefix + "cluster"
}
// ShortTableName is the compressed version of table name for kubeapi storage and others
func (c *Cluster) ShortTableName() string {
return "cls"
}
// PrimaryKey primary key for datastore
func (c *Cluster) PrimaryKey() string {
return c.Name
}
// Index set to nil for list
func (c *Cluster) Index() map[string]interface{} {
index := make(map[string]interface{})
if c.Name != "" {
index["name"] = c.Name
}
return index
}
// DeepCopy create a copy of cluster
func (c *Cluster) DeepCopy() *Cluster {
return deepCopy(c).(*Cluster)
}