@@ -49,265 +49,7 @@ export declare const internal: FilterApi<
4949> ;
5050
5151export declare const components : {
52- smallPool : {
53- lib : {
54- cancel : FunctionReference <
55- "mutation" ,
56- "internal" ,
57- {
58- id : string ;
59- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
60- } ,
61- any
62- > ;
63- cancelAll : FunctionReference <
64- "mutation" ,
65- "internal" ,
66- {
67- before ?: number ;
68- limit ?: number ;
69- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
70- } ,
71- any
72- > ;
73- enqueue : FunctionReference <
74- "mutation" ,
75- "internal" ,
76- {
77- config : {
78- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
79- maxParallelism : number ;
80- } ;
81- fnArgs : any ;
82- fnHandle : string ;
83- fnName : string ;
84- fnType : "action" | "mutation" | "query" ;
85- onComplete ?: { context ?: any ; fnHandle : string } ;
86- retryBehavior ?: {
87- base : number ;
88- initialBackoffMs : number ;
89- maxAttempts : number ;
90- } ;
91- runAt : number ;
92- } ,
93- string
94- > ;
95- enqueueBatch : FunctionReference <
96- "mutation" ,
97- "internal" ,
98- {
99- config : {
100- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
101- maxParallelism : number ;
102- } ;
103- items : Array < {
104- fnArgs : any ;
105- fnHandle : string ;
106- fnName : string ;
107- fnType : "action" | "mutation" | "query" ;
108- onComplete ?: { context ?: any ; fnHandle : string } ;
109- retryBehavior ?: {
110- base : number ;
111- initialBackoffMs : number ;
112- maxAttempts : number ;
113- } ;
114- runAt : number ;
115- } > ;
116- } ,
117- Array < string >
118- > ;
119- status : FunctionReference <
120- "query" ,
121- "internal" ,
122- { id : string } ,
123- | { previousAttempts : number ; state : "pending" }
124- | { previousAttempts : number ; state : "running" }
125- | { state : "finished" }
126- > ;
127- statusBatch : FunctionReference <
128- "query" ,
129- "internal" ,
130- { ids : Array < string > } ,
131- Array <
132- | { previousAttempts : number ; state : "pending" }
133- | { previousAttempts : number ; state : "running" }
134- | { state : "finished" }
135- >
136- > ;
137- } ;
138- } ;
139- bigPool : {
140- lib : {
141- cancel : FunctionReference <
142- "mutation" ,
143- "internal" ,
144- {
145- id : string ;
146- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
147- } ,
148- any
149- > ;
150- cancelAll : FunctionReference <
151- "mutation" ,
152- "internal" ,
153- {
154- before ?: number ;
155- limit ?: number ;
156- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
157- } ,
158- any
159- > ;
160- enqueue : FunctionReference <
161- "mutation" ,
162- "internal" ,
163- {
164- config : {
165- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
166- maxParallelism : number ;
167- } ;
168- fnArgs : any ;
169- fnHandle : string ;
170- fnName : string ;
171- fnType : "action" | "mutation" | "query" ;
172- onComplete ?: { context ?: any ; fnHandle : string } ;
173- retryBehavior ?: {
174- base : number ;
175- initialBackoffMs : number ;
176- maxAttempts : number ;
177- } ;
178- runAt : number ;
179- } ,
180- string
181- > ;
182- enqueueBatch : FunctionReference <
183- "mutation" ,
184- "internal" ,
185- {
186- config : {
187- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
188- maxParallelism : number ;
189- } ;
190- items : Array < {
191- fnArgs : any ;
192- fnHandle : string ;
193- fnName : string ;
194- fnType : "action" | "mutation" | "query" ;
195- onComplete ?: { context ?: any ; fnHandle : string } ;
196- retryBehavior ?: {
197- base : number ;
198- initialBackoffMs : number ;
199- maxAttempts : number ;
200- } ;
201- runAt : number ;
202- } > ;
203- } ,
204- Array < string >
205- > ;
206- status : FunctionReference <
207- "query" ,
208- "internal" ,
209- { id : string } ,
210- | { previousAttempts : number ; state : "pending" }
211- | { previousAttempts : number ; state : "running" }
212- | { state : "finished" }
213- > ;
214- statusBatch : FunctionReference <
215- "query" ,
216- "internal" ,
217- { ids : Array < string > } ,
218- Array <
219- | { previousAttempts : number ; state : "pending" }
220- | { previousAttempts : number ; state : "running" }
221- | { state : "finished" }
222- >
223- > ;
224- } ;
225- } ;
226- serializedPool : {
227- lib : {
228- cancel : FunctionReference <
229- "mutation" ,
230- "internal" ,
231- {
232- id : string ;
233- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
234- } ,
235- any
236- > ;
237- cancelAll : FunctionReference <
238- "mutation" ,
239- "internal" ,
240- {
241- before ?: number ;
242- limit ?: number ;
243- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
244- } ,
245- any
246- > ;
247- enqueue : FunctionReference <
248- "mutation" ,
249- "internal" ,
250- {
251- config : {
252- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
253- maxParallelism : number ;
254- } ;
255- fnArgs : any ;
256- fnHandle : string ;
257- fnName : string ;
258- fnType : "action" | "mutation" | "query" ;
259- onComplete ?: { context ?: any ; fnHandle : string } ;
260- retryBehavior ?: {
261- base : number ;
262- initialBackoffMs : number ;
263- maxAttempts : number ;
264- } ;
265- runAt : number ;
266- } ,
267- string
268- > ;
269- enqueueBatch : FunctionReference <
270- "mutation" ,
271- "internal" ,
272- {
273- config : {
274- logLevel : "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR" ;
275- maxParallelism : number ;
276- } ;
277- items : Array < {
278- fnArgs : any ;
279- fnHandle : string ;
280- fnName : string ;
281- fnType : "action" | "mutation" | "query" ;
282- onComplete ?: { context ?: any ; fnHandle : string } ;
283- retryBehavior ?: {
284- base : number ;
285- initialBackoffMs : number ;
286- maxAttempts : number ;
287- } ;
288- runAt : number ;
289- } > ;
290- } ,
291- Array < string >
292- > ;
293- status : FunctionReference <
294- "query" ,
295- "internal" ,
296- { id : string } ,
297- | { previousAttempts : number ; state : "pending" }
298- | { previousAttempts : number ; state : "running" }
299- | { state : "finished" }
300- > ;
301- statusBatch : FunctionReference <
302- "query" ,
303- "internal" ,
304- { ids : Array < string > } ,
305- Array <
306- | { previousAttempts : number ; state : "pending" }
307- | { previousAttempts : number ; state : "running" }
308- | { state : "finished" }
309- >
310- > ;
311- } ;
312- } ;
52+ smallPool : import ( "@convex-dev/workpool/_generated/component.js" ) . ComponentApi < "smallPool" > ;
53+ bigPool : import ( "@convex-dev/workpool/_generated/component.js" ) . ComponentApi < "bigPool" > ;
54+ serializedPool : import ( "@convex-dev/workpool/_generated/component.js" ) . ComponentApi < "serializedPool" > ;
31355} ;
0 commit comments