- func GetDesiredWorkers(queueName string, queueMessages int32, messagesSentPerMinute float64, ...) int32
- type Controller
- type WokerPodAutoScalerEvent
const ( // SuccessSynced is used as part of the Event 'reason' when a WorkerPodAutoScaler is synced SuccessSynced = "Synced" // ErrResourceExists is used as part of the Event 'reason' when a WorkerPodAutoScaler fails // to sync due to a Deployment of the same name already existing. ErrResourceExists = "ErrResourceExists" // MessageResourceExists is the message used for Events when a resource // fails to sync due to a Deployment already existing MessageResourceExists = "Resource %q already exists and is not managed by WorkerPodAutoScaler" // MessageResourceSynced is the message used for an Event fired when a WorkerPodAutoScaler // is synced successfully MessageResourceSynced = "WorkerPodAutoScaler synced successfully" // WokerPodAutoScalerEventAdd stores the add event name WokerPodAutoScalerEventAdd = "add" // WokerPodAutoScalerEventUpdate stores the add event name WokerPodAutoScalerEventUpdate = "update" // WokerPodAutoScalerEventDelete stores the add event name WokerPodAutoScalerEventDelete = "delete" )
This section is empty.
func GetDesiredWorkers ¶ added in v1.1.0
GetDesiredWorkers finds the desired number of workers which are required
type Controller ¶
Controller is the controller implementation for WorkerPodAutoScaler resources
func NewController ¶
func NewController( ctx context.Context, kubeclientset kubernetes.Interface, customclientset clientset.Interface, deploymentInformer appsinformers.DeploymentInformer, replicaSetInformer appsinformers.ReplicaSetInformer, workerPodAutoScalerInformer informers.WorkerPodAutoScalerInformer, defaultMaxDisruption string, queues *queue.Queues) *Controller
NewController returns a new sample controller
Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.