Documentation
¶
Index ¶
- func CheckBucketAccessAccountID(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CheckBucketAccessFromSecret(ctx context.Context, clientset *kubernetes.Clientset, validSecret *v1.Secret)
- func CheckBucketAccessStatus(ctx context.Context, bucketClient *bucketclientset.Clientset, ...) *v1alpha1.BucketAccess
- func CheckBucketClaimEvents(ctx context.Context, clientset *kubernetes.Clientset, ...)
- func CheckBucketClaimStatus(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CheckBucketDeletionInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, ...)
- func CheckBucketID(bucket *v1alpha1.Bucket)
- func CheckBucketNotInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, ...)
- func CheckBucketResourceInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, ...)
- func CheckBucketStatus(bucket *v1alpha1.Bucket, status bool)
- func CheckBucketStatusEmpty(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CheckCOSIControllerInstallation(ctx context.Context, clientset *kubernetes.Clientset, controllerName string, ...)
- func CheckCOSIDriverInstallation(ctx context.Context, clientset *kubernetes.Clientset, driver string, ...)
- func CheckClusterAvailability(clientset *kubernetes.Clientset)
- func CheckErrors(ctx context.Context, clientset *kubernetes.Clientset, ...)
- func CheckObjectScaleInstallation(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string)
- func CheckObjectStoreExists(ctx context.Context, objectscale *objectscaleRest.ClientSet, ...)
- func CheckPolicy(ctx context.Context, objectscale *objectscaleRest.ClientSet, ...)
- func CheckSecret(ctx context.Context, clientset *kubernetes.Clientset, inputSecret *v1.Secret) *v1.Secret
- func CheckUser(ctx context.Context, iamClient *iam.IAM, user string, namespace string)
- func CheckUserDeleted(ctx context.Context, iamClient *iam.IAM, user string, namespace string)
- func CreateBucket(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, ...)
- func CreateBucketAccessClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CreateBucketAccessResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CreateBucketClaimResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CreateBucketClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...) *v1alpha1.BucketClass
- func CreateBucketResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func CreateNamespace(ctx context.Context, clientset *kubernetes.Clientset, namespace string)
- func DeleteBucket(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, ...)
- func DeleteBucketAccessClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func DeleteBucketAccessResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func DeleteBucketClaimResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func DeleteBucketClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...)
- func GetBucketResource(ctx context.Context, bucketClient *bucketclientset.Clientset, ...) *v1alpha1.Bucket
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckBucketAccessAccountID ¶
func CheckBucketAccessAccountID(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccess *v1alpha1.BucketAccess, accountID string)
CheckBucketAccessAccountID Function for checking BucketAccess accountID.
func CheckBucketAccessFromSecret ¶
func CheckBucketAccessFromSecret(ctx context.Context, clientset *kubernetes.Clientset, validSecret *v1.Secret)
CheckBucketAccessFromSecret Check if Bucket can be accessed with data from specified secret.
func CheckBucketAccessStatus ¶
func CheckBucketAccessStatus(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccess *v1alpha1.BucketAccess, status bool) *v1alpha1.BucketAccess
CheckBucketAccessStatus Function for checking BucketAccess status.
func CheckBucketClaimEvents ¶
func CheckBucketClaimEvents(ctx context.Context, clientset *kubernetes.Clientset, bucketClaim *v1alpha1.BucketClaim, expected *v1.Event)
CheckBucketClaimEvents Check BucketClaim events.
func CheckBucketClaimStatus ¶
func CheckBucketClaimStatus(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClaim *v1alpha1.BucketClaim, status bool)
CheckBucketClaimStatus Function for checking BucketClaim status.
func CheckBucketDeletionInObjectStore ¶
func CheckBucketDeletionInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, bucket *v1alpha1.Bucket)
CheckBucketDeletionInObjectStore Function for checking Bucket deletion in ObjectStore.
func CheckBucketID ¶
CheckBucketID Function for checking bucketID.
func CheckBucketNotInObjectStore ¶
func CheckBucketNotInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, bucketClaim *v1alpha1.BucketClaim)
CheckBucketNotInObjectStore Function for checking if bucket is not in objectstore.
func CheckBucketResourceInObjectStore ¶
func CheckBucketResourceInObjectStore(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, bucket *v1alpha1.Bucket)
CheckBucketResourceInObjectStore Function checking if Bucket resource is in objectstore.
func CheckBucketStatus ¶
CheckBucketStatus Function for checking Bucket status.
func CheckBucketStatusEmpty ¶
func CheckBucketStatusEmpty(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClaim *v1alpha1.BucketClaim)
CheckBucketStatusEmpty function for checking if Bucket status is empty.
func CheckCOSIControllerInstallation ¶
func CheckCOSIControllerInstallation(ctx context.Context, clientset *kubernetes.Clientset, controllerName string, namespace string)
CheckCOSIControllerInstallation Ensure that COSI controller objectstorage-controller is installed in particular namespace.
func CheckCOSIDriverInstallation ¶
func CheckCOSIDriverInstallation(ctx context.Context, clientset *kubernetes.Clientset, driver string, namespace string)
CheckCOSIDriverInstallation Ensure that COSI driver is installed in particular namespace.
func CheckClusterAvailability ¶
func CheckClusterAvailability(clientset *kubernetes.Clientset)
CheckClusterAvailability Ensure that Kubernetes cluster is available.
func CheckErrors ¶
func CheckErrors(ctx context.Context, clientset *kubernetes.Clientset, pod, container, namespace string)
CheckErrors parses logs and counts occurrences of error messages.
func CheckObjectScaleInstallation ¶
func CheckObjectScaleInstallation(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string)
CheckObjectScaleInstallation Ensure that ObjectScale platform is installed on the cluster.
func CheckObjectStoreExists ¶
func CheckObjectStoreExists(ctx context.Context, objectscale *objectscaleRest.ClientSet, objectstore string)
CheckObjectStoreExists Ensure that ObjectStore "${objectstoreId}" is created.
func CheckPolicy ¶
func CheckPolicy(ctx context.Context, objectscale *objectscaleRest.ClientSet, expectedPolicyDocument policy.Document, myBucket *v1alpha1.Bucket, namespace string)
CheckPolicy checks if policy exists in ObjectScale.
func CheckSecret ¶
func CheckSecret(ctx context.Context, clientset *kubernetes.Clientset, inputSecret *v1.Secret) *v1.Secret
CheckSecret is used to check if secret exists.
func CheckUserDeleted ¶
CheckUserDeleted checks if user does not exist in ObjectScale.
func CreateBucket ¶
func CreateBucket(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, bucket *v1alpha1.Bucket)
CreateBucket Function for creating bucket on Objectscale.
func CreateBucketAccessClassResource ¶
func CreateBucketAccessClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccessClass *v1alpha1.BucketAccessClass)
CreateBucketAccessClassResource Function for creating BucketAccessClass resource.
func CreateBucketAccessResource ¶
func CreateBucketAccessResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccess *v1alpha1.BucketAccess)
CreateBucketAccessResource Function for creating BucketAccess resource.
func CreateBucketClaimResource ¶
func CreateBucketClaimResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClaim *v1alpha1.BucketClaim)
CreateBucketClaimResource Function creating a BucketClaim resource from specification.
func CreateBucketClassResource ¶
func CreateBucketClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClass *v1alpha1.BucketClass) *v1alpha1.BucketClass
CreateBucketClassResource Function for creating BucketClass resource.
func CreateBucketResource ¶
func CreateBucketResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucket *v1alpha1.Bucket)
CreateBucketClaimResource Function creating a BucketClaim resource from specification.
func CreateNamespace ¶
func CreateNamespace(ctx context.Context, clientset *kubernetes.Clientset, namespace string)
CreateNamespace Ensure that Kubernetes namespace is created.
func DeleteBucket ¶
func DeleteBucket(ctx context.Context, objectscale *objectscaleRest.ClientSet, namespace string, bucket *v1alpha1.Bucket)
DeleteBucket Function for deleting existing from ObjectScale (useful if BucketClaim deletionPolicy is set to "retain").
func DeleteBucketAccessClassResource ¶
func DeleteBucketAccessClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccessClass *v1alpha1.BucketAccessClass)
DeleteBucketAccessClassResource Function for deleting BucketAccessClass resource.
func DeleteBucketAccessResource ¶
func DeleteBucketAccessResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketAccess *v1alpha1.BucketAccess)
DeleteBucketAccessResource Function for deleting BucketAccess resource.
func DeleteBucketClaimResource ¶
func DeleteBucketClaimResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClaim *v1alpha1.BucketClaim)
DeleteBucketClaimResource Function for deleting BucketClaim resource.
func DeleteBucketClassResource ¶
func DeleteBucketClassResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClass *v1alpha1.BucketClass)
DeleteBucketClassResource Function for deleting BucketClass resource.
func GetBucketResource ¶
func GetBucketResource(ctx context.Context, bucketClient *bucketclientset.Clientset, bucketClaim *v1alpha1.BucketClaim) *v1alpha1.Bucket
GetBucketResource function for getting Bucket resource.
Types ¶
This section is empty.
Source Files