openstack

Documentation

Index

• Constants
• func CreateNamespace(ctx context.Context, clientSet *kubernetes.Clientset, baseName string, ...) *v1.Namespace
• func CreatePVC(ctx context.Context, clientSet *kubernetes.Clientset, baseName string, ...) *v1.PersistentVolumeClaim
• func CreatePod(ctx context.Context, clientSet *kubernetes.Clientset, nsName string, ...) (*v1.Pod, error)
• func DeleteMachinesetsDefer(client runtimeclient.Client, ms *machinev1.MachineSet)
• func DeleteNamespace(ctx context.Context, clientSet *kubernetes.Clientset, ns *v1.Namespace)
• func ElementExists(s []string, str string) bool
• func FindStorageClassByProvider(oc *exutil.CLI, provisioner string, seek_default bool) *storagev1.StorageClass
• func GetClusterLoadBalancerSetting(setting string, config *ini.File) (string, error)
• func GetFloatingNetworkID(ctx context.Context, client *gophercloud.ServiceClient, ...) (string, error)
• func GetMachinesetRetry(ctx context.Context, client runtimeclient.Client, ms *machinev1.MachineSet, ...) error
• func GetPVCsFromNamespace(ctx context.Context, dc dynamic.Interface, namespace string) ([]objx.Map, error)
• func GetShareTypesFromName(ctx context.Context, client *gophercloud.ServiceClient, shareTypeName string) ([]sharetypes.ShareType, error)
• func GetSharesFromName(ctx context.Context, client *gophercloud.ServiceClient, shareName string) ([]shares.Share, error)
• func GetSubnetIDfromKuryrNetwork(ctx context.Context, clientSet *kubernetes.Clientset, namespace string) (string, error)
• func IsOctaviaVersionGreaterThanOrEqual(ctx context.Context, client *gophercloud.ServiceClient, constraint string) (bool, error)
• func RandomSuffix() string
• type KuryrNetwork
  • func GetKuryrNetwork(ctx context.Context, clientSet *kubernetes.Clientset, namespace string) (KuryrNetwork, error)

Constants

const (
	NetworkTypeOpenShiftSDN  = "OpenShiftSDN"
	NetworkTypeOVNKubernetes = "OVNKubernetes"
	NetworkTypeKuryr         = "Kuryr"
)

Functions

func CreateNamespace

func CreateNamespace(ctx context.Context, clientSet *kubernetes.Clientset, baseName string, privileged bool) *v1.Namespace

func CreatePVC

func CreatePVC(ctx context.Context, clientSet *kubernetes.Clientset, baseName string, nsName string, scName string, pvcSize string) *v1.PersistentVolumeClaim

func CreatePod

func CreatePod(ctx context.Context, clientSet *kubernetes.Clientset, nsName string, baseName string, hostNetwork bool, command []string) (*v1.Pod, error)

func DeleteMachinesetsDefer

func DeleteMachinesetsDefer(client runtimeclient.Client, ms *machinev1.MachineSet)

func DeleteNamespace

func DeleteNamespace(ctx context.Context, clientSet *kubernetes.Clientset, ns *v1.Namespace)

func ElementExists

func ElementExists(s []string, str string) bool

func FindStorageClassByProvider

func FindStorageClassByProvider(oc *exutil.CLI, provisioner string, seek_default bool) *storagev1.StorageClass

return storageClass with specific provisioner. If seek_default is true, it will look also for the default annotation.

func GetClusterLoadBalancerSetting

func GetClusterLoadBalancerSetting(setting string, config *ini.File) (string, error)

get the LoadBalancer setting based on the provided CloudProviderConfig INI file and the default values

func GetFloatingNetworkID

func GetFloatingNetworkID(ctx context.Context, client *gophercloud.ServiceClient, cloudProviderConfig *ini.File) (string, error)

GetFloatingNetworkID returns a floating network ID.

func GetMachinesetRetry

func GetMachinesetRetry(ctx context.Context, client runtimeclient.Client, ms *machinev1.MachineSet, shouldExist bool) error

func GetPVCsFromNamespace

func GetPVCsFromNamespace(ctx context.Context, dc dynamic.Interface, namespace string) ([]objx.Map, error)

return list of PVCs defined in a given namespace

func GetShareTypesFromName

func GetShareTypesFromName(ctx context.Context, client *gophercloud.ServiceClient, shareTypeName string) ([]sharetypes.ShareType, error)

return sharetype from openstack with specific name

func GetSharesFromName

func GetSharesFromName(ctx context.Context, client *gophercloud.ServiceClient, shareName string) ([]shares.Share, error)

return share from openstack with specific name

func GetSubnetIDfromKuryrNetwork

func GetSubnetIDfromKuryrNetwork(ctx context.Context, clientSet *kubernetes.Clientset, namespace string) (string, error)

func IsOctaviaVersionGreaterThanOrEqual

func IsOctaviaVersionGreaterThanOrEqual(ctx context.Context, client *gophercloud.ServiceClient, constraint string) (bool, error)

func RandomSuffix

func RandomSuffix() string

Types

type KuryrNetwork

type KuryrNetwork struct {
	Status struct {
		SubnetID string `json:"subnetId"`
	} `json:"status"`
}

func GetKuryrNetwork

func GetKuryrNetwork(ctx context.Context, clientSet *kubernetes.Clientset, namespace string) (KuryrNetwork, error)