model

package

Go to main page

Versions in this module

v0

v0.7.1

Dec 15, 2022

v0.7.0

Sep 28, 2022

Changes in this version

+ func SaveByInstanceId(instance Instance) error

+ func UpdateWhere(model interface{}, where map[string]interface{}, ...) error

type Cluster

+ AuthType string

+ KeyId string

type ClusterTag

+ ValueDesc string

type ExpandTaskInfo

+ func (e *ExpandTaskInfo) GetCount() int

type FindSecurityGroupConditions

+ AK string

+ Provider string

+ RegionId string

+ type KeyPair struct

+ KeyPairId string

+ KeyPairName string

+ KeyType string

+ PrivateKey string

+ Provider string

+ PublicKey string

+ RegionId string

+ func (r *KeyPair) AfterFind(*gorm.DB) (err error)

+ func (r *KeyPair) BeforeSave(*gorm.DB) (err error)

+ func (t *KeyPair) GetIdStr() string

+ func (t *KeyPair) TableName() string

type Network

+ AK string

type SecurityGroup

+ AK string

+ Provider string

+ RegionId string

+ func FindSecurityGroupById(ctx context.Context, securityGroupId string) (result SecurityGroup, err error)

type SecurityGroupRule

+ func FindSecurityGroupRulesById(ctx context.Context, securityGroupId string) (result []SecurityGroupRule, err error)

type ShrinkTaskInfo

+ func (e *ShrinkTaskInfo) GetCount() int

type Switch

+ func FindSwitchById(ctx context.Context, vpcId, switchId string) (result Switch, err error)

type TaskInfo

+ GetCount func() int

+ type TaskResult struct

+ SuccessNum int

type Vpc

+ AK string

v0.6.0

Jan 27, 2022

v0.5.1

Jan 27, 2022

Changes in this version

+ func UpdateUserType(ctx context.Context, ids []int64, updates map[string]interface{}) error

type User

+ func GetUserList(ctx context.Context, orgId int64, pageNum, pageSize int) ([]User, int64, error)

+ func GetUsersByUsernamesAndUserType(ctx context.Context, usernames []string, userType int8) ([]User, error)

v0.5.0

Jan 14, 2022

Changes in this version

+ func ListClusterInstallStep(clusterId int64) (result []gf_cluster.KubernetesInstallStep, err error)

type Cluster

+ ExtendConfig string

+ func (c *Cluster) GetCpuType() string

+ func (c *Cluster) GetInstanceTypeDesc() string

+ func (c *Cluster) UnmarshalExtendConfig() (*types.ExtendConfig, error)

v0.4.0

Dec 24, 2021

Changes in this version

+ func CreateClusterWithTagsAndInstances(ctx context.Context, cluster *Cluster, tags []*ClusterTag, ...) error

+ func GetAksByOrgAk(ctx context.Context, orgId int64, ak string) ([]string, error)

+ func GetKubernetesClusterByName(clusterName string) (*gf_cluster.KubernetesInfo, error)

type Cluster

+ ClusterType string

+ type ClusterSearchCond struct

+ AccountKeys []string

+ ClusterName string

+ ClusterType string

+ PageNum int

+ PageSize int

+ Provider string

+ Usage string

+ type ConnectableResult struct

+ InstanceIp string

+ IsPass bool

+ type CustomClusterInstance struct

+ InstanceIp string

+ LoginName string

+ LoginPassword string

+ type ExtractCondition struct

+ Operations []string

+ Operators []int64

+ PageNumber int

+ PageSize int

+ TimeEnd time.Time

+ TimeStart time.Time

type FindSwitchesConditions

+ ZoneId string

type FindVpcConditions

+ AccountKey string

type Instance

+ Attrs *string

+ type InstanceAttr struct

+ LoginName string

+ LoginPassword string

+ type OperationLog struct

+ Diff string

+ ObjectName string

+ Operation string

+ Operator int64

+ UserName string

+ func ExtractLogs(ctx context.Context, conds ExtractCondition) (logs []OperationLog, count int64, err error)

+ func (OperationLog) TableName() string

type User

+ func GetUsersByIDs(ctx context.Context, ids []int64) []User

v0.3.0

Dec 17, 2021

v0.2.1

Dec 17, 2021

Changes in this version

