operation

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 25, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RegistryContainerName = "topo-registry"
	DefaultRegistryPort   = "12737"
)

Variables

This section is empty.

Functions

func NewRunRegistry

func NewRunRegistry(port string) operation.Sequence

func ParseDigestFromPushOutput

func ParseDigestFromPushOutput(output string) (string, error)

Types

type ContainerExistsPredicate

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

func NewContainerExistsPredicate

func NewContainerExistsPredicate(host ssh.Destination, containerName string) *ContainerExistsPredicate

func (*ContainerExistsPredicate) Eval

func (p *ContainerExistsPredicate) Eval() bool

type Docker

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

func NewDocker

func NewDocker(description string, h ssh.Destination, args []string) *Docker

func NewDockerPull

func NewDockerPull(host ssh.Destination, image string) *Docker

func NewDockerRun

func NewDockerRun(host ssh.Destination, image string, container string, dockerArgs []string) *Docker

func NewDockerStart

func NewDockerStart(host ssh.Destination, container string) *Docker

func (*Docker) Description

func (d *Docker) Description() string

func (*Docker) DryRun

func (d *Docker) DryRun(output io.Writer) error

func (*Docker) Run

func (d *Docker) Run(cmdOutput io.Writer) error

type DockerCompose

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

func NewDockerCompose

func NewDockerCompose(description string, composeFile string, h ssh.Destination, args []string) *DockerCompose

func NewDockerComposeBuild

func NewDockerComposeBuild(composeFile string, h ssh.Destination) *DockerCompose

func NewDockerComposePull

func NewDockerComposePull(composeFile string, h ssh.Destination) *DockerCompose

func NewDockerComposeStop

func NewDockerComposeStop(composeFile string, h ssh.Destination) *DockerCompose

func NewDockerComposeUp

func NewDockerComposeUp(composeFile string, h ssh.Destination, mode RecreateMode) *DockerCompose

func (*DockerCompose) Description

func (dc *DockerCompose) Description() string

func (*DockerCompose) DryRun

func (dc *DockerCompose) DryRun(output io.Writer) error

func (*DockerCompose) Run

func (dc *DockerCompose) Run(cmdOutput io.Writer) error

type DockerComposePipeTransfer

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

func NewDockerComposePipeTransfer

func NewDockerComposePipeTransfer(composeFile string, source, dest ssh.Destination) *DockerComposePipeTransfer

func (*DockerComposePipeTransfer) Description

func (t *DockerComposePipeTransfer) Description() string

func (*DockerComposePipeTransfer) DryRun

func (t *DockerComposePipeTransfer) DryRun(output io.Writer) error

func (*DockerComposePipeTransfer) Run

func (t *DockerComposePipeTransfer) Run(cmdOutput io.Writer) error

type RecreateMode

type RecreateMode int
const (
	RecreateModeDefault RecreateMode = iota
	RecreateModeForce
	RecreateModeNone
)

type RegistryRunWrapper

type RegistryRunWrapper struct {
	*Docker
}

func NewRegistryRunWrapper

func NewRegistryRunWrapper(d *Docker) *RegistryRunWrapper

func (*RegistryRunWrapper) Run

func (r *RegistryRunWrapper) Run(w io.Writer) error

type RegistryTransfer

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

func NewRegistryTransfer

func NewRegistryTransfer(composeFile string, sourceHost, dest ssh.Destination, port string) *RegistryTransfer

func (*RegistryTransfer) Description

func (r *RegistryTransfer) Description() string

func (*RegistryTransfer) DryRun

func (r *RegistryTransfer) DryRun(w io.Writer) error

func (*RegistryTransfer) Run

func (r *RegistryTransfer) Run(w io.Writer) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL