service

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

+ const DefaultRegionAws

+ const DefaultRegionBaidu

+ func CreateKeyPair(ctx context.Context, ak, provider, regionId, keyPairName string) error

+ func CreateKeyPairByPrivateKey(ctx context.Context, ...) (*model.KeyPair, error)

+ func DescribeSecurityGroups(provider, ak, regionId, vpcId string) ([]cloud.SecurityGroup, error)

+ func DoesSecurityGroupBelongsVpc(provider string) bool

+ func GetKeyPair(ctx context.Context, keyId int64) (*model.KeyPair, error)

+ func GetKeyPairByKeyIds(ctx context.Context, keyIds []int64) (map[int64]model.KeyPair, error)

+ func ImportKeyPair(ctx context.Context, ...) error

+ func IsInstanceReady(instance cloud.Instance, needPublicIp bool) bool

+ func ListKeyPairs(ctx context.Context, ak, provider, regionId string, page types.PageReq) ([]*model.KeyPair, *types.PageRsp, error)

+ func RefreshAccount(t *SimpleTask) error

+ func SyncNetwork(ctx context.Context, req SyncNetworkRequest) error

type AddSecurityGroupRuleRequest

+ AK string

type CreateNetworkRequest

+ AK string

+ GatewayIp string

+ Rules []GroupRule

type CreateSecurityGroupRequest

+ AK string

type CreateSwitchRequest

+ AK string

type CreateVPCRequest

+ AK string

type GetSecurityGroupRequest

+ AK string

type GetVPCFromCloudRequest

+ AK string

+ type GroupRuleRsp struct

+ CidrIp string

+ Direction string

+ GroupId string

+ PortRange string

+ PrefixListId string

+ Protocol string

+ type SecurityGroupWithRule struct

+ Rules []GroupRuleRsp

+ SgId string

+ SgName string

+ SgType string

+ func GetSecurityGroupWithRules(ctx context.Context, securityGroupId string) (SecurityGroupWithRule, error)

type Switch

+ GatewayIp string

+ func GetSwitchById(ctx context.Context, vpcId, switchId string) (Switch, error)

+ type SyncNetworkRequest struct

+ AccountKey string

+ Provider string

+ RegionId string

type Vpc

+ func GetVpcById(ctx context.Context, vpcId string) (Vpc, error)

v0.6.0

Jan 27, 2022

v0.5.1

Jan 27, 2022

Changes in this version

+ func ExistAdmin(ctx context.Context, usernames []string) (bool, error)

+ func ModifyUsertype(ctx context.Context, userIds []int64, userType int8) error

v0.5.0

Jan 14, 2022

Changes in this version

+ const DefaultRegionTencent

+ func CheckClusterParam(clusterInfo *types.ClusterInfo) error

+ func ExpandInDeed(c *types.ClusterInfo, num int, taskId int64) ([]string, error)

v0.4.0

Dec 24, 2021

Changes in this version

+ func CheckInstanceConnectable(instances []model.CustomClusterInstance) response.CheckInstanceConnectableResponse

+ func CheckIsGpuComputingPowerType(instanceType string, provider string) bool

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

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

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

+ func GetAllCustomInstanceInCluster(ctx context.Context, user *authorization.CustomClaims, clusterName string) ([]model.Instance, error)

+ func GetComputingPowerType(instanceType string, provider string) string

+ func GetStandardClusterNamesByAccounts(ctx context.Context, accountKeys []string) ([]string, error)

+ func IsNeedAkSk(clusterInfo *types.ClusterInfo) bool

+ func RecordOperationLog(ctx context.Context, oplog OperationLog) error

+ func UserMapByIDs(ctx context.Context, ids []int64) map[int64]string

+ type GetInstancesCond struct

+ AccountKeys []string

+ ClusterName string

+ InstanceId string

+ Ip string

+ PageNum int

+ PageSize int

+ Provider string

+ Status []string

type GetSwitchRequest

+ ZoneId string

type GetVPCRequest

+ AccountKey string

type InstancesSearchCond

+ ClusterName string

type ListInstanceTypeRequest

+ ComputingPowerType string

+ type Operation string

+ const OperationCreate

+ const OperationDelete

+ const OperationUpdate

+ type OperationLog struct

+ New schema.Tabler

+ Old schema.Tabler

+ Operation Operation

+ Operator int64

v0.3.0

Dec 17, 2021

v0.2.1

Dec 17, 2021

Changes in this version

+ const DefaultRegionHuaWei

+ func DecryptAccount(pepper, salt, key, encrypted string) (string, error)

+ func DecryptAccounts(accounts []*model.Account)

+ func EncryptAccount(pepper, salt, key, text string) (string, error)