+ func GetAllProvider(ctx context.Context) (provider []string, err error)

type Account

+ EncryptedAccountSecret string

+ Salt string

+ func GetAccountByAk(ctx context.Context, ak string) (a Account, err error)

type Base

+ func (b *Base) GetId() int64

+ type Cacheable interface

+ GetId func() int64

type Cluster

+ ImageConfig string

type Switch

+ GatewayIp string

type User

+ func GetUserThroughBigCache(ids []int64, keyMaker func(int64) string, ...) ([]*User, []int64, error)

v0.2.0

Dec 10, 2021

Changes in this version

+ func CreateInstanceFormFromDB(instanceForm *gf_cluster.InstanceForm) error

+ func CreateInstanceGroupFromDB(instanceGroup *gf_cluster.InstanceGroup) error

+ func DeleteInstanceGroupFromDB(instanceGroupId int64) error

+ func DeleteKubernetesCluster(kubernetesId int64) error

+ func GetInstanceGroupFromDB(instanceGroupId int64) (*gf_cluster.InstanceGroup, error)

+ func GetKubernetesCluster(kubernetesId int64) (*gf_cluster.KubernetesInfo, error)

+ func ListAllInstanceGroupFromDB() ([]*gf_cluster.InstanceGroup, error)

+ func ListInstanceFormFromDB(id string, pageNumber int, pageSize int) ([]*gf_cluster.InstanceForm, int64, error)

+ func ListInstanceGroupByUser(curUserId string) ([]*gf_cluster.InstanceGroup, error)

+ func ListInstanceGroupFromDB(name string, pageNumber int, pageSize int) ([]*gf_cluster.InstanceGroup, int64, error)

+ func ListInstanceGroupInKubernetes(kubernetesId int64) ([]*gf_cluster.InstanceGroup, error)

+ func ListKubernetesClusters(id string, name string, pageNumber int, pageSize int) ([]*gf_cluster.KubernetesInfo, int, error)

+ func ListRunningKubernetesClusters() ([]*gf_cluster.KubernetesInfo, error)

+ func RegisterKubernetesCluster(kubernetes *gf_cluster.KubernetesInfo) error

+ func UpdateInstanceGroupFromDB(instanceGroup *gf_cluster.InstanceGroup) error

+ func UpdateInstanceGroupInstanceCountFromDB(count int, id int64) error

+ func UpdateKubernetesCluster(kubernetes *gf_cluster.KubernetesInfo) error

type ExpandTaskInfo

+ func (e *ExpandTaskInfo) GetAfterInstanceCount(success int) (afterCount int)

+ func (e *ExpandTaskInfo) GetBeforeInstanceCount() (beforeCount int)

+ func (e *ExpandTaskInfo) GetCreateUsername() (username string)

+ func (e *ExpandTaskInfo) GetExpectInstanceCount() (expectCount int)

type ShrinkTaskInfo

+ func (s *ShrinkTaskInfo) GetAfterInstanceCount(success int) (afterCount int)

+ func (s *ShrinkTaskInfo) GetBeforeInstanceCount() (beforeCount int)

+ func (s *ShrinkTaskInfo) GetCreateUsername() (username string)

+ func (s *ShrinkTaskInfo) GetExpectInstanceCount() (expectCount int)

type TaskInfo

+ GetAfterInstanceCount func(success int) (afterCount int)

+ GetBeforeInstanceCount func() (beforeCount int)

+ GetCreateUsername func() (username string)

+ GetExpectInstanceCount func() (expectCount int)

type User

+ func GetUserById(ctx context.Context, uid int64) (*User, error)

v0.1.5

Dec 8, 2021

Changes in this version

+ func QueryFirst(where map[string]interface{}, out interface{}) error

type Cluster

+ ChargeConfig string

+ func (c *Cluster) GetChargeType() string

+ func (c *Cluster) UnmarshalChargeConfig() (*types.ChargeConfig, error)

type ClusterTag

+ func GetBySpecifyClusterTag(clusterName string, tagKey string) (*ClusterTag, error)

+ func GetClusterNamesByTags(ctx context.Context, tags map[string]string, pageSize, pageNum int) ([]ClusterTag, int64, error)

+ func GetClusterTags(ctx context.Context, clusterName, tagKey string, pageNum, pageSize int) ([]ClusterTag, int64, error)

