Documentation ¶
Index ¶
Constants ¶
View Source
const (
// SuccessSynced is used as part of the Event 'reason' when a ControllersManager is synced
SuccessSynced = "Synced"
)
Variables ¶
View Source
var ( // SyncWorkerSpecFromCarbonJobLatency SyncWorkerSpecFromCarbonJobLatency SyncWorkerSpecFromCarbonJobLatency = prometheus.NewSummaryVec( prometheus.SummaryOpts{ Namespace: "carbon", Subsystem: "carbonjob", Name: "sync_worker_spec_latency", Help: "no help can be found here", MaxAge: metric.SummaryMaxAge, AgeBuckets: metric.SummaryAgeBuckets, Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.99: 0.001}, }, []string{"namespace", "name", "success"}, ) )
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct { schema.GroupVersionKind controller.DefaultController // contains filtered or unexported fields }
Controller is the controller implementation for ControllersManager resources
func NewController ¶
func NewController( kubeclientset kubernetes.Interface, carbonclientset clientset.Interface, podInformer coreinformers.PodInformer, workerNodeInformer informers.WorkerNodeInformer, carbonJobInformer informers.CarbonJobInformer, ) *Controller
NewController returns a new ControllersManager controller
func (*Controller) DeleteSubObj ¶
func (c *Controller) DeleteSubObj(namespace, name string) error
DeleteSubObj DeleteSubObj
func (*Controller) GetObj ¶
func (c *Controller) GetObj(namespace, key string) (interface{}, error)
GetObj GetObj
func (*Controller) WaitForCacheSync ¶
func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool
WaitForCacheSync WaitForCacheSync
Click to show internal directories.
Click to hide internal directories.