mocks

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ExecuteActionWithoutStatus condition
	ExecuteActionWithoutStatus = conditionType("ExecuteActionWithoutStatus")
	// ExecuteActionWithoutSuccess condition
	ExecuteActionWithoutSuccess = conditionType("ExecuteActionWithoutSuccess")
	// ExecuteActionWithSwap condition
	ExecuteActionWithSwap = conditionType("ExecuteActionWithSwap")
	// CreatePGWithMissingPGID condition
	CreatePGWithMissingPGID = conditionType("CreatePGWithMissingPGID")
	// CreatePGWithOutStatus condition
	CreatePGWithOutStatus = conditionType("CreatePGWithOutStatus")
	// GetPGStatusForTarget condition
	GetPGStatusForTarget = conditionType("GetPGStatusForTarget")
	// GetPGStatusInProgress condition
	GetPGStatusInProgress = conditionType("GetPGStatusInProgress")
)

Variables

This section is empty.

Functions

func New 

func New(source string, targets ...string) connection.MultiClusterClient

New creates new fake config with prepopulated parameters

func NewFakeConfig 

func NewFakeConfig(source string, targets ...string) connection.MultiClusterClient

NewFakeConfig returns new FakeClient with initialized fake remote clients

func NewFakeConfigForSingleCluster 

func NewFakeConfigForSingleCluster(selfClient client.Client, source string, targets ...string) connection.MultiClusterClient

NewFakeConfigForSingleCluster returns new FakeClient configured to be used in single-cluster scenario

func NewFakeIdentityClient 

func NewFakeIdentityClient(name string) identity.Identity

NewFakeIdentityClient returns fake identity client

Types

type FakeConfig 

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

FakeConfig is a structure that implements MultiClusterClient interface providing dummy functionality

func (*FakeConfig) GetClusterID 

func (c *FakeConfig) GetClusterID() string

GetClusterID returns ID of fake cluster

func (*FakeConfig) GetConnection 

func (c *FakeConfig) GetConnection(clusterID string) (connection.RemoteClusterClient, error)

GetConnection returns fake connection remote client

type MockMigration 

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

MockMigration is dummy implementation of Migration interface

func NewFakeMigrationClient 

func NewFakeMigrationClient(contextPrefix string) MockMigration

NewFakeMigrationClient returns mock implementation of Migration interface

func (*MockMigration) ArrayMigrate 

func (m *MockMigration) ArrayMigrate(_ context.Context, migrateAction *csiext.ArrayMigrateRequest_Action, _ map[string]string) (*csiext.ArrayMigrateResponse, error)

ArrayMigrate migrates volume from source array to target

func (*MockMigration) ClearError 

func (m *MockMigration) ClearError(force bool)

ClearError clears injected error

func (*MockMigration) InjectError 

func (m *MockMigration) InjectError(err error)

InjectError injects error

func (*MockMigration) VolumeMigrate 

func (m *MockMigration) VolumeMigrate(_ context.Context, _ string, _ string, _ *csiext.VolumeMigrateRequest_Type,
	_ map[string]string, _ map[string]string, _ bool,
) (*csiext.VolumeMigrateResponse, error)

VolumeMigrate migrates volume

type MockReplication 

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

MockReplication is dummy implementation of Replication interface

func NewFakeReplicationClient 

func NewFakeReplicationClient(contextPrefix string) MockReplication

NewFakeReplicationClient returns mock implementation of Replication interface

func (*MockReplication) ClearErrorAndCondition 

func (m *MockReplication) ClearErrorAndCondition(force bool)

ClearErrorAndCondition clears injected error and resets condition

func (*MockReplication) CreateRemoteVolume 

func (m *MockReplication) CreateRemoteVolume(_ context.Context, volumeHandle string,
	params map[string]string,
) (*csiext.CreateRemoteVolumeResponse, error)

CreateRemoteVolume mocks call

func (*MockReplication) CreateStorageProtectionGroup 

func (m *MockReplication) CreateStorageProtectionGroup(_ context.Context, _ string,
	_ map[string]string,
) (*csiext.CreateStorageProtectionGroupResponse, error)

CreateStorageProtectionGroup mocks call

func (*MockReplication) DeleteLocalVolume 

func (m *MockReplication) DeleteLocalVolume(_ context.Context, _ string,
	_ map[string]string,
) (*csiext.DeleteLocalVolumeResponse, error)

DeleteLocalVolume mocks call

func (*MockReplication) DeleteStorageProtectionGroup 

func (m *MockReplication) DeleteStorageProtectionGroup(_ context.Context, _ string,
	_ map[string]string,
) error

DeleteStorageProtectionGroup mocks call

func (*MockReplication) ExecuteAction 

func (m *MockReplication) ExecuteAction(_ context.Context, _ string,
	actionType *csiext.ExecuteActionRequest_Action, _ map[string]string,
	_ string, _ map[string]string,
) (*csiext.ExecuteActionResponse, error)

ExecuteAction mocks call

func (*MockReplication) GetStorageProtectionGroupStatus 

func (m *MockReplication) GetStorageProtectionGroupStatus(_ context.Context,
	_ string, _ map[string]string,
) (*csiext.GetStorageProtectionGroupStatusResponse, error)

GetStorageProtectionGroupStatus mocks call

func (*MockReplication) InjectError 

func (m *MockReplication) InjectError(err error)

InjectError injects error

func (*MockReplication) InjectErrorAutoClear 

func (m *MockReplication) InjectErrorAutoClear(err error)

InjectErrorAutoClear injects error and clears after 1 try

func (*MockReplication) InjectErrorClearAfterN 

func (m *MockReplication) InjectErrorClearAfterN(err error, clearAfter int)

InjectErrorClearAfterN injects error and clears after N tries

func (*MockReplication) SetCondition 

func (m *MockReplication) SetCondition(conditionType conditionType)

SetCondition sets condition to provided condition type

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.