+ func GetClusterTagsByClusterNames(ctx context.Context, clusterNames []string) ([]ClusterTag, error)

type ExpandTaskInfo

+ BeforeCount int

+ func (e *ExpandTaskInfo) GetBeforeAndExpectInstanceCount() (beforeCount int, expectCount int)

type Instance

+ ChargeType string

+ ExpireAt *time.Time

type ShrinkTaskInfo

+ BeforeCount int

+ func (e *ShrinkTaskInfo) GetBeforeAndExpectInstanceCount() (beforeCount int, expectCount int)

+ type TaskInfo interface

+ GetBeforeAndExpectInstanceCount func() (beforeCount int, expectCount int)

v0.1.4

Nov 26, 2021

v0.1.3

Nov 25, 2021

v0.1.2

Nov 23, 2021

Changes in this version

type Cluster

+ DeleteUniqKey int64

type InstanceType

+ func GetInstanceTypeByName(ctx context.Context, instanceTypeName string) (*InstanceType, error)

v0.1.1

Nov 22, 2021

Changes in this version

+ func CreateIgnoreDuplicate(model interface{}) error

type Account

+ func (a *Account) BeforeSave(tx *gorm.DB) (err error)

type Cluster

+ func GetOneRegionByAccKey(accountKey string) (*Cluster, error)

v0.1.0

Nov 19, 2021

Changes in this version

+ const BATCH_SIZE

+ const InstanceTypeStatusActivated

+ const InstanceTypeStatusExpired

+ const InstanceTypeStatusNoActivate

+ func AddSecurityGroupRule(ctx context.Context, r SecurityGroupRule) error

+ func BatchCreate(values interface{}) error

+ func BatchCreateInstance(instances []Instance) error

+ func BatchUpdateByInstanceIds(instanceIds []string, instance Instance) error

+ func Count(where map[string]interface{}, model interface{}) (int64, error)

+ func CountActiveInstancesByClusterName(ctx context.Context, clusterNames []string) (int64, error)

+ func CountByTaskStatus(taskFilter string, statuses []string) (int64, error)

+ func Create(model interface{}) error

+ func CreateSecurityGroup(ctx context.Context, s SecurityGroup) error

+ func CreateSwitch(ctx context.Context, s Switch) error

+ func CreateVpc(ctx context.Context, vpc Vpc) error

+ func Delete(model interface{}) error

+ func DropExpiredInstanceType(ctx context.Context, tx *gorm.DB) error

+ func Get(id int64, out interface{}) error

+ func GetAccountSecretByAccountKey(ak string) string

+ func GetAksByOrgAkProvider(ctx context.Context, orgId int64, ak, provider string) ([]string, error)

+ func GetTaskCount(ctx context.Context, clusterNames []string) (int64, error)

+ func Gets(ids []int64, out interface{}) error

+ func Query(where map[string]interface{}, page int, pageSize int, models interface{}, ...) (count int64, err error)

+ func QueryAll(where map[string]interface{}, models interface{}, order string) (err error)

+ func QueryWhere(where *gorm.DB, page int, pageSize int, models interface{}, order string, ...) (count int64, err error)

+ func ReplaceRules(ctx context.Context, vpcID, groupId string, rules []SecurityGroupRule) error

+ func Save(model interface{}) error

+ func UpdateByInstanceId(instance Instance) error

+ func UpdateInstanceTypeIStatus(ctx context.Context, tx *gorm.DB, status int) error

+ func UpdateOrCreateGroups(ctx context.Context, groups []SecurityGroup) error

+ func UpdateOrCreateSwitches(ctx context.Context, switches []Switch) error

+ func UpdateOrCreateVpcs(ctx context.Context, vpcs []Vpc) error

+ func UpdateSwitch(ctx context.Context, availableIpAddressCount, isDefault int, ...) error

+ func UpdateTaskStatus(taskIds []int64, status string) error

+ func UpdateUserStatus(ctx context.Context, model interface{}, usernames []string, ...) error

+ func UpdateVpc(ctx context.Context, vpcId, cidrBlock, vStatus string, switchIds []string) error

+ func Updates(model interface{}, ids []int64, updates map[string]interface{}) error

+ type Account struct

+ AccountKey string

+ AccountName string

+ AccountSecret string

+ CreateBy string

