Versions in this module Expand all Collapse all v0 v0.1442.0 Feb 27, 2024 Changes in this version + const AdminAccessLog + const AdsClusterName + const BindMountCleanupFailed + const C2CCredCreationFailedCount + const C2CCredCreationSucceededCount + const C2CCredCreationSucceededDuration + const C2CTLSPort + const ContainerCompletedCount + const ContainerCreationFailedMessage + const ContainerExitedOnTimeoutCount + const ContainerExpirationMessage + const ContainerMissingMessage + const ContainerSetupFailedDuration + const CredCreationFailedCount + const CredCreationSucceededCount + const CredCreationSucceededDuration + const CredDirFailed + const DefaultHTTPPort + const DownloadCachedDependenciesFailed + const EndProxyPort + const GardenContainerCreationFailedDuration + const GardenContainerCreationSucceededDuration + const GardenContainerDestructionFailedDuration + const GardenContainerDestructionSucceededDuration + const IngressListener + const StartProxyPort + const TcpProxy + const TimeOut + const VolmanMountFailed + var AlpnProtocols = []string + var ErrC2CTLSPortIsReserved = fmt.Errorf("port %d is reserved for container networking", C2CTLSPort) + var ErrFailedToCAS = errors.New("failed-to-cas") + var ErrIPRangeConversionFailed = errors.New("failed to convert destination to ip range") + var ErrInvalidCertificate = errors.New("cannot parse invalid certificate") + var ErrNoPortsAvailable = errors.New("no ports available") + var SupportedCipherSuites = []string + type BindMountCacheKey struct + CacheKey string + Dir string + func NewbindMountCacheKey(cacheKey, dir string) BindMountCacheKey + type BindMounts struct + CacheKeys []BindMountCacheKey + GardenBindMounts []garden.BindMount + func NewBindMounts(capacity int) BindMounts + func (b *BindMounts) AddBindMount(cacheKey string, mount garden.BindMount) + type ContainerConfig struct + INodeLimit uint64 + MaxCPUShares uint64 + MaxLogLinesPerSecond int + MetricReportInterval time.Duration + OwnerName string + ReapInterval time.Duration + ReservedExpirationTime time.Duration + SetCPUWeight bool + type ContainerInfoProvider interface + Info func() executor.Container + type ContainerStore interface + Cleanup func(logger lager.Logger) + Create func(logger lager.Logger, traceID string, guid string) (executor.Container, error) + Destroy func(logger lager.Logger, traceID string, guid string) error + Get func(logger lager.Logger, guid string) (executor.Container, error) + GetFiles func(logger lager.Logger, guid, sourcePath string) (io.ReadCloser, error) + Initialize func(logger lager.Logger, req *executor.RunRequest) error + List func(logger lager.Logger) []executor.Container + Metrics func(logger lager.Logger) (map[string]executor.ContainerMetrics, error) + NewContainerReaper func(logger lager.Logger) ifrit.Runner + NewRegistryPruner func(logger lager.Logger) ifrit.Runner + RemainingResources func(logger lager.Logger) executor.ExecutorResources + Reserve func(logger lager.Logger, traceID string, req *executor.AllocationRequest) (executor.Container, error) + Run func(logger lager.Logger, traceID string, guid string) error + Stop func(logger lager.Logger, traceID string, guid string) error + Update func(logger lager.Logger, req *executor.UpdateRequest) error + func New(containerConfig ContainerConfig, totalCapacity *executor.ExecutorResources, ...) ContainerStore + type CredManager interface + CreateCredDir func(lager.Logger, executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + RemoveCredDir func(lager.Logger, executor.Container) error + Runner func(lager.Logger, ContainerInfoProvider, <-chan struct{}) ifrit.Runner + func NewCredManager(logger lager.Logger, metronClient loggingclient.IngressClient, ...) CredManager + func NewNoopCredManager() CredManager + type Credential struct + Cert string + Key string + func (c Credential) IsEmpty() bool + type CredentialHandler interface + Close func(invalidCredentials Credentials, container executor.Container) error + CreateDir func(logger lager.Logger, container executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + RemoveDir func(logger lager.Logger, container executor.Container) error + Update func(credentials Credentials, container executor.Container) error + type Credentials struct + C2CCredential Credential + InstanceIdentityCredential Credential + type DependencyManager interface + DownloadCachedDependencies func(logger lager.Logger, mounts []executor.CachedDependency, ...) (BindMounts, error) + ReleaseCachedDependencies func(logger lager.Logger, keys []BindMountCacheKey) error + Stop func(logger lager.Logger) + func NewDependencyManager(cache cacheddownloader.CachedDownloader, downloadRateLimiter chan struct{}) DependencyManager + type GardenClientFactory interface + NewGardenClient func(logger lager.Logger, traceID string) garden.Client + func NewGardenClientFactory(network, address string) GardenClientFactory + type InstanceIdentityHandler struct + func NewInstanceIdentityHandler(credDir string, containerMountPath string) *InstanceIdentityHandler + func (h *InstanceIdentityHandler) Close(creds Credentials, container executor.Container) error + func (h *InstanceIdentityHandler) CreateDir(logger lager.Logger, container executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (h *InstanceIdentityHandler) RemoveDir(logger lager.Logger, container executor.Container) error + func (h *InstanceIdentityHandler) Update(creds Credentials, container executor.Container) error + type LogManager interface + NewLogStreamer func(conf executor.LogConfig, metronClient loggingclient.IngressClient, ...) log_streamer.LogStreamer + func NewLogManager() LogManager + type NoopProxyConfigHandler struct + func NewNoopProxyConfigHandler() *NoopProxyConfigHandler + func (p *NoopProxyConfigHandler) Close(invalidCredentials Credentials, container executor.Container) error + func (p *NoopProxyConfigHandler) CreateDir(logger lager.Logger, container executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (p *NoopProxyConfigHandler) ProxyPorts(lager.Logger, *executor.Container) ([]executor.ProxyPortMapping, []uint16, error) + func (p *NoopProxyConfigHandler) RemoveDir(logger lager.Logger, container executor.Container) error + func (p *NoopProxyConfigHandler) RemoveProxyConfigDir(logger lager.Logger, container executor.Container) error + func (p *NoopProxyConfigHandler) Runner(logger lager.Logger, container executor.Container, ...) (ifrit.Runner, error) + func (p *NoopProxyConfigHandler) Update(credentials Credentials, container executor.Container) error + type ProxyConfigHandler struct + func NewProxyConfigHandler(logger lager.Logger, containerProxyPath string, ...) *ProxyConfigHandler + func (p *ProxyConfigHandler) Close(invalidCredentials Credentials, container executor.Container) error + func (p *ProxyConfigHandler) CreateDir(logger lager.Logger, container executor.Container) ([]garden.BindMount, []executor.EnvironmentVariable, error) + func (p *ProxyConfigHandler) ProxyPorts(logger lager.Logger, container *executor.Container) ([]executor.ProxyPortMapping, []uint16, error) + func (p *ProxyConfigHandler) RemoveDir(logger lager.Logger, container executor.Container) error + func (p *ProxyConfigHandler) Update(credentials Credentials, container executor.Container) error + type ProxyManager interface + ProxyPorts func(lager.Logger, *executor.Container) ([]executor.ProxyPortMapping, []uint16, error)