kubernetes/test/e2e/storage/testsuites/capacity.go

type capacityTestSuite …

// InitCustomCapacityTestSuite returns capacityTestSuite that implements TestSuite interface
// using custom test patterns
func InitCustomCapacityTestSuite(patterns []storageframework.TestPattern) storageframework.TestSuite { … }

// InitCapacityTestSuite returns capacityTestSuite that implements TestSuite interface\
// using test suite default patterns
func InitCapacityTestSuite() storageframework.TestSuite { … }

func (p *capacityTestSuite) GetTestSuiteInfo() storageframework.TestSuiteInfo { … }

func (p *capacityTestSuite) SkipUnsupportedTests(driver storageframework.TestDriver, pattern storageframework.TestPattern) { … }

func (p *capacityTestSuite) DefineTests(driver storageframework.TestDriver, pattern storageframework.TestPattern) { … }

func formatCapacities(capacities []storagev1.CSIStorageCapacity) []string { … }

// MatchCapacities runs some kind of check against *storagev1.CSIStorageCapacityList.
// In case of failure, all actual objects are appended to the failure message.
func MatchCapacities(match types.GomegaMatcher) types.GomegaMatcher { … }

type matchCSIStorageCapacities …

var _ …

func (m matchCSIStorageCapacities) Match(actual interface{ … }

func (m matchCSIStorageCapacities) FailureMessage(actual interface{ … }

func (m matchCSIStorageCapacities) NegatedFailureMessage(actual interface{ … }

func (m matchCSIStorageCapacities) dump(actual interface{ … }

type CapacityMatcher …

// HaveCapacitiesForClass filters all storage capacity objects in a *storagev1.CSIStorageCapacityList
// by storage class. Success is when when there is at least one.
func HaveCapacitiesForClass(scName string) CapacityMatcher { … }

type haveCSIStorageCapacities …

var _ …

func (h *haveCSIStorageCapacities) Match(actual interface{ … }

func (h *haveCSIStorageCapacities) MatchedCapacities() []storagev1.CSIStorageCapacity { … }

func (h *haveCSIStorageCapacities) FailureMessage(actual interface{ … }

func (h *haveCSIStorageCapacities) NegatedFailureMessage(actual interface{ … }

// HaveCapacitiesForClassAndNodes matches objects by storage class name. It finds
// all nodes on which the driver runs and expects one object per node.
func HaveCapacitiesForClassAndNodes(ctx context.Context, client kubernetes.Interface, driverName, scName, topologyKey string) CapacityMatcher { … }

type haveLocalStorageCapacities …

var _ …

func (h *haveLocalStorageCapacities) Match(actual interface{ … }

func (h *haveLocalStorageCapacities) MatchedCapacities() []storagev1.CSIStorageCapacity { … }

func (h *haveLocalStorageCapacities) FailureMessage(actual interface{ … }

func (h *haveLocalStorageCapacities) NegatedFailureMessage(actual interface{ … }