+ DeletedAt gorm.DeletedAt

+ OrgId int64

+ Provider string

+ UpdateBy string

+ func GetAccounts(provider, accountName, accountKey string, pageNum, pageSize int) ([]Account, int64, error)

+ func GetAccountsByAk(ctx context.Context, ak string) (a Account, err error)

+ func GetAccountsByOrgId(orgId int64) (accounts []Account, err error)

+ func GetDefaultAccountByProvider(provider string) (account Account, err error)

+ func (a *Account) AfterFind(tx *gorm.DB) (err error)

+ func (a *Account) BeforeCreate(tx *gorm.DB) (err error)

+ func (a Account) TableName() string

+ type Base struct

+ CreateAt *time.Time

+ Id int64

+ UpdateAt *time.Time

+ type Cluster struct

+ AccountKey string

+ ChargeType string

+ ClusterDesc string

+ ClusterName string

+ CreateBy string

+ DeletedAt gorm.DeletedAt

+ ExpectCount int

+ Image string

+ InstanceType string

+ NetworkConfig string

+ Password string

+ Provider string

+ RegionId string

+ Status string

+ StorageConfig string

+ UpdateBy string

+ ZoneId string

+ func GetByClusterName(clusterName string) (*Cluster, error)

+ func GetByClusterNames(clusterNames []string) ([]Cluster, error)

+ func GetClusterById(id int64) (*Cluster, error)

+ func GetRegionByAccKey(accountKey string) ([]Cluster, error)

+ func GetUpdatedCluster(currentTime time.Time) ([]Cluster, error)

+ func ListClustersByCond(ctx context.Context, accountKeys []string, clusterName, provider string, ...) ([]Cluster, int, error)

+ func (Cluster) TableName() string

+ type ClusterSnapshot struct

+ ActiveInstances []Instance

+ Cluster Cluster

+ RunningTask []Task

+ func GetClusterSnapshot(clusterName string) (*ClusterSnapshot, error)

+ type ClusterTag struct

+ ClusterName string

+ TagKey string

+ TagValue string

+ func GetTagsByClusterName(clusterName string) ([]ClusterTag, error)

+ func (ClusterTag) TableName() string

+ type ExpandTaskInfo struct

+ ClusterName string

+ Count int

+ TaskExecHost string

+ TaskSubmitHost string

+ UserId int64

+ type ExpandTaskRes struct

+ InstanceIdList []string

+ type FindSecurityGroupConditions struct

+ PageNumber int

+ PageSize int

+ SecurityGroupId string

+ SecurityGroupName string

+ VpcId string

+ type FindSwitchesConditions struct

+ PageNumber int

+ PageSize int

+ SwitchId string

+ SwitchName string

+ VpcId string

+ type FindVpcConditions struct

+ Aks []string

+ PageNumber int

+ PageSize int

+ Provider string

+ RegionId string

+ VpcId string

+ VpcName string

+ type Instance struct

+ ClusterName string

+ CreateAt *time.Time

+ DeleteAt *time.Time

+ Id int64

+ InstanceId string

+ IpInner string

+ IpOuter string

+ RunningAt *time.Time

+ ShrinkTaskId int64

+ Status constants.Status

+ TaskId int64

+ func GetActiveInstancesByClusterName(clusterName string) ([]Instance, error)

+ func GetActiveInstancesByClusters(ctx context.Context, clusterName []string) ([]Instance, error)

+ func GetActiveInstancesWithCount(clusterName string, count int) ([]Instance, error)

+ func GetDeletedInstancesByTime(ctx context.Context, clusterName []string, createBefore, deleteAfter time.Time) ([]Instance, error)

+ func GetInstanceByCond(ctx context.Context, cond InstanceSearchCond) (ret []Instance, total int64, err error)

+ func GetInstanceByInstanceId(instanceId string) (*Instance, error)

+ func GetInstanceByIpInner(ipInner string) (Instance, error)

+ func GetInstancesByIPs(ipList []string, clusterName string) ([]Instance, error)

+ func GetUsageInstancesBySpecifyDay(ctx context.Context, clusterName []string, createBefore, deleteAfter time.Time, ...) ([]Instance, int64, error)

+ func (Instance) TableName() string

+ type InstanceSearchCond struct

+ ClusterNames []string

