class TransactedGHTorrent
A version of the GHTorrent
class that creates a transaction per processed item
Public Instance Methods
check_transaction() { |block| ... }
click to toggle source
# File lib/ghtorrent/transacted_gh_torrent.rb, line 112 def check_transaction(&block) if get_db.in_transaction? yield block else transaction do yield block end end end
ensure_commit(repo, sha, user, comments = true)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_commit
# File lib/ghtorrent/transacted_gh_torrent.rb, line 14 def ensure_commit(repo, sha, user, comments = true) check_transaction do super(repo, sha, user, comments) end end
ensure_commit_comment(owner, repo, sha, comment_id)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_commit_comment
# File lib/ghtorrent/transacted_gh_torrent.rb, line 20 def ensure_commit_comment(owner, repo, sha, comment_id) check_transaction do super(owner, repo, sha, comment_id) end end
ensure_fork(owner, repo, fork_id)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_fork
# File lib/ghtorrent/transacted_gh_torrent.rb, line 26 def ensure_fork(owner, repo, fork_id) check_transaction do super(owner, repo, fork_id) end end
ensure_fork_commits(owner, repo, parent_owner, parent_repo)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_fork_commits
# File lib/ghtorrent/transacted_gh_torrent.rb, line 32 def ensure_fork_commits(owner, repo, parent_owner, parent_repo) check_transaction do super(owner, repo, parent_owner, parent_repo) end end
ensure_issue(owner, repo, issue_id, events = true, comments = true, labels = true)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_issue
# File lib/ghtorrent/transacted_gh_torrent.rb, line 52 def ensure_issue(owner, repo, issue_id, events = true, comments = true, labels = true) check_transaction do super(owner, repo, issue_id, events, comments, labels) end end
ensure_issue_comment(owner, repo, issue_id, comment_id, pull_req_id = nil)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_issue_comment
# File lib/ghtorrent/transacted_gh_torrent.rb, line 64 def ensure_issue_comment(owner, repo, issue_id, comment_id, pull_req_id = nil) check_transaction do super(owner, repo, issue_id, comment_id, pull_req_id) end end
ensure_issue_event(owner, repo, issue_id, event_id)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_issue_event
# File lib/ghtorrent/transacted_gh_torrent.rb, line 58 def ensure_issue_event(owner, repo, issue_id, event_id) check_transaction do super(owner, repo, issue_id, event_id) end end
ensure_issue_label(owner, repo, issue_id, name)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_issue_label
# File lib/ghtorrent/transacted_gh_torrent.rb, line 70 def ensure_issue_label(owner, repo, issue_id, name) check_transaction do super(owner, repo, issue_id, name) end end
ensure_org(user, members = true)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_org
# File lib/ghtorrent/transacted_gh_torrent.rb, line 106 def ensure_org(user, members = true) check_transaction do super(user, members) end end
ensure_orgs(user)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_orgs
# File lib/ghtorrent/transacted_gh_torrent.rb, line 100 def ensure_orgs(user) check_transaction do super(user) end end
ensure_project_member(owner, repo, new_member, date_added)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_project_member
# File lib/ghtorrent/transacted_gh_torrent.rb, line 76 def ensure_project_member(owner, repo, new_member, date_added) check_transaction do super(owner, repo, new_member, date_added) end end
ensure_pull_request(owner, repo, pullreq_id, comments = true, commits = true, history = true, state = nil, actor = nil, created_at = nil)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_pull_request
# File lib/ghtorrent/transacted_gh_torrent.rb, line 38 def ensure_pull_request(owner, repo, pullreq_id, comments = true, commits = true, history = true, state = nil, actor = nil, created_at = nil) check_transaction do super(owner, repo, pullreq_id, comments, commits, history, state, actor, created_at) end end
ensure_pullreq_comment(owner, repo, pullreq_id, comment_id)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_pullreq_comment
# File lib/ghtorrent/transacted_gh_torrent.rb, line 46 def ensure_pullreq_comment(owner, repo, pullreq_id, comment_id) check_transaction do super(owner, repo, pullreq_id, comment_id) end end
ensure_repo(owner, repo, recursive = false)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_repo
# File lib/ghtorrent/transacted_gh_torrent.rb, line 8 def ensure_repo(owner, repo, recursive = false) check_transaction do super(owner, repo, recursive) end end
ensure_repo_label(owner, repo, name)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_repo_label
# File lib/ghtorrent/transacted_gh_torrent.rb, line 88 def ensure_repo_label(owner, repo, name) check_transaction do super(owner, repo, name) end end
ensure_user_followers(user)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_user_followers
# File lib/ghtorrent/transacted_gh_torrent.rb, line 94 def ensure_user_followers(user) check_transaction do super(user) end end
ensure_watcher(owner, repo, watcher, date_added = nil)
click to toggle source
Calls superclass method
GHTorrent::Mirror#ensure_watcher
# File lib/ghtorrent/transacted_gh_torrent.rb, line 82 def ensure_watcher(owner, repo, watcher, date_added = nil) check_transaction do super(owner, repo, watcher, date_added) end end