drvolume

package
v0.0.13 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DRVolume 

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

func (*DRVolume) SnapshotAndWaitReady 

func (drv *DRVolume) SnapshotAndWaitReady(ctx *contexts.Context, snapshotName string, opts DRVolumeSnapshotAndWaitOptions) error

type DRVolumeCreateOptions 

type DRVolumeCreateOptions struct {
	VolumeStorageClass string   `yaml:"volumeStorageClass,omitempty"`
	CNPGClusterNames   []string `yaml:"cnpgClusterNames,omitempty"`
}

type DRVolumeInterface 

type DRVolumeInterface interface {
	SnapshotAndWaitReady(ctx *contexts.Context, snapshotName string, opts DRVolumeSnapshotAndWaitOptions) error
	// contains filtered or unexported methods
}

type DRVolumeSnapshotAndWaitOptions 

type DRVolumeSnapshotAndWaitOptions struct {
	ReadyTimeout  helpers.MaxWaitTime `yaml:"snapshotReadyTimeout,omitempty"`
	SnapshotClass string              `yaml:"snapshotClass,omitempty"`
}

type MockDRVolumeInterface 

type MockDRVolumeInterface struct {
	mock.Mock
}

MockDRVolumeInterface is an autogenerated mock type for the DRVolumeInterface type

func NewMockDRVolumeInterface 

func NewMockDRVolumeInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDRVolumeInterface

NewMockDRVolumeInterface creates a new instance of MockDRVolumeInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDRVolumeInterface) EXPECT 

func (_m *MockDRVolumeInterface) EXPECT() *MockDRVolumeInterface_Expecter

func (*MockDRVolumeInterface) SnapshotAndWaitReady 

func (_m *MockDRVolumeInterface) SnapshotAndWaitReady(ctx *contexts.Context, snapshotName string, opts DRVolumeSnapshotAndWaitOptions) error

SnapshotAndWaitReady provides a mock function with given fields: ctx, snapshotName, opts

type MockDRVolumeInterface_Expecter 

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

func (*MockDRVolumeInterface_Expecter) SnapshotAndWaitReady 

func (_e *MockDRVolumeInterface_Expecter) SnapshotAndWaitReady(ctx interface{}, snapshotName interface{}, opts interface{}) *MockDRVolumeInterface_SnapshotAndWaitReady_Call

SnapshotAndWaitReady is a helper method to define mock.On call

  • ctx *contexts.Context
  • snapshotName string
  • opts DRVolumeSnapshotAndWaitOptions

type MockDRVolumeInterface_SnapshotAndWaitReady_Call 

type MockDRVolumeInterface_SnapshotAndWaitReady_Call struct {
	*mock.Call
}

MockDRVolumeInterface_SnapshotAndWaitReady_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SnapshotAndWaitReady'

func (*MockDRVolumeInterface_SnapshotAndWaitReady_Call) Return 

func (_c *MockDRVolumeInterface_SnapshotAndWaitReady_Call) Return(_a0 error) *MockDRVolumeInterface_SnapshotAndWaitReady_Call

func (*MockDRVolumeInterface_SnapshotAndWaitReady_Call) Run 

func (_c *MockDRVolumeInterface_SnapshotAndWaitReady_Call) Run(run func(ctx *contexts.Context, snapshotName string, opts DRVolumeSnapshotAndWaitOptions)) *MockDRVolumeInterface_SnapshotAndWaitReady_Call

func (*MockDRVolumeInterface_SnapshotAndWaitReady_Call) RunAndReturn 

func (_c *MockDRVolumeInterface_SnapshotAndWaitReady_Call) RunAndReturn(run func(*contexts.Context, string, DRVolumeSnapshotAndWaitOptions) error) *MockDRVolumeInterface_SnapshotAndWaitReady_Call

type MockDRVolumeInterface_setPVC_Call 

type MockDRVolumeInterface_setPVC_Call struct {
	*mock.Call
}

