Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + var ApplicationThreadNum int + var DeploymentThreadNum int + var ExportserviceThreadNum int + var TaskgroupThreadNum int + func GenerateRandnum() int + func NewEtcdCluster(cfg *types.CmdConfig, st storage.Storage, netservice *service.InnerService) cluster.Cluster + type AppWatch struct + func NewAppWatch(cxt context.Context, informer bkbcsv2.ApplicationInformer, ...) *AppWatch + func (app *AppWatch) AddEvent(obj interface{}) + func (app *AppWatch) DeleteEvent(obj interface{}) + func (app *AppWatch) GetApplicationChannel(application *schedulertypes.Application) string + func (app *AppWatch) UpdateEvent(old, cur interface{}, force bool) + func (app *AppWatch) Work() + type ConfigMapInfo struct + type ConfigMapWatch struct + func NewConfigMapWatch(cxt context.Context, informer bkbcsv2.BcsConfigMapInformer, ...) *ConfigMapWatch + func (watch *ConfigMapWatch) AddEvent(obj interface{}) + func (watch *ConfigMapWatch) DeleteEvent(obj interface{}) + func (watch *ConfigMapWatch) ProcessAllConfigmaps() error + func (watch *ConfigMapWatch) UpdateEvent(old, cur interface{}) + func (watch *ConfigMapWatch) Work() + type DeploymentInfo struct + type DeploymentWatch struct + func NewDeploymentWatch(cxt context.Context, informer bkbcsv2.DeploymentInformer, ...) *DeploymentWatch + func (watch *DeploymentWatch) AddEvent(obj interface{}) + func (watch *DeploymentWatch) DeleteEvent(obj interface{}) + func (watch *DeploymentWatch) GetDeploymentChannel(deployment *schedulertypes.Deployment) string + func (watch *DeploymentWatch) ProcessAllDeployments() error + func (watch *DeploymentWatch) UpdateEvent(old, cur interface{}) + func (watch *DeploymentWatch) Work() + type EndpointInfo struct + type EndpointWatch struct + func NewEndpointWatch(cxt context.Context, informer bkbcsv2.BcsEndpointInformer, ...) *EndpointWatch + func (watch *EndpointWatch) AddEvent(obj interface{}) + func (watch *EndpointWatch) DeleteEvent(obj interface{}) + func (watch *EndpointWatch) ProcessAllEndpoints() error + func (watch *EndpointWatch) UpdateEvent(old, cur interface{}) + func (watch *EndpointWatch) Work() + type EtcdCluster struct + Status string + func (ms *EtcdCluster) GetClusterStatus() string + func (ms *EtcdCluster) ReportData(data *types.BcsSyncData) error + func (ms *EtcdCluster) Run(cxt context.Context) + func (ms *EtcdCluster) Stop() + func (ms *EtcdCluster) Sync(tp string) error + type ExportServiceInfo struct + type ExportServiceWatch struct + ClusterID string + func NewExportServiceWatch(cxt context.Context, factory informers.SharedInformerFactory, ...) *ExportServiceWatch + func (watch *ExportServiceWatch) AddEvent(obj interface{}) + func (watch *ExportServiceWatch) DeleteEvent(obj interface{}) + func (watch *ExportServiceWatch) GetExportserviceChannel(exportservice *lbtypes.ExportService) string + func (watch *ExportServiceWatch) SyncEpTaskgroupBackend(esInfo *ExportServiceInfo, taskgroup *schedtypes.TaskGroup) error + func (watch *ExportServiceWatch) SyncExportServiceBackends(esInfo *ExportServiceInfo) error + func (watch *ExportServiceWatch) UpdateEvent(obj interface{}) + type NSControlInfo struct + type NetServiceWatcher struct + func NewNetServiceWatcher(clusterID string, reporter cluster.Reporter, netservice *service.InnerService) *NetServiceWatcher + func (w *NetServiceWatcher) Run(stopCh <-chan struct{}) + func (w *NetServiceWatcher) SyncIPResource() + func (w *NetServiceWatcher) SyncIPResourceDetail() + type SecretInfo struct + type SecretWatch struct + func NewSecretWatch(cxt context.Context, informer bkbcsv2.BcsSecretInformer, ...) *SecretWatch + func (watch *SecretWatch) AddEvent(obj interface{}) + func (watch *SecretWatch) DeleteEvent(obj interface{}) + func (watch *SecretWatch) ProcessAllSecrets() error + func (watch *SecretWatch) UpdateEvent(old, cur interface{}) + func (watch *SecretWatch) Work() + type ServiceInfo struct + type ServiceWatch struct + func NewServiceWatch(cxt context.Context, informer bkbcsv2.BcsServiceInformer, ...) *ServiceWatch + func (watch *ServiceWatch) AddEvent(obj interface{}) + func (watch *ServiceWatch) DeleteEvent(obj interface{}) + func (watch *ServiceWatch) ProcessAllServices() error + func (watch *ServiceWatch) UpdateEvent(old, cur interface{}) + func (watch *ServiceWatch) Work() + type TaskControlInfo struct + type TaskGroupWatch struct + func NewTaskGroupWatch(cxt context.Context, informer bkbcsv2.TaskGroupInformer, ...) *TaskGroupWatch + func (task *TaskGroupWatch) AddEvent(obj interface{}) + func (task *TaskGroupWatch) DeleteEvent(obj interface{}) + func (task *TaskGroupWatch) GetTaskGroupChannel(taskGroup *schedulertypes.TaskGroup) string + func (task *TaskGroupWatch) GetTaskGroupChannelV2(taskGroup *schedulertypes.TaskGroup) string + func (task *TaskGroupWatch) UpdateEvent(old, cur interface{}, force bool) + func (task *TaskGroupWatch) Work()
Go to main page