node

Feb 4, 2018

Changes in this version

+ type Controller struct

+ func (nc *Controller) ComputeZoneState(nodeReadyConditions []*v1.NodeCondition) (int, ZoneState)

+ func (nc *Controller) HealthyQPSFunc(nodeNum int) float32

+ func (nc *Controller) ReducedQPSFunc(nodeNum int) float32

+ func (nc *Controller) Run(stopCh <-chan struct{})

+ type ZoneState string

Jun 29, 2017

Changes in this version

+ var NotReadyTaintTemplate = &v1.Taint

+ var UnreachableTaintTemplate = &v1.Taint

type CIDRAllocator

+ func NewCloudCIDRAllocator(client clientset.Interface, cloud cloudprovider.Interface) (ca CIDRAllocator, err error)

+ type CIDRAllocatorType string

+ const CloudAllocatorType

+ const RangeAllocatorType

+ type NoExecuteTaintManager struct

+ func NewNoExecuteTaintManager(c clientset.Interface) *NoExecuteTaintManager

+ func (tc *NoExecuteTaintManager) NodeUpdated(oldNode *v1.Node, newNode *v1.Node)

+ func (tc *NoExecuteTaintManager) PodUpdated(oldPod *v1.Pod, newPod *v1.Pod)

+ func (tc *NoExecuteTaintManager) Run(stopCh <-chan struct{})

+ type TimedWorker struct

+ CreatedAt time.Time

+ FireAt time.Time

+ Timer *time.Timer

+ WorkItem *WorkArgs

+ func CreateWorker(args *WorkArgs, createdAt time.Time, fireAt time.Time, ...) *TimedWorker

+ func (w *TimedWorker) Cancel()

+ type TimedWorkerQueue struct

+ func CreateWorkerQueue(f func(args *WorkArgs) error) *TimedWorkerQueue

+ func (q *TimedWorkerQueue) AddWork(args *WorkArgs, createdAt time.Time, fireAt time.Time)

+ func (q *TimedWorkerQueue) CancelWork(key string) bool

+ func (q *TimedWorkerQueue) GetWorkerUnsafe(key string) *TimedWorker

+ type WorkArgs struct

+ NamespacedName types.NamespacedName

+ func NewWorkArgs(name, namespace string) *WorkArgs

+ func (w *WorkArgs) KeyFromWorkArgs() string

Oct 29, 2016

Changes in this version

+ const EvictionsNumberKey

+ const LargeClusterThreshold

+ const NodeControllerSubsystem

+ const ZoneHealthStatisticKey

+ const ZoneNoUnhealthyNodesKey

+ const ZoneSizeKey

+ var EvictionsNumber = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var UnhealthyNodes = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var ZoneHealth = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var ZoneSize = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ func Register()

type CIDRAllocator

+ AllocateOrOccupyCIDR func(node *api.Node) error

+ ReleaseCIDR func(node *api.Node) error

+ type FakeLegacyHandler struct

+ func (m *FakeLegacyHandler) Nodes() unversionedcore.NodeInterface

+ type FakeNodeHandler struct

+ CreateHook func(*FakeNodeHandler, *api.Node) bool

+ CreatedNodes []*api.Node

+ DeletedNodes []*api.Node

+ Existing []*api.Node

+ RequestCount int

+ UpdatedNodeStatuses []*api.Node

+ UpdatedNodes []*api.Node

+ func (c *FakeNodeHandler) Core() unversionedcore.CoreInterface

+ func (m *FakeNodeHandler) Create(node *api.Node) (*api.Node, error)

+ func (m *FakeNodeHandler) Delete(id string, opt *api.DeleteOptions) error

+ func (m *FakeNodeHandler) DeleteCollection(opt *api.DeleteOptions, listOpts api.ListOptions) error

+ func (m *FakeNodeHandler) Get(name string) (*api.Node, error)

+ func (m *FakeNodeHandler) List(opts api.ListOptions) (*api.NodeList, error)

+ func (m *FakeNodeHandler) Patch(name string, pt api.PatchType, data []byte, subresources ...string) (*api.Node, error)

+ func (m *FakeNodeHandler) PatchStatus(nodeName string, data []byte) (*api.Node, error)

+ func (m *FakeNodeHandler) Update(node *api.Node) (*api.Node, error)

+ func (m *FakeNodeHandler) UpdateStatus(node *api.Node) (*api.Node, error)

+ func (m *FakeNodeHandler) Watch(opts api.ListOptions) (watch.Interface, error)

+ type FakeRecorder struct

+ func NewFakeRecorder() *FakeRecorder

+ func (f *FakeRecorder) Event(obj runtime.Object, eventtype, reason, message string)

+ func (f *FakeRecorder) Eventf(obj runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

+ func (f *FakeRecorder) PastEventf(obj runtime.Object, timestamp unversioned.Time, ...)

type NodeController

+ func NewNodeControllerFromClient(cloud cloudprovider.Interface, kubeClient clientset.Interface, ...) (*NodeController, error)

+ func (nc *NodeController) ComputeZoneState(nodeReadyConditions []*api.NodeCondition) (int, zoneState)

+ func (nc *NodeController) HealthyQPSFunc(nodeNum int) float32

+ func (nc *NodeController) ReducedQPSFunc(nodeNum int) float32

type RateLimitedTimedQueue

+ func (q *RateLimitedTimedQueue) SwapLimiter(newQPS float32)

type TimedValue

+ UID interface{}

type UniqueQueue

+ func (q *UniqueQueue) RemoveFromQueue(value string) bool

Jul 1, 2016

Changes in this version

+ var ErrCloudInstance = errors.New("cloud provider doesn't support instances.")

+ type ActionFunc func(TimedValue) (bool, time.Duration)

+ type CIDRAllocator interface

+ AllocateNext func() (*net.IPNet, error)

+ Occupy func(*net.IPNet) error

+ Release func(*net.IPNet) error

+ func NewCIDRRangeAllocator(clusterCIDR *net.IPNet, subNetMaskSize int) CIDRAllocator

+ type NodeController struct

+ func NewNodeController(cloud cloudprovider.Interface, kubeClient clientset.Interface, ...) *NodeController

+ func (nc *NodeController) Run(period time.Duration)

+ type RateLimitedTimedQueue struct

+ func NewRateLimitedTimedQueue(limiter flowcontrol.RateLimiter) *RateLimitedTimedQueue

+ func (q *RateLimitedTimedQueue) Add(value string) bool

+ func (q *RateLimitedTimedQueue) Clear()

+ func (q *RateLimitedTimedQueue) Remove(value string) bool

+ func (q *RateLimitedTimedQueue) Try(fn ActionFunc)

+ type TimedQueue []*TimedValue

+ func (h *TimedQueue) Pop() interface{}

+ func (h *TimedQueue) Push(x interface{})

+ func (h TimedQueue) Len() int

+ func (h TimedQueue) Less(i, j int) bool

+ func (h TimedQueue) Swap(i, j int)

+ type TimedValue struct

+ AddedAt time.Time

+ ProcessAt time.Time

+ Value string

+ type UniqueQueue struct

+ func (q *UniqueQueue) Add(value TimedValue) bool

+ func (q *UniqueQueue) Clear()

+ func (q *UniqueQueue) Get() (TimedValue, bool)

+ func (q *UniqueQueue) Head() (TimedValue, bool)

+ func (q *UniqueQueue) Remove(value string) bool

+ func (q *UniqueQueue) Replace(value TimedValue) bool