Versions in this module Expand all Collapse all v0 v0.1.0 Sep 12, 2023 Changes in this version + var ErrNoMappedPort = errors.New("no mapped port found") + type BuildRContainerSpec struct + BinariesDir string + Capabilities Capabilities + Content map[string]string + ExtraBinaries []string + ID string + Image string + ModuleName string + Mounts []mount.Mount + Privileged bool + RepoRoot string + User string + type Capabilities struct + Add []string + Drop []string + type Client interface + type Container interface + CopyFileFromContainer func(ctx context.Context, path string, f CopyContainerFileHandler) error + ID func() string + MappedPort func(ctx context.Context, port nat.Port) (hostIP, hostPort string, err error) + NetworkID func() string + Shutdown func(ctx context.Context) error + type ContainerFileCopier interface + CopyFromContainer func(ctx context.Context, containerID, srcPath string) (io.ReadCloser, types.ContainerPathStat, error) + type ContainerProber struct + func NewContainerProbe(logger *slog.Logger, containerID string, probe Probe, inspector Inspector) *ContainerProber + func (p *ContainerProber) WaitReady(ctx context.Context) error + type ContainerSpec struct + AutoRemove bool + Capabilities Capabilities + Cmd []string + Entrypoint []string + Env map[string]string + ExposedPorts []string + Image string + Mounts []mount.Mount + Privileged bool + User string + WorkingDir string + func (s *ContainerSpec) WorkDir() string + type CopyContainerFileHandler func(header *tar.Header, reader io.Reader) error + type GrpcHealthProbe struct + func NewGRPCHealthProbe(baseUrl string) GrpcHealthProbe + func (g GrpcHealthProbe) Execute(ctx context.Context) (ready chan bool, errs chan error) + type Inspector interface + ContainerInspect func(ctx context.Context, containerID string) (types.ContainerJSON, error) + type Orchestrator struct + func NewOrchestrator(ctx context.Context, cli *client.Client, ignorer *ignore.Ignorer) (*Orchestrator, error) + func (o *Orchestrator) BuildRContainer(ctx context.Context, spec *BuildRContainerSpec) (con Container, baseUrl string, err error) + func (o *Orchestrator) ShutdownContainer(ctx context.Context, con Container) error + type Probe interface + Execute func(ctx context.Context) (ready chan bool, errs chan error) + type Shutdowner interface + ShutdownContainer func(ctx context.Context, container Container) error