46
}
47
48
>
dlqTasks := make([]*commonspb.HistoryDLQTask, len(response.Tasks))
api.go
49
>
for i, task := range response.Tasks {
50
>
dlqTasks[i] = &commonspb.HistoryDLQTask{
51
>
Metadata: &commonspb.HistoryDLQTaskMetadata{
52
>
MessageId: task.MessageMetadata.ID,
53
>
},
54
>
Payload: &commonspb.HistoryTask{
55
>
ShardId: task.Payload.ShardId,
56
>
Blob: task.Payload.Blob,
57
>
},
58
>
}
59
>
}
60
61
>
return &historyservice.GetDLQTasksResponse{
api.go
62
>
DlqTasks: dlqTasks,
63
>
NextPageToken: response.NextPageToken,
64
>
}, nil
65
}