Function NewActiveReplicator

db/active_replicator.go:36–66

NewActiveReplicator returns a bidirectional active replicator for the given config.

(ctx context.Context, config *ActiveReplicatorConfig)

// NewActiveReplicator returns a bidirectional active replicator for the given config.
func NewActiveReplicator(ctx context.Context, config *ActiveReplicatorConfig) (*ActiveReplicator, error) {
	ar := &ActiveReplicator{
		ID:     config.ID,
		config: config,
	}

	if pushReplication := config.Direction == ActiveReplicatorTypePush || config.Direction == ActiveReplicatorTypePushAndPull; pushReplication {
		var err error
		ar.Push, err = NewPushReplicator(ctx, config)
		if err != nil {
			return nil, err
		}
		if ar.config.onComplete != nil {
			ar.Push.onReplicatorComplete = ar._onReplicationComplete
		}
	}

	if pullReplication := config.Direction == ActiveReplicatorTypePull || config.Direction == ActiveReplicatorTypePushAndPull; pullReplication {
		var err error
		ar.Pull, err = NewPullReplicator(ctx, config)
		if err != nil {
			return nil, err
		}
		if ar.config.onComplete != nil {
			ar.Pull.onReplicatorComplete = ar._onReplicationComplete
		}
	}

	base.InfofCtx(ctx, base.KeyReplicate, "Created active replicator ID:%s", config.ID)
	return ar, nil
}

func (ar *ActiveReplicator) Start(ctx context.Context) error {