MCPcopy Index your code
hub / github.com/riverqueue/river / IndexExists

Method IndexExists

riverdriver/riversqlite/river_sqlite_driver.go:216–219  ·  view source on GitHub ↗
(ctx context.Context, params *riverdriver.IndexExistsParams)

Source from the content-addressed store, hash-verified

214}
215
216func (e *Executor) IndexExists(ctx context.Context, params *riverdriver.IndexExistsParams) (bool, error) {
217 exists, err := dbsqlc.New().IndexExists(schemaTemplateParam(ctx, params.Schema), e.dbtx, params.Index)
218 return exists, interpretError(err)
219}
220
221func (e *Executor) IndexReindex(ctx context.Context, params *riverdriver.IndexReindexParams) error {
222 var maybeSchema string

Callers 1

IndexesExistMethod · 0.95

Implementers 3

Executorriverdriver/riverpgxv5/river_pgx_v5_dr
Executorriverdriver/riverdatabasesql/river_dat
Executorriverdriver/riversqlite/river_sqlite_d

Calls 4

NewFunction · 0.92
schemaTemplateParamFunction · 0.70
interpretErrorFunction · 0.70
IndexExistsMethod · 0.65

Tested by

no test coverage detected