Make AccountIndexer an interface

For our stack at Google we need to bind another implementation.

Change-Id: Ie369d0aaf71108d1cd4def8f2c9fcfda46bd4ee7
Signed-off-by: Edwin Kempin <ekempin@google.com>
This commit is contained in:
Edwin Kempin
2016-07-08 17:34:55 +02:00
parent fc332099e5
commit 994a5bc91c
3 changed files with 77 additions and 52 deletions

View File

@@ -30,6 +30,7 @@ import com.google.gerrit.server.index.account.AccountIndexCollection;
import com.google.gerrit.server.index.account.AccountIndexDefinition;
import com.google.gerrit.server.index.account.AccountIndexRewriter;
import com.google.gerrit.server.index.account.AccountIndexer;
import com.google.gerrit.server.index.account.AccountIndexerImpl;
import com.google.gerrit.server.index.account.AccountSchemaDefinitions;
import com.google.gerrit.server.index.change.ChangeIndexCollection;
import com.google.gerrit.server.index.change.ChangeIndexDefinition;
@@ -92,7 +93,7 @@ public class IndexModule extends LifecycleModule {
bind(AccountIndexRewriter.class);
bind(AccountIndexCollection.class);
listener().to(AccountIndexCollection.class);
factory(AccountIndexer.Factory.class);
factory(AccountIndexerImpl.Factory.class);
bind(ChangeIndexRewriter.class);
bind(ChangeIndexCollection.class);
@@ -132,7 +133,7 @@ public class IndexModule extends LifecycleModule {
@Provides
@Singleton
AccountIndexer getAccountIndexer(AccountIndexer.Factory factory,
AccountIndexer getAccountIndexer(AccountIndexerImpl.Factory factory,
AccountIndexCollection indexes) {
return factory.create(indexes);
}

View File

@@ -14,64 +14,16 @@
package com.google.gerrit.server.index.account;
import com.google.common.collect.ImmutableSet;
import com.google.gerrit.common.Nullable;
import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.server.account.AccountCache;
import com.google.gerrit.server.account.AccountState;
import com.google.gerrit.server.index.Index;
import com.google.inject.assistedinject.Assisted;
import com.google.inject.assistedinject.AssistedInject;
import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
public class AccountIndexer {
public interface Factory {
AccountIndexer create(AccountIndexCollection indexes);
AccountIndexer create(@Nullable AccountIndex index);
}
private final AccountCache byIdCache;
private final AccountIndexCollection indexes;
private final AccountIndex index;
@AssistedInject
AccountIndexer(AccountCache byIdCache,
@Assisted AccountIndexCollection indexes) {
this.byIdCache = byIdCache;
this.indexes = indexes;
this.index = null;
}
@AssistedInject
AccountIndexer(AccountCache byIdCache,
@Assisted AccountIndex index) {
this.byIdCache = byIdCache;
this.indexes = null;
this.index = index;
}
public interface AccountIndexer {
/**
* Synchronously index an account.
*
* @param id account id to index.
*/
public void index(Account.Id id) throws IOException {
for (Index<?, AccountState> i : getWriteIndexes()) {
i.replace(byIdCache.get(id));
}
}
private Collection<AccountIndex> getWriteIndexes() {
if (indexes != null) {
return indexes.getWriteIndexes();
}
return index != null
? Collections.singleton(index)
: ImmutableSet.<AccountIndex> of();
}
void index(Account.Id id) throws IOException;
}

View File

@@ -0,0 +1,72 @@
// Copyright (C) 2016 The Android Open Source Project
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package com.google.gerrit.server.index.account;
import com.google.common.collect.ImmutableSet;
import com.google.gerrit.common.Nullable;
import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.server.account.AccountCache;
import com.google.gerrit.server.account.AccountState;
import com.google.gerrit.server.index.Index;
import com.google.inject.assistedinject.Assisted;
import com.google.inject.assistedinject.AssistedInject;
import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
public class AccountIndexerImpl implements AccountIndexer {
public interface Factory {
AccountIndexerImpl create(AccountIndexCollection indexes);
AccountIndexerImpl create(@Nullable AccountIndex index);
}
private final AccountCache byIdCache;
private final AccountIndexCollection indexes;
private final AccountIndex index;
@AssistedInject
AccountIndexerImpl(AccountCache byIdCache,
@Assisted AccountIndexCollection indexes) {
this.byIdCache = byIdCache;
this.indexes = indexes;
this.index = null;
}
@AssistedInject
AccountIndexerImpl(AccountCache byIdCache,
@Assisted AccountIndex index) {
this.byIdCache = byIdCache;
this.indexes = null;
this.index = index;
}
@Override
public void index(Account.Id id) throws IOException {
for (Index<?, AccountState> i : getWriteIndexes()) {
i.replace(byIdCache.get(id));
}
}
private Collection<AccountIndex> getWriteIndexes() {
if (indexes != null) {
return indexes.getWriteIndexes();
}
return index != null
? Collections.singleton(index)
: ImmutableSet.<AccountIndex> of();
}
}