Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProductionBackgroundScheduler ¶
func NewProductionBackgroundScheduler(ctx context.Context, bounds auxreq.SchedulerConfig) *auxreq.BackgroundScheduler
NewProductionBackgroundScheduler creates the process-lifetime bounded pool with generic scheduler bounds. Bounds come from the initial configuration and remain immutable across reload.
Types ¶
type GenerationExecutorRunner ¶
type GenerationExecutorRunner struct {
// contains filtered or unexported fields
}
GenerationExecutorRunner closes the scheduler/executor construction cycle.
func NewGenerationExecutorRunner ¶
func NewGenerationExecutorRunner() *GenerationExecutorRunner
func (*GenerationExecutorRunner) Bind ¶
func (r *GenerationExecutorRunner) Bind(exec *runtime.Executor)
func (*GenerationExecutorRunner) Execute ¶
func (r *GenerationExecutorRunner) Execute(ctx context.Context, call *lipapi.Call) (lipapi.EventStream, error)
Source Files
Click to show internal directories.
Click to hide internal directories.