-
Notifications
You must be signed in to change notification settings - Fork 4
/
dd.go
51 lines (45 loc) · 1.57 KB
/
dd.go
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
package datadog
import (
"context"
"fmt"
"log"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
"github.com/girishg4t/dd-downloader/pkg/model"
)
func GetDataDogLogs(filter model.DataDogFilter, cur *string, limit int32) datadogV2.LogsListResponse {
log.Printf("query=>%s, from %d, to %d\n", filter.Query, filter.From, filter.To)
body := datadogV2.LogsListRequest{
Filter: &datadogV2.LogsQueryFilter{
Query: datadog.PtrString(filter.Query),
Indexes: []string{
"main",
},
From: datadog.PtrString(fmt.Sprintf("%d", filter.From)),
To: datadog.PtrString(fmt.Sprintf("%d", filter.To)),
},
Sort: datadogV2.LOGSSORT_TIMESTAMP_ASCENDING.Ptr(),
Page: &datadogV2.LogsListRequestPage{
Limit: datadog.PtrInt32(limit),
Cursor: cur,
},
}
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewLogsApi(apiClient)
resp, r, err := api.ListLogs(ctx, *datadogV2.NewListLogsOptionalParameters().WithBody(body))
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `LogsApi.ListLogs`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
return datadogV2.LogsListResponse{
Data: []datadogV2.Log{},
Links: &datadogV2.LogsListResponseLinks{},
Meta: &datadogV2.LogsResponseMetadata{},
UnparsedObject: map[string]interface{}{},
AdditionalProperties: map[string]interface{}{},
}
}
return resp
}