storage

package
v0.15.4 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package storage is a generated GoMock package.

Index

Constants

View Source 
const (
	DiskDumpCMD       = "dd"
	DiskDumpTimeout   = 60 * 10 // seconds
	DiskDumpBlockSize = "bs=10M"
)
View Source 
const (
	LVMask = 1
	VGMask = 1 << 1
	PVMask = 1 << 2
)

consts

View Source 
const LVMUnknownStatus = "unknown"

LVMUnknownStatus this represents no error or this status is not set

View Source 
const SysDevicePath = "/dev"

Variables

View Source 
var (
	ErrNotLVMByteNum   = errors.New("LVM byte format unrecognised")
	ErrReplicaNotFound = errors.New("volume replica not found on host")
	LVMTimeLayout      = "2006-01-02 15:04:05 -0700"
)

variables

View Source 
var (
	ErrorPoolNotFound                   = errors.New("not found pool")
	ErrorReplicaNotFound                = errors.New("not found replica")
	ErrorSnapshotNotFound               = errors.New("not found snapshot")
	ErrorReplicaExists                  = errors.New("already exists replica")
	ErrorLocalVolumeExistsInVolumeGroup = errors.New("already exists in volume group")
	ErrorInsufficientRequestResources   = errors.New("insufficient request resources")
	ErrorOverLimitedRequestResource     = errors.New("over limited request resources")
)

variables

Functions

This section is empty.

Types

type LocalManager 

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

LocalManager struct

func NewLocalManager 

func NewLocalManager(nodeConf *apisv1alpha1.NodeConfig, cli client.Client, scheme *runtime.Scheme, recorder record.EventRecorder) *LocalManager

NewLocalManager creates a local manager

func (*LocalManager) NodeConfig 

func (lm *LocalManager) NodeConfig() *apisv1alpha1.NodeConfig

NodeConfig gets node configuration

func (*LocalManager) PoolManager 

func (lm *LocalManager) PoolManager() LocalPoolManager

PoolManager gets pool manager

func (*LocalManager) Register 

func (lm *LocalManager) Register() error

Register for local storage

func (*LocalManager) Registry 

func (lm *LocalManager) Registry() LocalRegistry

Registry return singleton of local registry

func (*LocalManager) UpdateNodeForVolumeReplica 

func (lm *LocalManager) UpdateNodeForVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica)

UpdateNodeForVolumeReplica updates LocalStorageNode for volume replica

func (*LocalManager) VolumeReplicaManager 

func (lm *LocalManager) VolumeReplicaManager() LocalVolumeReplicaManager

VolumeReplicaManager gets volume replica manager

func (*LocalManager) VolumeReplicaSnapshotManager 

func (lm *LocalManager) VolumeReplicaSnapshotManager() LocalVolumeReplicaSnapshotManager

VolumeReplicaSnapshotManager gets volume replica snapshot manager

type LocalPoolExecutor 

type LocalPoolExecutor interface {
	ExtendPools(localDisks []*apisv1alpha1.LocalDevice) (bool, error)
	GetPools() (map[string]*apisv1alpha1.LocalPool, error)
	GetReplicas() (map[string]*apisv1alpha1.LocalVolumeReplica, error)
	ResizePhysicalVolumes(localDisks map[string]*apisv1alpha1.LocalDevice) error
}

LocalPoolExecutor interface

type LocalPoolManager 

type LocalPoolManager interface {
	ExtendPools(localDisks []*apisv1alpha1.LocalDevice) (bool, error)

	GetPools() (map[string]*apisv1alpha1.LocalPool, error)

	GetReplicas() (map[string]*apisv1alpha1.LocalVolumeReplica, error)

	ResizePhysicalVolumes(localDisks map[string]*apisv1alpha1.LocalDevice) error
}

LocalPoolManager is an interface to manage local storage pools

type LocalRegistry 

