94 lines
2.6 KiB
Go
94 lines
2.6 KiB
Go
|
package nomad
|
||
|
|
|
||
|
|
import (
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc"
|
||
|
|
"github.com/hashicorp/nomad/client"
|
||
|
|
"github.com/hashicorp/nomad/client/config"
|
||
|
|
cstructs "github.com/hashicorp/nomad/client/structs"
|
||
|
|
"github.com/hashicorp/nomad/nomad/structs"
|
||
|
|
"github.com/hashicorp/nomad/testutil"
|
||
|
|
"github.com/stretchr/testify/require"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestClientCSIController_AttachVolume_Local(t *testing.T) {
|
||
|
|
t.Parallel()
|
||
|
|
require := require.New(t)
|
||
|
|
|
||
|
|
// Start a server and client
|
||
|
|
s, cleanupS := TestServer(t, nil)
|
||
|
|
defer cleanupS()
|
||
|
|
codec := rpcClient(t, s)
|
||
|
|
testutil.WaitForLeader(t, s.RPC)
|
||
|
|
|
||
|
|
c, cleanupC := client.TestClient(t, func(c *config.Config) {
|
||
|
|
c.Servers = []string{s.config.RPCAddr.String()}
|
||
|
|
})
|
||
|
|
defer cleanupC()
|
||
|
|
|
||
|
|
testutil.WaitForResult(func() (bool, error) {
|
||
|
|
nodes := s.connectedNodes()
|
||
|
|
return len(nodes) == 1, nil
|
||
|
|
}, func(err error) {
|
||
|
|
require.Fail("should have a client")
|
||
|
|
})
|
||
|
|
|
||
|
|
req := &cstructs.ClientCSIControllerAttachVolumeRequest{
|
||
|
|
CSIControllerQuery: cstructs.CSIControllerQuery{ControllerNodeID: c.NodeID()},
|
||
|
|
}
|
||
|
|
|
||
|
|
// Fetch the response
|
||
|
|
var resp structs.GenericResponse
|
||
|
|
err := msgpackrpc.CallWithCodec(codec, "ClientCSIController.AttachVolume", req, &resp)
|
||
|
|
require.NotNil(err)
|
||
|
|
// Should recieve an error from the client endpoint
|
||
|
|
require.Contains(err.Error(), "must specify plugin name to dispense")
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClientCSIController_AttachVolume_Forwarded(t *testing.T) {
|
||
|
|
t.Parallel()
|
||
|
|
require := require.New(t)
|
||
|
|
|
||
|
|
// Start a server and client
|
||
|
|
s1, cleanupS1 := TestServer(t, nil)
|
||
|
|
defer cleanupS1()
|
||
|
|
s2, cleanupS2 := TestServer(t, func(c *Config) {
|
||
|
|
c.DevDisableBootstrap = true
|
||
|
|
})
|
||
|
|
defer cleanupS2()
|
||
|
|
TestJoin(t, s1, s2)
|
||
|
|
testutil.WaitForLeader(t, s1.RPC)
|
||
|
|
testutil.WaitForLeader(t, s2.RPC)
|
||
|
|
codec := rpcClient(t, s2)
|
||
|
|
|
||
|
|
c, cleanupC := client.TestClient(t, func(c *config.Config) {
|
||
|
|
c.Servers = []string{s2.config.RPCAddr.String()}
|
||
|
|
c.GCDiskUsageThreshold = 100.0
|
||
|
|
})
|
||
|
|
defer cleanupC()
|
||
|
|
|
||
|
|
testutil.WaitForResult(func() (bool, error) {
|
||
|
|
nodes := s2.connectedNodes()
|
||
|
|
return len(nodes) == 1, nil
|
||
|
|
}, func(err error) {
|
||
|
|
require.Fail("should have a client")
|
||
|
|
})
|
||
|
|
|
||
|
|
// Force remove the connection locally in case it exists
|
||
|
|
s1.nodeConnsLock.Lock()
|
||
|
|
delete(s1.nodeConns, c.NodeID())
|
||
|
|
s1.nodeConnsLock.Unlock()
|
||
|
|
|
||
|
|
req := &cstructs.ClientCSIControllerAttachVolumeRequest{
|
||
|
|
CSIControllerQuery: cstructs.CSIControllerQuery{ControllerNodeID: c.NodeID()},
|
||
|
|
}
|
||
|
|
|
||
|
|
// Fetch the response
|
||
|
|
var resp structs.GenericResponse
|
||
|
|
err := msgpackrpc.CallWithCodec(codec, "ClientCSIController.AttachVolume", req, &resp)
|
||
|
|
require.NotNil(err)
|
||
|
|
// Should recieve an error from the client endpoint
|
||
|
|
require.Contains(err.Error(), "must specify plugin name to dispense")
|
||
|
|
}
|