What's the es-states, can't find it in git_mirror.rb?

On Tue, Jan 19, 2021 at 09:53:46AM +0800, Li Yuanchao wrote:

When init fork_stat{}, first query the es, get states in es if there is.

|| query stats in es at first?

Thanks, Xueliang

So historical data can be kept.

Signed-off-by: Li Yuanchao lyc163mail@163.com

lib/git_mirror.rb | 38 +++++++++++++++++++++++++++++--------- 1 file changed, 29 insertions(+), 9 deletions(-)

diff --git a/lib/git_mirror.rb b/lib/git_mirror.rb index 86f02e5..1109cfe 100644 --- a/lib/git_mirror.rb +++ b/lib/git_mirror.rb @@ -109,15 +109,8 @@ class MirrorMain @webhook_queue = channel.queue('web_hook') end

• def fork_stat_init(stat_key)
• @fork_stat[stat_key] = {

•  queued: false,
  

•  priority: 0,
  

•  fetch_time: [],
  

•  offset_fetch: 0,
  

•  new_refs_time: [],
  

•  offset_new_refs: 0
  

• }

• def fork_stat_init(git_repo)

• @fork_stat[git_repo] = get_fork_stat(git_repo) end

  def load_defaults(repodir)

@@ -372,4 +365,31 @@ class MirrorMain

handle_submodule(submodule)

end

• def copy_from_es(es_data)
• fork_stat = {}
• fork_stat[:queued] = es_data['queued']
• fork_stat[:priority] = es_data['priority']
• fork_stat[:fetch_time] = es_data['fetch_time']
• fork_stat[:offset_fetch] = es_data['offset_fetch']
• fork_stat[:new_refs_time] = es_data['new_refs_time']
• fork_stat[:offset_new_refs] = es_data['offset_new_refs']
• return fork_stat
• end
• def get_fork_stat(git_repo)
• query = { query: { match: { git_repo: git_repo } } }
• result = @es_client.search(index: 'repo', body: query)['hits']
• return copy_from_es(result['hits'][0]['_source']) if result['total'].positive?
• fork_stat = {

•  queued: false,
  

•  priority: 0,
  

•  fetch_time: [],
  

•  offset_fetch: 0,
  

•  new_refs_time: [],
  

•  offset_new_refs: 0
  

• }
• return fork_stat
• end

end

2.23.0