summaryrefslogtreecommitdiff
path: root/internal/clients/connectors
diff options
context:
space:
mode:
Diffstat (limited to 'internal/clients/connectors')
-rw-r--r--internal/clients/connectors/serverless.go7
1 files changed, 6 insertions, 1 deletions
diff --git a/internal/clients/connectors/serverless.go b/internal/clients/connectors/serverless.go
index c7b5f62..7740aab 100644
--- a/internal/clients/connectors/serverless.go
+++ b/internal/clients/connectors/serverless.go
@@ -53,8 +53,13 @@ func (s *Serverless) Start(ctx context.Context, cancel context.CancelFunc, throt
func (s *Serverless) handle(ctx context.Context, cancel context.CancelFunc) error {
dlog.Client.Debug("Creating server handler for a serverless session")
+ user, err := user.New(s.userName, s.Server())
+ if err != nil {
+ return err
+ }
+
serverHandler := serverHandlers.NewServerHandler(
- user.New(s.userName, s.Server()),
+ user,
make(chan struct{}, config.Server.MaxConcurrentCats),
make(chan struct{}, config.Server.MaxConcurrentTails),
)