resources

package
v0.8.12 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 59 Imported by: 2

Documentation

Index

Constants

View Source
const (
	DNSNameservers   = "8.8.8.8"
	ResourceNotFound = "Resource not found"
)
View Source
const (
	VolumeV2 string = "volumev2"
	VolumeV3 string = "volumev3"
)
View Source
const (
	NLBPublicType   NLBType  = "PUBLIC"
	NLBInternalType NLBType  = "INTERNAL"
	NLBGlobalType   NLBScope = "GLOBAL"
	NLBRegionType   NLBScope = "REGION"
)
View Source
const (
	Inbound       = "inbound"
	Outbound      = "outbound"
	ICMP          = "icmp"
	SecurityGroup = "SECURITYGROUP"
)
View Source
const (
	WindowBaseUser = "Administrator"
	VM             = "VM"
	SSHDefaultUser = "cb-user"
)
View Source
const (
	Image = "IMAGE"
)
View Source
const (
	KeyPair = "KEYPAIR"
)
View Source
const (
	VMSpec = "VMSPEC"
)
View Source
const (
	VPC = "VPC"
)

Variables

This section is empty.

Functions

func AttachList added in v0.6.12

func AttachList(diskIIDList []irs.IID, ownerVMIID irs.IID, computeClient *gophercloud.ServiceClient, volumeClient *gophercloud.ServiceClient) (*servers.Server, error)

func CheckExistKey added in v0.4.15

func CheckExistKey(client *gophercloud.ServiceClient, keyIID irs.IID) (bool, error)

func CheckIIDValidation added in v0.4.12

func CheckIIDValidation(IId irs.IID) bool

func CheckKeyPairReqInfo added in v0.4.15

func CheckKeyPairReqInfo(keyPairReqInfo irs.KeyPairReqInfo) error

func CheckSnapshot added in v0.6.9

func CheckSnapshot(image images.Image) (bool, error)

func GetCallLogScheme added in v0.2.1

func GetCallLogScheme(endpoint string, resourceType call.RES_TYPE, resourceName string, apiName string) call.CLOUDLOGSCHEMA

func GetFlavorByName added in v0.3.14

func GetFlavorByName(client *gophercloud.ServiceClient, flavorName string) (flavors.Flavor, error)

func GetNetworkByName added in v0.1.5

func GetNetworkByName(networkClient *gophercloud.ServiceClient, networkName string) (*networks.Network, error)

func GetPortByDeviceID added in v0.1.5

func GetPortByDeviceID(networkClient *gophercloud.ServiceClient, deviceID string) (*ports.Port, error)

func GetPublicVPCInfo added in v0.1.9

func GetPublicVPCInfo(client *gophercloud.ServiceClient, typeName string) (string, error)

func GetRawKey added in v0.4.15

func GetRawKey(client *gophercloud.ServiceClient, keyIID irs.IID) (keypairs.KeyPair, error)

func GetSecurityByName added in v0.1.5

func GetSecurityByName(networkClient *gophercloud.ServiceClient, securityName string) (*secgroups.SecurityGroup, error)

func GetSubnetByID added in v0.1.5

func GetSubnetByID(networkClient *gophercloud.ServiceClient, subnetId string) (*subnets.Subnet, error)

func Hosts added in v0.5.5

func Hosts(cidr string) ([]string, error)

func InitLog added in v0.2.1

func InitLog()

func LoggingError added in v0.2.1

func LoggingError(hiscallInfo call.CLOUDLOGSCHEMA, err error)

func LoggingInfo added in v0.2.1

func LoggingInfo(hiscallInfo call.CLOUDLOGSCHEMA, start time.Time)

Types

type BlockDeviceMapping added in v0.6.9

type BlockDeviceMapping struct {
	SnapshotId string `json:"snapshot_id"`
	VolumeSize int    `json:"volume_size"`
	SourceType string `json:"source_type"`
	DeviceName string `json:"device_name"`
}

type DataDiskInfo added in v0.6.9

type DataDiskInfo struct {
	Volume       volumes3.Volume
	AttachDevice string
}

type ImageMetaData added in v0.6.9

