clients

Oct 10, 2022

Changes in this version

+ const StorageDriverAUFS

+ const StorageDriverBTRFS

+ const StorageDriverDeviceMapper

+ const StorageDriverFuse

+ const StorageDriverOverlay

+ const StorageDriverOverlay2

+ const StorageDriverVFS

+ const StorageDriverZFS

type ContainerTasks

+ EngineInfo func() *EngineInfo

type Docker

+ Info func(ctx context.Context) (types.Info, error)

type DockerTasks

+ func (d *DockerTasks) EngineInfo() *EngineInfo

+ type EngineInfo struct

+ EngineType string

+ StorageDriver string

+ type MockContainerTasks struct

+ func (d *MockContainerTasks) AttachNetwork(network, containerid string, aliases []string, ipaddress string) error

+ func (d *MockContainerTasks) ContainerLogs(id string, stdOut, stdErr bool) (io.ReadCloser, error)

+ func (d *MockContainerTasks) CopyFileToContainer(id, src, dst string) error

+ func (d *MockContainerTasks) CopyFilesToVolume(volume string, files []string, path string, force bool) ([]string, error)

+ func (d *MockContainerTasks) CopyFromContainer(id, src, dst string) error

+ func (d *MockContainerTasks) CopyLocalDockerImagesToVolume(images []string, volume string, force bool) ([]string, error)

+ func (d *MockContainerTasks) CreateShell(id string, command []string, stdin io.ReadCloser, stdout io.Writer, ...) error

+ func (d *MockContainerTasks) DetachNetwork(network, containerid string) error

+ func (d *MockContainerTasks) EngineInfo() *EngineInfo

+ func (d *MockContainerTasks) ExecuteCommand(id string, command []string, env []string, workingDirectory string, ...) error

+ func (d *MockContainerTasks) ListNetworks(id string) []config.NetworkAttachment

+ func (m *MockContainerTasks) BuildContainer(config *config.Container, force bool) (string, error)

+ func (m *MockContainerTasks) ContainerInfo(id string) (interface{}, error)

+ func (m *MockContainerTasks) CreateContainer(c *config.Container) (id string, err error)

+ func (m *MockContainerTasks) CreateVolume(name string) (id string, err error)

+ func (m *MockContainerTasks) FindContainerIDs(name string, typeName config.ResourceType) ([]string, error)

+ func (m *MockContainerTasks) PullImage(i config.Image, f bool) error

+ func (m *MockContainerTasks) RemoveContainer(id string, force bool) error

+ func (m *MockContainerTasks) RemoveVolume(name string) error

+ func (m *MockContainerTasks) SetForcePull(f bool)

Feb 7, 2022

Changes in this version

type Helm

+ UpsertChartRepository func(name, url string) error

type HelmImpl

+ func (h *HelmImpl) UpsertChartRepository(name, url string) error

Feb 4, 2022

Changes in this version

+ const EngineNotFound

Jan 29, 2022

Changes in this version

+ const EngineTypeDocker

+ const EngineTypePodman

type Connector

+ ListServices func() ([]*shipyard.Service, error)

type ConnectorImpl

+ func (c *ConnectorImpl) ListServices() ([]*shipyard.Service, error)

type ConnectorMock

+ func (m *ConnectorMock) ListServices() ([]*shipyard.Service, error)

type Docker

+ ServerVersion func(ctx context.Context) (types.Version, error)

type DockerTasks

+ EngineType string

Aug 13, 2021

Changes in this version

type Kubernetes

+ GetPodLogs func(ctx context.Context, podName, nameSpace string) (io.ReadCloser, error)

type KubernetesImpl

+ func (k *KubernetesImpl) GetPodLogs(ctx context.Context, podName, nameSpace string) (io.ReadCloser, error)

type MockKubernetes

+ func (m *MockKubernetes) GetPodLogs(ctx context.Context, podName, nameSpace string) (io.ReadCloser, error)

+ type TarGz struct

