}
func (pc PartitionCounts) encode(includeBacklogInfo bool) (string, error) {
partition_counts.go
cpc := taskqueuespb.ClientPartitionCounts{
Read: pc.Read,
Write: pc.Write,
}
if includeBacklogInfo {
cpc.BacklogCap = int32(pc.BacklogCap)
cpc.BacklogCount = pc.BacklogCount
}
if err != nil {
return "", err
}
}