statsd

// First create a client config. Here is a simple config that sends one
// stat per packet (for compatibility).
config := &ClientConfig{
	Address: "127.0.0.1:8125",
	Prefix:  "test-client",
}

// Now create the client
client, err := NewClientWithConfig(config)

// and handle any initialization errors
if err != nil {
	log.Fatal(err)
}

// make sure to clean up
defer client.Close()

// Send a stat
err = client.Inc("stat1", 42, 1.0)
// handle any errors
if err != nil {
	log.Printf("Error sending metric: %+v", err)
}

Output:

// This one is for a buffered client, which sends multiple stats in one
// packet, is recommended when your server supports it (better performance).
config := &ClientConfig{
	Address:     "127.0.0.1:8125",
	Prefix:      "test-client",
	UseBuffered: true,
	// interval to force flush buffer. full buffers will flush on their own,
	// but for data not frequently sent, a max threshold is useful
	FlushInterval: 300 * time.Millisecond,
}

// Now create the client
client, err := NewClientWithConfig(config)

// and handle any initialization errors
if err != nil {
	log.Fatal(err)
}

// make sure to close to clean up when done, to avoid leaks.
defer client.Close()

// Send a stat
err = client.Inc("stat1", 42, 1.0)
// handle any errors
if err != nil {
	log.Printf("Error sending metric: %+v", err)
}

Output:

// first create a client
client, err := NewBufferedClient("127.0.0.1:8125", "test-client", 10*time.Millisecond, 0)
// handle any errors
if err != nil {
	log.Fatal(err)
}
// make sure to close to clean up when done, to avoid leaks.
defer client.Close()

// Send a stat
err = client.Inc("stat1", 42, 1.0)
// handle any errors
if err != nil {
	log.Printf("Error sending metric: %+v", err)
}

Output:

// first create a client
client, err := NewClient("127.0.0.1:8125", "test-client")
// handle any errors
if err != nil {
	log.Fatal(err)
}
// make sure to close to clean up when done, to avoid leaks.
defer client.Close()

// Send a stat
err = client.Inc("stat1", 42, 1.0)
// handle any errors
if err != nil {
	log.Printf("Error sending metric: %+v", err)
}

Output:

// use interface so we can sub noop client if needed
var client Statter
var err error

// First create a client config. Here is a simple config that sends one
// stat per packet (for compatibility).
config := &ClientConfig{
	Address: "not-resolvable:8125",
	Prefix:  "test-client",
}

// Now create the client
client, err = NewClientWithConfig(config)

// Let us say real client creation fails, but you don't care enough about
// stats that you don't want your program to run. Just log an error and
// make a NoopClient instead
if err != nil {
	log.Println("Remote endpoint did not resolve. Disabling stats", err)
}
// at this point, client is a nil *Client. This will work like a noop client.
// It is ok to call close when client is nil. It will be a noop too.
defer client.Close()

// Sicne client is nil, this is a noop.
err = client.Inc("stat1", 42, 1.0)

Output:

// First create a client config. Here is a simple config that sends one
// stat per packet (for compatibility).
config := &ClientConfig{
	Address: "127.0.0.1:8125",
	Prefix:  "test-client",
}

// Now create the client
client, err := NewClientWithConfig(config)
// handle any errors
if err != nil {
	log.Fatal(err)
}
// make sure to close to clean up when done, to avoid leaks.
defer client.Close()

// create a substatter
subclient := client.NewSubStatter("sub")
// send a stat
err = subclient.Inc("stat1", 42, 1.0)
// handle any errors
if err != nil {
	log.Printf("Error sending metric: %+v", err)
}

Output: