Versions in this module Expand all Collapse all v1 v1.0.0 Dec 3, 2024 Changes in this version + const ContainerNamePrefix + const DefaultFactor + const DefaultJitter + const DefaultMaxAttempts + const DefaultMaxDelay + const DefaultMinRetryDelay + const MaxVirtualMachines + type ContainerParams struct + Args []string + Command []string + Env []corev1.EnvVar + Image string + ImagePullPolicy corev1.PullPolicy + Mounts []volumes.Mount + Name string + PodName string + PodNamespace string + PostStartAction *resource.ExecAction + Stdin bool + StdinOnce bool + TTY bool + WorkingDir string + type ContainersClient interface + AttachToContainer func(ctx context.Context, namespace, name, containerName string, ...) error + CreateContainer func(ctx context.Context, params ContainerParams) error + ExecInContainer func(ctx context.Context, namespace, name, containerName string, cmd []string, ...) error + GetContainerLogs func(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, error) + GetContainers func(ctx context.Context, podNs, podName string) ([]resource.Container, error) + GetContainersListResult func(ctx context.Context) (map[types.NamespacedName][]resource.Container, error) + IsContainerPresent func(ctx context.Context, podNs, podName, containerName string) bool + RemoveContainers func(ctx context.Context, podNs, podName string, gracePeriod int64) error + type DockerClient struct + func NewDockerClient(ctx context.Context, client *dockercl.Client, ...) (c *DockerClient, err error) + func (c *DockerClient) AttachToContainer(ctx context.Context, namespace, name, containerName string, ...) (err error) + func (c *DockerClient) CreateContainer(ctx context.Context, params ContainerParams) (err error) + func (c *DockerClient) ExecInContainer(ctx context.Context, namespace, name, containerName string, cmd []string, ...) (err error) + func (c *DockerClient) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, ...) (in io.ReadCloser, err error) + func (c *DockerClient) GetContainers(ctx context.Context, podNs, podName string) (containers []resource.Container, err error) + func (c *DockerClient) GetContainersListResult(ctx context.Context) (map[k8stypes.NamespacedName][]resource.Container, error) + func (c *DockerClient) IsContainerPresent(ctx context.Context, podNs, podName, containerName string) bool + func (c *DockerClient) RemoveContainers(ctx context.Context, podNs, podName string, gracePeriod int64) (err error) + type MacOSClient struct + func NewMacOSClient(ctx context.Context, eventRecorder event.EventRecorder, ...) *MacOSClient + func (c *MacOSClient) CreateVirtualMachine(ctx context.Context, params VirtualMachineParams) (err error) + func (c *MacOSClient) DeleteVirtualMachine(ctx context.Context, namespace string, name string, gracePeriod int64) (err error) + func (c *MacOSClient) ExecInVirtualMachine(ctx context.Context, namespace, name string, cmd []string, attach api.AttachIO) (err error) + func (c *MacOSClient) GetVirtualMachine(ctx context.Context, namespace string, name string) (i resource.MacOSVirtualMachine, err error) + func (c *MacOSClient) GetVirtualMachineListResult(ctx context.Context) (map[types.NamespacedName]resource.MacOSVirtualMachine, error) + type VirtualMachineParams struct + CPU uint + ContainerName string + Env []corev1.EnvVar + IgnoreImageCache bool + Image string + MemorySize uint64 + Mounts []volumes.Mount + Name string + Namespace string + PostStartAction *resource.ExecAction + UID string