type ImageMetaData struct {
	BaseImageRef        string               `json:"base_image_ref"`
	RootDeviceName      string               `json:"root_device_name"`
	ImageType           string               `json:"image_type"`
	ImageLocation       string               `json:"image_location"`
	InstanceUuid        string               `json:"instance_uuid"`
	BlockDeviceMapping  []BlockDeviceMapping `json:"block_device_mapping"`
	DeviceType          string               `json:"device_type"`
	DestinationType     string               `json:"destination_type"`
	DeleteOnTermination bool                 `json:"delete_on_termination"`
	SourceVMID          string               `json:"source_vm_id"`   // spider Tag
	SourceVMName        string               `json:"source_vm_name"` // spider Tag
	DataVolumesString   string               `json:"data_volumes_raw"`
}

type NLBScope added in v0.5.10

type NLBScope string

type NLBType added in v0.5.10

type NLBType string

type NetworkWithExt added in v0.3.14

type NetworkWithExt struct {
	networks.Network
	external.NetworkExternalExt
}

type OpenStackAnyCallHandler added in v0.6.9

type OpenStackAnyCallHandler struct {
	Region         idrv.RegionInfo
	CredentialInfo idrv.CredentialInfo
}

func (*OpenStackAnyCallHandler) AnyCall added in v0.6.9

func (anyCallHandler *OpenStackAnyCallHandler) AnyCall(callInfo irs.AnyCallInfo) (irs.AnyCallInfo, error)

*******************************************************

	// call example
	curl -sX POST http://localhost:1024/spider/anycall -H 'Content-Type: application/json' -d \
        '{
                "ConnectionName" : "openstack-config01",
                "ReqInfo" : {
                        "FID" : "getConnectionInfo"
                }
        }' | json_pp

*******************************************************

type OpenStackImageHandler

type OpenStackImageHandler struct {
	Client      *gophercloud.ServiceClient
	ImageClient *gophercloud.ServiceClient
}

func (*OpenStackImageHandler) CheckWindowsImage added in v0.6.15

func (imageHandler *OpenStackImageHandler) CheckWindowsImage(imageIID irs.IID) (bool, error)

func (*OpenStackImageHandler) CreateImage

func (imageHandler *OpenStackImageHandler) CreateImage(imageReqInfo irs.ImageReqInfo) (irs.ImageInfo, error)

func (*OpenStackImageHandler) DeleteImage

func (imageHandler *OpenStackImageHandler) DeleteImage(imageIID irs.IID) (bool, error)

func (*OpenStackImageHandler) GetImage

func (imageHandler *OpenStackImageHandler) GetImage(imageIID irs.IID) (irs.ImageInfo, error)

func (*OpenStackImageHandler) ListImage

func (imageHandler *OpenStackImageHandler) ListImage() ([]*irs.ImageInfo, error)

type OpenStackKeyPairHandler

type OpenStackKeyPairHandler struct {
	Client *gophercloud.ServiceClient
}

func (*OpenStackKeyPairHandler) CreateKey

func (keyPairHandler *OpenStackKeyPairHandler) CreateKey(keyPairReqInfo irs.KeyPairReqInfo) (irs.KeyPairInfo, error)

func (*OpenStackKeyPairHandler) DeleteKey

func (keyPairHandler *OpenStackKeyPairHandler) DeleteKey(keyIID irs.IID) (bool, error)

func (*OpenStackKeyPairHandler) GetKey

func (keyPairHandler *OpenStackKeyPairHandler) GetKey(keyIID irs.IID) (irs.KeyPairInfo, error)

func (*OpenStackKeyPairHandler) ListKey

func (keyPairHandler *OpenStackKeyPairHandler) ListKey() ([]*irs.KeyPairInfo, error)

type OpenStackMyImageHandler added in v0.6.9

type OpenStackMyImageHandler struct {
	CredentialInfo idrv.CredentialInfo
	Region         idrv.RegionInfo
	Ctx            context.Context
	ComputeClient  *gophercloud.ServiceClient
	VolumeClient   *gophercloud.ServiceClient
}

func (*OpenStackMyImageHandler) CheckWindowsImage added in v0.6.15

func (myImageHandler *OpenStackMyImageHandler) CheckWindowsImage(myImageIID irs.IID) (bool, error)

func (*OpenStackMyImageHandler) DeleteMyImage added in v0.6.9

func (myImageHandler *OpenStackMyImageHandler) DeleteMyImage(myImageIID irs.IID) (bool, error)

