Function PushCheckpointID

db/active_replicator.go:411–413

(replicationID string)

}

func PushCheckpointID(replicationID string) string {
	return "sgr2cp:push:" + replicationID
}

func PullCheckpointID(replicationID string) string {
	return "sgr2cp:pull:" + replicationID