Versions in this module Expand all Collapse all v0 v0.1442.0 Feb 27, 2024 Changes in this version + type FakeContainerInfoProvider struct + InfoStub func() executor.Container + func (fake *FakeContainerInfoProvider) Info() executor.Container + func (fake *FakeContainerInfoProvider) InfoCallCount() int + func (fake *FakeContainerInfoProvider) InfoCalls(stub func() executor.Container) + func (fake *FakeContainerInfoProvider) InfoReturns(result1 executor.Container) + func (fake *FakeContainerInfoProvider) InfoReturnsOnCall(i int, result1 executor.Container) + func (fake *FakeContainerInfoProvider) Invocations() map[string][][]interface{} + type FakeContainerStore struct + CleanupStub func(lager.Logger) + CreateStub func(lager.Logger, string, string) (executor.Container, error) + DestroyStub func(lager.Logger, string, string) error + GetFilesStub func(lager.Logger, string, string) (io.ReadCloser, error) + GetStub func(lager.Logger, string) (executor.Container, error) + InitializeStub func(lager.Logger, *executor.RunRequest) error + ListStub func(lager.Logger) []executor.Container + MetricsStub func(lager.Logger) (map[string]executor.ContainerMetrics, error) + NewContainerReaperStub func(lager.Logger) ifrit.Runner + NewRegistryPrunerStub func(lager.Logger) ifrit.Runner + RemainingResourcesStub func(lager.Logger) executor.ExecutorResources + ReserveStub func(lager.Logger, string, *executor.AllocationRequest) (executor.Container, error) + RunStub func(lager.Logger, string, string) error + StopStub func(lager.Logger, string, string) error + UpdateStub func(lager.Logger, *executor.UpdateRequest) error + func (fake *FakeContainerStore) Cleanup(arg1 lager.Logger) + func (fake *FakeContainerStore) CleanupArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) CleanupCallCount() int + func (fake *FakeContainerStore) CleanupCalls(stub func(lager.Logger)) + func (fake *FakeContainerStore) Create(arg1 lager.Logger, arg2 string, arg3 string) (executor.Container, error) + func (fake *FakeContainerStore) CreateArgsForCall(i int) (lager.Logger, string, string) + func (fake *FakeContainerStore) CreateCallCount() int + func (fake *FakeContainerStore) CreateCalls(stub func(lager.Logger, string, string) (executor.Container, error)) + func (fake *FakeContainerStore) CreateReturns(result1 executor.Container, result2 error) + func (fake *FakeContainerStore) CreateReturnsOnCall(i int, result1 executor.Container, result2 error) + func (fake *FakeContainerStore) Destroy(arg1 lager.Logger, arg2 string, arg3 string) error + func (fake *FakeContainerStore) DestroyArgsForCall(i int) (lager.Logger, string, string) + func (fake *FakeContainerStore) DestroyCallCount() int + func (fake *FakeContainerStore) DestroyCalls(stub func(lager.Logger, string, string) error) + func (fake *FakeContainerStore) DestroyReturns(result1 error) + func (fake *FakeContainerStore) DestroyReturnsOnCall(i int, result1 error) + func (fake *FakeContainerStore) Get(arg1 lager.Logger, arg2 string) (executor.Container, error) + func (fake *FakeContainerStore) GetArgsForCall(i int) (lager.Logger, string) + func (fake *FakeContainerStore) GetCallCount() int + func (fake *FakeContainerStore) GetCalls(stub func(lager.Logger, string) (executor.Container, error)) + func (fake *FakeContainerStore) GetFiles(arg1 lager.Logger, arg2 string, arg3 string) (io.ReadCloser, error) + func (fake *FakeContainerStore) GetFilesArgsForCall(i int) (lager.Logger, string, string) + func (fake *FakeContainerStore) GetFilesCallCount() int + func (fake *FakeContainerStore) GetFilesCalls(stub func(lager.Logger, string, string) (io.ReadCloser, error)) + func (fake *FakeContainerStore) GetFilesReturns(result1 io.ReadCloser, result2 error) + func (fake *FakeContainerStore) GetFilesReturnsOnCall(i int, result1 io.ReadCloser, result2 error) + func (fake *FakeContainerStore) GetReturns(result1 executor.Container, result2 error) + func (fake *FakeContainerStore) GetReturnsOnCall(i int, result1 executor.Container, result2 error) + func (fake *FakeContainerStore) Initialize(arg1 lager.Logger, arg2 *executor.RunRequest) error + func (fake *FakeContainerStore) InitializeArgsForCall(i int) (lager.Logger, *executor.RunRequest) + func (fake *FakeContainerStore) InitializeCallCount() int + func (fake *FakeContainerStore) InitializeCalls(stub func(lager.Logger, *executor.RunRequest) error) + func (fake *FakeContainerStore) InitializeReturns(result1 error) + func (fake *FakeContainerStore) InitializeReturnsOnCall(i int, result1 error) + func (fake *FakeContainerStore) Invocations() map[string][][]interface{} + func (fake *FakeContainerStore) List(arg1 lager.Logger) []executor.Container + func (fake *FakeContainerStore) ListArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) ListCallCount() int + func (fake *FakeContainerStore) ListCalls(stub func(lager.Logger) []executor.Container) + func (fake *FakeContainerStore) ListReturns(result1 []executor.Container) + func (fake *FakeContainerStore) ListReturnsOnCall(i int, result1 []executor.Container) + func (fake *FakeContainerStore) Metrics(arg1 lager.Logger) (map[string]executor.ContainerMetrics, error) + func (fake *FakeContainerStore) MetricsArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) MetricsCallCount() int + func (fake *FakeContainerStore) MetricsCalls(stub func(lager.Logger) (map[string]executor.ContainerMetrics, error)) + func (fake *FakeContainerStore) MetricsReturns(result1 map[string]executor.ContainerMetrics, result2 error) + func (fake *FakeContainerStore) MetricsReturnsOnCall(i int, result1 map[string]executor.ContainerMetrics, result2 error) + func (fake *FakeContainerStore) NewContainerReaper(arg1 lager.Logger) ifrit.Runner + func (fake *FakeContainerStore) NewContainerReaperArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) NewContainerReaperCallCount() int + func (fake *FakeContainerStore) NewContainerReaperCalls(stub func(lager.Logger) ifrit.Runner) + func (fake *FakeContainerStore) NewContainerReaperReturns(result1 ifrit.Runner) + func (fake *FakeContainerStore) NewContainerReaperReturnsOnCall(i int, result1 ifrit.Runner) + func (fake *FakeContainerStore) NewRegistryPruner(arg1 lager.Logger) ifrit.Runner + func (fake *FakeContainerStore) NewRegistryPrunerArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) NewRegistryPrunerCallCount() int + func (fake *FakeContainerStore) NewRegistryPrunerCalls(stub func(lager.Logger) ifrit.Runner) + func (fake *FakeContainerStore) NewRegistryPrunerReturns(result1 ifrit.Runner) + func (fake *FakeContainerStore) NewRegistryPrunerReturnsOnCall(i int, result1 ifrit.Runner) + func (fake *FakeContainerStore) RemainingResources(arg1 lager.Logger) executor.ExecutorResources + func (fake *FakeContainerStore) RemainingResourcesArgsForCall(i int) lager.Logger + func (fake *FakeContainerStore) RemainingResourcesCallCount() int + func (fake *FakeContainerStore) RemainingResourcesCalls(stub func(lager.Logger) executor.ExecutorResources) + func (fake *FakeContainerStore) RemainingResourcesReturns(result1 executor.ExecutorResources) + func (fake *FakeContainerStore) RemainingResourcesReturnsOnCall(i int, result1 executor.ExecutorResources) + func (fake *FakeContainerStore) Reserve(arg1 lager.Logger, arg2 string, arg3 *executor.AllocationRequest) (executor.Container, error) + func (fake *FakeContainerStore) ReserveArgsForCall(i int) (lager.Logger, string, *executor.AllocationRequest) + func (fake *FakeContainerStore) ReserveCallCount() int + func (fake *FakeContainerStore) ReserveCalls(...) + func (fake *FakeContainerStore) ReserveReturns(result1 executor.Container, result2 error) + func (fake *FakeContainerStore) ReserveReturnsOnCall(i int, result1 executor.Container, result2 error) + func (fake *FakeContainerStore) Run(arg1 lager.Logger, arg2 string, arg3 string) error + func (fake *FakeContainerStore) RunArgsForCall(i int) (lager.Logger, string, string) + func (fake *FakeContainerStore) RunCallCount() int + func (fake *FakeContainerStore) RunCalls(stub func(lager.Logger, string, string) error) + func (fake *FakeContainerStore) RunReturns(result1 error) + func (fake *FakeContainerStore) RunReturnsOnCall(i int, result1 error) + func (fake *FakeContainerStore) Stop(arg1 lager.Logger, arg2 string, arg3 string) error + func (fake *FakeContainerStore) StopArgsForCall(i int) (lager.Logger, string, string) + func (fake *FakeContainerStore) StopCallCount() int + func (fake *FakeContainerStore) StopCalls(stub func(lager.Logger, string, string) error) + func (fake *FakeContainerStore) StopReturns(result1 error) + func (fake *FakeContainerStore) StopReturnsOnCall(i int, result1 error) + func (fake *FakeContainerStore) Update(arg1 lager.Logger, arg2 *executor.UpdateRequest) error + func (fake *FakeContainerStore) UpdateArgsForCall(i int) (lager.Logger, *executor.UpdateRequest) + func (fake *FakeContainerStore) UpdateCallCount() int + func (fake *FakeContainerStore) UpdateCalls(stub func(lager.Logger, *executor.UpdateRequest) error) + func (fake *FakeContainerStore) UpdateReturns(result1 error) + func (fake *FakeContainerStore) UpdateReturnsOnCall(i int, result1 error) + type FakeCredManager struct + CreateCredDirStub func(lager.Logger, executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + RemoveCredDirStub func(lager.Logger, executor.Container) error + RunnerStub func(lager.Logger, containerstore.ContainerInfoProvider, <-chan struct{}) ifrit.Runner + func (fake *FakeCredManager) CreateCredDir(arg1 lager.Logger, arg2 executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (fake *FakeCredManager) CreateCredDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeCredManager) CreateCredDirCallCount() int + func (fake *FakeCredManager) CreateCredDirCalls(...) + func (fake *FakeCredManager) CreateCredDirReturns(result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeCredManager) CreateCredDirReturnsOnCall(i int, result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeCredManager) Invocations() map[string][][]interface{} + func (fake *FakeCredManager) RemoveCredDir(arg1 lager.Logger, arg2 executor.Container) error + func (fake *FakeCredManager) RemoveCredDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeCredManager) RemoveCredDirCallCount() int + func (fake *FakeCredManager) RemoveCredDirCalls(stub func(lager.Logger, executor.Container) error) + func (fake *FakeCredManager) RemoveCredDirReturns(result1 error) + func (fake *FakeCredManager) RemoveCredDirReturnsOnCall(i int, result1 error) + func (fake *FakeCredManager) Runner(arg1 lager.Logger, arg2 containerstore.ContainerInfoProvider, ...) ifrit.Runner + func (fake *FakeCredManager) RunnerArgsForCall(i int) (lager.Logger, containerstore.ContainerInfoProvider, <-chan struct{}) + func (fake *FakeCredManager) RunnerCallCount() int + func (fake *FakeCredManager) RunnerCalls(...) + func (fake *FakeCredManager) RunnerReturns(result1 ifrit.Runner) + func (fake *FakeCredManager) RunnerReturnsOnCall(i int, result1 ifrit.Runner) + type FakeCredentialHandler struct + CloseStub func(containerstore.Credentials, executor.Container) error + CreateDirStub func(lager.Logger, executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + RemoveDirStub func(lager.Logger, executor.Container) error + UpdateStub func(containerstore.Credentials, executor.Container) error + func (fake *FakeCredentialHandler) Close(arg1 containerstore.Credentials, arg2 executor.Container) error + func (fake *FakeCredentialHandler) CloseArgsForCall(i int) (containerstore.Credentials, executor.Container) + func (fake *FakeCredentialHandler) CloseCallCount() int + func (fake *FakeCredentialHandler) CloseCalls(stub func(containerstore.Credentials, executor.Container) error) + func (fake *FakeCredentialHandler) CloseReturns(result1 error) + func (fake *FakeCredentialHandler) CloseReturnsOnCall(i int, result1 error) + func (fake *FakeCredentialHandler) CreateDir(arg1 lager.Logger, arg2 executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (fake *FakeCredentialHandler) CreateDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeCredentialHandler) CreateDirCallCount() int + func (fake *FakeCredentialHandler) CreateDirCalls(...) + func (fake *FakeCredentialHandler) CreateDirReturns(result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeCredentialHandler) CreateDirReturnsOnCall(i int, result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeCredentialHandler) Invocations() map[string][][]interface{} + func (fake *FakeCredentialHandler) RemoveDir(arg1 lager.Logger, arg2 executor.Container) error + func (fake *FakeCredentialHandler) RemoveDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeCredentialHandler) RemoveDirCallCount() int + func (fake *FakeCredentialHandler) RemoveDirCalls(stub func(lager.Logger, executor.Container) error) + func (fake *FakeCredentialHandler) RemoveDirReturns(result1 error) + func (fake *FakeCredentialHandler) RemoveDirReturnsOnCall(i int, result1 error) + func (fake *FakeCredentialHandler) Update(arg1 containerstore.Credentials, arg2 executor.Container) error + func (fake *FakeCredentialHandler) UpdateArgsForCall(i int) (containerstore.Credentials, executor.Container) + func (fake *FakeCredentialHandler) UpdateCallCount() int + func (fake *FakeCredentialHandler) UpdateCalls(stub func(containerstore.Credentials, executor.Container) error) + func (fake *FakeCredentialHandler) UpdateReturns(result1 error) + func (fake *FakeCredentialHandler) UpdateReturnsOnCall(i int, result1 error) + type FakeDependencyManager struct + DownloadCachedDependenciesStub func(lager.Logger, []executor.CachedDependency, executor.LogConfig, ...) (containerstore.BindMounts, error) + ReleaseCachedDependenciesStub func(lager.Logger, []containerstore.BindMountCacheKey) error + StopStub func(lager.Logger) + func (fake *FakeDependencyManager) DownloadCachedDependencies(arg1 lager.Logger, arg2 []executor.CachedDependency, arg3 executor.LogConfig, ...) (containerstore.BindMounts, error) + func (fake *FakeDependencyManager) DownloadCachedDependenciesArgsForCall(i int) (lager.Logger, []executor.CachedDependency, executor.LogConfig, ...) + func (fake *FakeDependencyManager) DownloadCachedDependenciesCallCount() int + func (fake *FakeDependencyManager) DownloadCachedDependenciesCalls(...) + func (fake *FakeDependencyManager) DownloadCachedDependenciesReturns(result1 containerstore.BindMounts, result2 error) + func (fake *FakeDependencyManager) DownloadCachedDependenciesReturnsOnCall(i int, result1 containerstore.BindMounts, result2 error) + func (fake *FakeDependencyManager) Invocations() map[string][][]interface{} + func (fake *FakeDependencyManager) ReleaseCachedDependencies(arg1 lager.Logger, arg2 []containerstore.BindMountCacheKey) error + func (fake *FakeDependencyManager) ReleaseCachedDependenciesArgsForCall(i int) (lager.Logger, []containerstore.BindMountCacheKey) + func (fake *FakeDependencyManager) ReleaseCachedDependenciesCallCount() int + func (fake *FakeDependencyManager) ReleaseCachedDependenciesCalls(stub func(lager.Logger, []containerstore.BindMountCacheKey) error) + func (fake *FakeDependencyManager) ReleaseCachedDependenciesReturns(result1 error) + func (fake *FakeDependencyManager) ReleaseCachedDependenciesReturnsOnCall(i int, result1 error) + func (fake *FakeDependencyManager) Stop(arg1 lager.Logger) + func (fake *FakeDependencyManager) StopArgsForCall(i int) lager.Logger + func (fake *FakeDependencyManager) StopCallCount() int + func (fake *FakeDependencyManager) StopCalls(stub func(lager.Logger)) + type FakeGardenClientFactory struct + NewGardenClientStub func(lager.Logger, string) garden.Client + func (fake *FakeGardenClientFactory) Invocations() map[string][][]interface{} + func (fake *FakeGardenClientFactory) NewGardenClient(arg1 lager.Logger, arg2 string) garden.Client + func (fake *FakeGardenClientFactory) NewGardenClientArgsForCall(i int) (lager.Logger, string) + func (fake *FakeGardenClientFactory) NewGardenClientCallCount() int + func (fake *FakeGardenClientFactory) NewGardenClientCalls(stub func(lager.Logger, string) garden.Client) + func (fake *FakeGardenClientFactory) NewGardenClientReturns(result1 garden.Client) + func (fake *FakeGardenClientFactory) NewGardenClientReturnsOnCall(i int, result1 garden.Client) + type FakeLogManager struct + NewLogStreamerStub func(executor.LogConfig, diego_logging_client.IngressClient, int, int64, ...) log_streamer.LogStreamer + func (fake *FakeLogManager) Invocations() map[string][][]interface{} + func (fake *FakeLogManager) NewLogStreamer(arg1 executor.LogConfig, arg2 diego_logging_client.IngressClient, arg3 int, ...) log_streamer.LogStreamer + func (fake *FakeLogManager) NewLogStreamerArgsForCall(i int) (executor.LogConfig, diego_logging_client.IngressClient, int, int64, ...) + func (fake *FakeLogManager) NewLogStreamerCallCount() int + func (fake *FakeLogManager) NewLogStreamerCalls(...) + func (fake *FakeLogManager) NewLogStreamerReturns(result1 log_streamer.LogStreamer) + func (fake *FakeLogManager) NewLogStreamerReturnsOnCall(i int, result1 log_streamer.LogStreamer) + type FakeProxyManager struct + CloseStub func(containerstore.Credentials, executor.Container) error + CreateDirStub func(lager.Logger, executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + ProxyPortsStub func(lager.Logger, *executor.Container) ([]executor.ProxyPortMapping, []uint16, error) + RemoveDirStub func(lager.Logger, executor.Container) error + UpdateStub func(containerstore.Credentials, executor.Container) error + func (fake *FakeProxyManager) Close(arg1 containerstore.Credentials, arg2 executor.Container) error + func (fake *FakeProxyManager) CloseArgsForCall(i int) (containerstore.Credentials, executor.Container) + func (fake *FakeProxyManager) CloseCallCount() int + func (fake *FakeProxyManager) CloseCalls(stub func(containerstore.Credentials, executor.Container) error) + func (fake *FakeProxyManager) CloseReturns(result1 error) + func (fake *FakeProxyManager) CloseReturnsOnCall(i int, result1 error) + func (fake *FakeProxyManager) CreateDir(arg1 lager.Logger, arg2 executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (fake *FakeProxyManager) CreateDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeProxyManager) CreateDirCallCount() int + func (fake *FakeProxyManager) CreateDirCalls(...) + func (fake *FakeProxyManager) CreateDirReturns(result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeProxyManager) CreateDirReturnsOnCall(i int, result1 []garden.BindMount, result2 []executor.EnvironmentVariable, ...) + func (fake *FakeProxyManager) Invocations() map[string][][]interface{} + func (fake *FakeProxyManager) ProxyPorts(arg1 lager.Logger, arg2 *executor.Container) ([]executor.ProxyPortMapping, []uint16, error) + func (fake *FakeProxyManager) ProxyPortsArgsForCall(i int) (lager.Logger, *executor.Container) + func (fake *FakeProxyManager) ProxyPortsCallCount() int + func (fake *FakeProxyManager) ProxyPortsCalls(...) + func (fake *FakeProxyManager) ProxyPortsReturns(result1 []executor.ProxyPortMapping, result2 []uint16, result3 error) + func (fake *FakeProxyManager) ProxyPortsReturnsOnCall(i int, result1 []executor.ProxyPortMapping, result2 []uint16, result3 error) + func (fake *FakeProxyManager) RemoveDir(arg1 lager.Logger, arg2 executor.Container) error + func (fake *FakeProxyManager) RemoveDirArgsForCall(i int) (lager.Logger, executor.Container) + func (fake *FakeProxyManager) RemoveDirCallCount() int + func (fake *FakeProxyManager) RemoveDirCalls(stub func(lager.Logger, executor.Container) error) + func (fake *FakeProxyManager) RemoveDirReturns(result1 error) + func (fake *FakeProxyManager) RemoveDirReturnsOnCall(i int, result1 error) + func (fake *FakeProxyManager) Update(arg1 containerstore.Credentials, arg2 executor.Container) error + func (fake *FakeProxyManager) UpdateArgsForCall(i int) (containerstore.Credentials, executor.Container) + func (fake *FakeProxyManager) UpdateCallCount() int + func (fake *FakeProxyManager) UpdateCalls(stub func(containerstore.Credentials, executor.Container) error) + func (fake *FakeProxyManager) UpdateReturns(result1 error) + func (fake *FakeProxyManager) UpdateReturnsOnCall(i int, result1 error)
Go to main page