Skip to content
Snippets Groups Projects
Select Git revision
  • 33746391a4779268bcebf692183bb68ec1c7b6e7
  • without_tipselection default
  • develop protected
  • fix/grafana-local-dashboard
  • wasp
  • fix/dashboard-explorer-freeze
  • master
  • feat/timerqueue
  • test/sync_debug_and_650
  • feat/sync_revamp_inv
  • wip/sync
  • tool/db-recovery
  • portcheck/fix
  • fix/synchronization
  • feat/new-dashboard-analysis
  • feat/refactored-analysis-dashboard
  • feat/new-analysis-dashboard
  • test/demo-prometheus-fpc
  • prometheus_metrics
  • wip/analysis-server
  • merge/fpc-test-value-transfer
  • v0.2.2
  • v0.2.1
  • v0.2.0
  • v0.1.3
  • v0.1.2
  • v0.1.1
  • v0.1.0
28 results

drng.go

Blame
  • remotelogger.go 688 B
    package remotelog
    
    import (
    	"encoding/json"
    	"fmt"
    	"net"
    )
    
    // RemoteLoggerConn is a wrapper for a connection to our RemoteLog server.
    type RemoteLoggerConn struct {
    	conn net.Conn
    }
    
    func newRemoteLoggerConn(address string) (*RemoteLoggerConn, error) {
    	c, err := net.Dial("udp", address)
    	if err != nil {
    		return nil, fmt.Errorf("could not create UDP socket to '%s'. %v", address, err)
    	}
    
    	return &RemoteLoggerConn{conn: c}, nil
    }
    
    // Send sends a message on the RemoteLoggers connection.
    func (r *RemoteLoggerConn) Send(msg interface{}) error {
    	b, err := json.Marshal(msg)
    	if err != nil {
    		return err
    	}
    	_, err = r.conn.Write(b)
    	if err != nil {
    		return err
    	}
    
    	return nil
    }