Skip to content
This repository has been archived by the owner on Nov 3, 2023. It is now read-only.

Commit

Permalink
helm: support for cloud lb (#238)
Browse files Browse the repository at this point in the history
Signed-off-by: Miguel Ángel Ortuño <[email protected]>
  • Loading branch information
ortuman authored Jun 6, 2022
1 parent e86a615 commit e2eedb1
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 10 deletions.
2 changes: 0 additions & 2 deletions pkg/c2s/router.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,6 @@ func (r *c2sRouter) Register(stm stream.C2S) error {
if err := r.local.Register(stm); err != nil {
return err
}
level.Info(r.logger).Log("msg", "registered C2S stream", "id", stm.ID())
return nil
}

Expand All @@ -113,7 +112,6 @@ func (r *c2sRouter) Unregister(stm stream.C2S) error {
if err := r.local.Unregister(stm); err != nil {
return err
}
level.Info(r.logger).Log("msg", "unregistered C2S stream", "id", stm.ID())
return nil
}

Expand Down
4 changes: 0 additions & 4 deletions pkg/c2s/socket_listener.go
Original file line number Diff line number Diff line change
Expand Up @@ -187,10 +187,6 @@ func (l *SocketListener) Start(ctx context.Context) error {
if err != nil {
continue
}
level.Info(l.logger).Log("msg", "received C2S incoming connection",
"bind_addr", l.getAddress(),
"remote_address", conn.RemoteAddr().String(),
)

go l.connHandlerFn(conn)
}
Expand Down
4 changes: 0 additions & 4 deletions pkg/s2s/socket_listener.go
Original file line number Diff line number Diff line change
Expand Up @@ -147,10 +147,6 @@ func (l *SocketListener) Start(ctx context.Context) error {
if err != nil {
continue
}
level.Info(l.logger).Log("msg", "received S2S incoming connection",
"bind_addr", l.getAddress(),
"remote_address", conn.RemoteAddr().String(),
)

go l.connHandlerFn(conn)
}
Expand Down

0 comments on commit e2eedb1

Please sign in to comment.