summaryrefslogtreecommitdiff
path: root/internal/clients/connectors/serverless.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2021-09-26 16:42:47 +0300
committerPaul Buetow <paul@buetow.org>2021-10-02 12:26:36 +0300
commitfcaa94c7453efa0d74e330128c0f5c2cde8f11b3 (patch)
tree1f686e5eeeb1b180cc14a3586f388f1a3492899c /internal/clients/connectors/serverless.go
parentfe3e68afd99d8ea246be52893730f987e138ec24 (diff)
refactor config reader - also looks in additional search paths for config file unless NONE is specified
Diffstat (limited to 'internal/clients/connectors/serverless.go')
-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),
)