Searched defs:number_of_partitions (Results 1 – 3 of 3) sorted by relevance
300 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_count() localVariable360 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_len_and_value() localVariable411 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_zero_len() localVariable445 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_less_than_buffer() localVariable486 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_name_max() localVariable549 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions() localVariable597 let number_of_partitions = unsafe { number_of_partitions.as_mut() }.unwrap(); in test_proto_get_partitions_empty() localVariable
90 def number_of_partitions(self): member in ShardingPolicy94 def set_number_of_partitions(self, number_of_partitions): argument
133 number_of_partitions=None, argument