MCPcopy
hub / github.com/google/cadvisor / createManagerAndAddContainers

Function createManagerAndAddContainers

lib/manager/manager_test.go:186–222  ·  view source on GitHub ↗

TODO(vmarmol): Refactor these tests.

(
	memoryCache *memory.InMemoryCache,
	sysfs *fakesysfs.FakeSysFs,
	containers []string,
	f func(*containertest.MockContainerHandler),
	t *testing.T,
)

Source from the content-addressed store, hash-verified

184// TODO(vmarmol): Refactor these tests.
185
186func 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
224func createManagerAndAddSubContainers(
225 memoryCache *memory.InMemoryCache,

Callers 2

Calls 4

newContainerDataFunction · 0.85
fFunction · 0.50
StoreMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…