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) ([]kubernetes_gather_model.KubernetesGatherBasicInfo, error)
  • func (m *Manager) GetKubernetesGatherResources(lcuuid string) ([]kubernetes_gather_model.KubernetesGatherResource, error)
  • func (m *Manager) GetRecorder(domainLcuuid string) (recorder.Recorder, error)
  • func (m *Manager) Start()
• type Task
  • func NewTask(domain mysql.Domain, cfg config.TaskConfig, ctx context.Context, ...) *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) ([]kubernetes_gather_model.KubernetesGatherBasicInfo, error)

func (*Manager) GetKubernetesGatherResources

func (m *Manager) GetKubernetesGatherResources(lcuuid string) ([]kubernetes_gather_model.KubernetesGatherResource, error)

func (*Manager) GetRecorder

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

func (*Manager) Start

func (m *Manager) Start()

type Task

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

func NewTask

func NewTask(domain mysql.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)