Function newActiveReplicatorCommon

db/active_replicator_common.go:85–141

(ctx context.Context, config *ActiveReplicatorConfig, direction ActiveReplicatorDirection)

}

func newActiveReplicatorCommon(ctx context.Context, config *ActiveReplicatorConfig, direction ActiveReplicatorDirection) (*activeReplicatorCommon, error) {

	var replicationStats *BlipSyncStats
	var checkpointID string
	switch direction {
	case ActiveReplicatorTypePush:
		replicationStats = BlipSyncStatsForSGRPush(config.ReplicationStatsMap)
		checkpointID = PushCheckpointID(config.ID)
	case ActiveReplicatorTypePull:
		replicationStats = BlipSyncStatsForSGRPull(config.ReplicationStatsMap)
		checkpointID = PullCheckpointID(config.ID)
	default:
		return nil, fmt.Errorf("Invalid replicator direction: %v", direction)
	}

	if config.CheckpointInterval == 0 {
		config.CheckpointInterval = DefaultCheckpointInterval
	}

	initialStatus, err := LoadReplicationStatus(ctx, config.ActiveDB.DatabaseContext, config.ID)
	if err != nil {
		// Not finding an initialStatus isn't fatal, but we should at least log that we'll reset stats when we do...
		base.InfofCtx(ctx, base.KeyReplicate, "Couldn't load initial replication status for %q: %v - stats will be reset", config.ID, err)
	}

	checkpointID = config.checkpointPrefix + checkpointID

	metakeys := base.DefaultMetadataKeys
	if config.ActiveDB != nil {
		metakeys = config.ActiveDB.MetadataKeys
	}

	arc := activeReplicatorCommon{
		config:           config,
		state:            ReplicationStateStopped,
		replicationStats: replicationStats,
		CheckpointID:     checkpointID,
		initialStatus:    initialStatus,
		statusKey:        metakeys.ReplicationStatusKey(checkpointID),
		direction:        direction,
	}

	if config.CollectionsEnabled {
		arc.namedCollections = make(map[base.ScopeAndCollectionName]*activeReplicatorCollection)
	} else {
		defaultDatabaseCollection, err := config.ActiveDB.GetDefaultDatabaseCollection()
		if err != nil {
			return nil, err
		}
		arc.defaultCollection = &activeReplicatorCollection{
			metadataStore:       config.ActiveDB.MetadataStore,
			collectionDataStore: defaultDatabaseCollection.dataStore,
		}
	}

	return &arc, nil
}