+ func (tg *TarGz) Compress(buf io.Writer, options *TarGzOptions, src ...string) error

+ func (tg *TarGz) Uncompress(src io.Reader, dst string) error

+ type TarGzOptions struct

+ OmitRoot bool

May 7, 2021

Changes in this version

+ type MockKubernetes struct

+ func (m *MockKubernetes) Apply(files []string, waitUntilReady bool) error

+ func (m *MockKubernetes) Delete(files []string) error

+ func (m *MockKubernetes) GetPods(selector string) (*v1.PodList, error)

+ func (m *MockKubernetes) HealthCheckPods(selectors []string, timeout time.Duration) error

+ func (m *MockKubernetes) SetConfig(kubeconfig string) (Kubernetes, error)

Mar 17, 2021

Changes in this version

type ContainerTasks

+ CopyFilesToVolume func(volume string, files []string, path string, force bool) ([]string, error)

+ CopyLocalDockerImagesToVolume func(images []string, volume string, force bool) ([]string, error)

type DockerTasks

+ func (d *DockerTasks) CopyFilesToVolume(volumeID string, filenames []string, path string, force bool) ([]string, error)

+ func (d *DockerTasks) CopyLocalDockerImagesToVolume(images []string, volume string, force bool) ([]string, error)

Mar 12, 2021

Changes in this version

type ConnectorOptions

+ APIBind string

Feb 24, 2021

Changes in this version

type Command

+ Kill func(pid int) error

type CommandConfig

+ LogFilePath string

+ RunInBackground bool

+ Timeout time.Duration

type CommandImpl

+ func (c *CommandImpl) Kill(pid int) error

type CommandMock

+ func (m *CommandMock) Kill(pid int) error

Feb 18, 2021

Changes in this version

+ var ErrorCommandTimeout = fmt.Errorf("Command timed out before completing")

+ type CertBundle struct

+ LeafCertPath string

+ LeafKeyPath string

+ RootCertPath string

+ RootKeyPath string

+ type Connector interface

+ ExposeService func(name string, port int, remoteAddr string, destAddr string, direction string) (string, error)

+ GenerateLeafCert func(privateKey, rootCA string, hosts, ips []string, dir string) (*CertBundle, error)

+ GenerateLocalCertBundle func(out string) (*CertBundle, error)

+ GetLocalCertBundle func(dir string) (*CertBundle, error)

+ IsRunning func() bool

+ RemoveService func(id string) error

+ Start func(*CertBundle) error

+ Stop func() error

+ func NewConnector(opts ConnectorOptions) Connector

+ type ConnectorImpl struct

+ func (c *ConnectorImpl) ExposeService(name string, port int, remoteAddr string, destAddr string, direction string) (string, error)

+ func (c *ConnectorImpl) GenerateLeafCert(rootKey, rootCA string, host, ips []string, dir string) (*CertBundle, error)

+ func (c *ConnectorImpl) GenerateLocalCertBundle(out string) (*CertBundle, error)

+ func (c *ConnectorImpl) GetLocalCertBundle(dir string) (*CertBundle, error)

+ func (c *ConnectorImpl) IsRunning() bool

+ func (c *ConnectorImpl) RemoveService(id string) error

+ func (c *ConnectorImpl) Start(cb *CertBundle) error

+ func (c *ConnectorImpl) Stop() error

+ type ConnectorMock struct

+ func (m *ConnectorMock) ExposeService(name string, port int, remoteAddr string, destAddr string, direction string) (string, error)

+ func (m *ConnectorMock) GenerateLeafCert(privateKey, rootCA string, hosts, ips []string, dir string) (*CertBundle, error)

+ func (m *ConnectorMock) GenerateLocalCertBundle(out string) (*CertBundle, error)

+ func (m *ConnectorMock) GetLocalCertBundle(out string) (*CertBundle, error)

+ func (m *ConnectorMock) IsRunning() bool

+ func (m *ConnectorMock) RemoveService(id string) error

+ func (m *ConnectorMock) Start(cb *CertBundle) error

