watch

Documentation

Index

• Constants
• func SyncPodStatus(mgr client.K8sClusterInterface, stopChan chan struct{}) (err error)
• type AIPodController
  • func NewAIPodStatusController(cluster *kubernetes.Clientset, namespace, nodeName string) (c *AIPodController)
• type Controller
  • func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
• type ProcessNextItem

Constants

const (
	ResourceTypePod = "pods"
	ResourceTypeSvc = "services"
	ResourceTypeEp  = "endpoints"
	ResourceTypeDP  = "deployments"
)

Functions

func SyncPodStatus

func SyncPodStatus(mgr client.K8sClusterInterface, stopChan chan struct{}) (err error)

Types

type AIPodController

type AIPodController struct {
	*Controller
}

func NewAIPodStatusController

func NewAIPodStatusController(cluster *kubernetes.Clientset, namespace, nodeName string) (c *AIPodController)

type Controller

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

Controller demonstrates how to implement a controller with client-go.

func NewController

func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer,
	informer cache.Controller, processFunc ProcessNextItem) *Controller

NewController creates a new Controller.

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{})

Run begins watching and syncing.

type ProcessNextItem

type ProcessNextItem func() bool