sourceClusterShardID ClusterShardID,
targetClusterShardID ClusterShardID,
return metadata.Pairs(
MetadataKeyClientClusterID, strconv.Itoa(int(sourceClusterShardID.ClusterID)),
MetadataKeyClientShardID, strconv.Itoa(int(sourceClusterShardID.ShardID)),
MetadataKeyServerClusterID, strconv.Itoa(int(targetClusterShardID.ClusterID)),
MetadataKeyServerShardID, strconv.Itoa(int(targetClusterShardID.ShardID)),
)
}
func DecodeClusterShardMD(