mirror of
https://github.com/docker/docs.git
synced 2026-04-03 17:59:01 +07:00
a387265978
At startup, inspect all containers and store the data into the Container. When new containers are detected, inspect them as well. Signed-off-by: Andrea Luzzardi <aluzzardi@gmail.com>
96 lines
3.1 KiB
Go
96 lines
3.1 KiB
Go
package libcluster
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
|
|
"github.com/samalba/dockerclient"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/mock"
|
|
)
|
|
|
|
var (
|
|
mockInfo = &dockerclient.Info{
|
|
NCPU: 10,
|
|
MemTotal: 20,
|
|
Driver: "driver-test",
|
|
ExecutionDriver: "execution-driver-test",
|
|
KernelVersion: "1.2.3",
|
|
OperatingSystem: "golang",
|
|
}
|
|
)
|
|
|
|
func TestNodeConnectionFailure(t *testing.T) {
|
|
node := NewNode("test", "test")
|
|
assert.False(t, node.IsConnected())
|
|
|
|
// Always fail.
|
|
client := dockerclient.NewMockClient()
|
|
client.On("Info").Return(&dockerclient.Info{}, errors.New("fail"))
|
|
|
|
// Connect() should fail and IsConnected() return false.
|
|
assert.Error(t, node.connectClient(client))
|
|
assert.False(t, node.IsConnected())
|
|
|
|
client.Mock.AssertExpectations(t)
|
|
}
|
|
|
|
func TestNodeSpecs(t *testing.T) {
|
|
node := NewNode("test", "test")
|
|
assert.False(t, node.IsConnected())
|
|
|
|
client := dockerclient.NewMockClient()
|
|
client.On("Info").Return(mockInfo, nil)
|
|
client.On("ListContainers", true, false).Return([]dockerclient.Container{}, nil)
|
|
client.On("StartMonitorEvents", mock.Anything, mock.Anything).Return()
|
|
|
|
assert.NoError(t, node.connectClient(client))
|
|
assert.True(t, node.IsConnected())
|
|
|
|
assert.Equal(t, node.Cpus, mockInfo.NCPU)
|
|
assert.Equal(t, node.Memory, mockInfo.MemTotal)
|
|
assert.Equal(t, node.Labels["graphdriver"], mockInfo.Driver)
|
|
assert.Equal(t, node.Labels["executiondriver"], mockInfo.ExecutionDriver)
|
|
assert.Equal(t, node.Labels["kernelversion"], mockInfo.KernelVersion)
|
|
assert.Equal(t, node.Labels["operatingsystem"], mockInfo.OperatingSystem)
|
|
|
|
client.Mock.AssertExpectations(t)
|
|
}
|
|
|
|
func TestNodeState(t *testing.T) {
|
|
node := NewNode("test", "test")
|
|
assert.False(t, node.IsConnected())
|
|
|
|
client := dockerclient.NewMockClient()
|
|
client.On("Info").Return(mockInfo, nil)
|
|
client.On("StartMonitorEvents", mock.Anything, mock.Anything).Return()
|
|
|
|
// The client will return one container at first, then a second one will appear.
|
|
client.On("ListContainers", true, false).Return([]dockerclient.Container{{Id: "one"}}, nil).Once()
|
|
client.On("InspectContainer", mock.Anything).Return(&dockerclient.ContainerInfo{}, nil).Once()
|
|
client.On("ListContainers", true, false).Return([]dockerclient.Container{{Id: "one"}, {Id: "two"}}, nil).Once()
|
|
client.On("InspectContainer", mock.Anything).Return(&dockerclient.ContainerInfo{}, nil).Once()
|
|
client.On("InspectContainer", mock.Anything).Return(&dockerclient.ContainerInfo{}, nil).Once()
|
|
|
|
assert.NoError(t, node.connectClient(client))
|
|
assert.True(t, node.IsConnected())
|
|
|
|
// The node should only have a single container at this point.
|
|
assert.Len(t, node.Containers(), 1)
|
|
if _, ok := node.Containers()["one"]; !ok {
|
|
t.Fatalf("Missing container: one")
|
|
}
|
|
|
|
// Fake an event which will trigger a refresh. The second container will appear.
|
|
node.handler(&dockerclient.Event{Id: "two", Status: "created"})
|
|
assert.Len(t, node.Containers(), 2)
|
|
if _, ok := node.Containers()["one"]; !ok {
|
|
t.Fatalf("Missing container: one")
|
|
}
|
|
if _, ok := node.Containers()["two"]; !ok {
|
|
t.Fatalf("Missing container: two")
|
|
}
|
|
|
|
client.Mock.AssertExpectations(t)
|
|
}
|