Documentation ¶
Index ¶
- Constants
- func DispatchClusterEvent(clusterEvent apistructs.ClusterEvent)
- func Initialize(bundle *bundle.Bundle)
- func ListAllClusters() ([]apistructs.ClusterInfo, error)
- func RegisterClusterEvent() (<-chan apistructs.ClusterEvent, error)
- func RegisterClusterHook() error
- func RegisterRefreshChan() <-chan struct{}
- func TriggerManualRefresh()
Constants ¶
View Source
const ( ClusterEventListenerLimit = 10 ClusterHookApiPath = "/api/pipeline-clusters/actions/hook" )
Variables ¶
This section is empty.
Functions ¶
func DispatchClusterEvent ¶
func DispatchClusterEvent(clusterEvent apistructs.ClusterEvent)
DispatchClusterEvent dispatch every cluster event to registered chan
func Initialize ¶
func ListAllClusters ¶
func ListAllClusters() ([]apistructs.ClusterInfo, error)
func RegisterClusterEvent ¶
func RegisterClusterEvent() (<-chan apistructs.ClusterEvent, error)
func RegisterClusterHook ¶
func RegisterClusterHook() error
RegisterClusterHook register cluster hook in eventbox
func RegisterRefreshChan ¶
func RegisterRefreshChan() <-chan struct{}
RegisterRefreshChan return channel for manual trigger refresh executor only for scheduler task manager
func TriggerManualRefresh ¶
func TriggerManualRefresh()
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.