+ func (m *ConnectorMock) Stop() error

+ type ConnectorOptions struct

+ BinaryPath string

+ GrpcBind string

+ HTTPBind string

+ LogDirectory string

+ LogLevel string

+ PidFile string

+ func DefaultConnectorOptions() ConnectorOptions

Jan 13, 2021

Changes in this version

type ContainerTasks

+ CopyFileToContainer func(id, src, dst string) error

type DockerTasks

+ func (d *DockerTasks) CopyFileToContainer(containerID, filename, path string) error

Nov 6, 2020

Changes in this version

type ClusterConfig

+ LocalAddress string

+ RemoteAPIPort int

+ RemoteAddress string

+ type Context string

+ const LocalContext

+ const RemoteContext

type Nomad

+ Endpoints func(job, group, task string) ([]map[string]string, error)

+ JobRunning func(job string) (bool, error)

type NomadImpl

+ func (n *NomadImpl) Endpoints(job, group, task string) ([]map[string]string, error)

+ func (n *NomadImpl) JobRunning(job string) (bool, error)

Oct 20, 2020

Changes in this version

+ type CommandConfig struct

+ Args []string

+ Command string

+ Env []string

+ WorkingDirectory string

+ type CommandMock struct

+ func (m *CommandMock) Execute(config CommandConfig) error

Aug 26, 2020

Changes in this version

+ type ClusterConfig struct

+ APIPort int

+ Address string

+ ConnectorPort int

+ NodeCount int

+ SSL bool

+ func (n *ClusterConfig) APIAddress() string

+ func (n *ClusterConfig) ConnectorAddress() string

+ func (n *ClusterConfig) Load(file string) error

+ func (n *ClusterConfig) Save(file string) error

Aug 6, 2020

Changes in this version

type ContainerTasks

+ AttachNetwork func(network, containerid string) error

+ BuildContainer func(config *config.Container, force bool) (string, error)

+ ContainerInfo func(id string) (interface{}, error)

+ ListNetworks func(id string) []config.NetworkAttachment

type Docker

+ ContainerInspect func(ctx context.Context, containerID string) (types.ContainerJSON, error)

+ ImageBuild func(ctx context.Context, buildContext io.Reader, options types.ImageBuildOptions) (types.ImageBuildResponse, error)

type DockerTasks

+ func (d *DockerTasks) AttachNetwork(network, containerid string) error

+ func (d *DockerTasks) BuildContainer(config *config.Container, force bool) (string, error)

+ func (d *DockerTasks) ContainerInfo(id string) (interface{}, error)

+ func (d *DockerTasks) ListNetworks(id string) []config.NetworkAttachment

type System

+ PromptInput func(in io.Reader, out io.Writer, message string) string

type SystemImpl

+ func (b *SystemImpl) PromptInput(in io.Reader, out io.Writer, message string) string

Apr 26, 2020

Changes in this version

type Docker

+ VolumeList func(ctx context.Context, filter filters.Args) (volumetypes.VolumeListOKBody, error)

Apr 21, 2020

Changes in this version

+ const ImageTypeDocker

type Docker

+ ImageRemove func(ctx context.Context, imageID string, options types.ImageRemoveOptions) ([]types.ImageDeleteResponseItem, error)

+ type ImageFileLog struct

+ func NewImageFileLog(file string) *ImageFileLog

+ func (i *ImageFileLog) Clear() error

+ func (i *ImageFileLog) Log(name, t string) error

+ func (i *ImageFileLog) Read(t string) ([]string, error)

+ type ImageLog interface

+ Clear func() error

+ Log func(string, string) error

+ Read func(string) ([]string, error)

type System

+ CheckVersion func(string) (string, bool)

type SystemImpl

+ func (b *SystemImpl) CheckVersion(current string) (string, bool)

Apr 19, 2020

Changes in this version

+ const Green

+ const Red

+ const Yellow

+ type Command interface

+ Execute func(string, ...string) error

+ func NewCommand(maxCommandTime time.Duration, l hclog.Logger) Command