func (*OpenStackMyImageHandler) GetMyImage added in v0.6.9

func (myImageHandler *OpenStackMyImageHandler) GetMyImage(myImageIID irs.IID) (irs.MyImageInfo, error)

func (*OpenStackMyImageHandler) ListMyImage added in v0.6.9

func (myImageHandler *OpenStackMyImageHandler) ListMyImage() ([]*irs.MyImageInfo, error)

func (*OpenStackMyImageHandler) SnapshotVM added in v0.6.9

func (myImageHandler *OpenStackMyImageHandler) SnapshotVM(snapshotReqInfo irs.MyImageInfo) (irs.MyImageInfo, error)

type OpenStackNLBHandler added in v0.5.10

type OpenStackNLBHandler struct {
	CredentialInfo idrv.CredentialInfo
	Region         idrv.RegionInfo
	VMClient       *gophercloud.ServiceClient
	NetworkClient  *gophercloud.ServiceClient
	NLBClient      *gophercloud.ServiceClient
}

func (*OpenStackNLBHandler) AddVMs added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) AddVMs(nlbIID irs.IID, vmIIDs *[]irs.IID) (irs.VMGroupInfo, error)

func (*OpenStackNLBHandler) AssociatePublicIP added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) AssociatePublicIP(nlbPortId string) (bool, error)

func (*OpenStackNLBHandler) ChangeHealthCheckerInfo added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) ChangeHealthCheckerInfo(nlbIID irs.IID, healthChecker irs.HealthCheckerInfo) (irs.HealthCheckerInfo, error)

func (*OpenStackNLBHandler) ChangeListener added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) ChangeListener(nlbIID irs.IID, listener irs.ListenerInfo) (irs.ListenerInfo, error)

------ Frontend Control

func (*OpenStackNLBHandler) ChangeVMGroupInfo added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) ChangeVMGroupInfo(nlbIID irs.IID, vmGroup irs.VMGroupInfo) (irs.VMGroupInfo, error)

------ Backend Control

func (*OpenStackNLBHandler) CleanerNLB added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) CleanerNLB(nlbIID irs.IID) (bool, error)

func (*OpenStackNLBHandler) CreateNLB added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) CreateNLB(nlbReqInfo irs.NLBInfo) (createNLB irs.NLBInfo, createError error)

------ NLB Management

func (*OpenStackNLBHandler) DeleteNLB added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) DeleteNLB(nlbIID irs.IID) (bool, error)

func (*OpenStackNLBHandler) ExistEqualName added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) ExistEqualName(name string) (bool, error)

func (*OpenStackNLBHandler) GetNLB added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) GetNLB(nlbIID irs.IID) (irs.NLBInfo, error)

func (*OpenStackNLBHandler) GetVMGroupHealthInfo added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) GetVMGroupHealthInfo(nlbIID irs.IID) (irs.HealthInfo, error)

func (*OpenStackNLBHandler) ListNLB added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) ListNLB() ([]*irs.NLBInfo, error)

func (*OpenStackNLBHandler) RemoveVMs added in v0.5.10

func (nlbHandler *OpenStackNLBHandler) RemoveVMs(nlbIID irs.IID, vmIIDs *[]irs.IID) (bool, error)

type OpenStackRegionZoneHandler added in v0.7.6

type OpenStackRegionZoneHandler struct {
	Region         idrv.RegionInfo
	IdentityClient *gophercloud.ServiceClient
}

func (*OpenStackRegionZoneHandler) GetRegionZone added in v0.7.6

func (regionZoneHandler *OpenStackRegionZoneHandler) GetRegionZone(Name string) (irs.RegionZoneInfo, error)

func (*OpenStackRegionZoneHandler) ListOrgRegion added in v0.7.6

func (regionZoneHandler *OpenStackRegionZoneHandler) ListOrgRegion() (string, error)

func (*OpenStackRegionZoneHandler) ListOrgZone added in v0.7.6

func (regionZoneHandler *OpenStackRegionZoneHandler) ListOrgZone() (string, error)

ListOrgZone Region, Availability Zone 개념이 OpenStack은 다르게 작용함. 현재 구성은 config에 설정된 Region에서 사용가능한 zone 목록을 출력함.

