cluster

Documentation

Index

• func FillDefaults(cluster *api.Cluster)
• func ListTypeMeta() api.TypeMeta
• func NewDockerMachine(ctx context.Context, client dockerClient, ...) (*dockerMachine, error)
• func TypeMeta() api.TypeMeta
• type Admin
• type Controller
  • func DefaultController(iostreams genericclioptions.IOStreams) (*Controller, error)
  • func (c *Controller) Apply(ctx context.Context, desired *api.Cluster) (*api.Cluster, error)
  • func (c *Controller) Current(ctx context.Context) (*api.Cluster, error)
  • func (c *Controller) Delete(ctx context.Context, name string) error
  • func (c *Controller) Get(ctx context.Context, name string) (*api.Cluster, error)
  • func (c *Controller) List(ctx context.Context, options ListOptions) (*api.ClusterList, error)
• type DockerDesktopClient
  • func NewDockerDesktopClient() (DockerDesktopClient, error)
  • func (c DockerDesktopClient) Open(ctx context.Context) error
  • func (c DockerDesktopClient) Quit(ctx context.Context) error
  • func (c DockerDesktopClient) ResetCluster(ctx context.Context) error
  • func (c DockerDesktopClient) SetSettingValue(ctx context.Context, key, newValue string) error
  • func (c DockerDesktopClient) SettingsValues(ctx context.Context) (interface{}, error)
• type HTTPClient
• type ListOptions
• type Machine

Functions

func FillDefaults

func FillDefaults(cluster *api.Cluster)

func ListTypeMeta

func ListTypeMeta() api.TypeMeta

func NewDockerMachine

func NewDockerMachine(ctx context.Context, client dockerClient, iostreams genericclioptions.IOStreams) (*dockerMachine, error)

func TypeMeta

func TypeMeta() api.TypeMeta

Types

type Admin

type Admin interface {
	EnsureInstalled(ctx context.Context) error
	Create(ctx context.Context, desired *api.Cluster, registry *api.Registry) error

	// Infers the LocalRegistryHosting that this admin will try to configure.
	LocalRegistryHosting(ctx context.Context, desired *api.Cluster, registry *api.Registry) (*localregistry.LocalRegistryHostingV1, error)

	Delete(ctx context.Context, config *api.Cluster) error
}

A cluster admin provides the basic start/stop functionality of a cluster, independent of the configuration of the machine it's running on.

type Controller

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

func DefaultController

func DefaultController(iostreams genericclioptions.IOStreams) (*Controller, error)

func (*Controller) Apply

func (c *Controller) Apply(ctx context.Context, desired *api.Cluster) (*api.Cluster, error)

Compare the desired cluster against the existing cluster, and reconcile the two to match.

func (*Controller) Current

func (c *Controller) Current(ctx context.Context) (*api.Cluster, error)

func (*Controller) Delete

func (c *Controller) Delete(ctx context.Context, name string) error

func (*Controller) Get

func (c *Controller) Get(ctx context.Context, name string) (*api.Cluster, error)

func (*Controller) List

func (c *Controller) List(ctx context.Context, options ListOptions) (*api.ClusterList, error)

type DockerDesktopClient

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

Uses the DockerDesktop GUI+Backend protocols to control DockerDesktop.

There isn't an off-the-shelf library or documented protocol we can use for this, so we do the best we can.

func NewDockerDesktopClient

func NewDockerDesktopClient() (DockerDesktopClient, error)

func (DockerDesktopClient) Open

func (c DockerDesktopClient) Open(ctx context.Context) error

func (DockerDesktopClient) Quit

func (c DockerDesktopClient) Quit(ctx context.Context) error

func (DockerDesktopClient) ResetCluster

func (c DockerDesktopClient) ResetCluster(ctx context.Context) error

func (DockerDesktopClient) SetSettingValue

func (c DockerDesktopClient) SetSettingValue(ctx context.Context, key, newValue string) error

func (DockerDesktopClient) SettingsValues

func (c DockerDesktopClient) SettingsValues(ctx context.Context) (interface{}, error)

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type ListOptions

type ListOptions struct {
	FieldSelector string
}

type Machine

type Machine interface {
	CPUs(ctx context.Context) (int, error)
	EnsureExists(ctx context.Context) error
	Restart(ctx context.Context, desired, existing *api.Cluster) error
}