Home
last modified time | relevance | path

Searched refs:replicator (Results 1 – 25 of 616) sorted by relevance

12345678910>>...25

/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/sensu/sensu_go/tests/integration/molecule/module_etcd_replicator/
H A Dconverge.yml15 - name: Create new replicator (check mode)
17 name: cluster-role-replicator
40 - name: Create new replicator
67 name: cluster-role-replicator
83 name: cluster-role-replicator
90 - name: Update existing replicator
97 name: cluster-role-replicator
115 name: new-replicator
138 name: cluster-role-replicator
153 - name: Delete replicator
[all …]
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch_replicator/priv/
H A Dstats_descriptions.cfg3 {desc, <<"number of failed replicator changes read failures">>}
7 {desc, <<"number of failed replicator changes readers">>}
11 {desc, <<"number of failed replicator changes managers">>}
15 {desc, <<"number of failed replicator changes work queues">>}
31 {desc, <<"number of HTTP requests made by the replicator">>}
51 {desc, <<"number of failed replicator workers">>}
55 {desc, <<"number of replicator workers started">>}
115 {desc, <<"replicator scheduler running jobs">>}
119 {desc, <<"replicator scheduler pending jobs">>}
123 {desc, <<"replicator scheduler crashed jobs">>}
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/
H A DTestReplicationPolicyWithNodeGroup.java117 replicator = fsNamesystem.replicator;
391 targets = replicator.chooseTarget(filename, in testRereplicate1()
395 targets = replicator.chooseTarget(filename, in testRereplicate1()
400 targets = replicator.chooseTarget(filename, in testRereplicate1()
406 targets = replicator.chooseTarget(filename, in testRereplicate1()
429 targets = replicator.chooseTarget(filename, in testRereplicate2()
433 targets = replicator.chooseTarget(filename, in testRereplicate2()
438 targets = replicator.chooseTarget(filename, in testRereplicate2()
460 targets = replicator.chooseTarget(filename, in testRereplicate3()
464 targets = replicator.chooseTarget(filename, in testRereplicate3()
[all …]
H A DTestReplicationPolicy.java85 replicator = fsNamesystem.replicator;
116 targets = replicator.chooseTarget(filename, in testChooseTarget1()
120 targets = replicator.chooseTarget(filename, in testChooseTarget1()
125 targets = replicator.chooseTarget(filename, in testChooseTarget1()
131 targets = replicator.chooseTarget(filename, in testChooseTarget1()
138 targets = replicator.chooseTarget(filename, in testChooseTarget1()
228 targets = replicator.chooseTarget(filename, in testChooseTarget3()
232 targets = replicator.chooseTarget(filename, in testChooseTarget3()
237 targets = replicator.chooseTarget(filename, in testChooseTarget3()
243 targets = replicator.chooseTarget(filename, in testChooseTarget3()
[all …]
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/docs/src/config/
H A Dreplicator.rst19 .. _config/replicator:
43 [replicator]
54 [replicator]
66 [replicator]
77 [replicator]
96 [replicator]
104 [replicator]
111 [replicator]
121 [replicator]
135 [replicator]
[all …]
/dports/net/liveMedia/live/testProgs/
H A DtestReplicator.cpp32 void startReplicaUDPSink(StreamReplicator* replicator, char const* outputAddressStr, portNumBits ou…
33 void startReplicaFileSink(StreamReplicator* replicator, char const* outputFileName); // forward
68 StreamReplicator* replicator = StreamReplicator::createNew(*env, source); in main() local
72 startReplicaUDPSink(replicator, "239.255.43.43", 4444); in main()
76 startReplicaFileSink(replicator, "test.out"); in main()
84 void startReplicaUDPSink(StreamReplicator* replicator, char const* outputAddressStr, portNumBits ou… in startReplicaUDPSink() argument
86 FramedSource* source = replicator->createStreamReplica(); in startReplicaUDPSink()
105 void startReplicaFileSink(StreamReplicator* replicator, char const* outputFileName) { in startReplicaFileSink() argument
107 FramedSource* source = replicator->createStreamReplica(); in startReplicaFileSink()
/dports/sysutils/consul/consul-1.10.3/agent/consul/
H A Dreplication_test.go90 replicator := IndexReplicator{
97 idx, done, err := replicator.Replicate(context.Background(), 0, nil)
109 replicator := IndexReplicator{
117 idx, done, err := replicator.Replicate(context.Background(), 3, nil)
129 replicator := IndexReplicator{
151 replicator := IndexReplicator{
171 replicator := IndexReplicator{
193 replicator := IndexReplicator{
214 replicator := IndexReplicator{
236 replicator := IndexReplicator{
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/agent/consul/
H A Dreplication_test.go88 replicator := IndexReplicator{
95 idx, done, err := replicator.Replicate(context.Background(), 0, nil)
107 replicator := IndexReplicator{
115 idx, done, err := replicator.Replicate(context.Background(), 3, nil)
127 replicator := IndexReplicator{
149 replicator := IndexReplicator{
169 replicator := IndexReplicator{
191 replicator := IndexReplicator{
212 replicator := IndexReplicator{
234 replicator := IndexReplicator{
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/consul/
H A Dreplication_test.go90 replicator := IndexReplicator{
97 idx, done, err := replicator.Replicate(context.Background(), 0, nil)
109 replicator := IndexReplicator{
117 idx, done, err := replicator.Replicate(context.Background(), 3, nil)
129 replicator := IndexReplicator{
151 replicator := IndexReplicator{
171 replicator := IndexReplicator{
193 replicator := IndexReplicator{
214 replicator := IndexReplicator{
236 replicator := IndexReplicator{
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/consul/
H A Dreplication_test.go90 replicator := IndexReplicator{
97 idx, done, err := replicator.Replicate(context.Background(), 0, nil)
109 replicator := IndexReplicator{
117 idx, done, err := replicator.Replicate(context.Background(), 3, nil)
129 replicator := IndexReplicator{
151 replicator := IndexReplicator{
171 replicator := IndexReplicator{
193 replicator := IndexReplicator{
214 replicator := IndexReplicator{
236 replicator := IndexReplicator{
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/consul/
H A Dreplication_test.go88 replicator := IndexReplicator{
95 idx, done, err := replicator.Replicate(context.Background(), 0, nil)
107 replicator := IndexReplicator{
115 idx, done, err := replicator.Replicate(context.Background(), 3, nil)
127 replicator := IndexReplicator{
149 replicator := IndexReplicator{
169 replicator := IndexReplicator{
191 replicator := IndexReplicator{
212 replicator := IndexReplicator{
234 replicator := IndexReplicator{
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Parallel/src/System/Threading/Tasks/
H A DTaskReplicator.cs35 protected Replica(TaskReplicator replicator, int maxConcurrency, int timeout) in Replica() argument
37 _replicator = replicator; in Replica()
109 …public Replica(TaskReplicator replicator, int maxConcurrency, int timeout, ReplicatableUserAction<… in Replica() argument
110 : base(replicator, maxConcurrency, timeout) in Replica()
137 TaskReplicator replicator = new TaskReplicator(options, stopOnFirstFailure); in Run()
138 …new Replica<TState>(replicator, maxConcurrencyLevel, CooperativeMultitaskingTaskTimeout_RootTask, … in Run()
141 while (replicator._pendingReplicas.TryDequeue(out nextReplica)) in Run()
144 if (replicator._exceptions != null) in Run()
145 throw new AggregateException(replicator._exceptions); in Run()
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/txn/
H A DRollbackWorkload.java98 store = openStoreByName(replicator, TEST_DB, readOnly); in openStore()
108 store2 = openStoreByName(replicator, TEST_DB2, readOnly); in openStore2()
117 EntityStore openStoreByName(ReplicatedEnvironment replicator, in openStoreByName() argument
132 return new EntityStore(replicator, storeName, config); in openStoreByName()
139 Set<TestData> dumpData(ReplicatedEnvironment replicator) in dumpData() argument
144 if (openStore(replicator, true /* readOnly */)) { in dumpData()
148 if (openStore2(replicator, true /* readOnly */)) { in dumpData()
210 boolean containsAllData(ReplicatedEnvironment replicator) in containsAllData() argument
213 Set<TestData> dataInStore = dumpData(replicator); in containsAllData()
230 boolean containsSavedData(ReplicatedEnvironment replicator) in containsSavedData() argument
[all …]
/dports/mail/dovecot/dovecot-2.3.17/src/replication/aggregator/
H A Daggregator.c11 struct replicator_connection *replicator; variable
36 replicator = replicator_connection_create_inet(ips, ips_count, in main_preinit()
40 replicator = replicator_connection_create_unix(set->replicator_host, in main_preinit()
71 replicator_connection_destroy(&replicator); in main()
/dports/databases/xapian-core/xapian-core-1.4.18/api/
H A Dreplication.cc456 AutoPtr<DatabaseReplicator> replicator; in possibly_make_offline_live() local
458 replicator.reset(DatabaseReplicator::open(replica_path)); in possibly_make_offline_live()
465 if (!replicator->check_revision_at_least(offline_revision, in possibly_make_offline_live()
470 string replicated_uuid = replicator->get_uuid(); in possibly_make_offline_live()
518 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
520 replica_uuid = replicator->get_uuid(); in apply_next_changeset()
562 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
568 replicator->apply_changeset_from_conn(*conn, 0.0, true); in apply_next_changeset()
582 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
585 offline_revision = replicator-> in apply_next_changeset()
/dports/databases/xapian-core12/xapian-core-1.2.25/api/
H A Dreplication.cc476 AutoPtr<DatabaseReplicator> replicator; in possibly_make_offline_live() local
478 replicator.reset(DatabaseReplicator::open(replica_path)); in possibly_make_offline_live()
485 if (!replicator->check_revision_at_least(offline_revision, in possibly_make_offline_live()
490 string replicated_uuid = replicator->get_uuid(); in possibly_make_offline_live()
543 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
545 replica_uuid = replicator->get_uuid(); in apply_next_changeset()
587 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
593 replicator->apply_changeset_from_conn(*conn, 0.0, true); in apply_next_changeset()
607 AutoPtr<DatabaseReplicator> replicator( in apply_next_changeset() local
610 offline_revision = replicator-> in apply_next_changeset()
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/docs/src/replication/
H A Dreplicator.rst19 .. versionchanged:: 2.1.0 Scheduling replicator was introduced.
41 documents) added to the replicator database are ignored.
456 [replicator]
466 [replicator]
470 other replicator configuration options.
479 that data is ignored by the replicator.
568 Then remove the additional replicator database:
593 <config/replicator.shares>` configuration section.
613 ``_another/replicator``.
619 Replicating the replicator database
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/doc/development/geo/
H A Dframework.md71 ### The replicator
73 First of all, you need to write a replicator. The replicators live in
76 separate replicator specified, even if multiple resources are tied to
79 For example, the following replicator replicates a package file:
92 # Specify the model this replicator belongs to
115 To tie this replicator to the model, you need to add the following to
133 replicator = package_file.replicator
136 Or get the model back from the replicator:
139 replicator.model_record
143 The replicator can be used to generate events, for example in
[all …]
/dports/multimedia/zoneminder/zoneminder-1.36.5/src/
H A Dzm_rtsp_server_unicast_server_media_subsession.h27 StreamReplicator* replicator,
33 StreamReplicator* replicator, in UnicastServerMediaSubsession() argument
39 BaseServerMediaSubsession(replicator), in UnicastServerMediaSubsession()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/alertmanager/
H A Dstate_replication_test.go122 replicator := newFakeReplicator()
123 replicator.read = readStateResult{res: nil, err: nil}
125 …s := newReplicatedStates("user-1", tt.replicationFactor, replicator, store, log.NewNopLogger(), re…
154 replicator.mtx.Lock()
155 defer replicator.mtx.Unlock()
156 return len(replicator.results) == len(tt.results)
316 replicator := newFakeReplicator()
317 replicator.read = tt.read
320 …s := newReplicatedStates("user-1", tt.replicationFactor, replicator, store, log.NewNopLogger(), re…
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/storage-manager/src/
H A DIOCoordinator.cpp56 replicator = Replicator::get(); in IOCoordinator()
370 replicator->updateMetadata(metadata); in _write()
385 replicator->updateMetadata(metadata); in _write()
439 replicator->updateMetadata(metadata); in _write()
550 replicator->updateMetadata(metadata); in _write()
698 replicator->updateMetadata(metadata); in append()
834 err = replicator->updateMetadata(meta); in _truncate()
880 replicator->remove(file); in deleteMetaFile()
891 replicator->remove(cachePath/firstDir/object.key); in deleteMetaFile()
916 replicator->remove(p); in remove()
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/storage-manager/src/
H A DIOCoordinator.cpp56 replicator = Replicator::get(); in IOCoordinator()
370 replicator->updateMetadata(metadata); in _write()
385 replicator->updateMetadata(metadata); in _write()
439 replicator->updateMetadata(metadata); in _write()
550 replicator->updateMetadata(metadata); in _write()
698 replicator->updateMetadata(metadata); in append()
834 err = replicator->updateMetadata(meta); in _truncate()
880 replicator->remove(file); in deleteMetaFile()
891 replicator->remove(cachePath/firstDir/object.key); in deleteMetaFile()
916 replicator->remove(p); in remove()
[all …]
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/
H A DCommitPointConsistencyPolicyTest.java149 final ReplicatedEnvironment replicator; field in CommitPointConsistencyPolicyTest.TxnThread
153 TxnThread(ReplicatedEnvironment replicator, TransactionConfig tc) { in TxnThread() argument
154 this.replicator = replicator; in TxnThread()
161 Transaction txn = replicator.beginTransaction(null, tc); in run()
H A DJoinGroupTest.java260 final RepEnvInfo replicator; field in JoinGroupTest.JoinCommitThread
264 JoinCommitThread(CommitToken commitToken, RepEnvInfo replicator) { in JoinCommitThread() argument
266 this.replicator = replicator; in JoinCommitThread()
272 ReplicatedEnvironment repenv= replicator.openEnv in run()
279 replicator.getEnv().getRepStats(StatsConfig.DEFAULT); in run()
/dports/mail/dovecot/dovecot-2.3.17/src/replication/replicator/
H A DMakefile.in91 pkglibexec_PROGRAMS = replicator$(EXEEXT)
92 subdir = src/replication/replicator
155 dsync-client.$(OBJEXT) replicator.$(OBJEXT) \
156 replicator-brain.$(OBJEXT) replicator-queue.$(OBJEXT) \
157 replicator-queue-auth.$(OBJEXT) replicator-settings.$(OBJEXT) \
185 ./$(DEPDIR)/replicator-brain.Po \
186 ./$(DEPDIR)/replicator-queue-auth.Po \
187 ./$(DEPDIR)/replicator-queue.Po \
188 ./$(DEPDIR)/replicator-settings.Po ./$(DEPDIR)/replicator.Po

12345678910>>...25