sqlstore

Documentation

Index

• Constants
• Variables
• func CreateCluster(cluster *models.BcsCluster) error
• func CreateRegisterToken(clusterId string) error
• func CreateRole(role *models.BcsRole) error
• func CreateUser(user *models.BcsUser) error
• func CreateUserResourceRole(urr *models.BcsUserResourceRole) error
• func DelWsCredentials(serverKey string)
• func DeleteUserResourceRole(urr *models.BcsUserResourceRole) error
• func GetCluster(clusterId string) *models.BcsCluster
• func GetCredentials(clusterId string) *models.BcsClusterCredential
• func GetRegisterToken(clusterId string) *models.BcsRegisterToken
• func GetRole(RoleName string) *models.BcsRole
• func GetUrrByCondition(cond *models.BcsUserResourceRole) *models.BcsUserResourceRole
• func GetUserByCondition(cond *models.BcsUser) *models.BcsUser
• func GetWsCredentials(serverKey string) *models.BcsWsClusterCredentials
• func GetWsCredentialsByClusterId(clusterId string) []*models.BcsWsClusterCredentials
• func InitCoreDatabase(conf *config.UserMgrConfig) error
• func ListCredentials() []models.BcsClusterCredential
• func ListOldCredentials() []models.ClusterCredentials
• func QueryTkeCidr(tkeCidr *models.TkeCidr) *models.TkeCidr
• func SaveCredentials(clusterId, serverAddresses, caCertData, userToken, clusterDomain string) error
• func SaveTkeCidr(vpc, cidr string, ipNumber uint, status, cluster string) error
• func SaveWsCredentials(serverKey, clientModule, serverAddress, caCertData, userToken string) error
• func UpdateTkeCidr(tkeCidr, updatedTkeCidr *models.TkeCidr) error
• func UpdateUser(user, updatedUser *models.BcsUser) error
• type CidrCount
  • func CountTkeCidr() []CidrCount

Constants

const (
	CidrStatusAvailable = "available"
	CidrStatusUsed      = "used"
	CidrStatusReserved  = "reserved"
)

const (
	// expired after 24 hours
	PlainUserExpiredTime = 24 * time.Hour
	// this means never expired
	AdminSaasUserExpiredTime = 10 * 365 * 24 * time.Hour
)

const (
	AdminUser = iota + 1
	SaasUser
	PlainUser
)

const RegisterTokenLen = 128

Variables

var GCoreDB *gorm.DB

Functions

func CreateCluster

func CreateCluster(cluster *models.BcsCluster) error

func CreateRegisterToken

func CreateRegisterToken(clusterId string) error

CreateResterToken creates a new registerToken for given clusterId

func CreateRole

func CreateRole(role *models.BcsRole) error

func CreateUser

func CreateUser(user *models.BcsUser) error

func CreateUserResourceRole

func CreateUserResourceRole(urr *models.BcsUserResourceRole) error

func DelWsCredentials

func DelWsCredentials(serverKey string)

func DeleteUserResourceRole

func DeleteUserResourceRole(urr *models.BcsUserResourceRole) error

func GetCluster

func GetCluster(clusterId string) *models.BcsCluster

func GetCredentials

func GetCredentials(clusterId string) *models.BcsClusterCredential

GetCredentials query for clusterCredentials by clusterId

func GetRegisterToken

func GetRegisterToken(clusterId string) *models.BcsRegisterToken

GetRegisterToken return the registerToken by clusterId

func GetRole

func GetRole(RoleName string) *models.BcsRole

func GetUrrByCondition

func GetUrrByCondition(cond *models.BcsUserResourceRole) *models.BcsUserResourceRole

Query BcsUserResourceRole by condition

func GetUserByCondition

func GetUserByCondition(cond *models.BcsUser) *models.BcsUser

Query user by condition

func GetWsCredentials

func GetWsCredentials(serverKey string) *models.BcsWsClusterCredentials

GetWsCredentials query for clusterCredentials of cluster registered by websocket

func GetWsCredentialsByClusterId

func GetWsCredentialsByClusterId(clusterId string) []*models.BcsWsClusterCredentials

func InitCoreDatabase

func InitCoreDatabase(conf *config.UserMgrConfig) error

func ListCredentials

func ListCredentials() []models.BcsClusterCredential

func ListOldCredentials

func ListOldCredentials() []models.ClusterCredentials

func QueryTkeCidr

func QueryTkeCidr(tkeCidr *models.TkeCidr) *models.TkeCidr

func SaveCredentials

func SaveCredentials(clusterId, serverAddresses, caCertData, userToken, clusterDomain string) error

SaveCredentials saves the current cluster credentials

func SaveTkeCidr

func SaveTkeCidr(vpc, cidr string, ipNumber uint, status, cluster string) error

func SaveWsCredentials

func SaveWsCredentials(serverKey, clientModule, serverAddress, caCertData, userToken string) error

SaveWsCredentials saves the credentials of cluster registered by websocket

func UpdateTkeCidr

func UpdateTkeCidr(tkeCidr, updatedTkeCidr *models.TkeCidr) error

func UpdateUser

func UpdateUser(user, updatedUser *models.BcsUser) error

Types

type CidrCount

type CidrCount struct {
	Count    int    `json:"count"`
	Vpc      string `json:"vpc"`
	IpNumber uint   `json:"ip_number"`
	Status   string `json:"status"`
}

func CountTkeCidr

func CountTkeCidr() []CidrCount