type LocalRegistry interface {
	Init()

	Disks() map[string]*apisv1alpha1.LocalDevice
	Pools() map[string]*apisv1alpha1.LocalPool
	VolumeReplicas() map[string]*apisv1alpha1.LocalVolumeReplica
	HasVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) bool
	UpdateNodeForVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica)
	SyncNodeResources() error
	UpdateCondition(condition apisv1alpha1.StorageNodeCondition) error
	UpdatePoolExtendRecord(pool string, record apisv1alpha1.LocalDiskClaimSpec) error
}

LocalRegistry interface

type LocalVolumeExecutor 

type LocalVolumeExecutor interface {
	CreateVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) (*apisv1alpha1.LocalVolumeReplica, error)
	DeleteVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) error
	ExpandVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica, newCapacityBytes int64) (*apisv1alpha1.LocalVolumeReplica, error)
	TestVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) (*apisv1alpha1.LocalVolumeReplica, error)
	// GetReplicas return all replicas
	GetReplicas() (map[string]*apisv1alpha1.LocalVolumeReplica, error)

	// ConsistencyCheck on all volume replicas by comparing VolumeReplica and underlying volumes
	// will log all the check results for alerting or other purpose, but not block anything
	ConsistencyCheck(crdReplicas map[string]*apisv1alpha1.LocalVolumeReplica)
}

LocalVolumeExecutor interface

type LocalVolumeReplicaManager 

type LocalVolumeReplicaManager interface {
	CreateVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) (*apisv1alpha1.LocalVolumeReplica, error)
	DeleteVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) error
	ExpandVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica, newCapacityBytes int64) (*apisv1alpha1.LocalVolumeReplica, error)
	GetVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) (*apisv1alpha1.LocalVolumeReplica, error)
	TestVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) (*apisv1alpha1.LocalVolumeReplica, error)

	// ConsistencyCheck  on all volume replicas by comparing VolumeReplica and underlying volumes
	// will log all the check results for alerting or other purpose, but not block anything
	ConsistencyCheck()
}

LocalVolumeReplicaManager interface

type LocalVolumeReplicaSnapshotExecutor 

type LocalVolumeReplicaSnapshotExecutor interface {
	CreateVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) error
	DeleteVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) error
	UpdateVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) (*apisv1alpha1.LocalVolumeReplicaSnapshotStatus, error)
	GetVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) (*apisv1alpha1.LocalVolumeReplicaSnapshotStatus, error)

	LocalVolumeReplicaSnapshotRestoreManager
}

type LocalVolumeReplicaSnapshotManager 

type LocalVolumeReplicaSnapshotManager interface {
	CreateVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) error
	DeleteVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) error
	UpdateVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) (*apisv1alpha1.LocalVolumeReplicaSnapshotStatus, error)
	GetVolumeReplicaSnapshot(replicaSnapshot *apisv1alpha1.LocalVolumeReplicaSnapshot) (*apisv1alpha1.LocalVolumeReplicaSnapshotStatus, error)

	LocalVolumeReplicaSnapshotRestoreManager
}

LocalVolumeReplicaSnapshotManager interface

type LocalVolumeReplicaSnapshotRestoreManager 

type LocalVolumeReplicaSnapshotRestoreManager interface {
	RollbackVolumeReplicaSnapshot(snapshotRestore *apisv1alpha1.LocalVolumeReplicaSnapshotRestore) error
	RestoreVolumeReplicaSnapshot(snapshotRestore *apisv1alpha1.LocalVolumeReplicaSnapshotRestore) error
}

type MockLocalPoolExecutor 

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

MockLocalPoolExecutor is a mock of LocalPoolExecutor interface.

func NewMockLocalPoolExecutor 

func NewMockLocalPoolExecutor(ctrl *gomock.Controller) *MockLocalPoolExecutor

NewMockLocalPoolExecutor creates a new mock instance.

func (*MockLocalPoolExecutor) EXPECT 

func (m *MockLocalPoolExecutor) EXPECT() *MockLocalPoolExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalPoolExecutor) ExtendPools 

func (m *MockLocalPoolExecutor) ExtendPools(localDisks []*v1alpha1.LocalDevice) (bool, error)

ExtendPools mocks base method.

func (*MockLocalPoolExecutor) GetPools 

func (m *MockLocalPoolExecutor) GetPools() (map[string]*v1alpha1.LocalPool, error)

