(ctx context.Context, execTx riverdriver.ExecutorTx, params []InsertManyParams)
| 2158 | } |
| 2159 | |
| 2160 | func (c *Client[TTx]) insertManyFast(ctx context.Context, execTx riverdriver.ExecutorTx, params []InsertManyParams) ([]*rivertype.JobInsertResult, error) { |
| 2161 | insertParams, err := c.insertManyParams(params) |
| 2162 | if err != nil { |
| 2163 | return nil, err |
| 2164 | } |
| 2165 | |
| 2166 | return c.insertManyShared(ctx, execTx, insertParams, func(ctx context.Context, insertParams []*riverdriver.JobInsertFastParams) ([]*rivertype.JobInsertResult, error) { |
| 2167 | count, err := execTx.JobInsertFastManyNoReturning(ctx, &riverdriver.JobInsertFastManyParams{ |
| 2168 | Jobs: insertParams, |
| 2169 | Schema: c.config.Schema, |
| 2170 | }) |
| 2171 | if err != nil { |
| 2172 | return nil, err |
| 2173 | } |
| 2174 | return make([]*rivertype.JobInsertResult, count), nil |
| 2175 | }) |
| 2176 | } |
| 2177 | |
| 2178 | // Notify the given queues that new jobs are available. The queues list will be |
| 2179 | // deduplicated and each will be checked to see if it is due for an insert |
no test coverage detected