*/
public class CfgAttrsModule extends AbstractModule {
+ @Override
protected void configure() {
install(ConfigurationModule.create());
// Inject non-dependency configuration
public static final String HONEYCOMB_CONFIG_NONPERSIST = "honeycomb-config-nopersist";
public static final String HONEYCOMB_CONFIG = "honeycomb-config";
+ @Override
protected void configure() {
bind(ShutdownHandler.class).to(ShutdownHandlerImpl.class).in(Singleton.class);
expose(ShutdownHandler.class);
@Inject
private HoneycombConfiguration config;
+ @Override
public TipProducingDataTree create() {
TipProducingDataTree delegate = InMemoryDataTreeFactory.getInstance().create(getType());
delegate.setSchemaContext(schemaService.getGlobalContext());
public abstract TreeType getType();
public static class ConfigDataTreeProvider extends DataTreeProvider {
+ @Override
public TreeType getType() {
return TreeType.CONFIGURATION;
}
}
public static class ContextDataTreeProvider extends DataTreeProvider {
+ @Override
public TreeType getType() {
return TreeType.OPERATIONAL;
}
@Inject(optional = true)
private ReadableDataManager readDataManager;
+ @Override
protected DataBroker create() {
return readDataManager != null
? DataBroker.create(modDataManager, readDataManager)
@Inject
protected HoneycombConfiguration config;
+ @Override
public DataTree create() {
return isEnabled()
? new PersistingDataTreeAdapter(getDelegate(), schemaService, Paths.get(getPath()))
@Named(ConfigAndOperationalPipelineModule.HONEYCOMB_CONFIG_NONPERSIST)
private DataTree delegate;
+ @Override
public String getPath() {
return config.peristConfigPath;
}
+ @Override
public TreeType getType() {
return TreeType.CONFIGURATION;
}
+ @Override
public DataTree getDelegate() {
return delegate;
}
@Named(ContextPipelineModule.HONEYCOMB_CONTEXT_NOPERSIST)
private DataTree delegate;
+ @Override
public String getPath() {
return config.peristContextPath;
}
+ @Override
public TreeType getType() {
return TreeType.OPERATIONAL;
}
+ @Override
public DataTree getDelegate() {
return delegate;
}
@Inject
private ModifiableDataManager modDataManager;
+ @Override
public DataBroker create() {
return DataBroker.create(modDataManager);
}
public static final String HONEYCOMB_INITIALIZER = "honeycomb-initializer";
+ @Override
protected void configure() {
// Create data tree manager on top of non-persisting config data tree
bind(ModifiableDataManager.class).toProvider(ModifiableDTDelegInitProvider.class).in(Singleton.class);
public class SchemaModule extends AbstractModule {
+ @Override
protected void configure() {
bind(ModuleInfoBackedContext.class).toProvider(ModuleInfoBackedCtxProvider.class).in(Singleton.class);
bind(SchemaService.class).toProvider(SchemaServiceProvider.class).in(Singleton.class);
@Inject
private ModuleInfoBackedContext mibCtx;
+ @Override
public StaticSchemaService create() {
return new StaticSchemaService(mibCtx.getSchemaContext());
}
final SchemaContextListener listener) {
listener.onGlobalContextUpdated(schemaContext);
return new ListenerRegistration<SchemaContextListener>() {
+ @Override
public void close() {}
+ @Override
public SchemaContextListener getInstance() {
return listener;
}
public class YangBindingProviderModule extends AbstractModule {
private static final Logger LOG = LoggerFactory.getLogger(YangBindingProviderModule.class);
+ @Override
protected void configure() {
LOG.info("Configuring YangBindingProviderModule");
bind(YangModulesProvider.YangModules.class).toProvider(YangModulesProvider.class).asEagerSingleton();
public final class CommonBgpExtensionsModule extends AbstractModule {
private static final Logger LOG = LoggerFactory.getLogger(CommonBgpExtensionsModule.class);
+ @Override
protected void configure() {
LOG.debug("Initializing CommonBgpExtensionsModule");
// This should be part of BgpModule, but that one is Private and Multibinders + private BASE_MODULES
*/
final class BgpConfigurationModule extends AbstractModule {
+ @Override
protected void configure() {
install(ConfigurationModule.create());
// Inject non-dependency configuration
static final String HONEYCOMB_BGP = "honeycomb-bgp";
+ @Override
protected void configure() {
LOG.debug("Initializing BgpModule");
// Create BGPDispatcher BGPDispatcher for creating BGP clients
public final class BgpReadersModule extends AbstractModule {
private static final Logger LOG = LoggerFactory.getLogger(BgpReadersModule.class);
+ @Override
protected void configure() {
LOG.debug("Initializing BgpReadersModule");
// This should be part of BgpModule, but that one is Private and Multibinders + private BASE_MODULES
public final class BgpWritersModule extends AbstractModule {
private static final Logger LOG = LoggerFactory.getLogger(BgpWritersModule.class);
+ @Override
protected void configure() {
LOG.debug("Initializing BgpWritersModule");
// This should be part of BgpModule, but that one is Private and Multibinders + private BASE_MODULES
super(new NetconfConfigurationModule(), NetconfConfiguration.class);
}
+ @Override
protected void configure() {
if (!getConfiguration().isNetconfEnabled()) {
LOG.debug("NETCONF Northbound disabled, skipping readers initialization");
this.delegate = reader;
}
+ @Override
public ListReader<D, K, B> getDelegate() {
return delegate;
}
Reader<D, B> getDelegate();
+ @Override
@Nonnull
default Optional<? extends DataObject> read(@Nonnull final InstanceIdentifier<? extends DataObject> id,
@Nonnull final ReadContext ctx) throws ReadFailedException {
return getDelegate().read(id, ctx);
}
+ @Override
default void readCurrentAttributes(@Nonnull final InstanceIdentifier<D> id,
- @Nonnull final B builder,
- @Nonnull final ReadContext ctx) throws ReadFailedException {
+ @Nonnull final B builder,
+ @Nonnull final ReadContext ctx) throws ReadFailedException {
getDelegate().readCurrentAttributes(id, builder, ctx);
}
+ @Override
@Nonnull
default B getBuilder(final InstanceIdentifier<D> id) {
return getDelegate().getBuilder(id);
}
+ @Override
default void merge(@Nonnull final Builder<? extends DataObject> parentBuilder,
@Nonnull final D readValue) {
getDelegate().merge(parentBuilder, readValue);
return getDelegate().isPresent(id, built, ctx);
}
+ @Override
@Nonnull
default InstanceIdentifier<D> getManagedDataObjectType() {
return getDelegate().getManagedDataObjectType();
interface DelegatingListReader<D extends DataObject & Identifiable<K>, K extends Identifier<D>, B extends Builder<D>>
extends DelegatingReader<D, B>, ListReader<D, K, B> {
+ @Override
ListReader<D, K, B> getDelegate();
@Override
@Override
public <T extends DataObject> void put(final InstanceIdentifier<T> path, final T data) {}
+ @Override
public void close() {}
}
Code Review / honeycomb.git / commitdiff