+ type CommandImpl struct

+ func (c *CommandImpl) Execute(command string, args ...string) error

+ type ContainerTasks interface

+ ContainerLogs func(id string, stdOut, stdErr bool) (io.ReadCloser, error)

+ CopyFromContainer func(id, src, dst string) error

+ CopyLocalDockerImageToVolume func(images []string, volume string) (string, error)

+ CreateContainer func(*config.Container) (id string, err error)

+ CreateShell func(id string, command []string, stdin io.ReadCloser, stdout io.Writer, ...) error

+ CreateVolume func(name string) (id string, err error)

+ DetachNetwork func(network, containerid string) error

+ ExecuteCommand func(id string, command []string, writer io.Writer) error

+ FindContainerIDs func(name string, typeName config.ResourceType) ([]string, error)

+ PullImage func(image config.Image, force bool) error

+ RemoveContainer func(id string) error

+ RemoveVolume func(name string) error

+ SetForcePull func(bool)

+ type Docker interface

+ ContainerCreate func(ctx context.Context, config *container.Config, ...) (container.ContainerCreateCreatedBody, error)

+ ContainerExecAttach func(ctx context.Context, execID string, config types.ExecStartCheck) (types.HijackedResponse, error)

+ ContainerExecCreate func(ctx context.Context, container string, config types.ExecConfig) (types.IDResponse, error)

+ ContainerExecInspect func(ctx context.Context, execID string) (types.ContainerExecInspect, error)

+ ContainerExecResize func(ctx context.Context, execID string, config types.ResizeOptions) error

+ ContainerExecStart func(ctx context.Context, execID string, config types.ExecStartCheck) error

+ ContainerList func(ctx context.Context, options types.ContainerListOptions) ([]types.Container, error)

+ ContainerLogs func(ctx context.Context, container string, options types.ContainerLogsOptions) (io.ReadCloser, error)

+ ContainerRemove func(ctx context.Context, containerID string, options types.ContainerRemoveOptions) error

+ ContainerStart func(context.Context, string, types.ContainerStartOptions) error

+ ContainerStop func(ctx context.Context, containerID string, timeout *time.Duration) error

+ CopyFromContainer func(ctx context.Context, containerID, srcPath string) (io.ReadCloser, types.ContainerPathStat, error)

+ CopyToContainer func(ctx context.Context, container, path string, content io.Reader, ...) error

+ ImageList func(ctx context.Context, options types.ImageListOptions) ([]types.ImageSummary, error)

+ ImagePull func(ctx context.Context, refStr string, options types.ImagePullOptions) (io.ReadCloser, error)

+ ImageSave func(ctx context.Context, imageIDs []string) (io.ReadCloser, error)

+ NetworkConnect func(ctx context.Context, networkID, containerID string, ...) error

+ NetworkCreate func(ctx context.Context, name string, options types.NetworkCreate) (types.NetworkCreateResponse, error)

+ NetworkDisconnect func(ctx context.Context, networkID, containerID string, force bool) error

+ NetworkList func(ctx context.Context, options types.NetworkListOptions) ([]types.NetworkResource, error)

+ NetworkRemove func(ctx context.Context, networkID string) error

+ VolumeCreate func(ctx context.Context, options volumetypes.VolumeCreateBody) (types.Volume, error)

+ VolumeRemove func(ctx context.Context, volumeID string, force bool) error

+ func NewDocker() (Docker, error)

+ type DockerTasks struct

+ func NewDockerTasks(c Docker, l hclog.Logger) *DockerTasks

+ func (d *DockerTasks) ContainerLogs(id string, stdOut, stdErr bool) (io.ReadCloser, error)

+ func (d *DockerTasks) CopyFromContainer(id, src, dst string) error

+ func (d *DockerTasks) CopyLocalDockerImageToVolume(images []string, volume string) (string, error)

+ func (d *DockerTasks) CreateContainer(c *config.Container) (string, error)