+ InstanceId string

+ Ip string

+ PageNumber int

+ PageSize int

+ Status []string

+ type InstanceType struct

+ Core int

+ Family string

+ IStatus int

+ Memory int

+ Provider string

+ RegionId string

+ TypeName string

+ ZoneId string

+ func ScanInstanceType(ctx context.Context) (ins []InstanceType, err error)

+ func (InstanceType) TableName() string

+ type InstanceTypeCondition struct

+ Core int

+ Memory int

+ Provider string

+ RegionId string

+ ZoneId string

+ type Network struct

+ Ak string

+ InternetChargeType string

+ InternetMaxBandwidthOut string

+ RegionId string

+ SecurityGroup string

+ SubNetId string

+ VpcId string

+ func (Network) TableName() string

+ type Order struct

+ AccountName string

+ ChargeType string

+ Cost float32

+ Currency string

+ Extend string

+ OrderId string

+ OrderTime time.Time

+ PayStatus int8

+ Product string

+ Provider string

+ Quantity int32

+ RegionId string

+ UsageEndTime time.Time

+ UsageStartTime time.Time

+ func (Order) TableName() string

+ type Org struct

+ OrgName string

+ func (u *Org) TableName() string

+ type SecurityGroup struct

+ IsDel int

+ Name string

+ SecurityGroupId string

+ SecurityGroupType string

+ VpcId string

+ func FindSecurityGroupWithPage(ctx context.Context, cond FindSecurityGroupConditions) (result []SecurityGroup, total int64, err error)

+ func (SecurityGroup) TableName() string

+ type SecurityGroupIDStruct struct

+ SecurityGroupId string

+ func FindSecurityId(ctx context.Context, cond FindSecurityGroupConditions) (result SecurityGroupIDStruct, err error)

+ type SecurityGroupRule struct

+ CidrIp string

+ Direction string

+ GroupId string

+ IsDel int

+ PortRange string

+ PrefixListId string

+ Protocol string

+ SecurityGroupId string

+ VpcId string

+ func (SecurityGroupRule) TableName() string

+ type ShrinkTaskInfo struct

+ ClusterName string

+ Count int

+ IPs string

+ TaskExecHost string

+ TaskSubmitHost string

+ UserId int64

+ type Switch struct

+ AvailableIpAddressCount int

+ CidrBlock string

+ IsDefault int

+ IsDel int

+ Name string

+ SwitchId string

+ VStatus string

+ VpcId string

+ ZoneId string

+ func FindSwitchesWithPage(ctx context.Context, cond FindSwitchesConditions) (result []Switch, total int64, err error)

+ func (Switch) TableName() string

+ type SwitchIdStruct struct

+ SwitchId string

+ func FindSwitchId(ctx context.Context, cond FindSwitchesConditions) (result SwitchIdStruct, err error)

+ type Task struct

+ ErrMsg string

+ FinishTime *time.Time

+ Status string

+ SupportCancel bool

+ TaskAction string

+ TaskFilter string

+ TaskInfo string

+ TaskName string

+ TaskResult string

+ func GetExpireRunningTask(duration time.Duration) ([]Task, error)

+ func GetTaskByStatus(clusterName string, statuses []string) ([]Task, error)

+ func SearchTask(ctx context.Context, clusterNames []string, cond TaskSearchCond) (ret []Task, total int64, err error)

+ func (Task) TableName() string

+ type TaskSearchCond struct

+ ClusterName string

+ PageNumber int

+ PageSize int

+ TaskId string

+ TaskName string

+ TaskStatus string

+ type User struct

+ CreateBy string

+ OrgId int64

+ Password string

+ UserStatus string

+ UserType int8

+ Username string

+ func GetUserByName(ctx context.Context, username string) *User

+ func (u *User) TableName() string

+ type Vpc struct

+ Ak string

+ CidrBlock string

+ IsDel int

+ Name string

+ Provider string

+ RegionId string

+ SwitchIds string

+ VStatus string

+ VpcId string

+ func FindVpcById(ctx context.Context, cond FindVpcConditions) (result Vpc, err error)

+ func FindVpcsWithPage(ctx context.Context, cond FindVpcConditions) (result []Vpc, total int64, err error)

+ func (Vpc) TableName() string

+ type VpcIDStruct struct

+ VpcId string

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