config

Documentation

Overview

Package config provides mechanisms for low-level scheduler tuning.

Index

• Constants
• type Config
  • func CreateDefaultConfig() *Config
  • func (c *Config) Read(configReader io.Reader) error
  • func (c *Config) SetDefaults()
• type ConfigWrapper
• type WrappedDuration
  • func (wd *WrappedDuration) UnmarshalText(data []byte) error

Constants

const (
	DefaultOfferTTL                           = 5 * time.Second   // duration an offer is viable, prior to being expired
	DefaultOfferLingerTTL                     = 120 * time.Second // duration an expired offer lingers in history
	DefaultListenerDelay                      = 1 * time.Second   // duration between offer listener notifications
	DefaultUpdatesBacklog                     = 2048              // size of the pod updates channel
	DefaultFrameworkIdRefreshInterval         = 30 * time.Second  // interval we update the frameworkId stored in etcd
	DefaultInitialImplicitReconciliationDelay = 15 * time.Second  // wait this amount of time after initial registration before attempting implicit reconciliation
	DefaultExplicitReconciliationMaxBackoff   = 2 * time.Minute   // interval in between internal task status checks/updates
	DefaultExplicitReconciliationAbortTimeout = 30 * time.Second  // waiting period after attempting to cancel an ongoing reconciliation
	DefaultInitialPodBackoff                  = 1 * time.Second
	DefaultMaxPodBackoff                      = 60 * time.Second
	DefaultHttpHandlerTimeout                 = 10 * time.Second
	DefaultHttpBindInterval                   = 5 * time.Second
)

Types

type Config

type Config struct {
	OfferTTL                           WrappedDuration `gcfg:"offer-ttl"`
	OfferLingerTTL                     WrappedDuration `gcfg:"offer-linger-ttl"`
	ListenerDelay                      WrappedDuration `gcfg:"listener-delay"`
	UpdatesBacklog                     int             `gcfg:"updates-backlog"`
	FrameworkIdRefreshInterval         WrappedDuration `gcfg:"framework-id-refresh-interval"`
	InitialImplicitReconciliationDelay WrappedDuration `gcfg:"initial-implicit-reconciliation-delay"`
	ExplicitReconciliationMaxBackoff   WrappedDuration `gcfg:"explicit-reconciliantion-max-backoff"`
	ExplicitReconciliationAbortTimeout WrappedDuration `gcfg:"explicit-reconciliantion-abort-timeout"`
	InitialPodBackoff                  WrappedDuration `gcfg:"initial-pod-backoff"`
	MaxPodBackoff                      WrappedDuration `gcfg:"max-pod-backoff"`
	HttpHandlerTimeout                 WrappedDuration `gcfg:"http-handler-timeout"`
	HttpBindInterval                   WrappedDuration `gcfg:"http-bind-interval"`
}

func CreateDefaultConfig

func CreateDefaultConfig() *Config

func (*Config) Read

func (c *Config) Read(configReader io.Reader) error

func (*Config) SetDefaults

func (c *Config) SetDefaults()

type ConfigWrapper

type ConfigWrapper struct {
	Scheduler Config
}

type WrappedDuration

type WrappedDuration struct {
	time.Duration
}

func (*WrappedDuration) UnmarshalText

func (wd *WrappedDuration) UnmarshalText(data []byte) error