Skip to content

Commit 967d28b

Browse files
committed
api,adaptation,stub: let plugin know configured timeouts.
Let plugins know the configured registration and request processing timeout. Signed-off-by: Krisztian Litkey <krisztian.litkey@intel.com>
1 parent a3dd1a4 commit 967d28b

File tree

5 files changed

+639
-552
lines changed

5 files changed

+639
-552
lines changed

pkg/adaptation/plugin.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,9 +37,9 @@ import (
3737

3838
const (
3939
// DefaultPluginRegistrationTimeout is the default timeout for plugin registration.
40-
DefaultPluginRegistrationTimeout = 5 * time.Second
40+
DefaultPluginRegistrationTimeout = api.DefaultPluginRegistrationTimeout
4141
// DefaultPluginRequestTimeout is the default timeout for plugins to handle a request.
42-
DefaultPluginRequestTimeout = 2 * time.Second
42+
DefaultPluginRequestTimeout = api.DefaultPluginRequestTimeout
4343
)
4444

4545
var (
@@ -384,9 +384,11 @@ func (p *plugin) configure(ctx context.Context, name, version, config string) er
384384
defer cancel()
385385

386386
rpl, err := p.stub.Configure(ctx, &ConfigureRequest{
387-
Config: config,
388-
RuntimeName: name,
389-
RuntimeVersion: version,
387+
Config: config,
388+
RuntimeName: name,
389+
RuntimeVersion: version,
390+
RegistrationTimeout: getPluginRegistrationTimeout().Milliseconds(),
391+
RequestTimeout: getPluginRequestTimeout().Milliseconds(),
390392
})
391393
if err != nil {
392394
return fmt.Errorf("failed to configure plugin: %w", err)

0 commit comments

Comments
 (0)