utils

package

v1.8.0 Latest Latest Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dell/csm-replication

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetConfigFromFile(kubeconfig string) (*rest.Config, error)
func GetFakeClient() client.Client
func GetFakeClientWithObjects(initObjs ...client.Object) client.Client
func GetLogger() logr.Logger
func GetNonReplicationEnabledSC(provisionerName, scName string) *storagev1.StorageClass
func GetPVCObj(pvcName string, namespace string, sc string) *v1.PersistentVolumeClaim
func GetPVObj(name, volHandle, provisionerName, scName string, ...) *v1.PersistentVolume
func GetParams(remoteClusterID, remoteSCName string) map[string]string
func GetRGObj(name, driverName, remoteClusterID, pgID, remotePGID string, ...) *repv1.DellCSIReplicationGroup
func GetReplicationEnabledSC(provisionerName, scName, remoteSCName, remoteClusterID string) *storagev1.StorageClass
func InitializeSchemes()
func RunServer(stubsPath string)
func StopMockServer()
func ValidateAnnotations(annotations map[string]string, t *testing.T)
func ValidateRemotePVAnnotations(annotations map[string]string, t *testing.T)
func ValidateRemoteRGAnnotations(annotations map[string]string, t *testing.T)
func WaitForAllToBeBound(ctx context.Context, k8sClient client.Client, t *testing.T) error
type Common
type Driver
- func GetDefaultDriver() Driver
type MockUtils

Constants ¶

View Source

const (
	// FakePVName name of PV
	FakePVName = "fake-pv"
	// FakePVCName name of PVC
	FakePVCName = "fake-pvc"
	// FakeSCName name of SC
	FakeSCName = "fake-sc"
	// FakeDriverName name of driver
	FakeDriverName = "fake-csi-driver"
	// FakeRemoteSCName name of remote SC
	FakeRemoteSCName = "fake-remote-sc"
	// FakeRGName name of remote RG
	FakeRGName = "fake-rg"
	// FakeNamespaceName name of namespace
	FakeNamespaceName = "fake-namespace"
	// Self this cluster
	Self = "self"
	// RemoteClusterID id remote cluster
	RemoteClusterID = "remoteCluster"
	// SourceClusterID id source cluster
	SourceClusterID = "sourceCluster"
	// LocalPGID id of local protection group
	LocalPGID = "l-group-id"
	// RemotePGID id of remote protection group
	RemotePGID = "r-group-id"
	// ContextPrefix fake csi replication prefix
	ContextPrefix = "csi-fake"
)

View Source

const PVCName = "test-pvc"

PVCName name of testing PVC

Variables ¶

View Source

var MockServer *grpc.Server

MockServer mock grpc server

View Source

var Scheme = runtime.NewScheme()

Scheme runtime Scheme

Functions ¶

func GetConfigFromFile ¶

func GetConfigFromFile(kubeconfig string) (*rest.Config, error)

GetConfigFromFile creates *rest.Config object from provided config path

func GetFakeClient ¶

func GetFakeClient() client.Client

GetFakeClient returns fake k8s client

func GetFakeClientWithObjects ¶

func GetFakeClientWithObjects(initObjs ...client.Object) client.Client

GetFakeClientWithObjects returns fake k8s client and populates it with given objects

func GetLogger ¶

func GetLogger() logr.Logger

GetLogger returns currently used logger

func GetNonReplicationEnabledSC ¶

func GetNonReplicationEnabledSC(provisionerName, scName string) *storagev1.StorageClass

GetNonReplicationEnabledSC returns usual StorageClass testing object

func GetPVCObj ¶

func GetPVCObj(pvcName string, namespace string, sc string) *v1.PersistentVolumeClaim

GetPVCObj returns PersistentVolumeClaim testing object

func GetPVObj ¶

func GetPVObj(name, volHandle, provisionerName, scName string, volAttributes map[string]string) *v1.PersistentVolume

GetPVObj returns PersistentVolume testing object

func GetParams ¶

func GetParams(remoteClusterID, remoteSCName string) map[string]string

GetParams returns correct map of replication parameters

func GetRGObj ¶

func GetRGObj(name, driverName, remoteClusterID, pgID, remotePGID string, params,
	remoteParams map[string]string,
) *repv1.DellCSIReplicationGroup

GetRGObj returns DellCSIReplicationGroup testing object

func GetReplicationEnabledSC ¶

func GetReplicationEnabledSC(provisionerName, scName, remoteSCName, remoteClusterID string) *storagev1.StorageClass

GetReplicationEnabledSC returns replication enabled StorageClass testing object

func InitializeSchemes ¶

func InitializeSchemes()

InitializeSchemes inits client-go and replication v1 schemes

func RunServer ¶

func RunServer(stubsPath string)

RunServer launches mock grpc server

func StopMockServer ¶

func StopMockServer()

StopMockServer terminates mock grpc server

func ValidateAnnotations ¶

func ValidateAnnotations(annotations map[string]string, t *testing.T)

ValidateAnnotations validates that given annotations are correct

func ValidateRemotePVAnnotations ¶

func ValidateRemotePVAnnotations(annotations map[string]string, t *testing.T)

ValidateRemotePVAnnotations validates that given PV annotations are correct

func ValidateRemoteRGAnnotations ¶

func ValidateRemoteRGAnnotations(annotations map[string]string, t *testing.T)

ValidateRemoteRGAnnotations validates that given RG annotations are correct

func WaitForAllToBeBound ¶

func WaitForAllToBeBound(ctx context.Context, k8sClient client.Client, t *testing.T) error

WaitForAllToBeBound waits for every PVC, that belongs to PVCClient, to be Bound

Types ¶

type Common ¶

type Common struct {
	Namespace string
}

Common contains common resources

type Driver ¶

type Driver struct {
	DriverName      string
	StorageClass    string
	RemoteClusterID string
	RemoteSCName    string
	SourceClusterID string
	Namespace       string
	RGName          string
	PVName          string
}

Driver mock implementation of the driver

func GetDefaultDriver ¶

func GetDefaultDriver() Driver

GetDefaultDriver returns default mock implementation of the driver

type MockUtils ¶

type MockUtils struct {
	FakeClient           *fakeclient.Client
	Specs                Common
	FakeControllerClient client.Client
}

MockUtils contains utils for mocking calls

Source Files ¶

View all Source files

utils.go

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