replicator

Documentation

Index

• type Config
• type Replicator
  • func NewReplicator(clusterMetadata cluster.Metadata, clientBean client.Bean, logger log.Logger, ...) *Replicator
  • func (r *Replicator) Start()
  • func (r *Replicator) Stop()

Types

type Config

type Config struct {
}

Config contains all the replication config for worker

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,
	metricsHandler metrics.Handler,
	hostInfo membership.HostInfo,
	serviceResolver membership.ServiceResolver,
	namespaceReplicationQueue persistence.NamespaceReplicationQueue,
	namespaceReplicationTaskExecutor namespace.ReplicationTaskExecutor,
	matchingClient matchingservice.MatchingServiceClient,
) *Replicator

NewReplicator creates a new replicator for processing replication tasks

func (*Replicator) Start

func (r *Replicator) Start()

Start is called to start replicator

func (*Replicator) Stop

func (r *Replicator) Stop()

Stop is called to stop replicator