Add remote write logging.
parent
02349e6f16
commit
607c352412
|
@ -133,7 +133,12 @@ func (s *Service) handleConn(conn net.Conn) {
|
|||
switch typ {
|
||||
case writeShardRequestMessage:
|
||||
err := s.processWriteShardRequest(buf)
|
||||
if err != nil {
|
||||
s.Logger.Printf("process write shard error: %s", err)
|
||||
}
|
||||
s.writeShardResponse(conn, err)
|
||||
default:
|
||||
s.Logger.Printf("cluster service message type not found: %d", typ)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue