Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContainerClient ¶
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)
Click to show internal directories.
Click to hide internal directories.