MockDRVolumeInterface_setPVC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'setPVC'

func (*MockDRVolumeInterface_setPVC_Call) Return 

func (_c *MockDRVolumeInterface_setPVC_Call) Return() *MockDRVolumeInterface_setPVC_Call

func (*MockDRVolumeInterface_setPVC_Call) Run 

func (_c *MockDRVolumeInterface_setPVC_Call) Run(run func(pvc *v1.PersistentVolumeClaim)) *MockDRVolumeInterface_setPVC_Call

func (*MockDRVolumeInterface_setPVC_Call) RunAndReturn 

func (_c *MockDRVolumeInterface_setPVC_Call) RunAndReturn(run func(*v1.PersistentVolumeClaim)) *MockDRVolumeInterface_setPVC_Call

type MockProviderInterface 

type MockProviderInterface struct {
	mock.Mock
}

MockProviderInterface is an autogenerated mock type for the ProviderInterface type

func NewMockProviderInterface 

func NewMockProviderInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockProviderInterface

NewMockProviderInterface creates a new instance of MockProviderInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockProviderInterface) EXPECT 

func (_m *MockProviderInterface) EXPECT() *MockProviderInterface_Expecter

func (*MockProviderInterface) NewDRVolume 

func (_m *MockProviderInterface) NewDRVolume(ctx *contexts.Context, namespace string, name string, configuredSize resource.Quantity, opts DRVolumeCreateOptions) (DRVolumeInterface, error)

NewDRVolume provides a mock function with given fields: ctx, namespace, name, configuredSize, opts

type MockProviderInterface_Expecter 

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

func (*MockProviderInterface_Expecter) NewDRVolume 

func (_e *MockProviderInterface_Expecter) NewDRVolume(ctx interface{}, namespace interface{}, name interface{}, configuredSize interface{}, opts interface{}) *MockProviderInterface_NewDRVolume_Call

NewDRVolume is a helper method to define mock.On call

  • ctx *contexts.Context
  • namespace string
  • name string
  • configuredSize resource.Quantity
  • opts DRVolumeCreateOptions

type MockProviderInterface_NewDRVolume_Call 

type MockProviderInterface_NewDRVolume_Call struct {
	*mock.Call
}

MockProviderInterface_NewDRVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewDRVolume'

func (*MockProviderInterface_NewDRVolume_Call) Return 

func (_c *MockProviderInterface_NewDRVolume_Call) Return(_a0 DRVolumeInterface, _a1 error) *MockProviderInterface_NewDRVolume_Call

func (*MockProviderInterface_NewDRVolume_Call) Run 

func (_c *MockProviderInterface_NewDRVolume_Call) Run(run func(ctx *contexts.Context, namespace string, name string, configuredSize resource.Quantity, opts DRVolumeCreateOptions)) *MockProviderInterface_NewDRVolume_Call

func (*MockProviderInterface_NewDRVolume_Call) RunAndReturn 

func (_c *MockProviderInterface_NewDRVolume_Call) RunAndReturn(run func(*contexts.Context, string, string, resource.Quantity, DRVolumeCreateOptions) (DRVolumeInterface, error)) *MockProviderInterface_NewDRVolume_Call

type Provider 

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

func NewProvider 

func NewProvider(coreClient core.ClientInterface, esClient externalsnapshotter.ClientInterface, cnpgClient cnpg.ClientInterface) *Provider

func (*Provider) NewDRVolume 

func (p *Provider) NewDRVolume(ctx *contexts.Context, namespace, name string, configuredSize resource.Quantity, opts DRVolumeCreateOptions) (DRVolumeInterface, error)

TODO handle expansion?

type ProviderInterface 

type ProviderInterface interface {
	NewDRVolume(ctx *contexts.Context, namespace, name string, configuredSize resource.Quantity, opts DRVolumeCreateOptions) (DRVolumeInterface, error)
}

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.