manager

Documentation

Index

• type Manager
  • func NewManager(cfg config.ManagerConfig, resourceEventQueue *queue.OverwriteQueue) *Manager
  • func (m *Manager) GetCloudInfo(lcuuid string) (model.BasicInfo, error)
  • func (m *Manager) GetCloudInfos() []model.BasicInfo
  • func (m *Manager) GetCloudResource(lcuuid string) (model.Resource, error)
  • func (m *Manager) GetKubernetesGatherBasicInfos(lcuuid string) ([]gathermodel.KubernetesGatherBasicInfo, error)
  • func (m *Manager) GetKubernetesGatherResource(lcuuid, subDomainLcuuid string) (gathermodel.KubernetesGatherResource, error)
  • func (m *Manager) GetRecorder(domainLcuuid string) (recorder.Recorder, error)
  • func (m *Manager) GetSubDomainResource(lcuuid, subDomainLcuuid string) (model.SubDomainResource, error)
  • func (m *Manager) Start()
  • func (m *Manager) TriggerDomain(lcuuid string) error
  • func (m *Manager) TriggerKubernetesRefresh(domainLcuuid, subDomainLcuuid string, version int) error
• type Task
  • func NewTask(orgID int, domain mysqlmodel.Domain, cfg config.TaskConfig, ...) *Task
  • func (t *Task) Start()
  • func (t *Task) Stop()
  • func (t *Task) UpdateDomainName(name string)

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(cfg config.ManagerConfig, resourceEventQueue *queue.OverwriteQueue) *Manager

func (*Manager) GetCloudInfo

func (m *Manager) GetCloudInfo(lcuuid string) (model.BasicInfo, error)

func (*Manager) GetCloudInfos

func (m *Manager) GetCloudInfos() []model.BasicInfo

func (*Manager) GetCloudResource

func (m *Manager) GetCloudResource(lcuuid string) (model.Resource, error)

func (*Manager) GetKubernetesGatherBasicInfos

func (m *Manager) GetKubernetesGatherBasicInfos(lcuuid string) ([]gathermodel.KubernetesGatherBasicInfo, error)

func (*Manager) GetKubernetesGatherResource

func (m *Manager) GetKubernetesGatherResource(lcuuid, subDomainLcuuid string) (gathermodel.KubernetesGatherResource, error)

func (*Manager) GetRecorder

func (m *Manager) GetRecorder(domainLcuuid string) (recorder.Recorder, error)

func (*Manager) GetSubDomainResource

func (m *Manager) GetSubDomainResource(lcuuid, subDomainLcuuid string) (model.SubDomainResource, error)

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) TriggerDomain

func (m *Manager) TriggerDomain(lcuuid string) error

func (*Manager) TriggerKubernetesRefresh

func (m *Manager) TriggerKubernetesRefresh(domainLcuuid, subDomainLcuuid string, version int) error

type Task

type Task struct {
	LogPrefixORGID logger.Prefix
	Cloud          *cloud.Cloud
	Recorder       *recorder.Recorder
	DomainName     string // 云平台名称
	DomainConfig   string // 云平台配置字段config
	// contains filtered or unexported fields
}

func NewTask

func NewTask(orgID int, domain mysqlmodel.Domain, cfg config.TaskConfig, ctx context.Context, resourceEventQueue *queue.OverwriteQueue) *Task

func (*Task) Start

func (t *Task) Start()

func (*Task) Stop

func (t *Task) Stop()

func (*Task) UpdateDomainName

func (t *Task) UpdateDomainName(name string)