Function schemaTemplateParam

riverdriver/riversqlite/river_sqlite_driver.go:1642–1650

(ctx context.Context, schema string)

}

func schemaTemplateParam(ctx context.Context, schema string) context.Context {
	if schema != "" {
		schema = dbutil.SafeIdentifier(schema) + "."
	}

	return sqlctemplate.WithReplacements(ctx, map[string]sqlctemplate.Replacement{
		"schema": {Value: schema, Stable: true},
	}, nil)
}

func queueFromInternal(internal *dbsqlc.RiverQueue) *rivertype.Queue {
	var pausedAt *time.Time