service

func ClusterByURL ¶

func ClusterByURL(clusters map[string]cluster.Cluster, url string) *cluster.Cluster

func Clusters ¶

func Clusters(clusters map[string]cluster.Cluster) []cluster.Cluster

Clusters converts the given cluster map to an array slice

func NewCache ¶

func NewCache(config clusterConfig, options ...rest.HTTPClientOption) cluster.ClusterCache

func NewClusterService ¶

func NewClusterService(context servicecontext.ServiceContext, config clusterServiceConfig) service.ClusterService

NewClusterService creates a new cluster service

func Start ¶

func Start(ctx context.Context, factory service.ClusterCacheFactory, options ...rest.HTTPClientOption) (bool, error)

Start initializes the default Cluster cache if it's not initialized already Cache initialization loads the list of clusters from the cluster management service and starts regular cache refresher