lib/extensions/ar_adapter/ar_pglogical/pglogical_raw.rb
# Creates a subscription to a provider node
#
# @param name [String] subscription name
# @param dsn [String] provider node connection string
# @param replication_sets [Array<String>] replication set names to subscribe to
# @param sync_structure [Boolean] sync the schema structure when subscribing
# @param sync_data [Boolean] sync the data when subscribing
# @param forward_origins [Array<String>] names of non-provider nodes to replicate changes from (cascading replication)
Creates a subscription to a provider node
Creates a subscription to a provider node
def subscription_create(name, dsn, replication_sets = %w(default default_insert_only),
                          sync_structure = true, sync_data = true, forward_origins = ["all"])
    command = "SELECT pglogical.create_subscription($1, $2, $3, $4, $5, $6)"
    typed_exec(command, name, dsn, replication_sets, sync_structure, sync_data, forward_origins)
  end
def subscription_create ( name , dsn , replication_sets = %w( default default_insert_only ) , sync_structure = true , sync_data = true , forward_origins = [ "all" ] ) command = "SELECT pglogical.create_subscription($1, $2, $3, $4, $5, $6)" typed_exec ( command , name , dsn , replication_sets , sync_structure , sync_data , forward_origins ) end
Creates a subscription to a provider node
Creates a subscription to a provider node
name
None
dsn
provider node connection string
provider node connection string
replication_sets
replication set names to subscribe to
replication set names to subscribe to
sync_structure
sync the schema structure when subscribing
sync the schema structure when subscribing
sync_data
sync the data when subscribing
sync the data when subscribing
forward_origins
names of non-provider nodes to replicate changes from (cascading replication)
names of non - provider nodes to replicate changes from ( cascading replication )