impl

Documentation

Index

• type K8sDeploySyncServiceImpl
  • 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)

Types

type K8sDeploySyncServiceImpl

type K8sDeploySyncServiceImpl struct {
	ioc.ObjectImpl

	// 分布式TTL
	LockTTL string `json:"lock_ttl" yaml:"lock_ttl" toml:"lock_ttl" env:"LOCK_TTL"`
	// 刷新Cron
	RefreshCron string `json:"refresh_cron" yaml:"refresh_cron" toml:"refresh_cron" env:"REFRESH_CRON"`
	// k8s集群信息同步
	K8sSyncCron string `json:"k8s_sync_cron" yaml:"k8s_sync_cron" toml:"k8s_sync_cron" env:"K8S_SYNC_CRON"`
	// 强制同步, 默认有锁, 强制同步 不用加锁, 用于本地调试
	ForceSync bool `json:"force_sync" yaml:"force_sync" toml:"force_sync" env:"FORCE_SYNC"`
	// contains filtered or unexported fields
}

func (*K8sDeploySyncServiceImpl) AddWatcher

func (s *K8sDeploySyncServiceImpl) AddWatcher(watcher k8sWatcher, m lock.Lock)

func (*K8sDeploySyncServiceImpl) Close

func (s *K8sDeploySyncServiceImpl) Close(ctx context.Context)

func (*K8sDeploySyncServiceImpl) Init

func (s *K8sDeploySyncServiceImpl) Init() error

func (*K8sDeploySyncServiceImpl) Name

func (s *K8sDeploySyncServiceImpl) Name() string

func (*K8sDeploySyncServiceImpl) Priority

func (s *K8sDeploySyncServiceImpl) Priority() int

func (*K8sDeploySyncServiceImpl) RemoveWatcher

func (s *K8sDeploySyncServiceImpl) RemoveWatcher(wacherName string)

func (*K8sDeploySyncServiceImpl) Run

func (s *K8sDeploySyncServiceImpl) Run(ctx context.Context)

func (*K8sDeploySyncServiceImpl) RunBackGround

func (s *K8sDeploySyncServiceImpl) RunBackGround()

func (*K8sDeploySyncServiceImpl) RunWatcher

func (s *K8sDeploySyncServiceImpl) RunWatcher(ctx context.Context, forceSync bool, watcher k8sWatcher) error

func (*K8sDeploySyncServiceImpl) SyncCluster

func (s *K8sDeploySyncServiceImpl) SyncCluster(ctx context.Context, in *sync.SyncClusterRequest) (*sync.SyncClusterRecord, error)

SyncCluster implements sync.Service.

func (*K8sDeploySyncServiceImpl) Watch

func (s *K8sDeploySyncServiceImpl) Watch(ctx context.Context, k8sIns *k8s.Cluster)