cluster

Documentation

Index

• func Close(client clientset.Interface, in *api.Integration, tenant string) (err error)
• func EnsureServiceAccount(clusterClient *kubernetes.Clientset, namespace string) error
• func GetSchedulableClusters(client clientset.Interface, tenant string) ([]api.Integration, error)
• func Open(client clientset.Interface, in *api.Integration, tenantName string) (err error)
• func UpdateClusterIntegration(client clientset.Interface, tenant, name string, in *api.Integration) error

Functions

func Close

func Close(client clientset.Interface, in *api.Integration, tenant string) (err error)

Close closes a cluster

func EnsureServiceAccount

func EnsureServiceAccount(clusterClient *kubernetes.Clientset, namespace string) error

EnsureServiceAccount ensures default service account for stage pod created. Coordinator container in stage pod needs certain permission to pods and pods/log.

func GetSchedulableClusters

func GetSchedulableClusters(client clientset.Interface, tenant string) ([]api.Integration, error)

GetSchedulableClusters gets all clusters which are used to perform workload for this tenant.

func Open

func Open(client clientset.Interface, in *api.Integration, tenantName string) (err error)

Open opens cluster to run workload.

func UpdateClusterIntegration

func UpdateClusterIntegration(client clientset.Interface, tenant, name string, in *api.Integration) error

UpdateClusterIntegration ...