mirror of
https://github.com/k3s-io/kubernetes.git
synced 2026-07-18 04:54:54 +00:00
future-proof csi test mocks
Signed-off-by: Davanum Srinivas <davanum@gmail.com>
This commit is contained in:
@@ -34,19 +34,6 @@ type MockCSIDriver struct {
|
||||
interceptor grpc.UnaryServerInterceptor
|
||||
}
|
||||
|
||||
func NewMockCSIDriver(servers *MockCSIDriverServers, interceptor grpc.UnaryServerInterceptor) *MockCSIDriver {
|
||||
return &MockCSIDriver{
|
||||
CSIDriver: CSIDriver{
|
||||
servers: &CSIDriverServers{
|
||||
Controller: servers.Controller,
|
||||
Node: servers.Node,
|
||||
Identity: servers.Identity,
|
||||
},
|
||||
},
|
||||
interceptor: interceptor,
|
||||
}
|
||||
}
|
||||
|
||||
// StartOnAddress starts a new gRPC server listening on given address.
|
||||
func (m *MockCSIDriver) StartOnAddress(network, address string) error {
|
||||
l, err := net.Listen(network, address)
|
||||
|
||||
@@ -113,6 +113,9 @@ type Service interface {
|
||||
}
|
||||
|
||||
type service struct {
|
||||
csi.UnimplementedControllerServer
|
||||
csi.UnimplementedIdentityServer
|
||||
csi.UnimplementedNodeServer
|
||||
sync.Mutex
|
||||
nodeID string
|
||||
vols []csi.Volume
|
||||
|
||||
Reference in New Issue
Block a user