GetPools mocks base method.

func (*MockLocalPoolExecutor) GetReplicas 

func (m *MockLocalPoolExecutor) GetReplicas() (map[string]*v1alpha1.LocalVolumeReplica, error)

GetReplicas mocks base method.

func (*MockLocalPoolExecutor) ResizePhysicalVolumes 

func (m *MockLocalPoolExecutor) ResizePhysicalVolumes(localDisks map[string]*v1alpha1.LocalDevice) error

ResizePhysicalVolumes mocks base method.

type MockLocalPoolExecutorMockRecorder 

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

MockLocalPoolExecutorMockRecorder is the mock recorder for MockLocalPoolExecutor.

func (*MockLocalPoolExecutorMockRecorder) ExtendPools 

func (mr *MockLocalPoolExecutorMockRecorder) ExtendPools(localDisks interface{}) *gomock.Call

ExtendPools indicates an expected call of ExtendPools.

func (*MockLocalPoolExecutorMockRecorder) GetPools 

func (mr *MockLocalPoolExecutorMockRecorder) GetPools() *gomock.Call

GetPools indicates an expected call of GetPools.

func (*MockLocalPoolExecutorMockRecorder) GetReplicas 

func (mr *MockLocalPoolExecutorMockRecorder) GetReplicas() *gomock.Call

GetReplicas indicates an expected call of GetReplicas.

func (*MockLocalPoolExecutorMockRecorder) ResizePhysicalVolumes 

func (mr *MockLocalPoolExecutorMockRecorder) ResizePhysicalVolumes(localDisks interface{}) *gomock.Call

ResizePhysicalVolumes indicates an expected call of ResizePhysicalVolumes.

type MockLocalPoolManager 

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

MockLocalPoolManager is a mock of LocalPoolManager interface.

func NewMockLocalPoolManager 

func NewMockLocalPoolManager(ctrl *gomock.Controller) *MockLocalPoolManager

NewMockLocalPoolManager creates a new mock instance.

func (*MockLocalPoolManager) EXPECT 

func (m *MockLocalPoolManager) EXPECT() *MockLocalPoolManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalPoolManager) ExtendPools 

func (m *MockLocalPoolManager) ExtendPools(localDisks []*v1alpha1.LocalDevice) (bool, error)

ExtendPools mocks base method.

func (*MockLocalPoolManager) GetPools 

func (m *MockLocalPoolManager) GetPools() (map[string]*v1alpha1.LocalPool, error)

GetPools mocks base method.

func (*MockLocalPoolManager) GetReplicas 

func (m *MockLocalPoolManager) GetReplicas() (map[string]*v1alpha1.LocalVolumeReplica, error)

GetReplicas mocks base method.

func (*MockLocalPoolManager) ResizePhysicalVolumes 

func (m *MockLocalPoolManager) ResizePhysicalVolumes(localDisks map[string]*v1alpha1.LocalDevice) error

ResizePhysicalVolumes mocks base method.

type MockLocalPoolManagerMockRecorder 

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

MockLocalPoolManagerMockRecorder is the mock recorder for MockLocalPoolManager.

func (*MockLocalPoolManagerMockRecorder) ExtendPools 

func (mr *MockLocalPoolManagerMockRecorder) ExtendPools(localDisks interface{}) *gomock.Call

ExtendPools indicates an expected call of ExtendPools.

func (*MockLocalPoolManagerMockRecorder) GetPools 

func (mr *MockLocalPoolManagerMockRecorder) GetPools() *gomock.Call

GetPools indicates an expected call of GetPools.

func (*MockLocalPoolManagerMockRecorder) GetReplicas 

func (mr *MockLocalPoolManagerMockRecorder) GetReplicas() *gomock.Call

GetReplicas indicates an expected call of GetReplicas.

func (*MockLocalPoolManagerMockRecorder) ResizePhysicalVolumes 

func (mr *MockLocalPoolManagerMockRecorder) ResizePhysicalVolumes(localDisks interface{}) *gomock.Call

ResizePhysicalVolumes indicates an expected call of ResizePhysicalVolumes.

type MockLocalRegistry 

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

