Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Replicator ¶
type Replicator struct {
// contains filtered or unexported fields
}
Replicator is the processor for replication tasks
func NewReplicator ¶
func NewReplicator( clusterMetadata cluster.Metadata, clientBean client.Bean, logger log.Logger, metricsClient metrics.Client, hostInfo *membership.HostInfo, serviceResolver membership.ServiceResolver, domainReplicationQueue domain.ReplicationQueue, domainReplicationTaskExecutor domain.ReplicationTaskExecutor, replicationMaxRetry time.Duration, ) *Replicator
NewReplicator creates a new replicator for processing replication tasks
Click to show internal directories.
Click to hide internal directories.