mirror of
https://github.com/simon987/task_tracker.git
synced 2025-04-10 14:06:43 +00:00
Add log function in go client
This commit is contained in:
parent
961d692c61
commit
26a3552b7b
@ -4,11 +4,13 @@ import (
|
||||
"bytes"
|
||||
"encoding/base64"
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"github.com/simon987/task_tracker/api"
|
||||
"github.com/simon987/task_tracker/storage"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"time"
|
||||
)
|
||||
|
||||
type TaskTrackerClient struct {
|
||||
@ -159,6 +161,42 @@ func (c TaskTrackerClient) RequestAccess(req api.CreateWorkerAccessRequest) (api
|
||||
return jsonResp, err
|
||||
}
|
||||
|
||||
func (c TaskTrackerClient) Log(level storage.LogLevel, message string) error {
|
||||
|
||||
var levelString string
|
||||
req := api.LogRequest{
|
||||
Scope: "task_tracker go client",
|
||||
Message: message,
|
||||
TimeStamp: time.Now().Unix(),
|
||||
}
|
||||
|
||||
switch level {
|
||||
case storage.ERROR:
|
||||
levelString = "error"
|
||||
case storage.WARN:
|
||||
levelString = "warn"
|
||||
case storage.INFO:
|
||||
levelString = "panic"
|
||||
case storage.TRACE:
|
||||
levelString = "trace"
|
||||
default:
|
||||
return errors.New("this log level is not implemented")
|
||||
}
|
||||
|
||||
httpResp := c.post("/log/"+levelString, req)
|
||||
var jsonResp api.JsonResponse
|
||||
err := unmarshalResponse(httpResp, &jsonResp)
|
||||
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if !jsonResp.Ok {
|
||||
return errors.New(jsonResp.Message)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func handleErr(err error) {
|
||||
if err != nil {
|
||||
panic(err)
|
||||
|
Loading…
x
Reference in New Issue
Block a user