cluster

Documentation

Index

• Constants
• Variables
• func DockerClientFromEnv(ctx context.Context, env docker.Env) (docker.Client, error)
• func KubernetesClientFromEnv(ctx context.Context, contextOverride k8s.KubeContextOverride, ...) (k8s.Client, error)
• 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 DockerClientFactory
  • func FakeDockerClientOrError(client docker.Client, err error) DockerClientFactory
• type DockerClientFunc
  • func (d DockerClientFunc) New(ctx context.Context, env docker.Env) (docker.Client, error)
• type KubernetesClientFactory
  • func FakeKubernetesClientOrError(client k8s.Client, err error) KubernetesClientFactory
• type KubernetesClientFunc
  • func (k KubernetesClientFunc) New(ctx context.Context, contextOverride k8s.KubeContextOverride, ...) (k8s.Client, 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)

Constants

const ArchUnknown string = "unknown"

Variables

var WireSet = wire.NewSet(
	NewConnectionManager,
	wire.Bind(new(cluster.ClientProvider), new(*ConnectionManager)),
	wire.InterfaceValue(new(KubernetesClientFactory), KubernetesClientFunc(KubernetesClientFromEnv)),
	wire.InterfaceValue(new(DockerClientFactory), DockerClientFunc(DockerClientFromEnv)),
)

Functions

func DockerClientFromEnv

func DockerClientFromEnv(ctx context.Context, env docker.Env) (docker.Client, error)

func KubernetesClientFromEnv

func KubernetesClientFromEnv(ctx context.Context, contextOverride k8s.KubeContextOverride, namespaceOverride k8s.NamespaceOverride) (k8s.Client, error)

KubernetesClientFromEnv creates a client based on the machine environment.

The Kubernetes Client APIs are really defined for automatic dependency injection. (as opposed to the Kubernetes convention of nested factory structs.)

If you have to edit the below, it's easier to let wire generate the factory code for you, then adapt it here.

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 DockerClientFactory

type DockerClientFactory interface {
	New(ctx context.Context, env docker.Env) (docker.Client, error)
}

func FakeDockerClientOrError

func FakeDockerClientOrError(client docker.Client, err error) DockerClientFactory

type DockerClientFunc

type DockerClientFunc func(ctx context.Context, env docker.Env) (docker.Client, error)

func (DockerClientFunc) New

func (d DockerClientFunc) New(ctx context.Context, env docker.Env) (docker.Client, error)

type KubernetesClientFactory

type KubernetesClientFactory interface {
	New(ctx context.Context, contextOverride k8s.KubeContextOverride, namespaceOverride k8s.NamespaceOverride) (k8s.Client, error)
}

func FakeKubernetesClientOrError

func FakeKubernetesClientOrError(client k8s.Client, err error) KubernetesClientFactory

type KubernetesClientFunc

type KubernetesClientFunc func(ctx context.Context, contextOverride k8s.KubeContextOverride, namespaceOverride k8s.NamespaceOverride) (k8s.Client, error)

func (KubernetesClientFunc) New

func (k KubernetesClientFunc) New(ctx context.Context, contextOverride k8s.KubeContextOverride, namespaceOverride k8s.NamespaceOverride) (k8s.Client, error)

type Reconciler

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

func NewReconciler

func NewReconciler(
	globalCtx context.Context,
	ctrlClient ctrlclient.Client,
	store store.RStore,
	clock clockwork.Clock,
	connManager *ConnectionManager,
	localDockerEnv docker.LocalEnv,
	dockerClientFactory DockerClientFactory,
	k8sClientFactory KubernetesClientFactory,
	wsList *server.WebsocketList,
	base xdg.Base,
	apiServerName model.APIServerName,
) *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)