Refactored logging to use custom logger and set default logger.
This commit is contained in:
@@ -90,13 +90,6 @@ func (r *RELPHandler) connectToRELPServer() (net.Conn, error) {
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
conn, err = net.Dial("tcp", net.JoinHostPort(host, port))
|
||||
if err != nil {
|
||||
if relpDebug {
|
||||
log.Printf("Failed to connect to RELP server at %s: %v", net.JoinHostPort(host, port), err)
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
if relpDebug {
|
||||
log.Printf("Successfully connected to RELP server at %s", net.JoinHostPort(host, port))
|
||||
}
|
||||
@@ -166,7 +159,7 @@ func (r *RELPHandler) processFailedEvents() {
|
||||
func (r *RELPHandler) sendEventToRELPServer(event Event) error {
|
||||
jsonData, err := json.Marshal(event)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error marshaling event: %v", err)
|
||||
return fmt.Errorf("error marshaling event: %v", err)
|
||||
}
|
||||
_, err = r.conn.Write(jsonData)
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user