clusterinfo

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

const (
	ClusterEventListenerLimit = 10
	ClusterHookApiPath        = "/api/pipeline-clusters/actions/hook"
)

Functions

func DispatchClusterEvent

func DispatchClusterEvent(clusterEvent apistructs.ClusterEvent)

DispatchClusterEvent dispatch every cluster event to registered chan

func Initialize

func Initialize(bundle *bundle.Bundle)

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()