Versions in this module Expand all Collapse all v0 v0.0.8 Sep 14, 2025 Changes in this version + type K8sDeploySyncServiceImpl struct + ForceSync bool + K8sSyncCron string + LockTTL string + RefreshCron string + func (s *K8sDeploySyncServiceImpl) AddWatcher(watcher k8sWatcher, m lock.Lock) + func (s *K8sDeploySyncServiceImpl) Close(ctx context.Context) + func (s *K8sDeploySyncServiceImpl) Init() error + func (s *K8sDeploySyncServiceImpl) Name() string + func (s *K8sDeploySyncServiceImpl) Priority() int + func (s *K8sDeploySyncServiceImpl) RemoveWatcher(wacherName string) + func (s *K8sDeploySyncServiceImpl) Run(ctx context.Context) + func (s *K8sDeploySyncServiceImpl) RunBackGround() + func (s *K8sDeploySyncServiceImpl) RunWatcher(ctx context.Context, forceSync bool, watcher k8sWatcher) error + func (s *K8sDeploySyncServiceImpl) SyncCluster(ctx context.Context, in *sync.SyncClusterRequest) (*sync.SyncClusterRecord, error) + func (s *K8sDeploySyncServiceImpl) Watch(ctx context.Context, k8sIns *k8s.Cluster)
Go to main page