api,adaptation,stub: let plugin know configured timeouts.

Let plugins know the configured registration and request processing timeout. Signed-off-by: Krisztian Litkey <[email protected]>
containerd · Sep 20, 2024 · 1207e68 · 1207e68
1 parent 2450545
commit 1207e68
Show file tree

Hide file tree

Showing 5 changed files with 639 additions and 552 deletions.
diff --git a/pkg/adaptation/plugin.go b/pkg/adaptation/plugin.go
@@ -37,9 +37,9 @@ import (
 
 const (
 	// DefaultPluginRegistrationTimeout is the default timeout for plugin registration.
-	DefaultPluginRegistrationTimeout = 5 * time.Second
+	DefaultPluginRegistrationTimeout = api.DefaultPluginRegistrationTimeout
 	// DefaultPluginRequestTimeout is the default timeout for plugins to handle a request.
-	DefaultPluginRequestTimeout = 2 * time.Second
+	DefaultPluginRequestTimeout = api.DefaultPluginRequestTimeout
 )
 
 var (
@@ -384,9 +384,11 @@ func (p *plugin) configure(ctx context.Context, name, version, config string) er
 	defer cancel()
 
 	rpl, err := p.stub.Configure(ctx, &ConfigureRequest{
-		Config:         config,
-		RuntimeName:    name,
-		RuntimeVersion: version,
+		Config:              config,
+		RuntimeName:         name,
+		RuntimeVersion:      version,
+		RegistrationTimeout: getPluginRegistrationTimeout().Milliseconds(),
+		RequestTimeout:      getPluginRequestTimeout().Milliseconds(),
 	})
 	if err != nil {
 		return fmt.Errorf("failed to configure plugin: %w", err)