199
}
200
201
>
func PartitionFromPartitionProto(proto *taskqueuespb.TaskQueuePartition, namespaceId string) Partition {
task_queue_id.go
202
>
tq := &TaskQueue{TaskQueueFamily{namespaceId, proto.GetTaskQueue()}, proto.GetTaskQueueType()}
203
>
switch proto.GetPartitionId().(type) {
204
case *taskqueuespb.TaskQueuePartition_StickyName:
205
return tq.StickyPartition(proto.GetStickyName())
206
case *taskqueuespb.TaskQueuePartition_WorkerCommands:
207
return tq.WorkerCommandsPartition()
209
>
return tq.NormalPartition(int(proto.GetNormalPartitionId()))
210
}
211
}