|
@@ -62,10 +62,13 @@ func (s *LogPushCloudflareServer) CreateLogPushJobByZoneId(ctx context.Context,
|
|
|
ctxAPI := context.Background()
|
|
|
|
|
|
job := cloudflare.LogpushJob{
|
|
|
- Dataset: requestCloudflare.GetDataSet(),
|
|
|
- DestinationConf: requestCloudflare.GetDestinationConf(),
|
|
|
- Enabled: true,
|
|
|
- Frequency: "high",
|
|
|
+ Dataset: requestCloudflare.GetDataSet(),
|
|
|
+ DestinationConf: requestCloudflare.GetDestinationConf(),
|
|
|
+ Enabled: true,
|
|
|
+ Frequency: "low",
|
|
|
+ LogpullOptions: "fields=RayID,ZoneName," +
|
|
|
+ "ClientCountry,ClientIP,ClientRequestBytes,ClientRequestHost,ClientRequestPath," +
|
|
|
+ "EdgeResponseStatus,EdgeResponseBytes,EdgeStartTimestamp×tamps=rfc3339,EdgeEndTimestamp×tamps=rfc3339",
|
|
|
OwnershipChallenge: requestCloudflare.GetOwnershipChallenge(),
|
|
|
}
|
|
|
result, err := api.CreateZoneLogpushJob(ctxAPI, requestCloudflare.GetZoneId(), job)
|