Documentation
¶
Index ¶
- Constants
- Variables
- func AppToPb(app *App) *pb.App
- func AppVersionToPb(appVersion *AppVersion) *pb.AppVersion
- func AppVersionsToPbs(appVersions []*AppVersion) (pbAppVersions []*pb.AppVersion)
- func AppsToPbs(apps []*App) (pbApps []*pb.App)
- func CategoriesToPbs(categories []*Category) (pbCategories []*pb.Category)
- func CategoryToPb(category *Category) *pb.Category
- func ClusterCommonToPb(clusterCommon *ClusterCommon) *pb.ClusterCommon
- func ClusterCommonsToPbs(clusterCommons []*ClusterCommon) (pbClusterCommons []*pb.ClusterCommon)
- func ClusterLinkToPb(clusterLink *ClusterLink) *pb.ClusterLink
- func ClusterLinksToPbs(clusterLinks []*ClusterLink) (pbClusterLinks []*pb.ClusterLink)
- func ClusterLoadbalancerToPb(clusterLoadbalancer *ClusterLoadbalancer) *pb.ClusterLoadbalancer
- func ClusterLoadbalancersToPbs(clusterLoadbalancers []*ClusterLoadbalancer) (pbClusterLoadbalancers []*pb.ClusterLoadbalancer)
- func ClusterNodeToPb(clusterNode *ClusterNode) *pb.ClusterNode
- func ClusterNodeWrapperToPb(clusterNode *ClusterNode, clusterCommon *ClusterCommon, ...) *pb.ClusterNode
- func ClusterNodesToPbs(clusterNodes []*ClusterNode) (pbClusterNodes []*pb.ClusterNode)
- func ClusterRoleToPb(clusterRole *ClusterRole) *pb.ClusterRole
- func ClusterRolesToPbs(clusterRoles []*ClusterRole) (pbClusterRoles []*pb.ClusterRole)
- func ClusterToPb(cluster *Cluster) *pb.Cluster
- func ClusterWrapperToPb(clusterWrapper *ClusterWrapper) *pb.Cluster
- func GetColumnsFromStruct(s interface{}) []string
- func GetColumnsFromStructWithPrefix(prefix string, s interface{}) []string
- func JobToPb(job *Job) *pb.Job
- func JobsToPbs(jobs []*Job) (pbJobs []*pb.Job)
- func NewAppId() string
- func NewAppVersionId() string
- func NewCategoryId() string
- func NewClusterId() string
- func NewClusterNodeId() string
- func NewJobId() string
- func NewRepoEventId() string
- func NewRepoId() string
- func NewRepoLabelId() string
- func NewRepoSelectorId() string
- func NewRuntimeCrentialId() string
- func NewRuntimeId() string
- func NewRuntimeLabelId() string
- func NewTaskId() string
- func RepoEventToPb(repoTask *RepoEvent) *pb.RepoEvent
- func RepoEventsToPbs(repoTasks []*RepoEvent) (pbRepoTasks []*pb.RepoEvent)
- func RepoLabelToPb(repoLabel *RepoLabel) *pb.RepoLabel
- func RepoLabelsMap(repoLabels []*RepoLabel) map[string][]*RepoLabel
- func RepoLabelsToPbs(repoLabels []*RepoLabel) (pbRepoLabels []*pb.RepoLabel)
- func RepoProvidersMap(repoProviders []*RepoProvider) map[string][]*RepoProvider
- func RepoSelectorToPb(repoSelector *RepoSelector) *pb.RepoSelector
- func RepoSelectorsMap(repoSelectors []*RepoSelector) map[string][]*RepoSelector
- func RepoSelectorsToPbs(repoSelectors []*RepoSelector) (pbRepoSelectors []*pb.RepoSelector)
- func RepoToPb(repo *Repo) *pb.Repo
- func ReposToPbs(repos []*Repo) (pbRepos []*pb.Repo)
- func RuntimeCredentialMap(runtimeCredentials []*RuntimeCredential) map[string]*RuntimeCredential
- func RuntimeLabelToPb(runtimeLabel *RuntimeLabel) *pb.RuntimeLabel
- func RuntimeLabelsMap(runtimeLabels []*RuntimeLabel) map[string][]*RuntimeLabel
- func RuntimeLabelsToPbs(runtimeLabels []*RuntimeLabel) (pbRuntimeLabels []*pb.RuntimeLabel)
- func RuntimeToPb(runtime *Runtime) *pb.Runtime
- func RuntimeToPbs(runtimes []*Runtime) (pbRuntimes []*pb.Runtime)
- func TaskToPb(task *Task) *pb.Task
- func TasksToPbs(tasks []*Task) (pbTasks []*pb.Task)
- type App
- type AppVersion
- type Category
- type CategoryResource
- type Cluster
- type ClusterCommon
- type ClusterLink
- type ClusterLoadbalancer
- type ClusterNode
- type ClusterRole
- type ClusterSnapshot
- type ClusterUpgradeAudit
- type ClusterWrapper
- type Cmd
- type CmdCnodes
- type Eip
- type Instance
- type Job
- type Meta
- type Repo
- type RepoEvent
- type RepoLabel
- type RepoProvider
- type RepoSelector
- type Runtime
- type RuntimeCredential
- type RuntimeLabel
- type Subnet
- type Task
- type TaskLayer
- type Volume
- type Vpc
- type WalkFunc
Constants ¶
View Source
const ( ColumnRepoId = "repo_id" ColumnResouceId = "resource_id" ColumnCategoryId = "category_id" ColumnName = "name" ColumnDescription = "description" ColumnStatus = "status" ColumnType = "type" ColumnUrl = "url" ColumnCreateTime = "create_time" ColumnStatusTime = "status_time" ColumnSequence = "sequence" ColumnRepoLabelId = "repo_label_id" ColumnLabelKey = "label_key" ColumnLabelValue = "label_value" ColumnRepoSelectorId = "repo_selector_id" ColumnSelectorKey = "selector_key" ColumnSelectorValue = "selector_value" ColumnCredential = "credential" ColumnVisibility = "visibility" ColumnProvider = "provider" ColumnVersionId = "version_id" ColumnAppId = "app_id" )
View Source
const AppTableName = "app"
View Source
const AppVersionTableName = "app_version"
View Source
const CategoryResourceTableName = "category_resource"
View Source
const CategoryTableName = "category"
View Source
const ClusterCommonTableName = "cluster_common"
View Source
const ClusterLinkTableName = "cluster_link"
View Source
const ClusterLoadbalancerTableName = "cluster_loadbalancer"
View Source
const ClusterNodeTableName = "cluster_node"
View Source
const ClusterRoleTableName = "cluster_role"
View Source
const ClusterSnapshotTableName = "cluster_snapshot"
View Source
const ClusterTableName = "cluster"
View Source
const ClusterUpgradeAuditTableName = "cluster_upgrade_audit"
View Source
const JobTableName = "job"
View Source
const RepoEventTableName = "repo_event"
View Source
const RepoLabelTableName = "repo_label"
View Source
const RepoProviderTableName = "repo_provider"
View Source
const RepoSelectorTableName = "repo_selector"
View Source
const RepoTableName = "repo"
View Source
const RuntimeCredentialPrifix = "runtimec-"
View Source
const RuntimeCredentialTableName = "runtime_credential"
View Source
const RuntimeIdPrefix = "runtime-"
View Source
const RuntimeLabelTableName = "runtime_label"
View Source
const RuntimeTableName = "runtime"
View Source
const TaskTableName = "task"
Variables ¶
View Source
var AppColumns = GetColumnsFromStruct(&App{})
View Source
var AppVersionColumns = GetColumnsFromStruct(&AppVersion{})
View Source
var CategoryColumns = GetColumnsFromStruct(&Category{})
View Source
var CategoryResourceColumns = GetColumnsFromStruct(&CategoryResource{})
View Source
var ClusterColumns = GetColumnsFromStruct(&Cluster{})
View Source
var ClusterCommonColumns = GetColumnsFromStruct(&ClusterCommon{})
View Source
var ClusterLinkColumns = GetColumnsFromStruct(&ClusterLink{})
View Source
var ClusterLoadbalancerColumns = GetColumnsFromStruct(&ClusterLoadbalancer{})
View Source
var ClusterNodeColumns = GetColumnsFromStruct(&ClusterNode{})
View Source
var ClusterRoleColumns = GetColumnsFromStruct(&ClusterRole{})
View Source
var ClusterSnapshotColumns = GetColumnsFromStruct(&ClusterSnapshot{})
View Source
var ClusterUpgradeAuditColumns = GetColumnsFromStruct(&ClusterUpgradeAudit{})
View Source
var IndexedColumns = map[string][]string{
AppTableName: {
"app_id", "name", "repo_id", "description", "status",
"home", "icon", "screenshots", "maintainers", "sources",
"readme", "owner", "chart_name",
},
AppVersionTableName: {
"version_id", "app_id", "name", "owner", "description",
"package_name", "status",
},
JobTableName: {
"job_id", "cluster_id", "app_id", "version_id", "executor", "provider", "status", "owner",
},
TaskTableName: {
"job_id", "task_id", "executor", "status", "owner",
},
RepoTableName: {
"repo_id", "name", "type", "visibility", "status",
},
RuntimeTableName: {
"runtime_id", "provider", "zone", "status", "owner",
},
RepoLabelTableName: {
"repo_id", "repo_label_id", "status",
},
RepoSelectorTableName: {
"repo_id", "repo_selector_id", "status",
},
RepoEventTableName: {
"repo_event_id", "repo_id", "status",
},
ClusterTableName: {
"cluster_id", "app_id", "version_id", "status", "runtime_id", "frontgate_id", "owner",
},
ClusterNodeTableName: {
"cluster_id", "node_id", "status", "owner",
},
CategoryTableName: {
"category_id", "status", "locale", "owner", "name",
},
}
columns that can be search through sql '=' operator
View Source
var JobColumns = GetColumnsFromStruct(&Job{})
View Source
var RepoColumns = GetColumnsFromStruct(&Repo{})
View Source
var RepoColumnsWithTablePrefix = GetColumnsFromStructWithPrefix(RepoTableName, &Repo{})
View Source
var RepoEventColumns = GetColumnsFromStruct(&RepoEvent{})
View Source
var RepoLabelColumns = GetColumnsFromStruct(&RepoLabel{})
View Source
var RepoProviderColumns = GetColumnsFromStruct(&RepoProvider{})
View Source
var RepoSelectorColumns = GetColumnsFromStruct(&RepoSelector{})
View Source
var RuntimeColumns = GetColumnsFromStruct(&Runtime{})
View Source
var RuntimeColumnsWithTablePrefix = GetColumnsFromStructWithPrefix(RuntimeTableName, &Runtime{})
View Source
var RuntimeCredentialColumns = GetColumnsFromStruct(&RuntimeCredential{})
View Source
var RuntimeLabelColumns = GetColumnsFromStruct(&RuntimeLabel{})
View Source
var SearchColumns = map[string][]string{
AppTableName: {
"app_id", "name", "repo_id", "owner", "chart_name", "keywords",
},
AppVersionTableName: {
"version_id", "app_id", "name", "description", "owner", "package_name",
},
JobTableName: {
"executor", "provider",
},
TaskTableName: {
"job_id", "task_id", "status",
},
RuntimeTableName: {
"runtime_id", "name",
},
ClusterTableName: {
"name", "description",
},
ClusterNodeTableName: {
"name",
},
}
columns that can be search through sql 'like' operator
View Source
var SearchWordColumnTable = []string{ RuntimeTableName, AppTableName, AppVersionTableName, }
View Source
var TaskColumns = GetColumnsFromStruct(&Task{})
Functions ¶
func AppVersionToPb ¶
func AppVersionToPb(appVersion *AppVersion) *pb.AppVersion
func AppVersionsToPbs ¶
func AppVersionsToPbs(appVersions []*AppVersion) (pbAppVersions []*pb.AppVersion)
func CategoriesToPbs ¶
func CategoryToPb ¶
func ClusterCommonToPb ¶
func ClusterCommonToPb(clusterCommon *ClusterCommon) *pb.ClusterCommon
func ClusterCommonsToPbs ¶
func ClusterCommonsToPbs(clusterCommons []*ClusterCommon) (pbClusterCommons []*pb.ClusterCommon)
func ClusterLinkToPb ¶
func ClusterLinkToPb(clusterLink *ClusterLink) *pb.ClusterLink
func ClusterLinksToPbs ¶
func ClusterLinksToPbs(clusterLinks []*ClusterLink) (pbClusterLinks []*pb.ClusterLink)
func ClusterLoadbalancerToPb ¶
func ClusterLoadbalancerToPb(clusterLoadbalancer *ClusterLoadbalancer) *pb.ClusterLoadbalancer
func ClusterLoadbalancersToPbs ¶
func ClusterLoadbalancersToPbs(clusterLoadbalancers []*ClusterLoadbalancer) (pbClusterLoadbalancers []*pb.ClusterLoadbalancer)
func ClusterNodeToPb ¶
func ClusterNodeToPb(clusterNode *ClusterNode) *pb.ClusterNode
func ClusterNodeWrapperToPb ¶
func ClusterNodeWrapperToPb(clusterNode *ClusterNode, clusterCommon *ClusterCommon, clusterRole *ClusterRole) *pb.ClusterNode
func ClusterNodesToPbs ¶
func ClusterNodesToPbs(clusterNodes []*ClusterNode) (pbClusterNodes []*pb.ClusterNode)
func ClusterRoleToPb ¶
func ClusterRoleToPb(clusterRole *ClusterRole) *pb.ClusterRole
func ClusterRolesToPbs ¶
func ClusterRolesToPbs(clusterRoles []*ClusterRole) (pbClusterRoles []*pb.ClusterRole)
func ClusterToPb ¶
func ClusterWrapperToPb ¶
func ClusterWrapperToPb(clusterWrapper *ClusterWrapper) *pb.Cluster
func GetColumnsFromStruct ¶
func GetColumnsFromStruct(s interface{}) []string
func NewAppVersionId ¶
func NewAppVersionId() string
func NewCategoryId ¶
func NewCategoryId() string
func NewClusterId ¶
func NewClusterId() string
func NewClusterNodeId ¶
func NewClusterNodeId() string
func NewRepoEventId ¶
func NewRepoEventId() string
func NewRepoLabelId ¶
func NewRepoLabelId() string
func NewRepoSelectorId ¶
func NewRepoSelectorId() string
func NewRuntimeCrentialId ¶
func NewRuntimeCrentialId() string
func NewRuntimeId ¶
func NewRuntimeId() string
func NewRuntimeLabelId ¶
func NewRuntimeLabelId() string
func RepoEventToPb ¶
func RepoEventsToPbs ¶
func RepoLabelToPb ¶
func RepoLabelsMap ¶
func RepoLabelsToPbs ¶
func RepoProvidersMap ¶
func RepoProvidersMap(repoProviders []*RepoProvider) map[string][]*RepoProvider
func RepoSelectorToPb ¶
func RepoSelectorToPb(repoSelector *RepoSelector) *pb.RepoSelector
func RepoSelectorsMap ¶
func RepoSelectorsMap(repoSelectors []*RepoSelector) map[string][]*RepoSelector
func RepoSelectorsToPbs ¶
func RepoSelectorsToPbs(repoSelectors []*RepoSelector) (pbRepoSelectors []*pb.RepoSelector)
func ReposToPbs ¶
func RuntimeCredentialMap ¶
func RuntimeCredentialMap(runtimeCredentials []*RuntimeCredential) map[string]*RuntimeCredential
func RuntimeLabelToPb ¶
func RuntimeLabelToPb(runtimeLabel *RuntimeLabel) *pb.RuntimeLabel
func RuntimeLabelsMap ¶
func RuntimeLabelsMap(runtimeLabels []*RuntimeLabel) map[string][]*RuntimeLabel
func RuntimeLabelsToPbs ¶
func RuntimeLabelsToPbs(runtimeLabels []*RuntimeLabel) (pbRuntimeLabels []*pb.RuntimeLabel)
func RuntimeToPb ¶
func RuntimeToPbs ¶
func TasksToPbs ¶
Types ¶
type App ¶
type AppVersion ¶
type AppVersion struct {
VersionId string
AppId string
Owner string
Name string
Description string
PackageName string
Status string
Sequence uint32
CreateTime time.Time
StatusTime time.Time
UpdateTime *time.Time
}
func NewAppVersion ¶
func NewAppVersion(appId, name, description, owner, packageName string) *AppVersion
type Category ¶
type Category struct {
CategoryId string
Name string
Locale string
Owner string
CreateTime time.Time
UpdateTime *time.Time
}
func NewCategory ¶
type CategoryResource ¶
type CategoryResource struct {
CategoryId string
ResourceId string
Status string
CreateTime time.Time
StatusTime time.Time
}
func NewCategoryResource ¶
func NewCategoryResource(categoryId, resourceId, status string) *CategoryResource
type Cluster ¶
type Cluster struct {
ClusterId string
Name string
Description string
AppId string
VersionId string
SubnetId string
VpcId string
FrontgateId string
ClusterType uint32
Endpoints string
Status string
TransitionStatus string
MetadataRootAccess bool
Owner string
GlobalUuid string
UpgradeStatus string
UpgradeTime *time.Time
RuntimeId string
CreateTime time.Time
StatusTime time.Time
}
func NewCluster ¶
func NewCluster() *Cluster
func PbToCluster ¶
type ClusterCommon ¶
type ClusterCommon struct {
ClusterId string
Role string
ServerIdUpperBound uint32
AdvancedActions string
InitService string
StartService string
StopService string
ScaleOutService string
ScaleInService string
RestartService string
DestroyService string
UpgradeService string
CustomService string
BackupService string
RestoreService string
DeleteSnapshotService string
HealthCheck string
Monitor string
Passphraseless string
VerticalScalingPolicy string
AgentInstalled bool
CustomMetadataScript string
ImageId string
BackupPolicy string
IncrementalBackupSupported bool
Hypervisor string
}
func PbToClusterCommon ¶
func PbToClusterCommon(pbClusterCommon *pb.ClusterCommon) *ClusterCommon
func (ClusterCommon) GetAttribute ¶
func (c ClusterCommon) GetAttribute(attributeName string) interface{}
type ClusterLink ¶
func PbToClusterLink ¶
func PbToClusterLink(pbClusterLink *pb.ClusterLink) *ClusterLink
type ClusterLoadbalancer ¶
type ClusterLoadbalancer struct {
ClusterId string
Role string
LoadbalancerListenerId string
LoadbalancerPort uint32
LoadbalancerPolicyId string
}
func PbToClusterLoadbalancer ¶
func PbToClusterLoadbalancer(pbClusterLoadbalancer *pb.ClusterLoadbalancer) *ClusterLoadbalancer
type ClusterNode ¶
type ClusterNode struct {
NodeId string
ClusterId string
Name string
InstanceId string
VolumeId string
Device string
SubnetId string
PrivateIp string
ServerId uint32
Role string
Status string
TransitionStatus string
GroupId uint32
Owner string
GlobalServerId uint32
CustomMetadata string
PubKey string
HealthStatus string
IsBackup bool
AutoBackup bool
CreateTime time.Time
StatusTime time.Time
}
func NewClusterNode ¶
func NewClusterNode() *ClusterNode
func PbToClusterNode ¶
func PbToClusterNode(pbClusterNode *pb.ClusterNode) *ClusterNode
type ClusterRole ¶
type ClusterRole struct {
ClusterId string
Role string
Cpu uint32
Gpu uint32
Memory uint32
InstanceSize uint32
StorageSize uint32
MountPoint string
MountOptions string
FileSystem string
Env string
}
func PbToClusterRole ¶
func PbToClusterRole(pbClusterRole *pb.ClusterRole) *ClusterRole
type ClusterSnapshot ¶
type ClusterUpgradeAudit ¶
type ClusterWrapper ¶
type ClusterWrapper struct {
Cluster *Cluster
ClusterNodes map[string]*ClusterNode // key=nodeId
ClusterCommons map[string]*ClusterCommon // key=role
ClusterLinks map[string]*ClusterLink // key=name
ClusterRoles map[string]*ClusterRole // key=role
ClusterLoadbalancers map[string][]*ClusterLoadbalancer // key=role
}
func NewClusterWrapper ¶
func NewClusterWrapper(data string) (*ClusterWrapper, error)
func PbToClusterWrapper ¶
func PbToClusterWrapper(pbCluster *pb.Cluster) *ClusterWrapper
func (*ClusterWrapper) GetCommonAttribute ¶
func (c *ClusterWrapper) GetCommonAttribute(role, attributeName string) interface{}
func (*ClusterWrapper) GetEndpoints ¶
func (c *ClusterWrapper) GetEndpoints() (map[string]map[string]interface{}, error)
endpoints is in the following format:
{
"client_port": {
"port": 2181,
"protocol": "tcp"
},
"reserved_ips": {
"write_vip":{
},
"read_vip":{
}
}
}
where client_port is a developer-defined name. Port either is an integer or a reference to an env variable such as env.<port> or env.<role>.<port>. It may have multiple endpoints defined.
type CmdCnodes ¶
func NewCmdCnodes ¶
type Instance ¶
type Instance struct {
InstanceId string
NodeId string
Name string
ImageId string
Cpu int
Memory int
Gpu int
PrivateIp string
VolumeId string
Device string
LoginPasswd string
Subnet string
NeedUserData int
UserDataValue string
UserdataFile string
Zone string
Status string
TransitionStatus string
RuntimeId string
TargetJobId string // target cloud job id
Timeout int `json:"timeout"`
Hostname string
}
func NewInstance ¶
type Job ¶
type Meta ¶
type Repo ¶
type RepoEvent ¶
type RepoEvent struct {
RepoEventId string
RepoId string
Status string
Result string
Owner string
CreateTime time.Time
StatusTime time.Time
}
func NewRepoEvent ¶
type RepoLabel ¶
type RepoLabel struct {
RepoLabelId string
RepoId string
LabelKey string
LabelValue string
CreateTime time.Time
}
func NewRepoLabel ¶
type RepoProvider ¶
type RepoSelector ¶
type RepoSelector struct {
RepoSelectorId string
RepoId string
SelectorKey string
SelectorValue string
CreateTime time.Time
}
func NewRepoSelector ¶
func NewRepoSelector(repoId, selectorKey, selectorValue string) *RepoSelector
type Runtime ¶
type Runtime struct {
RuntimeId string
Name string
Description string
Provider string
RuntimeUrl string
Zone string
RuntimeCredentialId string
Owner string
Status string
CreateTime time.Time
StatusTime time.Time
}
func NewRuntime ¶
type RuntimeCredential ¶
func NewRuntimeCredential ¶
func NewRuntimeCredential(content string) *RuntimeCredential
type RuntimeLabel ¶
type RuntimeLabel struct {
RuntimeLabelId string
RuntimeId string
LabelKey string
LabelValue string
CreateTime time.Time
}
func NewRuntimeLabel ¶
func NewRuntimeLabel(runtimeId, labelKey, labelValue string) *RuntimeLabel
type Task ¶
type Task struct {
TaskId string
JobId string
TaskAction string
Directive string
Owner string
Status string
ErrorCode uint32
Executor string
Target string
NodeId string
FailureAllowed bool
CreateTime time.Time
StatusTime time.Time
}
type Volume ¶
Source Files
¶
- app.go
- app_version.go
- category.go
- category_resource.go
- cluster.go
- cluster_common.go
- cluster_link.go
- cluster_loadbalancer.go
- cluster_node.go
- cluster_role.go
- cluster_snapshot.go
- cluster_upgrade_audit.go
- cluster_wrapper.go
- cmd.go
- column_name.go
- common.go
- instance.go
- job.go
- meta.go
- repo.go
- repo_event.go
- repo_label.go
- repo_provider.go
- repo_selector.go
- runtime.go
- runtime_credential.go
- runtime_label.go
- subnet.go
- task.go
- task_layer.go
- volume.go
- vpc.go
Click to show internal directories.
Click to hide internal directories.