dbclient

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 8, 2021 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
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

func (AddonNode) TableName 

func (AddonNode) TableName() string

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 

type DBClient struct {
	*dbengine.DBEngine
}

func Open 

func Open(db *dbengine.DBEngine) *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 

func (c *DBClient) CreateEdgeApp(edgeApp *EdgeApp) error

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 

func (c *DBClient) CreateEdgeSite(edgeSite *EdgeSite) error

CreateEdgeSite Create edge site record

func (*DBClient) DeleteEdgeApp 

func (c *DBClient) DeleteEdgeApp(edgeAppID int64) error

DeleteEdgeApp Delete edge application

func (*DBClient) DeleteEdgeCfgSetItemByCfgID 

func (c *DBClient) DeleteEdgeCfgSetItemByCfgID(configSetID int64) error

DeleteEdgeCfgSetItemByCfgID Delete all edge configSet item under provided configSet id

func (*DBClient) DeleteEdgeConfigSet 

func (c *DBClient) DeleteEdgeConfigSet(edgeConfigSetID int64) error

DeleteEdgeConfigSet Delete edge configSet

func (*DBClient) DeleteEdgeConfigSetItem 

func (c *DBClient) DeleteEdgeConfigSetItem(cfgSetItemID int64) error

DeleteEdgeConfigSetItem Delete edge configSet item

func (*DBClient) DeleteEdgeConfigSetItemBySiteID 

func (c *DBClient) DeleteEdgeConfigSetItemBySiteID(siteID int64) error

DeleteEdgeConfigSetItemBySiteID Delete all edge configSet item under provided site id

func (*DBClient) DeleteEdgeSite 

func (c *DBClient) DeleteEdgeSite(edgeSiteID int64) error

DeleteEdgeSite Delete edge site

func (*DBClient) GetEdgeApp 

func (c *DBClient) GetEdgeApp(edgeAppID int64) (*EdgeApp, error)

GetEdgeSite Get edge site by id

func (*DBClient) GetEdgeAppByConfigset 

func (c *DBClient) GetEdgeAppByConfigset(configSetName string, clusterID int64) (*[]EdgeApp, error)

GetEdgeAppByConfigset Get edge application by configSet name

func (*DBClient) GetEdgeAppByName 

func (c *DBClient) GetEdgeAppByName(appName string, orgID int64) (*EdgeApp, error)

GetEdgeAppByName Get edge application by name

func (*DBClient) GetEdgeAppsBySiteName 

func (c *DBClient) GetEdgeAppsBySiteName(siteName string, clusterID int64) (*[]EdgeApp, error)

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 

func (c *DBClient) GetEdgeSite(edgeSiteID int64) (*EdgeSite, error)

GetEdgeSite Get edge site

func (*DBClient) ListAllEdgeApp 

func (c *DBClient) ListAllEdgeApp(orgID int64) (*[]EdgeApp, error)

ListAllEdgeApp List all edge application by orgID

func (*DBClient) ListAllEdgeAppByClusterID 

func (c *DBClient) ListAllEdgeAppByClusterID(orgID, clusterID int64) (*[]EdgeApp, error)

ListAllEdgeAppByClusterID List all edge application by orgID and clusterID

func (*DBClient) ListDependsEdgeApps 

func (c *DBClient) ListDependsEdgeApps(orgID, clusterID int64, appName string) (*[]EdgeApp, error)

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 

func (c *DBClient) UpdateEdgeApp(edgeApp *EdgeApp) error

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 

func (c *DBClient) UpdateEdgeSite(edgeSite *EdgeSite) error

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

func (EdgeApp) TableName 

func (EdgeApp) TableName() string

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
	ClusterID   int64
	Status      int64
}

edge site model

func (EdgeSite) TableName 

func (EdgeSite) TableName() string

type OrgAK 

type OrgAK struct {
	dbengine.BaseModel
	OrgID       string     `gorm:"type:varchar(64);index"`
	Vendor      VendorType `gorm:"type:varchar(64);index"`
	AccessKey   string     `gorm:"type:text"`
	SecretKey   string     `gorm:"type:text"`
	Description string     `gorm:"type:text"`
}

func (OrgAK) TableName 

func (OrgAK) TableName() string

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
}

func (Record) TableName 

func (Record) TableName() string

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"
)

type VendorType 

type VendorType string
const (
	VendorTypeAliyun VendorType = "aliyun"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.