Skip to content

Commit

Permalink
remove debug messages.
Browse files Browse the repository at this point in the history
  • Loading branch information
tjholm committed Sep 18, 2024
1 parent 61f9ebf commit 8f164c2
Show file tree
Hide file tree
Showing 6 changed files with 5 additions and 18 deletions.
3 changes: 0 additions & 3 deletions .golangci.yml
Original file line number Diff line number Diff line change
@@ -1,8 +1,5 @@
run:
timeout: "5m"
skip-files:
- tools/tools.go
- doc.go

linters:
disable-all: true
Expand Down
4 changes: 1 addition & 3 deletions nitric/api_workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ package nitric
import (
"context"
errorsstd "errors"
"fmt"
"io"

"google.golang.org/grpc"
Expand Down Expand Up @@ -73,8 +72,7 @@ func (a *apiWorker) Start(ctx context.Context) error {

return nil
} else if err == nil && resp.GetRegistrationResponse() != nil {
// Function connected with Nitric server
fmt.Println("Function connected with Nitric server")
// Do nothing
} else if err == nil && resp.GetHttpRequest() != nil {
ctx = httpx.NewCtx(resp)

Expand Down
4 changes: 1 addition & 3 deletions nitric/bucket_workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ package nitric
import (
"context"
errorsstd "errors"
"fmt"
"io"

"google.golang.org/grpc"
Expand Down Expand Up @@ -70,8 +69,7 @@ func (b *bucketEventWorker) Start(ctx context.Context) error {

return nil
} else if err == nil && resp.GetRegistrationResponse() != nil {
// Blob Notification has connected with Nitric server
fmt.Println("BlobEventWorker connected with Nitric server")
// Do nothing
} else if err == nil && resp.GetBlobEventRequest() != nil {
ctx = storage.NewCtx(resp)
ctx, err = b.middleware(ctx, dummyHandler)
Expand Down
4 changes: 1 addition & 3 deletions nitric/schedule_workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ package nitric
import (
"context"
errorsstd "errors"
"fmt"
"io"

"google.golang.org/grpc"
Expand Down Expand Up @@ -70,8 +69,7 @@ func (i *scheduleWorker) Start(ctx context.Context) error {

return nil
} else if err == nil && resp.GetRegistrationResponse() != nil {
// Interval worker has connected with Nitric server
fmt.Println("IntervalWorker connected with Nitric server")
// Do nothing
} else if err == nil && resp.GetIntervalRequest() != nil {
ctx = schedules.NewCtx(resp)
ctx, err = i.middleware(ctx, dummyHandler)
Expand Down
4 changes: 1 addition & 3 deletions nitric/topic_workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ package nitric

import (
"context"
"fmt"
"io"

"google.golang.org/grpc"
Expand Down Expand Up @@ -71,8 +70,7 @@ func (s *subscriptionWorker) Start(ctx context.Context) error {

return nil
} else if err == nil && resp.GetRegistrationResponse() != nil {
// Subscription worker has connected with Nitric server
fmt.Println("SubscriptionWorker connected with Nitric server")
// Do nothing
} else if err == nil && resp.GetMessageRequest() != nil {
ctx = topics.NewCtx(resp)
ctx, err = s.middleware(ctx, dummyHandler)
Expand Down
4 changes: 1 addition & 3 deletions nitric/websocket_workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ package nitric
import (
"context"
errorsstd "errors"
"fmt"
"io"

"google.golang.org/grpc"
Expand Down Expand Up @@ -70,8 +69,7 @@ func (w *websocketWorker) Start(ctx context.Context) error {

return nil
} else if err == nil && resp.GetRegistrationResponse() != nil {
// Blob Notification has connected with Nitric server
fmt.Println("WebsocketWorker connected with Nitric server")
// Do nothing
} else if err == nil && resp.GetWebsocketEventRequest() != nil {
ctx = websockets.NewCtx(resp)
ctx, err = w.middleware(ctx, dummyHandler)
Expand Down

0 comments on commit 8f164c2

Please sign in to comment.