(ctx context.Context, params *riverdriver.IndexesExistParams)
| 233 | } |
| 234 | |
| 235 | func (e *Executor) IndexesExist(ctx context.Context, params *riverdriver.IndexesExistParams) (map[string]bool, error) { |
| 236 | exists := make(map[string]bool) |
| 237 | for _, index := range params.IndexNames { |
| 238 | indexExists, err := e.IndexExists(ctx, &riverdriver.IndexExistsParams{ |
| 239 | Index: index, |
| 240 | Schema: params.Schema, |
| 241 | }) |
| 242 | if err != nil { |
| 243 | return nil, err |
| 244 | } |
| 245 | exists[index] = indexExists |
| 246 | } |
| 247 | |
| 248 | return exists, nil |
| 249 | } |
| 250 | |
| 251 | func (e *Executor) JobCancel(ctx context.Context, params *riverdriver.JobCancelParams) (*rivertype.JobRow, error) { |
| 252 | // Unlike Postgres, this must be carried out in two operations because |
nothing calls this directly
no test coverage detected