kubernetes/pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

const EmptyUniquePodName …

const EmptyUniqueVolumeName …

const EmptyNodeName …

type NestedPendingOperations …

// NewNestedPendingOperations returns a new instance of NestedPendingOperations.
func NewNestedPendingOperations(exponentialBackOffOnError bool) NestedPendingOperations { … }

type nestedPendingOperations …

type operation …

func (grm *nestedPendingOperations) Run(
	volumeName v1.UniqueVolumeName,
	podName volumetypes.UniquePodName,
	nodeName types.NodeName,
	generatedOperations volumetypes.GeneratedOperations) error { … }

func (grm *nestedPendingOperations) IsOperationSafeToRetry(
	volumeName v1.UniqueVolumeName,
	podName volumetypes.UniquePodName,
	nodeName types.NodeName,
	operationName string) bool { … }

func (grm *nestedPendingOperations) IsOperationPending(
	volumeName v1.UniqueVolumeName,
	podName volumetypes.UniquePodName,
	nodeName types.NodeName) bool { … }

// This is an internal function and caller should acquire and release the lock
func (grm *nestedPendingOperations) isOperationExists(key operationKey) (bool, int) { … }

func (grm *nestedPendingOperations) getOperation(key operationKey) (uint, error) { … }

func (grm *nestedPendingOperations) deleteOperation(key operationKey) { … }

func (grm *nestedPendingOperations) operationComplete(key operationKey, err *error) { … }

func (grm *nestedPendingOperations) Wait() { … }

type operationKey …

// NewAlreadyExistsError returns a new instance of AlreadyExists error.
func NewAlreadyExistsError(key operationKey) error { … }

// IsAlreadyExists returns true if an error returned from
// NestedPendingOperations indicates a new operation can not be started because
// an operation with the same operation name is already executing.
func IsAlreadyExists(err error) bool { … }

type alreadyExistsError …

var _ …

func (err alreadyExistsError) Error() string { … }