refactor plugin startup - bootstrap rate limiter table from plugin manager startup

Author: kaidaguerre

go.mod

@@ -9,7 +9,7 @@ require (
 	github.com/hashicorp/go-version v1.6.0 // indirect
 	github.com/turbot/go-kit v0.8.0-rc.0
 	github.com/turbot/steampipe v0.21.0-alpha.4
-	github.com/turbot/steampipe-plugin-sdk/v5 v5.6.0-dev.22
+	github.com/turbot/steampipe-plugin-sdk/v5 v5.6.0-rc.21
 	go.opentelemetry.io/otel v1.16.0
 	google.golang.org/protobuf v1.31.0
 )
@@ -183,4 +183,6 @@ replace (
 	github.com/deislabs/oras => github.com/oras-project/oras v0.9.0
 	github.com/docker/distribution => github.com/distribution/distribution v2.7.1+incompatible
 	github.com/docker/docker => github.com/moby/moby v20.10.17+incompatible
+	github.com/turbot/steampipe => /Users/kai/Dev/github/turbot/steampipe
+	github.com/turbot/steampipe-plugin-sdk/v5 => /Users/kai/Dev/github/turbot/steampipe-plugin-sdk
 )

go.sum

@@ -978,10 +978,6 @@ github.com/tmc/grpc-websocket-proxy v0.0.0-20171017195756-830351dc03c6/go.mod h1
 github.com/tombuildsstuff/giovanni v0.15.1/go.mod h1:0TZugJPEtqzPlMpuJHYfXY6Dq2uLPrXf98D2XQSxNbA=
 github.com/turbot/go-kit v0.8.0-rc.0 h1:Vj1w5TmZWwdSwBTcOq6FKVlQQ+XwCd27BZVPZ9m1hT0=
 github.com/turbot/go-kit v0.8.0-rc.0/go.mod h1:JkVKhR5XHK86aXY4WzB9Lr0jdnrsafjVh4yJA8ZS3Ck=
-github.com/turbot/steampipe v0.21.0-alpha.4 h1:xIzlfycDBux0/ltHeMk7ihFzWHy0oWyTt+YDAFnmRPs=
-github.com/turbot/steampipe v0.21.0-alpha.4/go.mod h1:ZFYpAGggT7cVGCXho2BkPpBFyFoNcd+gugjaIwoDzBM=
-github.com/turbot/steampipe-plugin-sdk/v5 v5.6.0-dev.22 h1:LFInIEjFtrZH4nrbLOW9MiG0ELlNFEd+2fLJeiEEzec=
-github.com/turbot/steampipe-plugin-sdk/v5 v5.6.0-dev.22/go.mod h1:Np0X1Oj3JNTcuf9JmvWwHrCqc0UB4iJLmUlOkRwMCWw=
 github.com/ugorji/go v0.0.0-20180813092308-00b869d2f4a5/go.mod h1:hnLbHMwcvSihnDhEfx2/BzKp2xb0Y+ErdfYcrs9tkJQ=
 github.com/ulikunitz/xz v0.5.8/go.mod h1:nbz6k7qbPmH4IRqmfOplQw/tblSgqTqBwxkY0oWt/14=
 github.com/ulikunitz/xz v0.5.10 h1:t92gobL9l3HE202wg3rlk19F6X+JOxl9BBrCCMYEYd8=

hub/connection_factory.go

@@ -2,6 +2,7 @@ package hub
 
 import (
 	"fmt"
+	"github.com/turbot/steampipe/pkg/pluginmanager"
 	"github.com/turbot/steampipe/pkg/utils"
 	"log"
 	"strings"
@@ -97,7 +98,13 @@ func (f *connectionFactory) createConnectionPlugin(pluginFQN string, connectionN
 
 	log.Printf("[TRACE] createConnectionPlugin plugin %s, connection %s, config: %s\n", utils.PluginFQNToSchemaName(pluginFQN), connectionName, connection.Config)
 
-	connectionPlugins, res := steampipeconfig.CreateConnectionPlugins([]string{connection.Name})
+	// get plugin manager
+	pluginManager, err := pluginmanager.GetPluginManager()
+	if err != nil {
+		return nil, err
+	}
+
+	connectionPlugins, res := steampipeconfig.CreateConnectionPlugins(pluginManager, []string{connection.Name})
 	if res.Error != nil {
 		return nil, res.Error
 	}