+ func GetAccountSecretByAccountKey(ctx context.Context, ak string) (string, error)

+ func GetAllInstanceInCluster(ctx context.Context, user *authorization.CustomClaims, clusterName string) ([]model.Instance, error)

+ func GetBridgxUnusedCluster(ctx context.Context, user *authorization.CustomClaims, pageSize, pageNum int) ([]*gf_cluster.BridgxUnusedCluster, int, error)

+ func GetClusterAccount(ctx *gin.Context, clusterName string) (*model.Account, error)

+ func GetClusterInfo(ctx context.Context, clusterName string) (*types.ClusterInfo, error)

+ func MustDecryptAccounts(accounts []*model.Account) error

+ func TagBridgxClusterUsage(clusterName, systemName string) error

type CreateSwitchRequest

+ GatewayIp string

type GetImagesRequest

+ ImageType string

+ InsType string

type GroupRule

+ PortFrom int

+ PortTo int

v0.2.0

Dec 10, 2021

v0.1.5

Dec 8, 2021

Changes in this version

+ func CreateShrinkAllTask(ctx context.Context, clusterName, taskName string, uid int64) (int64, error)

+ func DeleteClusterTags(tags []model.ClusterTag) error

+ func EditClusterTags(tags []model.ClusterTag) error

+ func GetAccount(provider, accountKey string) (*model.Account, error)

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

+ func GetClusterTagsByClusters(ctx context.Context, clusters []model.Cluster) (map[string]map[string]string, error)

+ func GetClustersByTags(ctx context.Context, tags map[string]string, pageSize, pageNum int) ([]model.Cluster, int64, error)

+ func SyncInstanceExpireTime(ctx context.Context, clusterName string) error

v0.1.4

Nov 26, 2021

Changes in this version

type InstanceTypeByZone

+ func (i *InstanceTypeByZone) GetDesc() string

v0.1.3

Nov 25, 2021

v0.1.2

Nov 23, 2021

Changes in this version

+ const TargetTypeInstanceType

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

v0.1.1

Nov 22, 2021

v0.1.0

Nov 19, 2021

Changes in this version

+ const DefaultRegion

+ const DirectionIn

+ const DirectionOut

+ const TargetTypeAccount

+ const TargetTypeNetwork

+ const TargetTypeSecurityGroup

+ const TargetTypeSwitch

+ const TargetTypeVpc

+ func AddSecurityGroupRule(ctx context.Context, req AddSecurityGroupRuleRequest) (string, error)

+ func BatchCreateInstanceType(ctx context.Context, inss []model.InstanceType) error

+ func CheckAccountValid(ak, sk string) error

+ func CleanClusterUnusedInstances(clusterInfo *types.ClusterInfo) (int, error)

+ func ConvertToClusterInfo(m *model.Cluster, tags []model.ClusterTag) (*types.ClusterInfo, error)

+ func CountUser(ctx context.Context, orgId int64) (int64, error)

+ func CreateCloudAccount(ctx context.Context, accountName, provider, ak, sk string, orgId int64, ...) error

+ func CreateCluster(cluster *model.Cluster) error

+ func CreateCluster4Test(clusterName string) error

+ func CreateClusterTags(tags *[]model.ClusterTag) error

+ func CreateExpandTask(ctx context.Context, clusterName string, count int, taskName string, uid int64) (int64, error)

+ func CreateOrg(ctx context.Context, orgName, username, password, createBy string) error

+ func CreateSecurityGroup(ctx context.Context, req CreateSecurityGroupRequest) (securityGroupId string, err error)

+ func CreateShrinkTask(ctx context.Context, clusterName string, count int, ips string, ...) (int64, error)

+ func CreateSwitch(ctx context.Context, req CreateSwitchRequest) (switchId string, err error)

+ func CreateUser(ctx context.Context, orgId int64, username, password, createBy string) error

+ func CreateVPC(ctx context.Context, req CreateVPCRequest) (vpcId string, err error)

+ func DeleteCloudAccount(ctx context.Context, ids []int64, orgId int64) error

+ func DeleteClusters(ctx context.Context, ids []int64, orgId int64) error

+ func EditCloudAccount(ctx context.Context, id int64, accountName, provider, username string) error

+ func EditCluster(cluster *model.Cluster) error

+ func EditOrg(ctx context.Context, orgId int64, orgName string) error

+ func Expand(clusterInfo *types.ClusterInfo, tags []cloud.Tag, num int) (instanceIds []string, err error)

+ func ExpandAndRepair(c *types.ClusterInfo, num int, taskId int64) ([]string, error)

+ func ExpandCluster(c *types.ClusterInfo, num int, taskId int64) (instanceIds []cloud.Instance, err error)

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

+ func GetAccountsByOrgId(orgId int64) (*types.OrgKeys, error)

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

+ func GetAksByOrgId(orgId int64) ([]string, error)

+ func GetCloudInstancesByClusterName(clusterInfo *types.ClusterInfo) (instances []cloud.Instance, err error)

+ func GetClusterById(ctx context.Context, Id int64) (*model.Cluster, error)

+ func GetClusterByName(ctx context.Context, name string) (*model.Cluster, error)

+ func GetClusterCount(ctx context.Context, accountKeys []string) (count int64, err error)

+ func GetClusterTagsByClusterName(ctx context.Context, name string) ([]model.ClusterTag, error)

+ func GetClustersByNames(ctx context.Context, names []string) ([]model.Cluster, error)

+ func GetDefaultAccount(provider string) (*types.OrgKeys, error)

+ func GetEnabledClusterNamesByAccount(ctx context.Context, accountKey string) ([]string, error)

+ func GetEnabledClusterNamesByAccounts(ctx context.Context, accountKeys []string) ([]string, error)

+ func GetEnabledClusterNamesByCond(ctx context.Context, ak, clusterName string, aks []string, strict bool) ([]string, error)

+ func GetImages(ctx context.Context, req GetImagesRequest) ([]cloud.Image, error)

+ func GetInstance(ctx context.Context, instanceId string) (*model.Instance, error)

+ func GetInstanceByTag(c *types.ClusterInfo, tags []cloud.Tag) (instances []cloud.Instance, err error)

+ func GetInstanceCount(ctx context.Context, accountKeys []string, clusterName string) (int64, error)

+ func GetInstanceCountByCluster(ctx context.Context, clusters []model.Cluster) map[string]int64

+ func GetInstanceUsageStatistics(ctx context.Context, clusterName string, specifyDay time.Time, orgId int64, ...) ([]model.Instance, int64, error)

+ func GetInstanceUsageTotal(ctx context.Context, clusterName string, specifyDay time.Time, orgId int64) (int64, error)

+ func GetInstances(clusterInfo *types.ClusterInfo, instancesIds []string) (instances []cloud.Instance, err error)

+ func GetInstancesByAccount(ctx context.Context, accountKey string, pageNum, pageSize int) (instances []model.Instance, total int64, err error)

+ func GetInstancesByAccounts(ctx context.Context, accountKeys, status []string, pageNum, pageSize int, ...) (clusterNames []string, instances []model.Instance, total int64, err error)

+ func GetInstancesByCond(ctx context.Context, cond InstancesSearchCond) (ret []model.Instance, total int64, err error)

+ func GetInstancesByTaskId(ctx context.Context, taskId string, taskAction string) ([]model.Instance, error)

+ func GetOrgInfoById(ctx context.Context, id int64) (*model.Org, error)

+ func GetOrgKeysByAk(ctx context.Context, ak string) (*types.OrgKeys, error)

+ func GetOrgList(ctx context.Context) (ret []model.Org, err error)

+ func GetRegions(ctx context.Context, req GetRegionsRequest) ([]cloud.Region, error)

+ func GetTask(ctx context.Context, taskId string) (*model.Task, error)

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

+ func GetTaskListByAk(ctx context.Context, accountKey string, pageNum, pageSize int) ([]model.Task, int64, error)

+ func GetTaskListByAks(ctx context.Context, accountKeys []string, pageNum, pageSize int) ([]model.Task, int64, error)

+ func GetTaskListByCond(ctx context.Context, accountKey []string, cond model.TaskSearchCond) ([]model.Task, int64, error)

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

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

+ func GetVPCFromCloud(ctx context.Context, req GetVPCFromCloudRequest) (vpc cloud.VPC, err error)

+ func GetZones(ctx context.Context, req GetZonesRequest) ([]cloud.Zone, error)

+ func Init(workerCount int)

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

+ func Login(ctx context.Context, username, password string) *model.User

+ func ModifyAdminPassword(ctx context.Context, userId int64, userName, oldPassword, newPassword string) error

+ func ModifyUsername(ctx context.Context, uid int64, newUsername string) error

+ func QueryOrders(accName, provider, ak, regionId string, startTime, endTime time.Time) error

+ func RefreshCache(ctx context.Context) error

+ func RepairCluster(c *types.ClusterInfo, taskId int64, instanceIds []string) (err error)

+ func SaveOrders(accName, provider string, cloudOrder []cloud.Order) error

+ func Shrink(clusterInfo *types.ClusterInfo, instanceIds []string) error

+ func ShrinkCluster(c *types.ClusterInfo, num int, taskId int64) (err error)

