Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + var ClusterHookApiPath = "/api/pipeline-clusters/actions/hook" + func GetClusterInfoByName(clusterName string) (apistructs.ClusterInfo, error) + type ClusterInfoCache struct + func NewClusterInfoCache() *ClusterInfoCache + func (c *ClusterInfoCache) DeleteClusterInfo(name string) + func (c *ClusterInfoCache) GetAllClusters() []apistructs.ClusterInfo + func (c *ClusterInfoCache) GetClusterInfoByName(name string) (apistructs.ClusterInfo, bool) + func (c *ClusterInfoCache) UpdateClusterInfo(clusterInfo apistructs.ClusterInfo) + type ClusterInfoNotifier struct + func NewClusterInfoNotifier() *ClusterInfoNotifier + func (c *ClusterInfoNotifier) NotifyClusterEvent(event apistructs.ClusterEvent) + func (c *ClusterInfoNotifier) NotifyRefreshEvent() + func (c *ClusterInfoNotifier) RegisterClusterEvent() <-chan apistructs.ClusterEvent + func (c *ClusterInfoNotifier) RegisterRefreshEvent() <-chan struct{} + type Interface interface + BatchUpdateAndDispatchRefresh func() error + DispatchClusterEvent func(apistructs.ClusterEvent) + GetClusterInfoByName func(string) (apistructs.ClusterInfo, error) + ListAllClusterInfos func() ([]apistructs.ClusterInfo, error) + ListEdgeClusterInfos func() ([]apistructs.ClusterInfo, error) + RegisterClusterEvent func() <-chan apistructs.ClusterEvent + RegisterRefreshEvent func() <-chan struct{} + type Notifier interface + NotifyClusterEvent func(event apistructs.ClusterEvent) + NotifyRefreshEvent func() + RegisterClusterEvent func() <-chan apistructs.ClusterEvent + RegisterRefreshEvent func() <-chan struct{}
Go to main page