kubernetes: k8s.io/kubernetes/pkg/controller/daemon Index | Files | Directories

package daemon

import "k8s.io/kubernetes/pkg/controller/daemon"

Package daemon contains logic for watching and synchronizing daemons.

Index

Package Files

daemon_controller.go doc.go update.go

Constants

const (
    // BurstReplicas is a rate limiter for booting pods on a lot of pods.
    // The value of 250 is chosen b/c values that are too high can cause registry DoS issues.
    BurstReplicas = 250

    // StatusUpdateRetries limits the number of retries if sending a status update to API server fails.
    StatusUpdateRetries = 1
)
const (
    // SelectingAllReason is added to an event when a DaemonSet selects all Pods.
    SelectingAllReason = "SelectingAll"
    // FailedPlacementReason is added to an event when a DaemonSet can't schedule a Pod to a specified node.
    FailedPlacementReason = "FailedPlacement"
    // FailedDaemonPodReason is added to an event when the status of a Pod of a DaemonSet is 'Failed'.
    FailedDaemonPodReason = "FailedDaemonPod"
)

Reasons for DaemonSet events

func Match Uses

func Match(ds *apps.DaemonSet, history *apps.ControllerRevision) (bool, error)

Match check if the given DaemonSet's template matches the template stored in the given history.

func NewPod Uses

func NewPod(ds *apps.DaemonSet, nodeName string) *v1.Pod

NewPod creates a new pod

func Predicates Uses

func Predicates(pod *v1.Pod, nodeInfo *schedulercache.NodeInfo) (bool, []algorithm.PredicateFailureReason, error)

Predicates checks if a DaemonSet's pod can be scheduled on a node using GeneralPredicates and PodToleratesNodeTaints predicate

type DaemonSetsController Uses

type DaemonSetsController struct {
    // contains filtered or unexported fields
}

DaemonSetsController is responsible for synchronizing DaemonSet objects stored in the system with actual running pods.

func NewDaemonSetsController Uses

func NewDaemonSetsController(daemonSetInformer appsinformers.DaemonSetInformer, historyInformer appsinformers.ControllerRevisionInformer, podInformer coreinformers.PodInformer, nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface) (*DaemonSetsController, error)

NewDaemonSetsController creates a new DaemonSetsController

func (*DaemonSetsController) Run Uses

func (dsc *DaemonSetsController) Run(workers int, stopCh <-chan struct{})

Run begins watching and syncing daemon sets.

Directories

PathSynopsis
util

Package daemon imports 45 packages (graph) and is imported by 102 packages. Updated 2018-06-17. Refresh now. Tools for package owners.