INNER CODE UNIT · Go

main

m3db/m3 · scripts/development/m3_consumer_service/main.go:22

func main() {
	log.Println("Starting M3 Aggregator Consumer Service...")

	// Listen address - this is where m3aggregator will send aggregated metrics
	listenAddr := "localhost:9000"
	if addr := os.Getenv("LISTEN_ADDR"); addr != "" {
		listenAddr = addr
	}

	// Create instrument options
	instrumentOpts := instrument.NewOptions()
	logger := instrumentOpts.Logger()

	// Create IO options
	ioOpts := xio.NewOptions()

	// Define our write function that will handle incoming metrics
	writeFn := func(

View source record →