+ func ShrinkClusterBySpecificIps(c *types.ClusterInfo, deletingIPs string, count int, taskId int64) (err error)

+ func SyncInstanceTypes(ctx context.Context, provider string) error

+ func UpdateUserStatus(ctx context.Context, usernames []string, status string) error

+ type AddSecurityGroupRuleRequest struct

+ RegionId string

+ Rules []GroupRule

+ SecurityGroupId string

+ VpcId string

+ type CreateNetworkRequest struct

+ Ak string

+ CidrBlock string

+ Provider string

+ RegionId string

+ SecurityGroupName string

+ SecurityGroupType string

+ SwitchCidrBlock string

+ SwitchName string

+ VpcName string

+ ZoneId string

+ type CreateNetworkResponse struct

+ SecurityGroupId string

+ SwitchId string

+ VpcId string

+ func CreateNetwork(ctx context.Context, req *CreateNetworkRequest) (vpcRes CreateNetworkResponse, err error)

+ type CreateSecurityGroupRequest struct

+ SecurityGroupName string

+ SecurityGroupType string

+ VpcId string

+ type CreateSwitchRequest struct

+ CidrBlock string

+ SwitchName string

+ VpcId string

+ ZoneId string

+ type CreateVPCRequest struct

+ Ak string

+ CidrBlock string

+ Provider string

+ RegionId string

+ VpcName string

+ type GetImagesRequest struct

+ Account *types.OrgKeys

+ Provider string

+ RegionId string

+ type GetRegionsRequest struct

+ Account *types.OrgKeys

+ Provider string

+ type GetSecurityGroupRequest struct

+ PageNumber int

+ PageSize int

+ SecurityGroupName string

+ VpcId string

+ type GetSwitchRequest struct

+ PageNumber int

+ PageSize int

+ SwitchName string

+ VpcId string

+ type GetVPCFromCloudRequest struct

+ Ak string

+ PageNumber int32

+ PageSize int32

+ Provider string

+ RegionId string

+ VpcId string

+ VpcName string

+ type GetVPCRequest struct

+ Account *types.OrgKeys

+ PageNumber int

+ PageSize int

+ Provider string

+ RegionId string

+ VpcName string

+ type GetZonesRequest struct

+ Account *types.OrgKeys

+ Provider string

+ RegionId string

+ type Group struct

+ CreateAt string

+ SecurityGroupId string

+ SecurityGroupName string

+ SecurityGroupType string

+ VpcId string

+ type GroupRule struct

+ CidrIp string

+ Direction string

+ GroupId string

+ PortRange string

+ PrefixListId string

+ Protocol string

+ type InstanceTypeByZone struct

+ Core int

+ InstanceType string

+ InstanceTypeFamily string

+ Memory int

+ type InstancesSearchCond struct

+ PageNumber int

+ PageSize int

+ Status string

+ TaskAction string

+ TaskId int64

+ type ListInstanceTypeRequest struct

+ Account *types.OrgKeys

+ Provider string

+ RegionId string

+ ZoneId string

+ type ListInstanceTypeResponse struct

+ InstanceTypes []InstanceTypeByZone

+ func ListInstanceType(req ListInstanceTypeRequest) (ListInstanceTypeResponse, error)

+ type SecurityGroupResponse struct

+ Groups []Group

+ Pager types.Pager

+ func GetSecurityGroup(ctx context.Context, req GetSecurityGroupRequest) (SecurityGroupResponse, error)

+ type SimpleTask struct

+ AccountKey string

+ Provider cloud.Provider

+ ProviderName string

+ RegionId string

+ Retry int

+ SwitchId string

+ TargetType targetType

+ VpcId string

+ VpcName string

+ type SimpleTaskHandler struct

+ Tasks chan *SimpleTask

+ var H *SimpleTaskHandler

+ func (s *SimpleTaskHandler) SubmitTask(t *SimpleTask)

+ type Switch struct

+ AvailableIpAddressCount int

+ CidrBlock string

+ CreateAt string

+ IsDefault string

+ SwitchId string

+ SwitchName string

+ VStatus string

+ VpcId string

+ ZoneId string

+ type SwitchResponse struct

+ Pager types.Pager

+ Switches []Switch

+ func GetSwitch(ctx context.Context, req GetSwitchRequest) (resp SwitchResponse, err error)

+ type VPCResponse struct

+ Pager types.Pager

+ Vpcs []Vpc

+ func GetVPC(ctx context.Context, req GetVPCRequest) (resp VPCResponse, err error)

+ type Vpc struct

+ CidrBlock string

+ CreateAt string

+ Provider string

+ Status string

+ SwitchIds string

+ VpcId string

+ VpcName string

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