MockLocalRegistry is a mock of LocalRegistry interface.

func NewMockLocalRegistry 

func NewMockLocalRegistry(ctrl *gomock.Controller) *MockLocalRegistry

NewMockLocalRegistry creates a new mock instance.

func (*MockLocalRegistry) Disks 

func (m *MockLocalRegistry) Disks() map[string]*v1alpha1.LocalDevice

Disks mocks base method.

func (*MockLocalRegistry) EXPECT 

func (m *MockLocalRegistry) EXPECT() *MockLocalRegistryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalRegistry) HasVolumeReplica 

func (m *MockLocalRegistry) HasVolumeReplica(replica *v1alpha1.LocalVolumeReplica) bool

HasVolumeReplica mocks base method.

func (*MockLocalRegistry) Init 

func (m *MockLocalRegistry) Init()

Init mocks base method.

func (*MockLocalRegistry) Pools 

func (m *MockLocalRegistry) Pools() map[string]*v1alpha1.LocalPool

Pools mocks base method.

func (*MockLocalRegistry) SyncNodeResources 

func (m *MockLocalRegistry) SyncNodeResources() error

SyncNodeResources mocks base method.

func (*MockLocalRegistry) UpdateCondition 

func (m *MockLocalRegistry) UpdateCondition(condition v1alpha1.StorageNodeCondition) error

UpdateCondition mocks base method.

func (*MockLocalRegistry) UpdateNodeForVolumeReplica 

func (m *MockLocalRegistry) UpdateNodeForVolumeReplica(replica *v1alpha1.LocalVolumeReplica)

UpdateNodeForVolumeReplica mocks base method.

func (*MockLocalRegistry) UpdatePoolExtendRecord 

func (m *MockLocalRegistry) UpdatePoolExtendRecord(pool string, record v1alpha1.LocalDiskClaimSpec) error

UpdatePoolExtendRecord mocks base method.

func (*MockLocalRegistry) VolumeReplicas 

func (m *MockLocalRegistry) VolumeReplicas() map[string]*v1alpha1.LocalVolumeReplica

VolumeReplicas mocks base method.

type MockLocalRegistryMockRecorder 

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

MockLocalRegistryMockRecorder is the mock recorder for MockLocalRegistry.

func (*MockLocalRegistryMockRecorder) Disks 

func (mr *MockLocalRegistryMockRecorder) Disks() *gomock.Call

Disks indicates an expected call of Disks.

func (*MockLocalRegistryMockRecorder) HasVolumeReplica 

func (mr *MockLocalRegistryMockRecorder) HasVolumeReplica(replica interface{}) *gomock.Call

HasVolumeReplica indicates an expected call of HasVolumeReplica.

func (*MockLocalRegistryMockRecorder) Init 

func (mr *MockLocalRegistryMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockLocalRegistryMockRecorder) Pools 

func (mr *MockLocalRegistryMockRecorder) Pools() *gomock.Call

Pools indicates an expected call of Pools.

func (*MockLocalRegistryMockRecorder) SyncNodeResources 

func (mr *MockLocalRegistryMockRecorder) SyncNodeResources() *gomock.Call

SyncNodeResources indicates an expected call of SyncNodeResources.

func (*MockLocalRegistryMockRecorder) UpdateCondition 

func (mr *MockLocalRegistryMockRecorder) UpdateCondition(condition interface{}) *gomock.Call

UpdateCondition indicates an expected call of UpdateCondition.

func (*MockLocalRegistryMockRecorder) UpdateNodeForVolumeReplica 

func (mr *MockLocalRegistryMockRecorder) UpdateNodeForVolumeReplica(replica interface{}) *gomock.Call

UpdateNodeForVolumeReplica indicates an expected call of UpdateNodeForVolumeReplica.

func (*MockLocalRegistryMockRecorder) UpdatePoolExtendRecord 

func (mr *MockLocalRegistryMockRecorder) UpdatePoolExtendRecord(pool, record interface{}) *gomock.Call

UpdatePoolExtendRecord indicates an expected call of UpdatePoolExtendRecord.

func (*MockLocalRegistryMockRecorder) VolumeReplicas 

