Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pool ¶
type Pool interface {
observer.Publisher[PoolEvent]
IsAvailableRunner() bool
RequestRunner() (Runner, error)
ReturnRunner(Runner)
}
func ProvideTaskRunnerPool ¶
func ProvideTaskRunnerPool(config PoolConfig) (Pool, error)
type PoolConfig ¶
type PoolConfig struct {
NumberOfInitialTaskRunner int
}
type Runner ¶
type Runner interface {
GetID() string
Run(ctx containerlibcontext.Context, handlerFunc facade.ContainerHandlerFunction, task model.Task) error
}
func ProvideRunner ¶
Click to show internal directories.
Click to hide internal directories.