clusterinfo

Documentation

Index

• Constants
• func DispatchClusterEvent(js jsonstore.JsonStore, clusterEvent apistructs.ClusterEvent) error
• func Initialize(bundle *bundle.Bundle)
• func ListAllClusters() ([]apistructs.ClusterInfo, error)
• func RegisterClusterHook() error
• func RegisterRefreshChan() <-chan struct{}
• func TriggerManualRefresh()

Constants

const (
	ClusterHookApiPath  = "/api/pipeline-clusters/actions/hook"
	ClusterEventEtcdKey = "/devops/pipeline/cluster-info/events"
)

Functions

func DispatchClusterEvent

func DispatchClusterEvent(js jsonstore.JsonStore, clusterEvent apistructs.ClusterEvent) error

DispatchClusterEvent dispatch every cluster event to registered chan

func Initialize

func Initialize(bundle *bundle.Bundle)

func ListAllClusters

func ListAllClusters() ([]apistructs.ClusterInfo, 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()