Help us shape the future of Go! Take the 2026 Go Developer Survey

runners

package
v0.0.38 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ForwardLogs

func ForwardLogs(r io.ReadCloser, ws ...io.Writer)

func WrapStart

func WrapStart(cmd *exec.Cmd, loggers ...shared.BaseLogger) error

func WrapStartDebug

func WrapStartDebug(cmd *exec.Cmd, logger *agents.AgentLogger) error

Types

type ContainerInstance

type ContainerInstance struct {
	ID    string
	Name  string
	Image string
	Host  string
	Port  int
}

type CreateDockerInput

type CreateDockerInput struct {
	DockerImage
	ApplicationEndpointInstance *network.ApplicationEndpointInstance
}

type DockerImage

type DockerImage struct {
	Image string
}

type DockerOption

type DockerOption func(option *Option)

func WithCmd

func WithCmd(cmd ...string) DockerOption

func WithEnvironmentVariable

func WithEnvironmentVariable(key, value string) DockerOption

func WithVolume

func WithVolume(source, target string) DockerOption

type DockerRunner

type DockerRunner struct {
	Containers    []*ContainerInstance
	AgentLogger   *agents.AgentLogger
	ServiceLogger *agents.ServiceLogger
	// contains filtered or unexported fields
}

func NewDockerRunner

func NewDockerRunner(ctx context.Context, serviceLogger *agents.ServiceLogger, agentLogger *agents.AgentLogger) (*DockerRunner, error)

NewDockerRunner creates a new docker runner

func (*DockerRunner) ContainerReady

func (r *DockerRunner) ContainerReady(name string) (bool, error)

func (*DockerRunner) CreateContainer

func (r *DockerRunner) CreateContainer(input CreateDockerInput, opts ...DockerOption) error

func (*DockerRunner) EnsureImage

func (r *DockerRunner) EnsureImage(imageName string) error

func (*DockerRunner) IP

func (*DockerRunner) Start

func (r *DockerRunner) Start() error

func (*DockerRunner) StartContainer

func (r *DockerRunner) StartContainer(c *ContainerInstance) error

func (*DockerRunner) Stop

func (r *DockerRunner) Stop() error

type Option

type Option struct {
	Cmd     []string
	Volumes []VolumeMount
	Envs    []string
}

type Runner

type Runner struct {
	Name  string
	Bin   string
	Dir   string
	Args  []string
	Envs  []string
	Debug bool

	ServiceLogger *agents.ServiceLogger
	AgentLogger   *agents.AgentLogger

	Wait bool

	Cmd *exec.Cmd
	// contains filtered or unexported fields
}

func (*Runner) Init

func (g *Runner) Init(ctx context.Context) error

func (*Runner) Kill

func (g *Runner) Kill() error

func (*Runner) Run

type VolumeMount

type VolumeMount struct {
	Source string
	Target string
}

Jump to

Keyboard shortcuts

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