container

package
v0.0.0-...-fbf1687 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ContainerClient

type ContainerClient interface {
	WriteFiles(ctx context.Context, containerID string, prepDir string, job *db.Job) error
	GetContainer(ctx context.Context) (*puddle.Resource[pool.Container], error)
	Execute(ctx context.Context, containerID string, command []string) (bool, string, error)
}

type ContainerExecutor

type ContainerExecutor struct {
	Queries   db.Store
	EnvConfig *config.EnvConfig
	WorkerId  int32
	Logger    *zerolog.Logger
	Tp        trace.TracerProvider
	Mp        metric.MeterProvider
	User      string
	Pool      *puddle.Pool[pool.Container]
}

func NewContainerExecutor

func NewContainerExecutor(ctx context.Context, env *config.EnvConfig, queries db.Store, workerId int32, tp trace.TracerProvider, mp metric.MeterProvider, logger *zerolog.Logger) (*ContainerExecutor, error)

func (*ContainerExecutor) Cleanup

func (ce *ContainerExecutor) Cleanup()

func (*ContainerExecutor) Execute

func (ce *ContainerExecutor) Execute(ctx context.Context, wg *concurrency.SafeWaitGroup, job *db.Job, logger zerolog.Logger)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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