code: func (t *Store) UpdateReplicationToken(token string, source TokenSource) {
  	t.l.Lock()
  	t.replicationToken = token
  	t.replicationTokenSource = source
  	t.l.Unlock()
  }
docs: // UpdateReplicationToken replaces the current replication token in the store.