Skip to content

Commit

Permalink
Merge pull request #98 from utilitywarehouse/upd-logs
Browse files Browse the repository at this point in the history
Lower OnStream logs down to Debug level
  • Loading branch information
DTLP authored Aug 16, 2023
2 parents 3d3bd9c + c877ad2 commit 1b4916a
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions xds/snapshotter.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,16 +119,16 @@ func (s *Snapshotter) SnapEndpoints(endpointStore XdsEndpointStore) error {
}

func (s *Snapshotter) OnStreamOpen(ctx context.Context, id int64, typ string) error {
log.Logger.Info("OnStreamOpen", "id", id, "type", typ)
log.Logger.Debug("OnStreamOpen", "id", id, "type", typ)
return nil
}

func (s *Snapshotter) OnStreamClosed(id int64, node *core.Node) {
log.Logger.Info("OnStreamClosed", "id", id, "node", node)
log.Logger.Debug("OnStreamClosed", "id", id, "node", node)
}

func (s *Snapshotter) OnStreamRequest(id int64, r *discovery.DiscoveryRequest) error {
log.Logger.Info("OnStreamRequest",
log.Logger.Debug("OnStreamRequest",
"id", id,
"received", r.GetTypeUrl(),
"node", r.GetNode().GetId(),
Expand All @@ -140,7 +140,7 @@ func (s *Snapshotter) OnStreamRequest(id int64, r *discovery.DiscoveryRequest) e
return nil
}
func (s *Snapshotter) OnStreamResponse(ctx context.Context, id int64, req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse) {
log.Logger.Info("OnStreamResponse",
log.Logger.Debug("OnStreamResponse",
"id", id,
"type", resp.GetTypeUrl(),
"version", resp.GetVersionInfo(),
Expand Down

0 comments on commit 1b4916a

Please sign in to comment.