clusters

type Connection ¶

type Connection struct {
	// contains filtered or unexported fields
}

Connection is a connection to a workload cluster. A connection can be shared between multiple controllers.

func NewConnection(client kubernetes.Interface, nodeAttacher func(ni corev1_informers.NodeInformer)) *Connection

func (conn *Connection) Shutdown()

func (conn *Connection) Start(ctx context.Context)

type Connections ¶

type Connections struct {
	// contains filtered or unexported fields
}

Connections is a collection of connections to workload clusters. It providers wrappers for getting and patching nodes in workload clusters that automatically recreate connections when the authentication expires.

func NewConnections(client client.Client, contextFactory func() context.Context) *Connections

func (cc *Connections) AddConn(ctx context.Context, log logr.Logger, cluster types.NamespacedName, conn *Connection)

func (cc *Connections) DeleteConn(log logr.Logger, cluster types.NamespacedName)

func (cc *Connections) GetConn(cluster types.NamespacedName) *Connection

func (cc *Connections) GetNode(ctx context.Context, params GetNodeParams) (*corev1.Node, error)

func (cc *Connections) PatchNode(ctx context.Context, params PatchNodeParams) error

func (cc *Connections) ReauthConn(ctx context.Context, params ReauthParams) error

type GetNodeParams ¶

type GetNodeParams struct {
	Log     logr.Logger
	Cluster types.NamespacedName
	Name    string
}

type PatchNodeParams ¶

type PatchNodeParams struct {
	Log        logr.Logger
	Cluster    types.NamespacedName
	Name       string
	MergePatch []byte
}

type ReauthParams ¶

type ReauthParams struct {
	Cluster types.NamespacedName
	Log     logr.Logger
}