connector

package

v0.0.0-...-7c77b90 Latest Latest Go to latest Published: May 27, 2022 License: Apache-2.0 Imports: 22 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var IsTestKubeClient bool = false

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

func CloseAllClusterWatchers()

CloseAllClusterWatchers close all channels

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(clusterId string, id string, v *v1alpha1.ResourceBundleState)

HandleStatusUpdate for an application in a cluster

func StopClusterWatcher(clusterId string)

StopClusterWatcher stop watching a cluster

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

Connection is for a cluster

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

GetClient returns client for the cluster

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

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

GetStatusCR returns a status monitoring customer resource

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

Init Connection for an app context

func (c *Connection) RemoveClient()

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

StartClusterWatcher watches for CR configBytes - Kubectl file data