mirror of
https://github.com/APIParkLab/APIPark.git
synced 2026-06-14 20:41:15 +08:00
Liujian
96 lines
3.2 KiB
Go
96 lines
3.2 KiB
Go
package loki
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestLoki(t *testing.T) {
|
|
d, err := NewDriver(`{"url":"http://localhost:3100","header":{"Content-Type":"application/json","X-Scope-OrgID":"tenant1"}}`)
|
|
if err != nil {
|
|
t.Fatalf("failed to create driver: %v", err)
|
|
}
|
|
logCountResult, err := d.LogCount("apinto", nil, 720, "strategy")
|
|
if err != nil {
|
|
t.Fatalf("failed to get log count: %v", err)
|
|
}
|
|
t.Log(logCountResult)
|
|
logs, count, err := d.Logs("apinto", map[string]string{"strategy": "03899736-5d79-4f26-bd6a-c312a5880780"}, time.Now().Add(-time.Hour*24), time.Now(), 1, 1)
|
|
if err != nil {
|
|
t.Fatalf("failed to get logs: %v", err)
|
|
}
|
|
t.Log(logs, count)
|
|
info, err := d.LogInfo("apinto", "c9f6b19c-7dfe-496b-9b39-4d049232fe95")
|
|
if err != nil {
|
|
t.Fatalf("failed to get log info: %v", err)
|
|
}
|
|
t.Log(info)
|
|
}
|
|
|
|
//func TestLokiLog(t *testing.T) {
|
|
//
|
|
// headers := make(map[string]string)
|
|
// headers["Content-Type"] = "application/json"
|
|
// headers["X-Scope-OrgID"] = "tenant1"
|
|
// queries := url.Values{}
|
|
// queries.Set("query", "{cluster=\"apinto\"} | json | request_id = `c9f6b19c-7dfe-496b-9b39-4d049232fe95`")
|
|
// now := time.Now()
|
|
// start := now.Add(-time.Hour * 24 * 30)
|
|
// queries.Set("start", strconv.FormatInt(start.UnixNano(), 10))
|
|
// queries.Set("end", strconv.FormatInt(now.UnixNano(), 10))
|
|
// queries.Set("limit", "100")
|
|
// a := time.Now()
|
|
// result, err := send[LogInfo](http.MethodGet, "http://localhost:3100/loki/api/v1/query_range", headers, queries, "")
|
|
// if err != nil {
|
|
// t.Fatalf("failed to send request: %v", err)
|
|
// }
|
|
// t.Log(time.Now().Sub(a))
|
|
// data, err := json.Marshal(result)
|
|
// if err != nil {
|
|
// t.Fatalf("failed to marshal data: %v", err)
|
|
// }
|
|
// t.Log(string(data))
|
|
//}
|
|
//
|
|
//func TestLokiLogCount(t *testing.T) {
|
|
// headers := make(map[string]string)
|
|
// headers["Content-Type"] = "application/json"
|
|
// headers["X-Scope-OrgID"] = "tenant1"
|
|
// queries := url.Values{}
|
|
// //queries.Set("query", "sum(count_over_time({cluster=\"apinto\"}[24h])) by (strategy)")
|
|
// queries.Set("query", "sum(count_over_time({cluster=\"apinto\"}[24h]))")
|
|
// result, err := send[LogCount](http.MethodGet, "http://localhost:3100/loki/api/v1/query", headers, queries, "")
|
|
// if err != nil {
|
|
// t.Fatalf("failed to send request: %v", err)
|
|
// }
|
|
// data, err := json.Marshal(result)
|
|
// if err != nil {
|
|
// t.Fatalf("failed to marshal data: %v", err)
|
|
// }
|
|
// t.Log(string(data))
|
|
//}
|
|
//
|
|
//func TestLokiLogs(t *testing.T) {
|
|
// headers := make(map[string]string)
|
|
// headers["Content-Type"] = "application/json"
|
|
// headers["X-Scope-OrgID"] = "tenant1"
|
|
// queries := url.Values{}
|
|
// queries.Set("query", "{cluster=\"apinto\"} | json | strategy=\"03899736-5d79-4f26-bd6a-c312a5880780\"")
|
|
// now := time.Now()
|
|
// start := now.Add(-time.Hour * 24 * 30)
|
|
// queries.Set("start", strconv.FormatInt(start.UnixNano(), 10))
|
|
// queries.Set("end", strconv.FormatInt(now.UnixNano(), 10))
|
|
// queries.Set("limit", "1")
|
|
// now = time.Now()
|
|
// result, err := send[map[string]interface{}](http.MethodGet, "http://localhost:3100/loki/api/v1/query_range", headers, queries, "")
|
|
// t.Log(time.Now().Sub(now))
|
|
// if err != nil {
|
|
// t.Fatalf("failed to send request: %v", err)
|
|
// }
|
|
// data, err := json.Marshal(result)
|
|
// if err != nil {
|
|
// t.Fatalf("failed to marshal data: %v", err)
|
|
// }
|
|
// t.Log(string(data))
|
|
//}
|