133 Commits

Author	SHA1	Message	Date
syumai	b47c53ff19	Rename BatchMessage to MessageSendRequest	2025-02-16 19:49:06 +09:00
syumai	9047d7f30d	rename Id to ID	2025-01-15 21:13:20 +09:00
syumai	13b10a693c	remove name prefix from ConsumerMessage / ConsumerMessageBatch	2025-01-15 21:12:26 +09:00
syumai	304350426f	add comment to rename batch message	2025-01-15 21:09:14 +09:00
syumai	0d08d319d6	stop treating string body as bytes body	2025-01-15 21:03:29 +09:00
syumai	85790d319c	remove IntBody and FloatBody from consumer message	2025-01-15 20:57:29 +09:00
syumai	3de551eed6	rename ConsumeNonBlocking to ConsumeNonBlock	2025-01-15 20:22:36 +09:00
syumai	0c1f74cc73	Merge pull request #137 from meandnano/feature/consumer ... Implement Queues Consumer	2025-01-15 20:21:17 +09:00
syumai	008452bca1	remove unnecessary blank r2 files	2025-01-12 23:01:26 +09:00
syumai	c30f8b601c	integrate cloudflare/(r2bucket,r2object,r2objects).go into cloudflare/r2.go	2025-01-12 22:45:43 +09:00
syumai	443e50a8bb	move R2 features to cloudflare/r2 package	2025-01-12 22:43:28 +09:00
syumai	c5873af476	split kv.go	2025-01-12 22:01:02 +09:00
syumai	b5dcf0d30d	move kv into cloudflare/kv package	2025-01-12 15:10:38 +09:00
mike.art	39b6eeae72	Implement Queues Consumer	2024-11-20 11:41:31 +01:00
syumai	d0919c3abf	add comments to queues public funcs	2024-11-10 00:30:20 +09:00
syumai	c55bf16a3e	update queues test impl	2024-11-10 00:28:47 +09:00
syumai	374d3a8461	rename queues.WithDelay to queues.WithDelaySeconds	2024-11-10 00:28:47 +09:00
syumai	c4e9274e73	update SendBatch impl	2024-11-10 00:28:47 +09:00
syumai	4fa8e20a64	rename producer_opts.go to sendoptions.go	2024-11-10 00:28:47 +09:00
syumai	b54a5edc0d	split queues.batchSendOptions	2024-11-10 00:28:47 +09:00
syumai	488aec9585	split queue.NewBatchMessage funcs	2024-11-10 00:28:47 +09:00
syumai	9cfa0111ef	split queue.Producer's send methods	2024-11-10 00:28:41 +09:00
syumai	693eaf206f	split batchmessage.go	2024-11-09 17:59:56 +09:00
syumai	68bb0c7e08	rename WaitForCompletion to Done	2024-11-08 02:33:28 +09:00
syumai	2a59c59bae	split cloudflare/cron.WaitForCompletion from cron.ScheduleTask	2024-11-08 02:23:20 +09:00
syumai	5f0fcb01dd	split workers.Ready and workers.WaitForCompletion from workers.Serve	2024-11-08 02:23:15 +09:00
Ben Krieger	84f6c350ca	Add cron.ScheduleTaskNonBlock for use with workers.Serve	2024-11-07 11:36:09 -05:00
syumai	f0f5c6ff9e	Merge pull request #128 from ben-krieger/d1-blob ... Support []byte arguments to D1 Query/Exec	2024-11-08 01:17:38 +09:00
Ben Krieger	6642597fbc	Support []byte arguments to D1 Query/Exec	2024-10-30 16:07:09 -04:00
mike.art	ae2bcf1937	Add tests and docs	2024-10-15 13:24:49 +02:00
mike.art	bdeff99c27	Fix "bytes" value mapping	2024-10-14 12:38:13 +02:00
mike.art	ee70c46c1e	Add message producer	2024-10-13 19:01:02 +02:00
syumai	cf3b68b6b3	fixed panic on fetch returning empty response	2024-08-11 22:07:10 +09:00
Mircea Suciu	0b2343b258	add jsutil.MaybeInt wrapper; apply it to IncomingProperties.Asn	2024-07-29 13:19:42 +00:00
syumai	a0eb7cdcb5	rename D1 row columns field name and changed to use result of rowsArray.shift() directly	2024-04-27 16:21:07 +09:00
syumai	640a515c7b	change rowObj var name to rowArray	2024-04-27 15:34:02 +09:00
zztkm	33abcb5423	fix some minor points	2024-04-25 07:59:07 +09:00
zztkm	cef5b9b6a2	fix D1 driver implementation using stmt.raw({ columnNames: true })	2024-04-24 23:52:54 +09:00
syumai	13b7485b1a	add missing null checks to R2 conversion	2024-04-18 01:58:23 +09:00
syumai	eeb9a13d92	implement D1 driver's sql.Open	2024-04-17 01:51:31 +09:00
syumai	52a78e1789	remove runtimeObj from runtimecontext.New	2024-04-17 00:56:35 +09:00
syumai	627ed95530	remove dependencies on Context from cloudflare-related APIs	2024-04-17 00:52:30 +09:00
syumai	33e4ad8f50	remove context.Context from existing RuntimeContext related func params	2024-04-17 00:41:39 +09:00
syumai	94f29ebdf1	move fetch's stream logic to jshttp.ToStreamResponse	2024-02-01 09:33:52 +09:00
aki-0421	afebbac9d5	R: fix memory error	2024-01-25 08:56:34 +09:00
syumai	5604a29f06	add jsutil.RawJSWriter and use it in jshttp.ResponseWriter	2024-01-25 00:00:36 +09:00
aki-0421	eac1510668	R: merge pkg	2024-01-23 13:01:33 +09:00
aki-0421	86f9f1cf26	R: fix illegal invocation error	2024-01-23 12:53:32 +09:00
aki-0421	83be8bc604	R: refactor incoming with new runtimecontext	2024-01-22 22:07:24 +09:00
aki-0421	a067e8e0b8	R: refactor cron with new runtimecontext	2024-01-22 22:06:54 +09:00