commonruntime

package
v0.7.3 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoServicePort string

GO Service Port

View Source
var MiddleStartTime string
View Source
var ServerIPorName string

// CB-Spider Servcie Address Configuration // cf) https://github.com/cloud-barista/cb-spider/wiki/CB-Spider-Service-Address-Configuration REST and GO SERVER_ADDRESS since v0.4.4

View Source
var ServerPort string
View Source
var ServiceIPorName string

REST SERVICE_ADDRESS for AdminWeb since v0.4.4

View Source
var ServicePort string
View Source
var ShortStartTime string
View Source
var StartTime string

Functions

func AddNLBVMs added in v0.5.11

func AddNLBVMs(connectionName string, nlbName string, vmNames []string) (*cres.NLBInfo, error)

(1) check exist(NameID) and VMs (2) add VMs (3) Get NLBInfo (4) Set ResoureInfo

func AddNodeGroup added in v0.6.13

func AddNodeGroup(connectionName string, rsType string, clusterName string, reqInfo cres.NodeGroupInfo) (*cres.ClusterInfo, error)

(1) check exist(NameID) (2) add NodeGroup (3) Get ClusterInfo (4) Set ResoureInfo

func AddRules added in v0.5.4

func AddRules(connectionName string, sgName string, reqInfoList []cres.SecurityRuleInfo) (*cres.SecurityInfo, error)

(1) check exist(NameID) (2) add Rules

func AddSubnet added in v0.3.1

func AddSubnet(connectionName string, rsType string, vpcName string, reqInfo cres.SubnetInfo) (*cres.VPCInfo, error)

(1) check exist(NameID) (2) create Resource (3) insert IID

func AnyCall added in v0.6.9

func AnyCall(connectionName string, reqInfo cres.AnyCallInfo) (*cres.AnyCallInfo, error)

================ AnyCall Handler

func AttachDisk added in v0.6.7

func AttachDisk(connectionName string, diskName string, ownerVMName string) (*cres.DiskInfo, error)

(1) check exist(NameID) and VMs (2) attach disk to VM (3) Set ResoureInfo

func ChangeDiskSize added in v0.6.7

func ChangeDiskSize(connectionName string, diskName string, size string) (bool, error)

func ChangeHealthChecker added in v0.5.10

func ChangeHealthChecker(connectionName string, nlbName string, healthChecker cres.HealthCheckerInfo) (*cres.NLBInfo, error)

---------------------------------------------------// @todo To support or not will be decided later. // ---------------------------------------------------// (1) check exist(NameID) (2) change HealthCheckerInfo (3) Get NLBInfo (4) Set ResoureInfo

func ChangeListener added in v0.5.10

func ChangeListener(connectionName string, nlbName string, listener cres.ListenerInfo) (*cres.NLBInfo, error)

---------------------------------------------------// @todo To support or not will be decided later. // ---------------------------------------------------// (1) check exist(NameID) (2) change listener (3) Get NLBInfo (4) Set ResoureInfo

func ChangeNodeGroupScaling added in v0.6.13

func ChangeNodeGroupScaling(connectionName string, clusterName string, nodeGroupName string,
	DesiredNodeSize int, MinNodeSize int, MaxNodeSize int) (cres.NodeGroupInfo, error)

func ChangeVMGroup added in v0.5.10

func ChangeVMGroup(connectionName string, nlbName string, vmGroup cres.VMGroupInfo) (*cres.NLBInfo, error)

---------------------------------------------------// @todo To support or not will be decided later. // ---------------------------------------------------// (1) check exist(NameID) (2) change VMGroup (3) Get NLBInfo (4) Set ResoureInfo

func ControlVM

func ControlVM(connectionName string, rsType string, nameID string, action string) (cres.VMStatus, error)

(1) get IID(NameId) (2) control CSP:VM(SystemId)

func CreateCluster added in v0.6.13

