(ctx context.Context, req pluginapi.SchedulerPickRequest)
| 352 | } |
| 353 | |
| 354 | func (a *rpcPluginAdapter) Pick(ctx context.Context, req pluginapi.SchedulerPickRequest) (pluginapi.SchedulerPickResponse, error) { |
| 355 | return callPlugin[pluginapi.SchedulerPickResponse](ctx, a.client, pluginabi.MethodSchedulerPick, req) |
| 356 | } |
| 357 | |
| 358 | func (a *rpcPluginAdapter) RouteModel(ctx context.Context, req pluginapi.ModelRouteRequest) (pluginapi.ModelRouteResponse, error) { |
| 359 | callbackID, closeCallback := a.openHostCallbackContext(ctx) |
nothing calls this directly
no test coverage detected