Function NewPullReplicator

db/active_replicator_pull.go:25–35

NewPullReplicator creates an ISGR pull replicator.

(ctx context.Context, config *ActiveReplicatorConfig)

// NewPullReplicator creates an ISGR pull replicator.
func NewPullReplicator(ctx context.Context, config *ActiveReplicatorConfig) (*ActivePullReplicator, error) {
	replicator, err := newActiveReplicatorCommon(ctx, config, ActiveReplicatorTypePull)
	if err != nil {
		return nil, err
	}
	apr := ActivePullReplicator{
		activeReplicatorCommon: replicator,
	}
	replicator.registerFunctions(apr._getStatus, apr._connect, apr.registerCheckpointerCallbacks)
	return &apr, nil
}

func (apr *ActivePullReplicator) _connect() error {
	var err error