We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8b6c7e8 commit 04c0b89Copy full SHA for 04c0b89
exporter/exporterhelper/logs.go
@@ -41,8 +41,8 @@ func NewLogsQueueBatchSettings() QueueBatchSettings {
41
},
42
43
44
- Partitioner: queuebatch.BasePartitioner{
45
- GetKeyFunc: func(_ context.Context, req request.Request) string {
+ Partitioner: queuebatch.NewPartitioner(
+ func(_ context.Context, req request.Request) string {
46
logRequest := req.(*logsRequest)
47
if logRequest.ld.ResourceLogs().Len() == 0 {
48
return ""
@@ -53,7 +53,7 @@ func NewLogsQueueBatchSettings() QueueBatchSettings {
53
}
54
return key.AsString()
55
56
- },
+ ),
57
58
59
0 commit comments