code: func (t *Store) ReplicationTokenAndSource() (string, TokenSource) {
  	t.l.RLock()
  	defer t.l.RUnlock()
  
  	return t.replicationToken, t.replicationTokenSource
  }
docs: // ReplicationToken returns the replication token.