Documentation
¶
Index ¶
- type Cloud
- func (c *Cloud) ClientTrigger() error
- 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) GetSubDomainResource(lcuuid string) model.Resource
- func (c *Cloud) Start()
- func (c *Cloud) Stop()
- func (c *Cloud) UpdateBasicInfoName(name string)
- type 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cloud ¶
type Cloud struct {
// contains filtered or unexported fields
}
func NewCloud ¶
func NewCloud(orgID int, domain mysqlmodel.Domain, cfg config.CloudConfig, ctx context.Context) *Cloud
TODO 添加参数
func (*Cloud) ClientTrigger ¶
func (*Cloud) GetBasicInfo ¶
func (*Cloud) GetDomainRefreshSignal ¶
func (c *Cloud) GetDomainRefreshSignal() *queue.OverwriteQueue
func (*Cloud) GetKubernetesGatherTaskMap ¶
func (c *Cloud) GetKubernetesGatherTaskMap() map[string]*KubernetesGatherTask
func (*Cloud) GetResource ¶
func (*Cloud) GetStatter ¶
func (c *Cloud) GetStatter() statsd.StatsdStatter
func (*Cloud) GetSubDomainRefreshSignals ¶
func (c *Cloud) GetSubDomainRefreshSignals() cmap.ConcurrentMap[string, *queue.OverwriteQueue]
func (*Cloud) GetSubDomainResource ¶
func (*Cloud) UpdateBasicInfoName ¶
type KubernetesGatherTask ¶
type KubernetesGatherTask struct {
SubDomainConfig string // 附属容器集群配置字段config
// contains filtered or unexported fields
}
func NewKubernetesGatherTask ¶
func NewKubernetesGatherTask( ctx context.Context, db *mysql.DB, domain *mysqlmodel.Domain, subDomain *mysqlmodel.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()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.