service

Documentation

Overview

Package service contains the cmd/k8sm-scheduler glue code

Index

• Constants
• type SchedulerServer
  • func NewSchedulerServer() *SchedulerServer
  • func (s *SchedulerServer) AddHyperkubeFlags(fs *pflag.FlagSet)
  • func (s *SchedulerServer) AddStandaloneFlags(fs *pflag.FlagSet)
  • func (s *SchedulerServer) Run(hks hyperkube.Interface, _ []string) error

Constants

const (
	SCHEDULER_SERVICE_NAME = "k8sm-scheduler"
)

Types

type SchedulerServer

type SchedulerServer struct {
	Port                int
	Address             net.IP
	EnableProfiling     bool
	AuthPath            string
	APIServerList       []string
	EtcdServerList      []string
	EtcdConfigFile      string
	AllowPrivileged     bool
	ExecutorPath        string
	ProxyPath           string
	MesosMaster         string
	MesosUser           string
	MesosRole           string
	MesosAuthPrincipal  string
	MesosAuthSecretFile string
	MesosCgroupPrefix   string
	MesosExecutorCPUs   mresource.CPUShares
	MesosExecutorMem    mresource.MegaBytes
	Checkpoint          bool
	FailoverTimeout     float64

	ExecutorLogV           int
	ExecutorBindall        bool
	ExecutorSuicideTimeout time.Duration
	LaunchGracePeriod      time.Duration

	RunProxy     bool
	ProxyBindall bool
	ProxyLogV    int

	MinionPathOverride    string
	MinionLogMaxSize      resource.Quantity
	MinionLogMaxBackups   int
	MinionLogMaxAgeInDays int

	MesosAuthProvider             string
	DriverPort                    uint
	HostnameOverride              string
	ReconcileInterval             int64
	ReconcileCooldown             time.Duration
	DefaultContainerCPULimit      mresource.CPUShares
	DefaultContainerMemLimit      mresource.MegaBytes
	SchedulerConfigFileName       string
	Graceful                      bool
	FrameworkName                 string
	FrameworkWebURI               string
	HA                            bool
	AdvertisedAddress             string
	ServiceAddress                net.IP
	HADomain                      string
	KMPath                        string
	ClusterDNS                    net.IP
	ClusterDomain                 string
	KubeletRootDirectory          string
	KubeletDockerEndpoint         string
	KubeletPodInfraContainerImage string
	KubeletCadvisorPort           uint
	KubeletHostNetworkSources     string
	KubeletSyncFrequency          time.Duration
	KubeletNetworkPluginName      string
	StaticPodsConfigPath          string
	DockerCfgPath                 string
	ContainPodResources           bool
	AccountForPodResources        bool
	// contains filtered or unexported fields
}

func NewSchedulerServer

func NewSchedulerServer() *SchedulerServer

NewSchedulerServer creates a new SchedulerServer with default parameters

func (*SchedulerServer) AddHyperkubeFlags

func (s *SchedulerServer) AddHyperkubeFlags(fs *pflag.FlagSet)

func (*SchedulerServer) AddStandaloneFlags

func (s *SchedulerServer) AddStandaloneFlags(fs *pflag.FlagSet)

func (*SchedulerServer) Run

func (s *SchedulerServer) Run(hks hyperkube.Interface, _ []string) error