func (*OpenStackRegionZoneHandler) ListRegionZone added in v0.7.6

func (regionZoneHandler *OpenStackRegionZoneHandler) ListRegionZone() ([]*irs.RegionZoneInfo, error)

type OpenStackSecurityHandler

type OpenStackSecurityHandler struct {
	Client        *gophercloud.ServiceClient
	NetworkClient *gophercloud.ServiceClient
}

func (*OpenStackSecurityHandler) AddRules added in v0.5.4

func (securityHandler *OpenStackSecurityHandler) AddRules(sgIID irs.IID, securityRules *[]irs.SecurityRuleInfo) (irs.SecurityInfo, error)

func (*OpenStackSecurityHandler) CreateSecurity

func (securityHandler *OpenStackSecurityHandler) CreateSecurity(securityReqInfo irs.SecurityReqInfo) (createdSG irs.SecurityInfo, creteErr error)

func (*OpenStackSecurityHandler) DeleteSecurity

func (securityHandler *OpenStackSecurityHandler) DeleteSecurity(securityIID irs.IID) (bool, error)

func (*OpenStackSecurityHandler) GetSecurity

func (securityHandler *OpenStackSecurityHandler) GetSecurity(securityIID irs.IID) (irs.SecurityInfo, error)

func (*OpenStackSecurityHandler) ListSecurity

func (securityHandler *OpenStackSecurityHandler) ListSecurity() ([]*irs.SecurityInfo, error)

func (*OpenStackSecurityHandler) RemoveRules added in v0.5.4

func (securityHandler *OpenStackSecurityHandler) RemoveRules(sgIID irs.IID, securityRules *[]irs.SecurityRuleInfo) (bool, error)

type OpenStackVMHandler

type OpenStackVMHandler struct {
	Region        idrv.RegionInfo
	ComputeClient *gophercloud.ServiceClient
	NetworkClient *gophercloud.ServiceClient
	VolumeClient  *gophercloud.ServiceClient
}

func (*OpenStackVMHandler) AssociatePublicIP

func (vmHandler *OpenStackVMHandler) AssociatePublicIP(serverID string) (bool, error)

func (*OpenStackVMHandler) GetVM

func (vmHandler *OpenStackVMHandler) GetVM(vmIID irs.IID) (irs.VMInfo, error)

func (*OpenStackVMHandler) GetVMStatus

func (vmHandler *OpenStackVMHandler) GetVMStatus(vmIID irs.IID) (irs.VMStatus, error)

func (*OpenStackVMHandler) ListVM

func (vmHandler *OpenStackVMHandler) ListVM() ([]*irs.VMInfo, error)

func (*OpenStackVMHandler) ListVMStatus

func (vmHandler *OpenStackVMHandler) ListVMStatus() ([]*irs.VMStatusInfo, error)

func (*OpenStackVMHandler) RebootVM

func (vmHandler *OpenStackVMHandler) RebootVM(vmIID irs.IID) (irs.VMStatus, error)

func (*OpenStackVMHandler) ResumeVM

func (vmHandler *OpenStackVMHandler) ResumeVM(vmIID irs.IID) (irs.VMStatus, error)

func (*OpenStackVMHandler) StartVM

func (vmHandler *OpenStackVMHandler) StartVM(vmReqInfo irs.VMReqInfo) (startvm irs.VMInfo, createErr error)

func (*OpenStackVMHandler) SuspendVM

func (vmHandler *OpenStackVMHandler) SuspendVM(vmIID irs.IID) (irs.VMStatus, error)

func (*OpenStackVMHandler) TerminateVM

func (vmHandler *OpenStackVMHandler) TerminateVM(vmIID irs.IID) (irs.VMStatus, error)

type OpenStackVMSpecHandler

type OpenStackVMSpecHandler struct {
	Region idrv.RegionInfo
	Client *gophercloud.ServiceClient
}

func (*OpenStackVMSpecHandler) GetOrgVMSpec

func (vmSpecHandler *OpenStackVMSpecHandler) GetOrgVMSpec(Name string) (string, error)

func (*OpenStackVMSpecHandler) GetVMSpec

func (vmSpecHandler *OpenStackVMSpecHandler) GetVMSpec(Name string) (irs.VMSpecInfo, error)

func (*OpenStackVMSpecHandler) ListOrgVMSpec

