cluster

Documentation

Index

• Constants
• Variables
• type ConnectionManager
  • func NewConnectionManager() *ConnectionManager
  • func (k *ConnectionManager) GetComposeDockerClient(key types.NamespacedName) (docker.Client, error)
  • func (k *ConnectionManager) GetK8sClient(clusterKey types.NamespacedName) (k8s.Client, metav1.MicroTime, error)
• type Reconciler
  • func NewReconciler(globalCtx context.Context, ctrlClient ctrlclient.Client, store store.RStore, ...) *Reconciler
  • func (r *Reconciler) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)
  • func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *Reconciler) SetFakeClientsForTesting(k8sClient k8s.Client, dockerClient docker.Client)

Constants

const ArchUnknown string = "unknown"

Variables

var WireSet = wire.NewSet(
	NewConnectionManager,
	wire.Bind(new(cluster.ClientProvider), new(*ConnectionManager)),
)

Types

type ConnectionManager

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

func NewConnectionManager

func NewConnectionManager() *ConnectionManager

func (*ConnectionManager) GetComposeDockerClient

func (k *ConnectionManager) GetComposeDockerClient(key types.NamespacedName) (docker.Client, error)

GetComposeDockerClient gets the Docker client for the instance that Docker Compose is deploying to.

This is not currently exposed by the ClientCache interface as Docker Compose logic has not been migrated to the apiserver.

func (*ConnectionManager) GetK8sClient

func (k *ConnectionManager) GetK8sClient(clusterKey types.NamespacedName) (k8s.Client, metav1.MicroTime, error)

type Reconciler

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

func NewReconciler

func NewReconciler(globalCtx context.Context, ctrlClient ctrlclient.Client, store store.RStore, localDockerEnv docker.LocalEnv, connManager *ConnectionManager) *Reconciler

func (*Reconciler) CreateBuilder

func (r *Reconciler) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*Reconciler) SetFakeClientsForTesting

func (r *Reconciler) SetFakeClientsForTesting(k8sClient k8s.Client, dockerClient docker.Client)