cloud

Documentation

Index

• type Cloud
  • func NewCloud(orgID int, domain mysql.Domain, cfg config.CloudConfig, ctx context.Context) *Cloud
  • func (c *Cloud) GetBasicInfo() model.BasicInfo
  • func (c *Cloud) GetDomainRefreshSignal() *queue.OverwriteQueue
  • func (c *Cloud) GetKubernetesGatherTaskMap() map[string]*KubernetesGatherTask
  • func (c *Cloud) GetOrgID() int
  • func (c *Cloud) GetResource() model.Resource
  • func (c *Cloud) GetStatter() statsd.StatsdStatter
  • func (c *Cloud) GetSubDomainRefreshSignals() cmap.ConcurrentMap[string, *queue.OverwriteQueue]
  • func (c *Cloud) Start()
  • func (c *Cloud) Stop()
  • func (c *Cloud) UpdateBasicInfoName(name string)
• type KubernetesGatherTask
  • func NewKubernetesGatherTask(ctx context.Context, db *mysql.DB, domain *mysql.Domain, ...) *KubernetesGatherTask
  • func (k *KubernetesGatherTask) GetBasicInfo() kmodel.KubernetesGatherBasicInfo
  • func (k *KubernetesGatherTask) GetGatherCost() float64
  • func (k *KubernetesGatherTask) GetResource() kmodel.KubernetesGatherResource
  • func (k *KubernetesGatherTask) PutRefreshSignal(version int) error
  • func (k *KubernetesGatherTask) Start(rSignal *queue.OverwriteQueue)
  • func (k *KubernetesGatherTask) Stop()

Types

type Cloud

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

func NewCloud

func NewCloud(orgID int, domain mysql.Domain, cfg config.CloudConfig, ctx context.Context) *Cloud

TODO 添加参数

func (*Cloud) GetBasicInfo

func (c *Cloud) GetBasicInfo() model.BasicInfo

func (*Cloud) GetDomainRefreshSignal

func (c *Cloud) GetDomainRefreshSignal() *queue.OverwriteQueue

func (*Cloud) GetKubernetesGatherTaskMap

func (c *Cloud) GetKubernetesGatherTaskMap() map[string]*KubernetesGatherTask

func (*Cloud) GetOrgID

func (c *Cloud) GetOrgID() int

func (*Cloud) GetResource

func (c *Cloud) GetResource() model.Resource

func (*Cloud) GetStatter

func (c *Cloud) GetStatter() statsd.StatsdStatter

func (*Cloud) GetSubDomainRefreshSignals

func (c *Cloud) GetSubDomainRefreshSignals() cmap.ConcurrentMap[string, *queue.OverwriteQueue]

func (*Cloud) Start

func (c *Cloud) Start()

func (*Cloud) Stop

func (c *Cloud) Stop()

func (*Cloud) UpdateBasicInfoName

func (c *Cloud) UpdateBasicInfoName(name string)

type KubernetesGatherTask

type KubernetesGatherTask struct {
	SubDomainConfig string // 附属容器集群配置字段config
	// contains filtered or unexported fields
}

func NewKubernetesGatherTask

func NewKubernetesGatherTask(
	ctx context.Context, db *mysql.DB, domain *mysql.Domain, subDomain *mysql.SubDomain, cfg config.CloudConfig, isSubDomain bool) *KubernetesGatherTask

func (*KubernetesGatherTask) GetBasicInfo

func (k *KubernetesGatherTask) GetBasicInfo() kmodel.KubernetesGatherBasicInfo

func (*KubernetesGatherTask) GetGatherCost

func (k *KubernetesGatherTask) GetGatherCost() float64

func (*KubernetesGatherTask) GetResource

func (k *KubernetesGatherTask) GetResource() kmodel.KubernetesGatherResource

func (*KubernetesGatherTask) PutRefreshSignal

func (k *KubernetesGatherTask) PutRefreshSignal(version int) error

func (*KubernetesGatherTask) Start

func (k *KubernetesGatherTask) Start(rSignal *queue.OverwriteQueue)

func (*KubernetesGatherTask) Stop

func (k *KubernetesGatherTask) Stop()