executor

Documentation

Index

• Constants
• func CredManagerFromConfig(logger lager.Logger, metronClient loggingclient.IngressClient, ...) (containerstore.CredManager, error)
• func Initialize(logger lager.Logger, config config.RepConfig, cellID string, zone string, ...) (executor.Client, *containermetrics.StatsReporter, grouper.Members, error)
• func TLSConfigFromConfig(logger lager.Logger, certsRetriever CertPoolRetriever, ...) (*tls.Config, error)
• type CertPoolRetriever
• type ExecutorConfig
  • func (config *ExecutorConfig) Validate(logger lager.Logger) bool

Constants

const (
	PingGardenInterval             = time.Second
	StalledMetricHeartbeatInterval = 5 * time.Second
	StalledGardenDuration          = "StalledGardenDuration"
)

Functions

func CredManagerFromConfig

func CredManagerFromConfig(logger lager.Logger, metronClient loggingclient.IngressClient, config initializer.ExecutorConfig, clock clock.Clock, handlers ...containerstore.CredentialHandler) (containerstore.CredManager, error)

func Initialize

func Initialize(
	logger lager.Logger,
	config config.RepConfig,
	cellID string,
	zone string,
	rootFSes map[string]string,
	sidecarRootFSPath string,
	metronClient loggingclient.IngressClient,
	clock clock.Clock,
) (
	executor.Client,
	*containermetrics.StatsReporter,
	grouper.Members,
	error,
)

As soon as we get rid of this Initializer code copy, we can revert the type of config parameter back to ExecutorConfig.

func TLSConfigFromConfig

func TLSConfigFromConfig(logger lager.Logger, certsRetriever CertPoolRetriever, config initializer.ExecutorConfig) (*tls.Config, error)

Types

type CertPoolRetriever

type CertPoolRetriever interface {
	SystemCerts() (*x509.CertPool, error)
}

type ExecutorConfig

