TODO(vmarmol): Refactor these tests.
( memoryCache *memory.InMemoryCache, sysfs *fakesysfs.FakeSysFs, containers []string, f func(*containertest.MockContainerHandler), t *testing.T, )
| 184 | // TODO(vmarmol): Refactor these tests. |
| 185 | |
| 186 | func createManagerAndAddContainers( |
| 187 | memoryCache *memory.InMemoryCache, |
| 188 | sysfs *fakesysfs.FakeSysFs, |
| 189 | containers []string, |
| 190 | f func(*containertest.MockContainerHandler), |
| 191 | t *testing.T, |
| 192 | ) *manager { |
| 193 | container.ClearContainerHandlerFactories() |
| 194 | mif := &manager{ |
| 195 | quitChannels: make([]chan error, 0, 2), |
| 196 | memoryCache: memoryCache, |
| 197 | } |
| 198 | for _, name := range containers { |
| 199 | mockHandler := containertest.NewMockContainerHandler(name) |
| 200 | spec := itest.GenerateRandomContainerSpec(4) |
| 201 | mockHandler.On("GetSpec").Return( |
| 202 | spec, |
| 203 | nil, |
| 204 | ).Once() |
| 205 | cont, err := newContainerData(name, memoryCache, mockHandler, 60*time.Second, true, clocktesting.NewFakeClock(time.Now())) |
| 206 | if err != nil { |
| 207 | t.Fatal(err) |
| 208 | } |
| 209 | mif.containers.Store(namespacedContainerName{ |
| 210 | Name: name, |
| 211 | }, cont) |
| 212 | // Add Docker containers under their namespace. |
| 213 | if strings.HasPrefix(name, "/docker") { |
| 214 | mif.containers.Store(namespacedContainerName{ |
| 215 | Namespace: DockerNamespace, |
| 216 | Name: strings.TrimPrefix(name, "/docker/"), |
| 217 | }, cont) |
| 218 | } |
| 219 | f(mockHandler) |
| 220 | } |
| 221 | return mif |
| 222 | } |
| 223 | |
| 224 | func createManagerAndAddSubContainers( |
| 225 | memoryCache *memory.InMemoryCache, |
no test coverage detected
searching dependent graphs…