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.