connector

Documentation

Index

• Variables
• func CloseAllClusterWatchers()
• func GetKubeConfig(clustername string, level string, namespace string) ([]byte, error)
• func HandleStatusUpdate(clusterId string, id string, v *v1alpha1.ResourceBundleState)
• func StopClusterWatcher(clusterId string)
• type Connection
  • func (c *Connection) GetClient(cluster string, level string, namespace string) (*kubeclient.Client, error)
  • func (c *Connection) GetClientInternal(cluster string, level string, namespace string) (types.ClientProvider, error)
  • func (c *Connection) GetStatusCR(label string) ([]byte, error)
  • func (c *Connection) Init(id interface{}) error
  • func (c *Connection) RemoveClient()
  • func (c *Connection) StartClusterWatcher(clusterId string) error

Variables

var IsTestKubeClient bool = false

IsTestKubeClient .. global variable used during unit-tests to check whether a fake kube client object has to be instantiated

Functions

func CloseAllClusterWatchers

func CloseAllClusterWatchers()

CloseAllClusterWatchers close all channels

func GetKubeConfig

func GetKubeConfig(clustername string, level string, namespace string) ([]byte, error)

GetKubeConfig uses the connectivity client to get the kubeconfig based on the name of the clustername.

func HandleStatusUpdate

func HandleStatusUpdate(clusterId string, id string, v *v1alpha1.ResourceBundleState)

HandleStatusUpdate for an application in a cluster

func StopClusterWatcher

func StopClusterWatcher(clusterId string)

StopClusterWatcher stop watching a cluster

Types

type Connection

type Connection struct {
	Cid     string
	Clients map[string]*kubeclient.Client
	sync.Mutex
}

Connection is for a cluster

func (*Connection) GetClient

func (c *Connection) GetClient(cluster string, level string, namespace string) (*kubeclient.Client, error)

GetClient returns client for the cluster

func (*Connection) GetClientInternal

func (c *Connection) GetClientInternal(cluster string, level string, namespace string) (types.ClientProvider, error)

func (*Connection) GetStatusCR

func (c *Connection) GetStatusCR(label string) ([]byte, error)

GetStatusCR returns a status monitoring customer resource

func (*Connection) Init

func (c *Connection) Init(id interface{}) error

Init Connection for an app context

func (*Connection) RemoveClient

func (c *Connection) RemoveClient()

func (*Connection) StartClusterWatcher

func (c *Connection) StartClusterWatcher(clusterId string) error

StartClusterWatcher watches for CR configBytes - Kubectl file data