func (vmSpecHandler *OpenStackVMSpecHandler) ListOrgVMSpec() (string, error)

func (*OpenStackVMSpecHandler) ListVMSpec

func (vmSpecHandler *OpenStackVMSpecHandler) ListVMSpec() ([]*irs.VMSpecInfo, error)

type OpenStackVPCHandler added in v0.1.3

type OpenStackVPCHandler struct {
	Client   *gophercloud.ServiceClient
	VMClient *gophercloud.ServiceClient
}

func (*OpenStackVPCHandler) AddInterface added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) AddInterface(subnetId string, routerId string) (bool, error)

func (*OpenStackVPCHandler) AddSubnet added in v0.2.1

func (vpcHandler *OpenStackVPCHandler) AddSubnet(vpcIID irs.IID, subnetInfo irs.SubnetInfo) (irs.VPCInfo, error)

func (*OpenStackVPCHandler) CreateRouter added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) CreateRouter(vpcName string) (*string, error)

func (*OpenStackVPCHandler) CreateSubnet added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) CreateSubnet(vpcId string, reqSubnetInfo irs.SubnetInfo) (irs.SubnetInfo, error)

func (*OpenStackVPCHandler) CreateVPC added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) CreateVPC(vpcReqInfo irs.VPCReqInfo) (createdVPC irs.VPCInfo, createErr error)

func (*OpenStackVPCHandler) DeleteInterface added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) DeleteInterface(subnetId string, routerId string) (bool, error)

func (*OpenStackVPCHandler) DeleteRouter added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) DeleteRouter(vpcName string) (bool, error)

func (*OpenStackVPCHandler) DeleteSubnet added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) DeleteSubnet(subnetIId irs.IID) (bool, error)

func (*OpenStackVPCHandler) DeleteVPC added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) DeleteVPC(vpcIID irs.IID) (bool, error)

func (*OpenStackVPCHandler) GetRouter added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) GetRouter(vpcName string) (*string, error)

func (*OpenStackVPCHandler) GetSubnet added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) GetSubnet(subnetIId irs.IID) (irs.SubnetInfo, error)

func (*OpenStackVPCHandler) GetVPC added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) GetVPC(vpcIID irs.IID) (irs.VPCInfo, error)

func (*OpenStackVPCHandler) ListVPC added in v0.1.3

func (vpcHandler *OpenStackVPCHandler) ListVPC() ([]*irs.VPCInfo, error)

func (*OpenStackVPCHandler) RemoveSubnet added in v0.2.1

func (vpcHandler *OpenStackVPCHandler) RemoveSubnet(vpcIID irs.IID, subnetIID irs.IID) (bool, error)

type OpenstackDiskHandler added in v0.6.7

type OpenstackDiskHandler struct {
	CredentialInfo idrv.CredentialInfo
	Region         idrv.RegionInfo
	ComputeClient  *gophercloud.ServiceClient
	VolumeClient   *gophercloud.ServiceClient
}

func (*OpenstackDiskHandler) AttachDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) AttachDisk(diskIID irs.IID, ownerVM irs.IID) (irs.DiskInfo, error)

func (*OpenstackDiskHandler) ChangeDiskSize added in v0.6.7

func (diskHandler *OpenstackDiskHandler) ChangeDiskSize(diskIID irs.IID, size string) (bool, error)

func (*OpenstackDiskHandler) CheckDiskHandler added in v0.6.9

func (diskHandler *OpenstackDiskHandler) CheckDiskHandler() error

func (*OpenstackDiskHandler) CreateDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) CreateDisk(DiskReqInfo irs.DiskInfo) (irs.DiskInfo, error)

func (*OpenstackDiskHandler) DeleteDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) DeleteDisk(diskIID irs.IID) (bool, error)

func (*OpenstackDiskHandler) DetachDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) DetachDisk(diskIID irs.IID, ownerVM irs.IID) (bool, error)

func (*OpenstackDiskHandler) GetDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) GetDisk(diskIID irs.IID) (irs.DiskInfo, error)

func (*OpenstackDiskHandler) ListDisk added in v0.6.7

func (diskHandler *OpenstackDiskHandler) ListDisk() ([]*irs.DiskInfo, error)

Jump to

Keyboard shortcuts

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