+ func (d *DockerTasks) CreateShell(id string, command []string, stdin io.ReadCloser, stdout io.Writer, ...) error

+ func (d *DockerTasks) CreateVolume(name string) (string, error)

+ func (d *DockerTasks) DetachNetwork(network, containerid string) error

+ func (d *DockerTasks) ExecuteCommand(id string, command []string, writer io.Writer) error

+ func (d *DockerTasks) FindContainerIDs(containerName string, typeName config.ResourceType) ([]string, error)

+ func (d *DockerTasks) PullImage(image config.Image, force bool) error

+ func (d *DockerTasks) RemoveContainer(id string) error

+ func (d *DockerTasks) RemoveVolume(name string) error

+ func (d *DockerTasks) SetForcePull(force bool)

+ type Getter interface

+ Get func(uri, dst string) error

+ SetForce func(force bool)

+ type GetterImpl struct

+ func NewGetter(force bool) *GetterImpl

+ func (g *GetterImpl) Get(uri, dst string) error

+ func (g *GetterImpl) SetForce(force bool)

+ type HTTP interface

+ Do func(r *http.Request) (*http.Response, error)

+ HealthCheckHTTP func(uri string, timeout time.Duration) error

+ func NewHTTP(backoff time.Duration, l hclog.Logger) HTTP

+ type HTTPImpl struct

+ func (h *HTTPImpl) Do(r *http.Request) (*http.Response, error)

+ func (h *HTTPImpl) HealthCheckHTTP(address string, timeout time.Duration) error

+ type Helm interface

+ Create func(kubeConfig, name, chartPath, valuesPath string, valuesString map[string]string) error

+ Destroy func(kubeConfif, name string) error

+ func NewHelm(l hclog.Logger) Helm

+ type HelmImpl struct

+ func (h *HelmImpl) Create(kubeConfig, name, chartPath, valuesPath string, valuesString map[string]string) error

+ func (h *HelmImpl) Destroy(kubeConfig, name string) error

+ type Kubernetes interface

+ Apply func(files []string, waitUntilReady bool) error

+ Delete func(files []string) error

+ GetPods func(string) (*v1.PodList, error)

+ HealthCheckPods func(selectors []string, timeout time.Duration) error

+ SetConfig func(string) error

+ func NewKubernetes(t time.Duration, l hclog.Logger) Kubernetes

+ type KubernetesImpl struct

+ func (k *KubernetesImpl) Apply(files []string, waitUntilReady bool) error

+ func (k *KubernetesImpl) Delete(files []string) error

+ func (k *KubernetesImpl) GetPods(selector string) (*v1.PodList, error)

+ func (k *KubernetesImpl) HealthCheckPods(selectors []string, timeout time.Duration) error

+ func (k *KubernetesImpl) SetConfig(kubeconfig string) error

+ type Nomad interface

+ Create func(files []string) error

+ HealthCheckAPI func(time.Duration) error

+ JobStatus func(job string) (string, error)

+ ParseJob func(file string) ([]byte, error)

+ SetConfig func(string) error

+ Stop func(files []string) error

+ func NewNomad(c HTTP, backoff time.Duration, l hclog.Logger) Nomad

+ type NomadConfig struct

+ Location string

+ NodeCount int

+ func (n *NomadConfig) Load(file string) error

+ func (n *NomadConfig) Save(file string) error

+ type NomadImpl struct

+ func (n *NomadImpl) Create(files []string) error

+ func (n *NomadImpl) HealthCheckAPI(timeout time.Duration) error

+ func (n *NomadImpl) JobStatus(job string) (string, error)

+ func (n *NomadImpl) ParseJob(file string) ([]byte, error)

+ func (n *NomadImpl) SetConfig(nomadconfig string) error

+ func (n *NomadImpl) Stop(files []string) error

+ type System interface

+ OpenBrowser func(string) error

+ Preflight func() (string, error)

+ type SystemImpl struct

+ func (b *SystemImpl) OpenBrowser(uri string) error

+ func (b *SystemImpl) Preflight() (string, error)