Documentation
¶
Index ¶
- Constants
- func NewEndpointPoolFromOptions(namespace string, name string, endpointSelector string, ...) (*datalayer.EndpointPool, error)
- type RunnableGroup
- type Runner
- func (r *Runner) Run(ctx context.Context) error
- func (r *Runner) WithCustomCollectors(collectors ...prometheus.Collector) *Runner
- func (r *Runner) WithExecutableName(exeName string) *Runner
- func (r *Runner) WithRequestControlConfig(requestControlConfig *requestcontrol.Config) *Runner
- func (r *Runner) WithSchedulerConfig(schedulerConfig *scheduling.SchedulerConfig) *Runner
Constants ¶
const ( LivenessCheckService = "liveness" ReadinessCheckService = "readiness" )
Variables ¶
This section is empty.
Functions ¶
func NewEndpointPoolFromOptions ¶
func NewEndpointPoolFromOptions( namespace string, name string, endpointSelector string, endpointTargetPorts []int, ) (*datalayer.EndpointPool, error)
NewEndpointPoolFromOptions constructs an EndpointPool from standalone options. This is shared between the production runner and standalone integration tests.
Types ¶
type RunnableGroup ¶
type RunnableGroup interface {
Add(name string, fn func(ctx context.Context) error)
Run(ctx context.Context) error
}
RunnableGroup collects named goroutines and starts them together under a shared context. The first non-nil error cancels the group; Run returns that error wrapped with the runnable name.
type Runner ¶
Runner is used to run epp with its plugins
func NewRunner ¶
func NewRunner() *Runner
NewRunner initializes a new EPP Runner and returns its pointer.
func NewTestRunnerSetup ¶
func NewTestRunnerSetup(ctx context.Context, cfg *rest.Config, opts *runserver.Options, mockDataSource fwkdl.DataSource) (*Runner, ctrl.Manager, datastore.Datastore, error)
NewTestRunnerSetup creates a setup runner dedicated for integration tests. When mockDataSource is non-nil, its plugin type is registered as a factory that returns the provided instance, so the YAML config can reference it by type name and the runner wires it into the endpoint factory automatically.
func (*Runner) WithCustomCollectors ¶
func (r *Runner) WithCustomCollectors(collectors ...prometheus.Collector) *Runner
func (*Runner) WithExecutableName ¶
WithExecutableName sets the name of the executable containing the runner. The name is used in the version log upon startup and is otherwise opaque.
func (*Runner) WithRequestControlConfig ¶
func (r *Runner) WithRequestControlConfig(requestControlConfig *requestcontrol.Config) *Runner
func (*Runner) WithSchedulerConfig ¶
func (r *Runner) WithSchedulerConfig(schedulerConfig *scheduling.SchedulerConfig) *Runner
Source Files