Module: Arango::Database::Replication

Included in:
Arango::Database
Defined in:
lib/arango/database/replication.rb

Instance Method Summary collapse

Instance Method Details

#cluster_inventory(include_system: nil) ⇒ Object 



15
16
17
18
 
# File 'lib/arango/database/replication.rb', line 15

def cluster_inventory(include_system: nil)
  query = { includeSystem: include_system }
  request("GET", "_api/replication/clusterInventory", query: query)
end

#inventory(batch_id:, global: nil, include_system: nil) ⇒ Object

REPLICATION ===



6
7
8
9
10
11
12
13
 
# File 'lib/arango/database/replication.rb', line 6

def inventory(batch_id:, global: nil, include_system: nil)
  query = {
    batchId: batch_id,
    global: global,
    includeSystem: include_system
  }
  request("GET", "_api/replication/inventory", query: query)
end

#last_tick ⇒ Object 



50
51
52
 
# File 'lib/arango/database/replication.rb', line 50

def last_tick
  request("GET", "_api/wal/lastTick")
end

#logger ⇒ Object 



20
21
22
 
# File 'lib/arango/database/replication.rb', line 20

def logger
  request("GET", "_api/replication/logger-state")
end

#logger_first_tick ⇒ Object 



34
35
36
 
# File 'lib/arango/database/replication.rb', line 34

def logger_first_tick
  request("GET", "_api/replication/logger-first-tick", key: :firstTick)
end

#logger_follow(from: nil, to: nil, chunk_size: nil, include_system: nil) ⇒ Object 



24
25
26
27
28
29
30
31
32
 
# File 'lib/arango/database/replication.rb', line 24

def logger_follow(from: nil, to: nil, chunk_size: nil, include_system: nil)
  query = {
    from: from,
    to:   to,
    chunkSize:     chunk_size,
    includeSystem: include_system
  }
  request("GET", "_api/replication/logger-follow", query: query)
end

#logger_range_tick ⇒ Object 



38
39
40
 
# File 'lib/arango/database/replication.rb', line 38

def logger_range_tick
  request("GET", "_api/replication/logger-tick-ranges")
end

#range ⇒ Object 



46
47
48
 
# File 'lib/arango/database/replication.rb', line 46

def range
  request("GET", "_api/wal/range")
end

#replication(master:, adaptive_polling: nil, auto_resync: nil, auto_resync_retries: nil, chunk_size: nil, connect_timeout: nil, connection_retry_wait_time: nil, idle_max_wait_time: nil, idle_min_wait_time: nil, include_system: true, incremental: nil, initial_sync_max_wait_time: nil, max_connect_retries: nil, request_timeout: nil, require_from_present: nil, restrict_collections: nil, restrict_type: nil, verbose: nil) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/arango/database/replication.rb', line 67

def replication(master:, adaptive_polling: nil, auto_resync: nil, auto_resync_retries: nil, chunk_size: nil, connect_timeout: nil,
                connection_retry_wait_time: nil, idle_max_wait_time: nil, idle_min_wait_time: nil, include_system: true, incremental: nil,
                initial_sync_max_wait_time: nil, max_connect_retries: nil, request_timeout: nil, require_from_present: nil,
                restrict_collections: nil, restrict_type: nil, verbose: nil)
  Arango::Replication.new(slave: self, master: master, adaptive_polling: adaptive_polling, auto_resync: auto_resync,
                          auto_resync_retries: auto_resync_retries, chunk_size: chunk_size, connect_timeout: connect_timeout,
                          connection_retry_wait_time: connection_retry_wait_time, idle_max_wait_time: idle_max_wait_time,
                          idle_min_wait_time: idle_min_wait_time, include_system: include_system, incremental: incremental,
                          initial_sync_max_wait_time: initial_sync_max_wait_time, max_connect_retries: max_connect_retries,
                          request_timeout: request_timeout, require_from_present: require_from_present,
                          restrict_collections: restrict_collections, restrict_type: restrict_type, verbose: verbose)
end

#replication_as_master(slave:, adaptive_polling: nil, auto_resync: nil, auto_resync_retries: nil, chunk_size: nil, connect_timeout: nil, connection_retry_wait_time: nil, idle_max_wait_time: nil, idle_min_wait_time: nil, include_system: true, incremental: nil, initial_sync_max_wait_time: nil, max_connect_retries: nil, request_timeout: nil, require_from_present: nil, restrict_collections: nil, restrict_type: nil, verbose: nil) ⇒ Object 



80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/arango/database/replication.rb', line 80

def replication_as_master(slave:, adaptive_polling: nil, auto_resync: nil, auto_resync_retries: nil, chunk_size: nil, connect_timeout: nil,
                          connection_retry_wait_time: nil, idle_max_wait_time: nil, idle_min_wait_time: nil, include_system: true,
                          incremental: nil, initial_sync_max_wait_time: nil, max_connect_retries: nil, request_timeout: nil,
                          require_from_present: nil, restrict_collections: nil, restrict_type: nil, verbose: nil)
  Arango::Replication.new(master: self, slave: slave, adaptive_polling: adaptive_polling, auto_resync: auto_resync,
                          auto_resync_retries: auto_resync_retries, chunk_size: chunk_size, connect_timeout: connect_timeout,
                          connection_retry_wait_time: connection_retry_wait_time, idle_max_wait_time: idle_max_wait_time,
                          idle_min_wait_time: idle_min_wait_time, include_system: include_system, incremental: incremental,
                          initial_sync_max_wait_time: initial_sync_max_wait_time, max_connect_retries: max_connect_retries,
                          request_timeout: request_timeout, require_from_present: require_from_present,
                          restrict_collections: restrict_collections, restrict_type: restrict_type, verbose: verbose)
end

#server_id ⇒ Object 



42
43
44
 
# File 'lib/arango/database/replication.rb', line 42

def server_id
  request("GET", "_api/replication/server-id", key: :serverId)
end

#tail(from: nil, to: nil, global: nil, chunk_size: nil, server_id: nil, barrier_id: nil) ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/arango/database/replication.rb', line 54

def tail(from: nil, to: nil, global: nil, chunk_size: nil,
         server_id: nil, barrier_id: nil)
  query = {
    from: from,
    to: to,
    barrierID: barrier_id,
    chunkSize: chunk_size,
    global: global,
    serverID: server_id,
  }
  request("GET", "_api/wal/tail", query: query)
end