func (mr *MockLocalRegistryMockRecorder) VolumeReplicas() *gomock.Call

VolumeReplicas indicates an expected call of VolumeReplicas.

type MockLocalVolumeExecutor 

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

MockLocalVolumeExecutor is a mock of LocalVolumeExecutor interface.

func NewMockLocalVolumeExecutor 

func NewMockLocalVolumeExecutor(ctrl *gomock.Controller) *MockLocalVolumeExecutor

NewMockLocalVolumeExecutor creates a new mock instance.

func (*MockLocalVolumeExecutor) ConsistencyCheck 

func (m *MockLocalVolumeExecutor) ConsistencyCheck(crdReplicas map[string]*v1alpha1.LocalVolumeReplica)

ConsistencyCheck mocks base method.

func (*MockLocalVolumeExecutor) CreateVolumeReplica 

func (m *MockLocalVolumeExecutor) CreateVolumeReplica(replica *v1alpha1.LocalVolumeReplica) (*v1alpha1.LocalVolumeReplica, error)

CreateVolumeReplica mocks base method.

func (*MockLocalVolumeExecutor) DeleteVolumeReplica 

func (m *MockLocalVolumeExecutor) DeleteVolumeReplica(replica *v1alpha1.LocalVolumeReplica) error

DeleteVolumeReplica mocks base method.

func (*MockLocalVolumeExecutor) EXPECT 

func (m *MockLocalVolumeExecutor) EXPECT() *MockLocalVolumeExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalVolumeExecutor) ExpandVolumeReplica 

func (m *MockLocalVolumeExecutor) ExpandVolumeReplica(replica *v1alpha1.LocalVolumeReplica, newCapacityBytes int64) (*v1alpha1.LocalVolumeReplica, error)

ExpandVolumeReplica mocks base method.

func (*MockLocalVolumeExecutor) GetReplicas 

func (m *MockLocalVolumeExecutor) GetReplicas() (map[string]*v1alpha1.LocalVolumeReplica, error)

GetReplicas mocks base method.

func (*MockLocalVolumeExecutor) TestVolumeReplica 

func (m *MockLocalVolumeExecutor) TestVolumeReplica(replica *v1alpha1.LocalVolumeReplica) (*v1alpha1.LocalVolumeReplica, error)

TestVolumeReplica mocks base method.

type MockLocalVolumeExecutorMockRecorder 

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

MockLocalVolumeExecutorMockRecorder is the mock recorder for MockLocalVolumeExecutor.

func (*MockLocalVolumeExecutorMockRecorder) ConsistencyCheck 

func (mr *MockLocalVolumeExecutorMockRecorder) ConsistencyCheck(crdReplicas interface{}) *gomock.Call

ConsistencyCheck indicates an expected call of ConsistencyCheck.

func (*MockLocalVolumeExecutorMockRecorder) CreateVolumeReplica 

func (mr *MockLocalVolumeExecutorMockRecorder) CreateVolumeReplica(replica interface{}) *gomock.Call

CreateVolumeReplica indicates an expected call of CreateVolumeReplica.

func (*MockLocalVolumeExecutorMockRecorder) DeleteVolumeReplica 

func (mr *MockLocalVolumeExecutorMockRecorder) DeleteVolumeReplica(replica interface{}) *gomock.Call

DeleteVolumeReplica indicates an expected call of DeleteVolumeReplica.

func (*MockLocalVolumeExecutorMockRecorder) ExpandVolumeReplica 

func (mr *MockLocalVolumeExecutorMockRecorder) ExpandVolumeReplica(replica, newCapacityBytes interface{}) *gomock.Call

ExpandVolumeReplica indicates an expected call of ExpandVolumeReplica.

func (*MockLocalVolumeExecutorMockRecorder) GetReplicas 

func (mr *MockLocalVolumeExecutorMockRecorder) GetReplicas() *gomock.Call

GetReplicas indicates an expected call of GetReplicas.

func (*MockLocalVolumeExecutorMockRecorder) TestVolumeReplica 

func (mr *MockLocalVolumeExecutorMockRecorder) TestVolumeReplica(replica interface{}) *gomock.Call

