Documentation ¶
Index ¶
- Constants
- type AddonManagement
- type AddonNode
- type AddonNodeList
- type DBClient
- func (c *DBClient) AddonManageReader() *addonManageReader
- func (c *DBClient) AddonManageWriter() *addonManageWriter
- func (c *DBClient) AddonNodeReader() *addonNodeReader
- func (c *DBClient) AddonNodeWriter() *addonNodeWriter
- func (c *DBClient) CreateEdgeApp(edgeApp *EdgeApp) error
- func (c *DBClient) CreateEdgeConfigSet(edgeConfigSet *EdgeConfigSet) error
- func (c *DBClient) CreateEdgeConfigSetItem(cfgSetItem *EdgeConfigSetItem) error
- func (c *DBClient) CreateEdgeSite(edgeSite *EdgeSite) error
- func (c *DBClient) DeleteEdgeApp(edgeAppID int64) error
- func (c *DBClient) DeleteEdgeCfgSetItemByCfgID(configSetID int64) error
- func (c *DBClient) DeleteEdgeConfigSet(edgeConfigSetID int64) error
- func (c *DBClient) DeleteEdgeConfigSetItem(cfgSetItemID int64) error
- func (c *DBClient) DeleteEdgeConfigSetItemBySiteID(siteID int64) error
- func (c *DBClient) DeleteEdgeSite(edgeSiteID int64) error
- func (c *DBClient) GetEdgeApp(edgeAppID int64) (*EdgeApp, error)
- func (c *DBClient) GetEdgeAppByConfigset(configSetName string, clusterID int64) (*[]EdgeApp, error)
- func (c *DBClient) GetEdgeAppByName(appName string, orgID int64) (*EdgeApp, error)
- func (c *DBClient) GetEdgeAppsBySiteName(siteName string, clusterID int64) (*[]EdgeApp, error)
- func (c *DBClient) GetEdgeConfigSet(configSetID int64) (*EdgeConfigSet, error)
- func (c *DBClient) GetEdgeConfigSetItem(itemID int64) (*EdgeConfigSetItem, error)
- func (c *DBClient) GetEdgeConfigSetItemsBySiteID(siteID int64) (*[]EdgeConfigSetItem, error)
- func (c *DBClient) GetEdgeSite(edgeSiteID int64) (*EdgeSite, error)
- func (c *DBClient) ListAllEdgeApp(orgID int64) (*[]EdgeApp, error)
- func (c *DBClient) ListAllEdgeAppByClusterID(orgID, clusterID int64) (*[]EdgeApp, error)
- func (c *DBClient) ListDependsEdgeApps(orgID, clusterID int64, appName string) (*[]EdgeApp, error)
- func (c *DBClient) ListEdgeApp(param *apistructs.EdgeAppListPageRequest) (int, *[]EdgeApp, error)
- func (c *DBClient) ListEdgeAppBySiteName(orgID, clusterID int64, siteName string) (*[]EdgeApp, error)
- func (c *DBClient) ListEdgeConfigSet(param *apistructs.EdgeConfigSetListPageRequest) (int, *[]EdgeConfigSet, error)
- func (c *DBClient) ListEdgeConfigSetItem(param *apistructs.EdgeCfgSetItemListPageRequest) (int, *[]EdgeConfigSetItem, error)
- func (c *DBClient) ListEdgeSite(param *apistructs.EdgeSiteListPageRequest) (int, *[]EdgeSite, error)
- func (c *DBClient) OrgAKReader() *orgakReader
- func (c *DBClient) OrgAKWriter() *orgakWriter
- func (c *DBClient) RecordsReader() *recordsReader
- func (c *DBClient) RecordsWriter() *recordsWriter
- func (c *DBClient) ResourceRoutingReader() *resourceRoutingReader
- func (c *DBClient) ResourceRoutingWriter() *resourceRoutingWriter
- func (c *DBClient) UpdateEdgeApp(edgeApp *EdgeApp) error
- func (c *DBClient) UpdateEdgeConfigSet(edgeConfigSet *EdgeConfigSet) error
- func (c *DBClient) UpdateEdgeConfigSetItem(cfgSetItem *EdgeConfigSetItem) error
- func (c *DBClient) UpdateEdgeSite(edgeSite *EdgeSite) error
- type EdgeApp
- type EdgeConfigSet
- type EdgeConfigSetItem
- type EdgeSite
- type OrgAK
- type Record
- type RecordType
- type ResourceRouting
- type ResourceType
- type RoutingStatus
- type StatusType
- type VendorType
Constants ¶
const (
ScopePublic = "public"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddonManagement ¶
type AddonManagement struct { ID uint64 `gorm:"primary_key"` AddonID string `gorm:"type:varchar(64)"` // Primary key Name string `gorm:"type:varchar(64)"` ProjectID string OrgID string AddonConfig string `gorm:"type:text"` CPU float64 Mem uint64 Nodes int CreateTime time.Time `gorm:"column:create_time"` UpdateTime time.Time `gorm:"column:update_time"` }
addon management
func (AddonManagement) TableName ¶
func (AddonManagement) TableName() string
type AddonNode ¶
type AddonNode struct { ID string `gorm:"type:varchar(64)"` InstanceID string `gorm:"type:varchar(64)"` // AddonInstance primary key Namespace string `gorm:"type:text"` NodeName string CPU float64 Mem uint64 Deleted string `gorm:"column:is_deleted"` // Y: deleted N: not delete CreatedAt time.Time `gorm:"column:create_time"` UpdatedAt time.Time `gorm:"column:update_time"` }
AddonNode Addon node info
type AddonNodeList ¶
type AddonNodeList []AddonNode
func (AddonNodeList) Len ¶
func (r AddonNodeList) Len() int
func (AddonNodeList) Less ¶
func (r AddonNodeList) Less(i, j int) bool
func (AddonNodeList) Swap ¶
func (r AddonNodeList) Swap(i, j int)
type DBClient ¶
func (*DBClient) AddonManageReader ¶
func (c *DBClient) AddonManageReader() *addonManageReader
read condition
func (*DBClient) AddonManageWriter ¶
func (c *DBClient) AddonManageWriter() *addonManageWriter
write
func (*DBClient) AddonNodeReader ¶
func (c *DBClient) AddonNodeReader() *addonNodeReader
func (*DBClient) AddonNodeWriter ¶
func (c *DBClient) AddonNodeWriter() *addonNodeWriter
func (*DBClient) CreateEdgeApp ¶
CreateEdgeApp Create edge application
func (*DBClient) CreateEdgeConfigSet ¶
func (c *DBClient) CreateEdgeConfigSet(edgeConfigSet *EdgeConfigSet) error
CreateEdgeConfigSet Create edge configSet
func (*DBClient) CreateEdgeConfigSetItem ¶
func (c *DBClient) CreateEdgeConfigSetItem(cfgSetItem *EdgeConfigSetItem) error
CreateEdgeConfigSetItem Create edge configSet item
func (*DBClient) CreateEdgeSite ¶
CreateEdgeSite Create edge site record
func (*DBClient) DeleteEdgeApp ¶
DeleteEdgeApp Delete edge application
func (*DBClient) DeleteEdgeCfgSetItemByCfgID ¶
DeleteEdgeCfgSetItemByCfgID Delete all edge configSet item under provided configSet id
func (*DBClient) DeleteEdgeConfigSet ¶
DeleteEdgeConfigSet Delete edge configSet
func (*DBClient) DeleteEdgeConfigSetItem ¶
DeleteEdgeConfigSetItem Delete edge configSet item
func (*DBClient) DeleteEdgeConfigSetItemBySiteID ¶
DeleteEdgeConfigSetItemBySiteID Delete all edge configSet item under provided site id
func (*DBClient) DeleteEdgeSite ¶
DeleteEdgeSite Delete edge site
func (*DBClient) GetEdgeApp ¶
GetEdgeSite Get edge site by id
func (*DBClient) GetEdgeAppByConfigset ¶
GetEdgeAppByConfigset Get edge application by configSet name
func (*DBClient) GetEdgeAppByName ¶
GetEdgeAppByName Get edge application by name
func (*DBClient) GetEdgeAppsBySiteName ¶
GetEdgeAppsBySiteName Get edge application
func (*DBClient) GetEdgeConfigSet ¶
func (c *DBClient) GetEdgeConfigSet(configSetID int64) (*EdgeConfigSet, error)
GetEdgeConfigSet Get edge configSet by configSet id
func (*DBClient) GetEdgeConfigSetItem ¶
func (c *DBClient) GetEdgeConfigSetItem(itemID int64) (*EdgeConfigSetItem, error)
GetEdgeConfigSetItem Get edge configSet item by id
func (*DBClient) GetEdgeConfigSetItemsBySiteID ¶
func (c *DBClient) GetEdgeConfigSetItemsBySiteID(siteID int64) (*[]EdgeConfigSetItem, error)
GetEdgeConfigSetItemsBySiteID Get configSet item by site id.
func (*DBClient) GetEdgeSite ¶
GetEdgeSite Get edge site
func (*DBClient) ListAllEdgeApp ¶
ListAllEdgeApp List all edge application by orgID
func (*DBClient) ListAllEdgeAppByClusterID ¶
ListAllEdgeAppByClusterID List all edge application by orgID and clusterID
func (*DBClient) ListDependsEdgeApps ¶
ListDependsEdgeApps List edge applications which depended
func (*DBClient) ListEdgeApp ¶
func (c *DBClient) ListEdgeApp(param *apistructs.EdgeAppListPageRequest) (int, *[]EdgeApp, error)
ListEdgeApp List edge app by paging
func (*DBClient) ListEdgeAppBySiteName ¶
func (c *DBClient) ListEdgeAppBySiteName(orgID, clusterID int64, siteName string) (*[]EdgeApp, error)
ListEdgeAppBySiteName List edge application by site name under specified cluster
func (*DBClient) ListEdgeConfigSet ¶
func (c *DBClient) ListEdgeConfigSet(param *apistructs.EdgeConfigSetListPageRequest) (int, *[]EdgeConfigSet, error)
ListEdgeConfigSet List edge configSet
func (*DBClient) ListEdgeConfigSetItem ¶
func (c *DBClient) ListEdgeConfigSetItem(param *apistructs.EdgeCfgSetItemListPageRequest) (int, *[]EdgeConfigSetItem, error)
ListEdgeConfigSetItem List edge configSet item
func (*DBClient) ListEdgeSite ¶
func (c *DBClient) ListEdgeSite(param *apistructs.EdgeSiteListPageRequest) (int, *[]EdgeSite, error)
ListEdgeSite List edge site
func (*DBClient) OrgAKReader ¶
func (c *DBClient) OrgAKReader() *orgakReader
func (*DBClient) OrgAKWriter ¶
func (c *DBClient) OrgAKWriter() *orgakWriter
func (*DBClient) RecordsReader ¶
func (c *DBClient) RecordsReader() *recordsReader
func (*DBClient) RecordsWriter ¶
func (c *DBClient) RecordsWriter() *recordsWriter
func (*DBClient) ResourceRoutingReader ¶
func (c *DBClient) ResourceRoutingReader() *resourceRoutingReader
func (*DBClient) ResourceRoutingWriter ¶
func (c *DBClient) ResourceRoutingWriter() *resourceRoutingWriter
func (*DBClient) UpdateEdgeApp ¶
UpdateEdgeApp Update edge application
func (*DBClient) UpdateEdgeConfigSet ¶
func (c *DBClient) UpdateEdgeConfigSet(edgeConfigSet *EdgeConfigSet) error
UpdateEdgeConfigSet Update edge configSet
func (*DBClient) UpdateEdgeConfigSetItem ¶
func (c *DBClient) UpdateEdgeConfigSetItem(cfgSetItem *EdgeConfigSetItem) error
UpdateEdgeConfigSetItem Update edge configSet item
func (*DBClient) UpdateEdgeSite ¶
UpdateEdgeSite Update edge site
type EdgeApp ¶
type EdgeApp struct { dbengine.BaseModel OrgID int64 Name string ClusterID int64 Type string Image string ProductID int64 AddonName string AddonVersion string RegistryAddr string RegistryUser string RegistryPassword string HealthCheckType string HealthCheckHttpPort int HealthCheckHttpPath string HealthCheckExec string ConfigSetName string Replicas int32 Description string EdgeSites string DependApp string LimitCpu float64 RequestCpu float64 LimitMem float64 RequestMem float64 PortMaps string ExtraData string }
edge app model
type EdgeConfigSet ¶
type EdgeConfigSet struct { dbengine.BaseModel OrgID int64 ClusterID int64 Name string DisplayName string Description string }
edge config set, union key: clusterName and name
func (EdgeConfigSet) TableName ¶
func (EdgeConfigSet) TableName() string
type EdgeConfigSetItem ¶
type EdgeConfigSetItem struct { dbengine.BaseModel ConfigsetID int64 Scope string SiteID int64 ItemKey string ItemValue string }
edge config data model, union key: clusterID, siteID, configKey TODO: ugly name
func (EdgeConfigSetItem) TableName ¶
func (EdgeConfigSetItem) TableName() string
type EdgeSite ¶
type EdgeSite struct { dbengine.BaseModel OrgID int64 Name string DisplayName string Description string Logo string ClusterID int64 Status int64 }
edge site model
type OrgAK ¶
type Record ¶
type Record struct { dbengine.BaseModel RecordType RecordType `gorm:"type:varchar(64)"` UserID string `gorm:"type:varchar(64)"` OrgID string `gorm:"type:varchar(64);index"` ClusterName string `gorm:"type:varchar(64);index"` Status StatusType `gorm:"type:varchar(64)"` Detail string `gorm:"type:text"` PipelineID uint64 }
type RecordType ¶
type RecordType string
const ( RecordTypeAddNodes RecordType = "addNodes" RecordTypeAddEssNodes RecordType = "addEssNodes" RecordTypeAddAliNodes RecordType = "addAliNodes" RecordTypeRmNodes RecordType = "rmNodes" RecordTypeDeleteNodes RecordType = "deleteNodes" RecordTypeDeleteEssNodes RecordType = "deleteEssNodes" RecordTypeDeleteEssNodesCronJob RecordType = "deleteEssNodesCronJob" RecordTypeSetLabels RecordType = "setLabels" RecordTypeAddAliECSECluster RecordType = "addAliECSEdgeCluster" RecordTypeAddAliACKECluster RecordType = "addAliACKEdgeCluster" // TODO remove RecordTypeAddAliCSECluster RecordType = "addAliCSEdgeCluster" RecordTypeAddAliCSManagedCluster RecordType = "addAliCSManagedEdgeCluster" RecordTypeUpgradeEdgeCluster RecordType = "upgradeEdgeCluster" RecordTypeOfflineEdgeCluster RecordType = "offlineEdgeCluster" RecordTypeCreateAliCloudMysql RecordType = "createAliCloudMysql" RecordTypeCreateAliCloudMysqlDB RecordType = "createAliCloudMysqlDB" RecordTypeCreateAliCloudRedis RecordType = "createAliCloudRedis" RecordTypeCreateAliCloudOss RecordType = "createAliCloudOss" RecordTypeCreateAliCloudOns RecordType = "createAliCloudOns" RecordTypeCreateAliCloudOnsTopic RecordType = "createAliCloudOnsTopic" RecordTypeCreateAliCloudGateway RecordType = "createAliCloudGateway" )
func (RecordType) String ¶
func (r RecordType) String() string
type ResourceRouting ¶
type ResourceRouting struct { dbengine.BaseModel ResourceID string `gorm:"type:varchar(128); index"` // e.g mysql instance/db name ResourceName string `gorm:"type:varchar(64)"` // e.g mysql/mysql db ResourceType ResourceType `gorm:"type:varchar(32)"` Vendor string `gorm:"type:varchar(32)"` OrgID string `gorm:"type:varchar(64)"` ClusterName string `gorm:"type:varchar(64)"` ProjectID string `gorm:"type:varchar(64); index"` AddonID string `gorm:"type:varchar(64)"` Status RoutingStatus `gorm:"type:varchar(32)"` RecordID uint64 Detail string `gorm:"type:text"` }
func (ResourceRouting) TableName ¶
func (ResourceRouting) TableName() string
type ResourceType ¶
type ResourceType string
const ( ResourceTypeMysql ResourceType = "MYSQL" ResourceTypeMysqlDB ResourceType = "MYSQL_DB" ResourceTypeGateway ResourceType = "GATEWAY" ResourceTypeGatewayVpcGrant ResourceType = "GATEWAY_VPC_GRANT" ResourceTypeOns ResourceType = "ONS" ResourceTypeOnsTopic ResourceType = "ONS_TOPIC" ResourceTypeRedis ResourceType = "REDIS" ResourceTypeOss ResourceType = "OSS" )
func (ResourceType) String ¶
func (r ResourceType) String() string
type RoutingStatus ¶
type RoutingStatus string
const ( ResourceStatusCreated RoutingStatus = "CREATED" ResourceStatusDeleted RoutingStatus = "DELETED" ResourceStatusAttached RoutingStatus = "ATTACHED" ResourceStatusDetached RoutingStatus = "DETACHED" )
func (RoutingStatus) String ¶
func (r RoutingStatus) String() string
type StatusType ¶
type StatusType string
const ( StatusTypeSuccess StatusType = "success" StatusTypeFailed StatusType = "failed" StatusTypeProcessing StatusType = "processing" StatusTypeUnknown StatusType = "unknown" )