yats.git

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

package main

import (
	"errors"
	"fmt"
	"strconv"
)

func (c *YatsClient) EventList(source string, from int64, to int64) string {
	if from == 0 {
		panic("From is empty")
	}
	var body string
	if to == 0 {
		body = "{\"source\": \"" + source + "\", \"from\":" + strconv.FormatInt(from, 10) + " }"
	} else {
		body = "{\"source\": \"" + source + "\", \"from\":" + strconv.FormatInt(from, 10) + ",\"to\":" + strconv.FormatInt(to, 10) + " }"
	}
	//fmt.Printf("request: [%s]\n", body)
	return c.ApiPost(c.config.Endpoint+"/event/search", body)
}

func (c *YatsClient) EventSave(eventName string, etime int64) (string, error) {
	if eventName == "" {
		//fmt.Println("Metric Name is empty")
		return "", errors.New("Event Name is empty")
	}

	var body string
	if etime == 0 {
		body = "{ \"name\":\"" + eventName + "\" }"
	} else {
		body = "{ \"name\":\"" + eventName + "\", \"etime\":\"" + strconv.FormatInt(etime, 10) + "\" }"
	}
	fmt.Print("payload: " + body)
	return c.ApiPost(c.config.Endpoint+"/event", body), nil
}