sqlstore

package

v1.19.1 Latest Latest Go to latest Published: Oct 25, 2022 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/marklinglon/bcs-gamestatefulset

Documentation ¶

Overview ¶

Package sqlstore is main SQL database storage

Index ¶

Constants
Variables
func CreateBCSClusterInfo(external *m.BCSClusterInfo) error
func CreateCluster(cluster *m.Cluster) error
func CreateExternalUserRecord(record *m.ExternalUserRecord) error
func CreateRegisterToken(clusterId string) error
func CreateUser(user *m.User) error
func CreateUserToken(userToken *m.UserToken) error
func DelWsCredentials(serverKey string)
func GetAllCluster() []m.Cluster
func GetCluster(clusterId string) *m.Cluster
func GetClusterByBCSInfo(sourceProjectID string, sourceClusterID string) *m.Cluster
func GetClusterByFuzzyClusterId(clusterId string) *m.Cluster
func GetClusterByIdentifier(clusterIdentifier string) *m.Cluster
func GetCredentials(clusterId string) *m.ClusterCredentials
func GetExternalUserRecord(sourceType uint, userId, userType string) *m.ExternalUserRecord
func GetOrCreateUser(sourceType uint, userId, userType string) (*m.User, error)
func GetOrCreateUserToken(user *m.User, tokenType uint, defaultToken string) (*m.UserToken, error)
func GetRegisterToken(clusterId string) *m.RegisterToken
func GetSubnetByClusterRegion(clusterRegion string) *m.TkeLbSubnet
func GetUser(id uint) *m.User
func GetUserByCondition(cond *m.User) *m.User
func GetUserClusterPerm(user *m.User, cluster *m.Cluster, name string) *m.UserClusterPermission
func GetUserToken(token string) *m.UserToken
func GetUserTokenByUser(user *m.User, tokenType uint) *m.UserToken
func GetWsCredentials(serverKey string) *m.WsClusterCredentials
func GetWsCredentialsByClusterId(clusterId string) []*m.WsClusterCredentials
func InitCoreDatabase(conf *config.ApiServConfig) error
func QueryBCSClusterInfo(info *m.BCSClusterInfo) *m.BCSClusterInfo
func QueryTkeCidr(tkeCidr *m.TkeCidr) *m.TkeCidr
func SaveCredentials(clusterId, serverAddresses, caCertData, userToken, clusterDomain string) error
func SaveTkeCidr(vpc, cidr string, ipNumber uint, status, cluster string) error
func SaveTkeLbSubnet(clusterRegion, subnetId string) error
func SaveUserClusterPerm(backend int, user *m.User, cluster *m.Cluster, name string, isActive bool) error
func SaveWsCredentials(serverKey, clientModule, serverAddress, caCertData, userToken string) error
func UpdateTkeCidr(tkeCidr, updatedTkeCidr *m.TkeCidr) error
func UpdateUserToken(userToken, updatedUserToken *m.UserToken) error
type CidrCount
- func CountTkeCidr() []CidrCount

Constants ¶

View Source

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

View Source

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

View Source

const DefaultTokenLength = 32

View Source

const RegisterTokenLen = 128

Variables ¶

View Source

var GCoreDB *gorm.DB

Functions ¶

func CreateBCSClusterInfo ¶

func CreateBCSClusterInfo(external *m.BCSClusterInfo) error

func CreateCluster ¶

func CreateCluster(cluster *m.Cluster) error

func CreateExternalUserRecord ¶

func CreateExternalUserRecord(record *m.ExternalUserRecord) error

func CreateRegisterToken ¶

func CreateRegisterToken(clusterId string) error

CreateResterToken creates a new registerToken for given clusterId

func CreateUser ¶

func CreateUser(user *m.User) error

func CreateUserToken ¶

func CreateUserToken(userToken *m.UserToken) error

func DelWsCredentials ¶

func DelWsCredentials(serverKey string)

func GetAllCluster ¶

func GetAllCluster() []m.Cluster

GetAllCluster query for all clusters

func GetCluster ¶

func GetCluster(clusterId string) *m.Cluster

GetCluster query for the cluster by given clusterId

func GetClusterByBCSInfo ¶

func GetClusterByBCSInfo(sourceProjectID string, sourceClusterID string) *m.Cluster

GetClusterByBCSInfo query for the cluster by given clusterId

func GetClusterByFuzzyClusterId ¶

func GetClusterByFuzzyClusterId(clusterId string) *m.Cluster

GetCluster query for the cluster by given fuzzy clusterId

func GetClusterByIdentifier ¶

func GetClusterByIdentifier(clusterIdentifier string) *m.Cluster

GetClusterByIdentifier query for the cluster by given identifier, which is a random string generated when the cluster was created.

func GetCredentials ¶

func GetCredentials(clusterId string) *m.ClusterCredentials

GetCredentials query for clusterCredentials by clusterId

func GetExternalUserRecord ¶

func GetExternalUserRecord(sourceType uint, userId, userType string) *m.ExternalUserRecord

func GetOrCreateUser ¶

func GetOrCreateUser(sourceType uint, userId, userType string) (*m.User, error)

func GetOrCreateUserToken ¶

func GetOrCreateUserToken(user *m.User, tokenType uint, defaultToken string) (*m.UserToken, error)

func GetRegisterToken ¶

func GetRegisterToken(clusterId string) *m.RegisterToken

GetRegisterToken return the registerToken by clusterId

func GetSubnetByClusterRegion ¶

func GetSubnetByClusterRegion(clusterRegion string) *m.TkeLbSubnet

func GetUser ¶

func GetUser(id uint) *m.User

Query user by user_id

func GetUserByCondition ¶

func GetUserByCondition(cond *m.User) *m.User

Query user by condition

func GetUserClusterPerm ¶

func GetUserClusterPerm(user *m.User, cluster *m.Cluster, name string) *m.UserClusterPermission

func GetUserToken ¶

func GetUserToken(token string) *m.UserToken

func GetUserTokenByUser ¶

func GetUserTokenByUser(user *m.User, tokenType uint) *m.UserToken

GetUserTokenByUser get user_token of tokenType by user

func GetWsCredentials ¶

func GetWsCredentials(serverKey string) *m.WsClusterCredentials

GetWsCredentials query for clusterCredentials of cluster registered by websocket

func GetWsCredentialsByClusterId ¶

func GetWsCredentialsByClusterId(clusterId string) []*m.WsClusterCredentials

func InitCoreDatabase ¶

func InitCoreDatabase(conf *config.ApiServConfig) error

InitCoreDabase initialize the GLOBAL database object

func QueryBCSClusterInfo ¶

func QueryBCSClusterInfo(info *m.BCSClusterInfo) *m.BCSClusterInfo

Query BCSClusterInfo search a BCSClusterInfo object using given conditions

func QueryTkeCidr ¶

func QueryTkeCidr(tkeCidr *m.TkeCidr) *m.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 SaveTkeLbSubnet ¶

func SaveTkeLbSubnet(clusterRegion, subnetId string) error

func SaveUserClusterPerm ¶

func SaveUserClusterPerm(backend int, user *m.User, cluster *m.Cluster, name string, isActive bool) error

SaveUserClusterPerm saves a user cluster permission to database, it will update the `UpdatedAt` filed to current timestamp.

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 *m.TkeCidr) error

func UpdateUserToken ¶

func UpdateUserToken(userToken, updatedUserToken *m.UserToken) 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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
utils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL