100 Commits

This Branch

This Branch

All Branches

Author	SHA1	Message	Date
b4tman	67e7d4daef	add manual impl Serialize for BatchInfo	2023-08-24 13:34:29 +03:00
b4tman	85a879e9ec	apps: don't use bincode	2023-08-23 22:40:54 +03:00
b4tman	fad2d1d63d	async db: postcard	2023-08-23 22:33:59 +03:00
b4tman	cb781ccf76	postcard no features	2023-08-23 22:33:36 +03:00
b4tman	7e6b513179	sync db: postcard	2023-08-23 21:40:07 +03:00
b4tman	1d4005abdb	postcard instead of bincode	2023-08-23 21:39:23 +03:00
b4tman	760f6d9415	add async bench	2023-08-23 13:30:51 +03:00
b4tman	699478f85e	async_zip, async-compression from crates.io ... instead of git	2023-08-18 10:05:22 +03:00
b4tman	23f8537e4e	source: pub fn new in async zip reader	2023-08-18 10:03:50 +03:00
b4tman	cd93f577be	lib: v1.2.0	2023-08-18 09:37:27 +03:00
b4tman	cd7f3674ca	ci: publish lib with all features	2023-08-18 09:33:42 +03:00
b4tman	797f781959	app_async: use for_each_concurrent	2023-08-16 14:48:47 +03:00
b4tman	6d850be1dc	async_db: add [bufread, bufread_stream] tests	2023-08-16 12:04:57 +03:00
b4tman	33abc15268	app_async: fix Reader::new	2023-08-16 11:49:08 +03:00
b4tman	feb2303db9	async_db: add BufReader, BufReaderStream ... for using as mutable reader	2023-08-16 11:48:45 +03:00
b4tman	ae96fb3bf8	add FIXME comment	2023-08-15 14:54:40 +03:00
b4tman	5ed0398203	db(+async) writer: add push_by_ref	2023-08-15 11:03:15 +03:00
b4tman	9196c61a12	add test for writer.sink()	2023-08-15 10:45:08 +03:00
b4tman	0adc11cabf	app_async: don't use writer.sink()	2023-08-15 10:44:32 +03:00
b4tman	07d7ba50cc	async_db "fixme" comments	2023-08-15 10:36:42 +03:00
b4tman	f1d4cf05c5	async_db: refactor WriterSink::poll_ready	2023-08-14 17:11:53 +03:00
b4tman	3ea4930105	async_db: add Reader::get_with_buf +test	2023-08-14 16:24:36 +03:00
b4tman	645b654dac	use BincodeVecWriter in (sync) db ... for reusing current item buf	2023-08-14 15:54:26 +03:00
b4tman	e074108560	use BincodeVecWriter in async_db ... for reusing current item buf	2023-08-14 15:53:17 +03:00
b4tman	ddd728cd5d	add utils::BincodeVecWriter	2023-08-14 15:50:50 +03:00
b4tman	c326fc59d3	questions converter: remove src clone	2023-08-14 12:21:14 +03:00
b4tman	31c02ae8ef	async_db: add WriterSink	2023-08-13 18:16:49 +03:00
b4tman	3e3572ce12	async deps: add pin-project	2023-08-13 18:14:41 +03:00
b4tman	908a6d8cae	fix source decode	2023-08-13 18:11:29 +03:00
b4tman	cd87529ede	questions: add QuestionsConverterAsyncForStream	2023-08-13 16:01:10 +03:00
b4tman	270af2c373	questions: add async convert_stream test	2023-08-13 13:19:40 +03:00
b4tman	ff6af8389d	questions: add sync convert test	2023-08-13 12:55:35 +03:00
b4tman	8e87e5e17b	source tests: reuse fn sample_batch()	2023-08-13 12:34:22 +03:00
b4tman	ed37fee697	fix clippy warnings in tests	2023-08-13 12:33:19 +03:00
b4tman	e0326e3b0a	add questions ser/de tests	2023-08-12 23:35:17 +03:00
b4tman	c061fef267	questions: add skip_serializing_if attr's	2023-08-12 22:53:36 +03:00
b4tman	acf741e721	source tests: check write on write_sample_zip	2023-08-12 22:51:39 +03:00
b4tman	e32316c6aa	source: reformat struct's	2023-08-12 22:34:01 +03:00
b4tman	ef98b1fea4	add source::reader_async get/stream tests	2023-08-12 22:11:36 +03:00
b4tman	08acb4e71b	add source::reader_sync get/iter tests	2023-08-12 22:10:48 +03:00
b4tman	7e633577b1	add source batch ser/de tests	2023-08-12 22:08:25 +03:00
b4tman	d4913a13f9	deps: add insta for tests	2023-08-12 21:42:14 +03:00
b4tman	21571787f2	source: add skip_serializing_if attr's	2023-08-12 21:40:33 +03:00
b4tman	f874e59a11	fix convert feature without source	2023-08-10 14:20:58 +03:00
b4tman	9c4882fbbb	Merge branch 'master' into async	2023-08-10 11:50:20 +03:00
b4tman	b12048c38d	PhantomData<Arc<T>> for Send to Reader/Writer	2023-08-10 11:48:34 +03:00
b4tman	68b276ce5e	PhantomData<Arc<T>>	2023-08-10 11:20:38 +03:00
b4tman	48438c1aec	Revert "ci: fix pipeline build" ... This reverts commit 851058245d.	2023-08-08 17:10:14 +03:00
b4tman	f2fc72056b	fmt	2023-08-08 16:55:22 +03:00
b4tman	4c555df8ca	fix async_db tests ... using ZstdEncoder from ..:tokio::bufread instead of ..:tokio::write	2023-08-08 16:54:40 +03:00
b4tman	daf41625ff	remove debug prints	2023-08-08 16:52:30 +03:00
b4tman	2c3950ccfc	fix write_db tokio join	2023-08-08 16:50:02 +03:00
b4tman	8306c76a0c	fix app_async	2023-08-08 14:31:08 +03:00
b4tman	965c021d83	fix async_db tests (to fail) ... --- failures: async_db::test::test_write_read async_db::test::test_write_read_stream thread 'async_db::test::test_write_read' panicked at 'get: "UnexpectedEnd { additional: 1 }	2023-08-08 14:29:18 +03:00
b4tman	a1a1d41403	replace PhantomData in async_db::Writer ... for Send for Writer	2023-08-08 14:25:01 +03:00
b4tman	b768d27f83	combine convert sync/async features	2023-08-08 14:22:29 +03:00
b4tman	7cbf5439b7	rewrite SourceQuestionsZipReaderAsync ... "impl Stream for SourceQuestionsZipReaderAsync" dropped	2023-08-08 14:20:40 +03:00
b4tman	8c4631e89f	add app_async ... -- write invalid: "UnexpectedEnd { additional: 385 }"	2023-08-07 22:06:21 +03:00
b4tman	467ebfcc67	rewrite async converter ... (poll_next removed // not work)	2023-08-07 22:04:29 +03:00
b4tman	80dda8d821	rewrite SourceQuestionsZipReaderAsync stream ... (poll_next not work)	2023-08-07 22:02:41 +03:00
b4tman	851058245d	ci: fix pipeline build	2023-08-06 17:03:18 +03:00
b4tman	ecfc34e821	+ async source ... (reader and converter)	2023-08-06 17:01:22 +03:00
b4tman	f55b6f681c	move str_err to util.rs	2023-08-06 16:58:43 +03:00
b4tman	c0193e4f74	ci: add "publish" pipeline type	2023-08-06 01:19:19 +03:00
b4tman	a496f37ef2	ci: build/test with --all-features	2023-08-06 01:09:57 +03:00
b4tman	5632c19866	ci: add pipeline type	2023-08-06 01:09:32 +03:00
b4tman	cad8ff0404	add async test_share_reader	2023-08-06 01:05:36 +03:00
b4tman	39ce0d8ceb	add async reader stream	2023-08-06 00:56:49 +03:00
b4tman	1ba645f337	add async reader	2023-08-06 00:12:15 +03:00
b4tman	150527efeb	move macro to convert mod	2023-08-06 00:11:44 +03:00
b4tman	0c0a4e31ba	optional feature for source	2023-08-05 23:26:45 +03:00
b4tman	abcb7d6dc2	add async writer	2023-08-05 23:10:30 +03:00
b4tman	307790ce49	fix set_pledged_src_size	2023-08-05 23:07:16 +03:00
b4tman	a6e5931f35	add sync/async features	2023-08-05 23:06:55 +03:00
b4tman	1e8cd4b461	cargo update	2023-07-19 14:43:22 +03:00
b4tman	9246d06783	cargo fix	2023-07-19 14:40:56 +03:00
b4tman	cc5ab52f32	ref bench	2023-07-19 14:40:25 +03:00
b4tman	e7491f6d3a	upd clap to v4	2023-05-07 18:15:45 +03:00
b4tman	39d4d6b610	add locks + file alloc in Writer::finish	2023-04-05 16:53:40 +03:00
b4tman	27260695f7	upd lock	2023-04-03 15:35:58 +03:00
b4tman	f5bd72b298	fix publish 2	2023-03-29 13:46:21 +03:00
b4tman	dda50e7d2b	fix build on publish	2023-03-29 13:31:23 +03:00
b4tman	693f349ae3	fix license	2023-03-29 13:30:57 +03:00
b4tman	7a2e58b1b9	remove branch filter for publish	2023-03-29 13:23:03 +03:00
b4tman	9570b1d6e2	add manifest info	2023-03-29 13:22:37 +03:00
b4tman	5355d0398d	remove ledb	2023-03-29 13:00:17 +03:00
b4tman	b63e9aa45c	add publish pipeline	2023-03-29 12:59:35 +03:00
b4tman	8120a996a3	add test_share_reader	2023-03-28 15:43:08 +03:00
b4tman	3a26a4aa7f	upd bench	2023-03-28 15:37:21 +03:00
b4tman	103b677d21	into_iter() for reader	2023-03-28 15:01:14 +03:00
b4tman	e18539a982	reader without mut	2023-03-28 14:59:44 +03:00
b4tman	249ac3a4ef	ci: use sparse protocol for crates.io	2023-03-13 17:10:09 +03:00
b4tman	e940f1c37c	cargo update	2023-03-02 14:50:06 +03:00
b4tman	f3dabe7a06	new db file rename	2023-01-03 23:52:50 +03:00
b4tman	e521e39f5e	add ledb read/write benches	2022-11-10 22:21:55 +03:00
b4tman	cf591198a0	separate lib	2022-11-10 21:43:15 +03:00
b4tman	be6b17a8e2	db::read -- io::Cursor instead of take	2022-11-09 21:31:38 +03:00
b4tman	6a3b3647b3	db read with mmap	2022-11-09 21:03:35 +03:00
b4tman	7efd03d624	add db_bench	2022-10-16 01:29:37 +03:00
b4tman	a05edad5f7	db::WriterOpts reduce current_buf_size	2022-10-13 21:27:41 +03:00