func CreateCluster(connectionName string, rsType string, reqInfo cres.ClusterInfo) (*cres.ClusterInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID (7) set used Resources's userIID

func CreateDisk added in v0.6.7

func CreateDisk(connectionName string, rsType string, reqInfo cres.DiskInfo) (*cres.DiskInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func CreateImage

func CreateImage(connectionName string, rsType string, reqInfo cres.ImageReqInfo) (*cres.ImageInfo, error)

================ Image Handler @todo (1) check exist(NameID) (2) gen SP-XID and create userIID, driverIID (3) create Resource (4) create spiderIID: {UserNameID, "DriverNameID:CSPSystemID"} (5) insert spiderIID

func CreateKey

func CreateKey(connectionName string, rsType string, reqInfo cres.KeyPairReqInfo) (*cres.KeyPairInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func CreateNLB added in v0.5.10

func CreateNLB(connectionName string, rsType string, reqInfo cres.NLBInfo) (*cres.NLBInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func CreateSecurity

func CreateSecurity(connectionName string, rsType string, reqInfo cres.SecurityReqInfo) (*cres.SecurityInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func CreateVPC

func CreateVPC(connectionName string, rsType string, reqInfo cres.VPCReqInfo) (*cres.VPCInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func DeleteCSPResource

func DeleteCSPResource(connectionName string, rsType string, systemID string) (bool, cres.VMStatus, error)

delete CSP's Resource(SystemId)

func DeleteImage

func DeleteImage(connectionName string, rsType string, nameID string) (bool, error)

(1) get spiderIID(NameId) (2) extract driverIID from spiderIID (3) delete Resource(SystemId) (4) delete spiderIID Currently this API is not used. @TODO

func DeleteResource

func DeleteResource(connectionName string, rsType string, nameID string, force string) (bool, cres.VMStatus, error)

(1) get spiderIID (2) delete Resource(SystemId) (3) delete IID

func DetachDisk added in v0.6.7

func DetachDisk(connectionName string, diskName string, ownerVMName string) (bool, error)

(1) check exist(NameID) (2) detach disk from VM

func EmptyCheckAndTrim added in v0.4.15

func EmptyCheckAndTrim(inputName string, inputValue string) (string, error)

func GetAllSPLockInfo added in v0.5.7

func GetAllSPLockInfo() []string

func GetCSPResourceInfo added in v0.6.17

func GetCSPResourceInfo(connectionName string, rsType string, systemID string) ([]byte, error)

Get Json string of CSP's Resource(SystemId) Info

func GetCSPResourceName added in v0.6.6

func GetCSPResourceName(connectionName string, rsType string, nameID string) (string, error)

================ get CSP Name

func GetCSPVM added in v0.6.16

func GetCSPVM(connectionName string, rsType string, cspID string) (*cres.VMInfo, error)

func GetCluster added in v0.6.13

func GetCluster(connectionName string, rsType string, clusterName string) (*cres.ClusterInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetClusterOwnerVPC added in v0.6.13

func GetClusterOwnerVPC(connectionName string, cspID string) (owerVPC cres.IID, err error)

func GetDisk added in v0.6.7

func GetDisk(connectionName string, rsType string, nameID string) (*cres.DiskInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetImage

func GetImage(connectionName string, rsType string, nameID string) (*cres.ImageInfo, error)

(1) get resource(SystemId) (2) set ResourceInfo(IID.NameId)

func GetKey

func GetKey(connectionName string, rsType string, nameID string) (*cres.KeyPairInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetMyImage added in v0.6.10

func GetMyImage(connectionName string, rsType string, nameID string) (*cres.MyImageInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetNLB added in v0.5.10

func GetNLB(connectionName string, rsType string, nameID string) (*cres.NLBInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetNLBOwnerVPC added in v0.5.10

func GetNLBOwnerVPC(connectionName string, cspID string) (owerVPC cres.IID, err error)

func GetOrgVMSpec

func GetOrgVMSpec(connectionName string, nameID string) (string, error)

func GetRegisterImage

func GetRegisterImage(connectionName string, rsType string, nameID string) (*cres.ImageInfo, error)

(1) get spiderIID(NameId) (2) extract driverIID from spiderIID (3) get resource(SystemId) (4) set ResourceInfo(IID.NameId) Currently this API is not used. @TODO

func GetSGOwnerVPC added in v0.5.5

func GetSGOwnerVPC(connectionName string, cspID string) (owerVPC cres.IID, err error)

func GetSecurity

func GetSecurity(connectionName string, rsType string, nameID string) (*cres.SecurityInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetVM

func GetVM(connectionName string, rsType string, nameID string) (*cres.VMInfo, error)

(1) get IID(NameId) (2) get resource(SystemId) (3) set ResourceInfo(IID.NameId)

func GetVMGroupHealthInfo added in v0.5.10

func GetVMGroupHealthInfo(connectionName string, nlbName string) (*cres.HealthInfo, error)

(1) check exist(NameID) (2) Get HealthInfo (3) Get NLBInfo (4) Set ResoureInfo

func GetVMSpec

func GetVMSpec(connectionName string, nameID string) (*cres.VMSpecInfo, error)

func GetVMStatus

func GetVMStatus(connectionName string, rsType string, nameID string) (cres.VMStatus, error)

(1) get IID(NameId) (2) get CSP:VMStatus(SystemId)

func GetVPC

func GetVPC(connectionName string, rsType string, nameID string) (*cres.VPCInfo, error)

(1) get spiderIID(NameId) (2) get resource(driverIID) (3) set ResourceInfo(userIID)

func ListCluster added in v0.6.13

func ListCluster(connectionName string, nameSpace string, rsType string) ([]*cres.ClusterInfo, error)

(1) get IID:list (2) get ClusterInfo:list (3) set userIID, and ...

func ListDisk added in v0.6.7

func ListDisk(connectionName string, rsType string) ([]*cres.DiskInfo, error)

(1) get IID:list (2) get DiskInfo:list (3) set userIID, and ...

func ListImage

func ListImage(connectionName string, rsType string) ([]*cres.ImageInfo, error)

(1) get IID:list (2) get CSP:list (3) filtering CSP-list by IID-list

func ListKey

func ListKey(connectionName string, rsType string) ([]*cres.KeyPairInfo, error)

(1) get IID:list (2) get KeyInfo:list

func ListMyImage added in v0.6.10

func ListMyImage(connectionName string, rsType string) ([]*cres.MyImageInfo, error)

(1) get IID:list (2) get MyImageInfo:list (3) set userIID, and ...

func ListNLB added in v0.5.10

func ListNLB(connectionName string, rsType string) ([]*cres.NLBInfo, error)

(1) get IID:list (2) get NLBInfo:list (3) set userIID, and ...

func ListOrgVMSpec

func ListOrgVMSpec(connectionName string) (string, error)

func ListRegisterImage

func ListRegisterImage(connectionName string, rsType string) ([]*cres.ImageInfo, error)

(1) get spiderIID:list (2) get CSP:list (3) filtering CSP-list by spiderIID-list Currently this API is not used. @TODO

func ListSecurity

func ListSecurity(connectionName string, rsType string) ([]*cres.SecurityInfo, error)

(1) get IID:list (2) get SecurityInfo:list (3) set userIID, and ...

func ListVM

func ListVM(connectionName string, rsType string) ([]*cres.VMInfo, error)

(1) get IID:list (2) get VMInfo:list

func ListVMSpec

func ListVMSpec(connectionName string) ([]*cres.VMSpecInfo, error)

================ VMSpec Handler

func ListVMStatus

func ListVMStatus(connectionName string, rsType string) ([]*cres.VMStatusInfo, error)

(1) get IID:list (2) get VMStatusInfo:list

func ListVPC

func ListVPC(connectionName string, rsType string) ([]*cres.VPCInfo, error)

(1) get IID:list (2) get VPCInfo:list (3) set userIID, and...

func RegisterCluster added in v0.6.13

func RegisterCluster(connectionName string, vpcUserID string, userIID cres.IID) (*cres.ClusterInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (0) check VPC existence(VPC UserID) (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterDisk added in v0.6.7

func RegisterDisk(connectionName string, userIID cres.IID) (*cres.DiskInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterKey added in v0.4.12

func RegisterKey(connectionName string, userIID cres.IID) (*cres.KeyPairInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterMyImage added in v0.6.10

func RegisterMyImage(connectionName string, userIID cres.IID) (*cres.MyImageInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterNLB added in v0.5.10

func RegisterNLB(connectionName string, vpcUserID string, userIID cres.IID) (*cres.NLBInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (0) check VPC existence(VPC UserID) (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterSecurity added in v0.4.12

func RegisterSecurity(connectionName string, vpcUserID string, userIID cres.IID) (*cres.SecurityInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (0) check VPC existence(VPC UserID) (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterVM added in v0.4.12

func RegisterVM(connectionName string, userIID cres.IID) (*cres.VMInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RegisterVPC added in v0.4.12

func RegisterVPC(connectionName string, userIID cres.IID) (*cres.VPCInfo, error)

UserIID{UserID, CSP-ID} => SpiderIID{UserID, SP-XID:CSP-ID} (1) check existence(UserID) (2) get resource info(CSP-ID) (3) create spiderIID: {UserID, SP-XID:CSP-ID} (4) insert spiderIID

func RemoveCSPNodeGroup added in v0.6.14

func RemoveCSPNodeGroup(connectionName string, clusterName string, systemID string) (bool, error)

func RemoveCSPSubnet added in v0.4.11

func RemoveCSPSubnet(connectionName string, vpcName string, systemID string) (bool, error)

remove CSP's Subnet(SystemId)

func RemoveNLBVMs added in v0.5.11

func RemoveNLBVMs(connectionName string, nlbName string, vmNames []string) (bool, error)

(1) check exist(NameID) (2) remove VMs

func RemoveNodeGroup added in v0.6.13

func RemoveNodeGroup(connectionName string, clusterName string, nodeGroupName string, force string) (bool, error)

func RemoveRules added in v0.5.4

func RemoveRules(connectionName string, sgName string, reqRuleInfoList []cres.SecurityRuleInfo) (bool, error)

(1) check exist(NameID) (2) remove Rules

func RemoveSubnet added in v0.4.11

func RemoveSubnet(connectionName string, vpcName string, nameID string, force string) (bool, error)

(1) get spiderIID (2) delete Resource(SystemId) (3) delete IID

func RsTypeString added in v0.5.1

func RsTypeString(rsType string) string

func SetNodeGroupAutoScaling added in v0.6.13

func SetNodeGroupAutoScaling(connectionName string, clusterName string, nodeGroupName string, on bool) (bool, error)

func SnapshotVM added in v0.6.10

func SnapshotVM(connectionName string, rsType string, reqInfo cres.MyImageInfo) (*cres.MyImageInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) create Resource (4) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (5) insert spiderIID (6) create userIID

func StartVM

func StartVM(connectionName string, rsType string, reqInfo cres.VMReqInfo) (*cres.VMInfo, error)

(1) check exist(NameID) (2) generate SP-XID and create reqIID, driverIID (3) clone the reqInfo with DriverIID (4) create Resource (5) create spiderIID: {reqNameID, "driverNameID:driverSystemID"} (6) insert spiderIID (7) create userIID

func UnregisterResource added in v0.4.12

func UnregisterResource(connectionName string, rsType string, nameId string) (bool, error)

UnregisterResource API does not delete the real resource. This API just unregister the resource from Spider. (1) check exist(NameID) (2) delete SpiderIID

func UpgradeCluster added in v0.6.14

func UpgradeCluster(connectionName string, clusterName string, newVersion string) (cres.ClusterInfo, error)

func ValidateStruct added in v0.4.15

func ValidateStruct(is interface{}, emptyPermissionList []string) error

Types

type AllResourceList

type AllResourceList struct {
	AllList struct {
		MappedList     []*cres.IID `json:"MappedList"`
		OnlySpiderList []*cres.IID `json:"OnlySpiderList"`
		OnlyCSPList    []*cres.IID `json:"OnlyCSPList"`
	}
}

func ListAllResource

func ListAllResource(connectionName string, rsType string) (AllResourceList, error)

list all Resources for management (1) get IID:list (2) get CSP:list (3) filtering CSP-list by IID-list (4) make MappedList, OnlySpiderList, OnlyCSPList

type ResultVMInfo added in v0.5.9

type ResultVMInfo struct {
	// contains filtered or unexported fields
}

type ResultVPCInfo added in v0.5.9

type ResultVPCInfo struct {
	// contains filtered or unexported fields
}

type VMUsingResources added in v0.5.5

type VMUsingResources struct {
	Resources struct {
		VPC    *cres.IID   `json:"VPC"`
		SGList []*cres.IID `json:"SGList"`
		VMKey  *cres.IID   `json:"VMKey"`
	}
}

func GetVMUsingRS added in v0.5.5

func GetVMUsingRS(connectionName string, cspID string) (VMUsingResources, error)

type WAITER added in v0.5.11

type WAITER struct {
	Sleep   int // sec, default = 1
	Timeout int // sec, default = 120
	// contains filtered or unexported fields
}

============================================

func NewWaiter added in v0.5.11

func NewWaiter(sleep int, timeout int) *WAITER

func (*WAITER) Wait added in v0.5.11

func (waiter *WAITER) Wait() bool

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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