falcon test

1.go

package main

import (
	"fmt"
	"time"

	"github.com/open-falcon/agent/g"
	"github.com/open-falcon/common/model"
)

func main() {
	t := g.SingleConnRpcClient{
		RpcServer: "10.1.201.45:8433",
		Timeout:   1000 * time.Millisecond,
	}
	var resp model.TransferResponse

	c := time.Tick(30 * time.Second)
	for now := range c {
		metrics := []*model.MetricValue{
			&model.MetricValue{
				Endpoint:  "test-Endpoint",
				Metric:    "cpu",
				Value:     1001,
				Step:      30,
				Type:      "GAUGE",
				Tags:      "test=a",
				Timestamp: now.Unix(),
			},
		}
		fmt.Println(metrics)
		err := t.Call("Transfer.Update", metrics, &resp)
		if err != nil {
			fmt.Println("call Transfer.Update fail", err)
		}
		fmt.Println(&resp)
	}
}