TestVolumeReplica indicates an expected call of TestVolumeReplica.

type MockLocalVolumeReplicaManager 

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

MockLocalVolumeReplicaManager is a mock of LocalVolumeReplicaManager interface.

func NewMockLocalVolumeReplicaManager 

func NewMockLocalVolumeReplicaManager(ctrl *gomock.Controller) *MockLocalVolumeReplicaManager

NewMockLocalVolumeReplicaManager creates a new mock instance.

func (*MockLocalVolumeReplicaManager) ConsistencyCheck 

func (m *MockLocalVolumeReplicaManager) ConsistencyCheck()

ConsistencyCheck mocks base method.

func (*MockLocalVolumeReplicaManager) CreateVolumeReplica 

func (m *MockLocalVolumeReplicaManager) CreateVolumeReplica(replica *v1alpha1.LocalVolumeReplica) (*v1alpha1.LocalVolumeReplica, error)

CreateVolumeReplica mocks base method.

func (*MockLocalVolumeReplicaManager) DeleteVolumeReplica 

func (m *MockLocalVolumeReplicaManager) DeleteVolumeReplica(replica *v1alpha1.LocalVolumeReplica) error

DeleteVolumeReplica mocks base method.

func (*MockLocalVolumeReplicaManager) EXPECT 

func (m *MockLocalVolumeReplicaManager) EXPECT() *MockLocalVolumeReplicaManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalVolumeReplicaManager) ExpandVolumeReplica 

func (m *MockLocalVolumeReplicaManager) ExpandVolumeReplica(replica *v1alpha1.LocalVolumeReplica, newCapacityBytes int64) (*v1alpha1.LocalVolumeReplica, error)

ExpandVolumeReplica mocks base method.

func (*MockLocalVolumeReplicaManager) GetVolumeReplica 

func (m *MockLocalVolumeReplicaManager) GetVolumeReplica(replica *v1alpha1.LocalVolumeReplica) (*v1alpha1.LocalVolumeReplica, error)

GetVolumeReplica mocks base method.

func (*MockLocalVolumeReplicaManager) TestVolumeReplica 

func (m *MockLocalVolumeReplicaManager) TestVolumeReplica(replica *v1alpha1.LocalVolumeReplica) (*v1alpha1.LocalVolumeReplica, error)

TestVolumeReplica mocks base method.

type MockLocalVolumeReplicaManagerMockRecorder 

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

MockLocalVolumeReplicaManagerMockRecorder is the mock recorder for MockLocalVolumeReplicaManager.

func (*MockLocalVolumeReplicaManagerMockRecorder) ConsistencyCheck 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) ConsistencyCheck() *gomock.Call

ConsistencyCheck indicates an expected call of ConsistencyCheck.

func (*MockLocalVolumeReplicaManagerMockRecorder) CreateVolumeReplica 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) CreateVolumeReplica(replica interface{}) *gomock.Call

CreateVolumeReplica indicates an expected call of CreateVolumeReplica.

func (*MockLocalVolumeReplicaManagerMockRecorder) DeleteVolumeReplica 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) DeleteVolumeReplica(replica interface{}) *gomock.Call

DeleteVolumeReplica indicates an expected call of DeleteVolumeReplica.

func (*MockLocalVolumeReplicaManagerMockRecorder) ExpandVolumeReplica 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) ExpandVolumeReplica(replica, newCapacityBytes interface{}) *gomock.Call

ExpandVolumeReplica indicates an expected call of ExpandVolumeReplica.

func (*MockLocalVolumeReplicaManagerMockRecorder) GetVolumeReplica 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) GetVolumeReplica(replica interface{}) *gomock.Call

GetVolumeReplica indicates an expected call of GetVolumeReplica.

func (*MockLocalVolumeReplicaManagerMockRecorder) TestVolumeReplica 

func (mr *MockLocalVolumeReplicaManagerMockRecorder) TestVolumeReplica(replica interface{}) *gomock.Call

TestVolumeReplica indicates an expected call of TestVolumeReplica.

type MockLocalVolumeReplicaSnapshotManager 

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

MockLocalVolumeReplicaSnapshotManager is a mock of LocalVolumeReplicaSnapshotManager interface.

func NewMockLocalVolumeReplicaSnapshotManager 

func NewMockLocalVolumeReplicaSnapshotManager(ctrl *gomock.Controller) *MockLocalVolumeReplicaSnapshotManager

NewMockLocalVolumeReplicaSnapshotManager creates a new mock instance.

func (*MockLocalVolumeReplicaSnapshotManager) CreateVolumeReplicaSnapshot 

func (m *MockLocalVolumeReplicaSnapshotManager) CreateVolumeReplicaSnapshot(replicaSnapshot *v1alpha1.LocalVolumeReplicaSnapshot) (*v1alpha1.LocalVolumeReplicaSnapshot, error)

CreateVolumeReplicaSnapshot mocks base method.

func (*MockLocalVolumeReplicaSnapshotManager) DeleteVolumeReplicaSnapshot 

func (m *MockLocalVolumeReplicaSnapshotManager) DeleteVolumeReplicaSnapshot(replicaSnapshot *v1alpha1.LocalVolumeReplicaSnapshot) error

DeleteVolumeReplicaSnapshot mocks base method.

func (*MockLocalVolumeReplicaSnapshotManager) EXPECT 

func (m *MockLocalVolumeReplicaSnapshotManager) EXPECT() *MockLocalVolumeReplicaSnapshotManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLocalVolumeReplicaSnapshotManager) ExpandVolumeReplicaSnapshot 

func (m *MockLocalVolumeReplicaSnapshotManager) ExpandVolumeReplicaSnapshot(replicaSnapshot *v1alpha1.LocalVolumeReplicaSnapshot) (*v1alpha1.LocalVolumeReplica, error)

ExpandVolumeReplicaSnapshot mocks base method.

func (*MockLocalVolumeReplicaSnapshotManager) GetVolumeReplicaSnapshot 

func (m *MockLocalVolumeReplicaSnapshotManager) GetVolumeReplicaSnapshot(replicaSnapshot *v1alpha1.LocalVolumeReplicaSnapshot) (*v1alpha1.LocalVolumeReplica, error)

GetVolumeReplicaSnapshot mocks base method.

type MockLocalVolumeReplicaSnapshotManagerMockRecorder 

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

MockLocalVolumeReplicaSnapshotManagerMockRecorder is the mock recorder for MockLocalVolumeReplicaSnapshotManager.

func (*MockLocalVolumeReplicaSnapshotManagerMockRecorder) CreateVolumeReplicaSnapshot 

func (mr *MockLocalVolumeReplicaSnapshotManagerMockRecorder) CreateVolumeReplicaSnapshot(replicaSnapshot interface{}) *gomock.Call

CreateVolumeReplicaSnapshot indicates an expected call of CreateVolumeReplicaSnapshot.

func (*MockLocalVolumeReplicaSnapshotManagerMockRecorder) DeleteVolumeReplicaSnapshot 

func (mr *MockLocalVolumeReplicaSnapshotManagerMockRecorder) DeleteVolumeReplicaSnapshot(replicaSnapshot interface{}) *gomock.Call

DeleteVolumeReplicaSnapshot indicates an expected call of DeleteVolumeReplicaSnapshot.

func (*MockLocalVolumeReplicaSnapshotManagerMockRecorder) ExpandVolumeReplicaSnapshot 

func (mr *MockLocalVolumeReplicaSnapshotManagerMockRecorder) ExpandVolumeReplicaSnapshot(replicaSnapshot interface{}) *gomock.Call

ExpandVolumeReplicaSnapshot indicates an expected call of ExpandVolumeReplicaSnapshot.

func (*MockLocalVolumeReplicaSnapshotManagerMockRecorder) GetVolumeReplicaSnapshot 

func (mr *MockLocalVolumeReplicaSnapshotManagerMockRecorder) GetVolumeReplicaSnapshot(replicaSnapshot interface{}) *gomock.Call

GetVolumeReplicaSnapshot indicates an expected call of GetVolumeReplicaSnapshot.

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.