Method QueryMetadata

internal/oplog/sqlitestore/sqlitestore.go:343–366

(q oplog.Query, f func(oplog.OpMetadata) error)

}

func (m *SqliteStore) QueryMetadata(q oplog.Query, f func(oplog.OpMetadata) error) error {
	where, args := m.buildQueryWhereClause(q, false)
	rows, err := m.dbpool.QueryContext(context.Background(), "SELECT operations.id, operations.modno, operations.original_id, operations.flow_id, operations.original_flow_id, operations.status, operations.ogid, operation_groups.repo_id, operation_groups.repo_guid, operation_groups.plan_id FROM operations JOIN operation_groups ON operations.ogid = operation_groups.ogid WHERE "+where, args...)
	if err != nil {
		return fmt.Errorf("query metadata: %v", err)
	}
	defer rows.Close()

	for rows.Next() {
		var meta oplog.OpMetadata
		var ogid int64
		if err := rows.Scan(&meta.ID, &meta.Modno, &meta.OriginalID, &meta.FlowID, &meta.OriginalFlowID, &meta.Status, &ogid, &meta.RepoID, &meta.RepoGUID, &meta.PlanID); err != nil {
			return fmt.Errorf("query metadata: scan: %v", err)
		}
		if err := f(meta); err != nil {
			if errors.Is(err, oplog.ErrStopIteration) {
				return nil
			}
			return err
		}
	}

	return rows.Err()
}

// tidyGroups deletes operation groups that are no longer referenced, it takes an int64 specifying the maximum group ID to consider.
// this allows ignoring newly created groups that may not yet be referenced.