controller

Documentation

Overview

Package controller is a generated GoMock package.

Index

• Constants
• type MockModifyController
  • func NewMockModifyController(ctrl *gomock.Controller) *MockModifyController
  • func (m *MockModifyController) EXPECT() *MockModifyControllerMockRecorder
  • func (m *MockModifyController) Run(arg0 int, arg1 context.Context)
• type MockModifyControllerMockRecorder
  • func (mr *MockModifyControllerMockRecorder) Run(arg0, arg1 interface{}) *gomock.Call
• type ModifyController
  • func NewModifyController(name string, modifier modifier.Modifier, kubeClient kubernetes.Interface, ...) ModifyController

Constants

const (
	VolumeModificationStarted = "VolumeModificationStarted"

	VolumeModificationFailed = "VolumeModificationFailed"

	VolumeModificationSuccessful = "VolumeModificationSuccessful"

	AnnotationPrefixPattern = "%s/"

	AnnotationStatusPrefixPattern = "%s/%s-status"
)

Types

type MockModifyController

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

MockModifyController is a mock of ModifyController interface.

func NewMockModifyController

func NewMockModifyController(ctrl *gomock.Controller) *MockModifyController

NewMockModifyController creates a new mock instance.

func (*MockModifyController) EXPECT

func (m *MockModifyController) EXPECT() *MockModifyControllerMockRecorder

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

func (*MockModifyController) Run

func (m *MockModifyController) Run(arg0 int, arg1 context.Context)

Run mocks base method.

type MockModifyControllerMockRecorder

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

MockModifyControllerMockRecorder is the mock recorder for MockModifyController.

func (*MockModifyControllerMockRecorder) Run

func (mr *MockModifyControllerMockRecorder) Run(arg0, arg1 interface{}) *gomock.Call

Run indicates an expected call of Run.

type ModifyController

type ModifyController interface {
	Run(int, context.Context)
}

func NewModifyController

func NewModifyController(
	name string,
	modifier modifier.Modifier,
	kubeClient kubernetes.Interface,
	resyncPeriod time.Duration,
	informerFactory informers.SharedInformerFactory,
	pvcRateLimiter workqueue.RateLimiter,
	retryModificationFailures bool,
) ModifyController