ShardsDB

JOBS_CHANNEL = "jobs"

new(connection : DB::Connection)

application_name=(application_name : String | Nil)

database_url=(database_url : String)

statement_timeout=(statement_timeout : String | Nil)

all_releases(shard_id : Int64)

create_category(category : Category)

create_owner(owner : Repo::Owner)

create_release(shard_id : Int64, release : Release, position : Int | Nil = nil)

create_repo(repo : Repo)

create_shard(shard : Shard)

delete_categorizations(repo_refs : Array(Repo::Ref))

delete_file(release_id, path)

fetch_file(release_id, path)

find_canonical_ref?(shard_id)

find_canonical_repo(shard_id : Int64)

find_mirror_repos(shard_id : Int64)

get_owned_repos(owner_id : Int64)

get_owner?(resolver : String, slug : String)

get_owner?(repo_ref : Repo::Ref)

get_repo(repo_id : Int64)

get_repo(repo_ref : Repo::Ref)

get_repo?(repo_ref : Repo::Ref)

get_repo_id(resolver : String, url : String)

get_repo_id(repo_ref : Repo::Ref)

get_repo_id?(resolver : String, url : String)

get_repo_id?(repo_ref : Repo::Ref)

get_shard(shard_id : Int64)

get_shard_id(name : String, qualifier : String = "")

get_shard_id?(name : String, qualifier : Nil)

get_shard_id?(name : String, qualifier : String = "")

log_activity(event : String, repo_id : Int64 | Nil = nil, shard_id : Int64 | Nil = nil, metadata = nil, exc = nil)

put_file(release_id, path, content)

remove_category(slug : String)

repo_sync_failed(repo)

send_job_notification(message)

set_owner(repo_ref : Repo::Ref, owner_id : Int64)

shards_in_category(category_id : Int64 | Nil)

sql_array(array)

update_categorization(repo_ref : Repo::Ref, categories : Array(String))

update_categorization(shard_id : Int64, categories : Array(String))

update_category(category : Category)

update_owner_shards_count(owner_id : Int64)

update_release(release : Release)

upsert_dependency(release_id : Int64, dependency : Dependency, repo_id = nil)