kubernetes/test/e2e/storage/drivers/csi-test/driver/mock.go

type MockCSIDriverServers …

type MockCSIDriver …

func NewMockCSIDriver(servers *MockCSIDriverServers, interceptor grpc.UnaryServerInterceptor) *MockCSIDriver { … }

// StartOnAddress starts a new gRPC server listening on given address.
func (m *MockCSIDriver) StartOnAddress(network, address string) error { … }

// Start starts a new gRPC server listening on a random TCP loopback port.
func (m *MockCSIDriver) Start() error { … }

func (m *MockCSIDriver) Close() { … }