type ExecutorConfig struct {
	AdvertisePreferenceForInstanceAddress bool                  `json:"advertise_preference_for_instance_address"`
	AutoDiskOverheadMB                    int                   `json:"auto_disk_capacity_overhead_mb"`
	CachePath                             string                `json:"cache_path,omitempty"`
	ContainerInodeLimit                   uint64                `json:"container_inode_limit,omitempty"`
	ContainerMaxCpuShares                 uint64                `json:"container_max_cpu_shares,omitempty"`
	ContainerMetricsReportInterval        durationjson.Duration `json:"container_metrics_report_interval,omitempty"`
	ContainerOwnerName                    string                `json:"container_owner_name,omitempty"`
	ContainerProxyADSServers              []string              `json:"container_proxy_ads_addresses,omitempty"`
	ContainerProxyConfigPath              string                `json:"container_proxy_config_path,omitempty"`
	ContainerProxyPath                    string                `json:"container_proxy_path,omitempty"`
	ContainerProxyRequireClientCerts      bool                  `json:"container_proxy_require_and_verify_client_certs"`
	ContainerProxyTrustedCACerts          []string              `json:"container_proxy_trusted_ca_certs"`
	ContainerProxyVerifySubjectAltName    []string              `json:"container_proxy_verify_subject_alt_name"`
	ContainerReapInterval                 durationjson.Duration `json:"container_reap_interval,omitempty"`
	CreateWorkPoolSize                    int                   `json:"create_work_pool_size,omitempty"`
	DeclarativeHealthcheckPath            string                `json:"declarative_healthcheck_path,omitempty"`
	DeleteWorkPoolSize                    int                   `json:"delete_work_pool_size,omitempty"`
	DiskMB                                string                `json:"disk_mb,omitempty"`
	EnableContainerProxy                  bool                  `json:"enable_container_proxy,omitempty"`
	EnableContainerProxyHealthChecks      bool                  `json:"enable_container_proxy_healthcheck,omitempty"`
	DeclarativeHealthCheckDefaultTimeout  durationjson.Duration `json:"declarative_healthcheck_default_timeout,omitempty"`
	EnableHealtcheckMetrics               bool                  `json:"enable_healthcheck_metrics,omitempty"`
	EnableUnproxiedPortMappings           bool                  `json:"enable_unproxied_port_mappings"`
	EnvoyConfigRefreshDelay               durationjson.Duration `json:"envoy_config_refresh_delay"`
	EnvoyConfigReloadDuration             durationjson.Duration `json:"envoy_config_reload_duration"`
	EnvoyDrainTimeout                     durationjson.Duration `json:"envoy_drain_timeout,omitempty"`
	ProxyHealthCheckInterval              durationjson.Duration `json:"proxy_healthcheck_interval,omitempty"`
	ExportNetworkEnvVars                  bool                  `json:"export_network_env_vars,omitempty"` // DEPRECATED. Kept around for dusts compatability
	GardenAddr                            string                `json:"garden_addr,omitempty"`
	GardenHealthcheckCommandRetryPause    durationjson.Duration `json:"garden_healthcheck_command_retry_pause,omitempty"`
	GardenHealthcheckEmissionInterval     durationjson.Duration `json:"garden_healthcheck_emission_interval,omitempty"`
	GardenHealthcheckInterval             durationjson.Duration `json:"garden_healthcheck_interval,omitempty"`
	GardenHealthcheckProcessArgs          []string              `json:"garden_healthcheck_process_args,omitempty"`
	GardenHealthcheckProcessDir           string                `json:"garden_healthcheck_process_dir"`
	GardenHealthcheckProcessEnv           []string              `json:"garden_healthcheck_process_env,omitempty"`
	GardenHealthcheckProcessPath          string                `json:"garden_healthcheck_process_path"`
	GardenHealthcheckProcessUser          string                `json:"garden_healthcheck_process_user"`
	GardenHealthcheckTimeout              durationjson.Duration `json:"garden_healthcheck_timeout,omitempty"`
	GardenNetwork                         string                `json:"garden_network,omitempty"`
	GracefulShutdownInterval              durationjson.Duration `json:"graceful_shutdown_interval,omitempty"`
	HealthCheckContainerOwnerName         string                `json:"healthcheck_container_owner_name,omitempty"`
	HealthCheckWorkPoolSize               int                   `json:"healthcheck_work_pool_size,omitempty"`
	HealthyMonitoringInterval             durationjson.Duration `json:"healthy_monitoring_interval,omitempty"`
	InstanceIdentityCAPath                string                `json:"instance_identity_ca_path,omitempty"`
	InstanceIdentityCredDir               string                `json:"instance_identity_cred_dir,omitempty"`
	InstanceIdentityPrivateKeyPath        string                `json:"instance_identity_private_key_path,omitempty"`
	InstanceIdentityValidityPeriod        durationjson.Duration `json:"instance_identity_validity_period,omitempty"`
	MaxCacheSizeInBytes                   uint64                `json:"max_cache_size_in_bytes,omitempty"`
	MaxConcurrentDownloads                int                   `json:"max_concurrent_downloads,omitempty"`
	MaxLogLinesPerSecond                  int                   `json:"max_log_lines_per_second"`
	MemoryMB                              string                `json:"memory_mb,omitempty"`
	MetricsWorkPoolSize                   int                   `json:"metrics_work_pool_size,omitempty"`
	PathToCACertsForDownloads             string                `json:"path_to_ca_certs_for_downloads"`
	PathToTLSCACert                       string                `json:"path_to_tls_ca_cert"`
	PathToTLSCert                         string                `json:"path_to_tls_cert"`
	PathToTLSKey                          string                `json:"path_to_tls_key"`
	PostSetupHook                         string                `json:"post_setup_hook"`
	PostSetupUser                         string                `json:"post_setup_user"`
	ProxyEnableHttp2                      bool                  `json:"proxy_enable_http2"`
	ProxyMemoryAllocationMB               int                   `json:"proxy_memory_allocation_mb,omitempty"`
	ReadWorkPoolSize                      int                   `json:"read_work_pool_size,omitempty"`
	ReservedExpirationTime                durationjson.Duration `json:"reserved_expiration_time,omitempty"`
	SetCPUWeight                          bool                  `json:"set_cpu_weight,omitempty"`
	SkipCertVerify                        bool                  `json:"skip_cert_verify,omitempty"`
	TempDir                               string                `json:"temp_dir,omitempty"`
	TrustedSystemCertificatesPath         string                `json:"trusted_system_certificates_path"`
	UnhealthyMonitoringInterval           durationjson.Duration `json:"unhealthy_monitoring_interval,omitempty"`
	UseSchedulableDiskSize                bool                  `json:"use_schedulable_disk_size,omitempty"`
	VolmanDriverPaths                     string                `json:"volman_driver_paths"`
	VolumeMountedFiles                    string                `json:"volume_mounted_files"`
}

func (*ExecutorConfig) Validate

func (config *ExecutorConfig) Validate(logger lager.Logger) bool