summaryrefslogtreecommitdiffstats
path: root/samples/interfaces/mapping
diff options
context:
space:
mode:
authorMaros Marsalek <mmarsale@cisco.com>2016-11-10 13:31:25 +0100
committerMarek Gradzki <mgradzki@cisco.com>2016-11-19 21:29:39 +0100
commit175197da8ea43335df3daeba4c6296fcd83a057c (patch)
tree110298a990c6191933c2ad65d1a06333bab76cee /samples/interfaces/mapping
parent1813bf59fa53e8eb913d34b212d45b227dead799 (diff)
Post split cleanup
- change groupIds - change packages - update poms Change-Id: I343c5a292a67de1dd50687870ca4ab5b7276e93e Signed-off-by: Maros Marsalek <mmarsale@cisco.com> Signed-off-by: Marek Gradzki <mgradzki@cisco.com>
Diffstat (limited to 'samples/interfaces/mapping')
-rw-r--r--samples/interfaces/mapping/asciidoc/Readme.adoc3
-rw-r--r--samples/interfaces/mapping/pom.xml77
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/LowerLayerAccess.java71
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/SampleInterfaceModule.java51
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/cfgattrs/InterfacesPluginConfiguration.java28
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfaceWriterCustomizer.java80
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfacesWriterFactory.java54
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/notification/InterfaceUpNotificationProducer.java96
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/CountersReaderCustomizer.java70
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfaceReaderCustomizer.java120
-rw-r--r--samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfacesReaderFactory.java68
-rw-r--r--samples/interfaces/mapping/src/main/resources/honeycomb-minimal-resources/config/sample-interfaces.json3
12 files changed, 0 insertions, 721 deletions
diff --git a/samples/interfaces/mapping/asciidoc/Readme.adoc b/samples/interfaces/mapping/asciidoc/Readme.adoc
deleted file mode 100644
index a89aee3b8..000000000
--- a/samples/interfaces/mapping/asciidoc/Readme.adoc
+++ /dev/null
@@ -1,3 +0,0 @@
-= interfaces-mapping
-
-Overview of interfaces-mapping \ No newline at end of file
diff --git a/samples/interfaces/mapping/pom.xml b/samples/interfaces/mapping/pom.xml
deleted file mode 100644
index 1bb3a4c97..000000000
--- a/samples/interfaces/mapping/pom.xml
+++ /dev/null
@@ -1,77 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- Copyright (c) 2015 Cisco and/or its affiliates.
- 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.
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <parent>
- <groupId>io.fd.honeycomb.common</groupId>
- <artifactId>impl-parent</artifactId>
- <version>1.16.12-SNAPSHOT</version>
- <relativePath>../../../common/impl-parent</relativePath>
- </parent>
-
- <modelVersion>4.0.0</modelVersion>
- <groupId>io.fd.honeycomb.samples.interfaces</groupId>
- <artifactId>interfaces-mapping</artifactId>
- <name>${project.artifactId}</name>
- <version>1.16.12-SNAPSHOT</version>
- <packaging>bundle</packaging>
-
- <properties>
- <honeycomb.infra.version>1.16.12-SNAPSHOT</honeycomb.infra.version>
- <sonar.skip>true</sonar.skip>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>${project.groupId}</groupId>
- <artifactId>interfaces-models</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <dependency>
- <groupId>com.google.inject</groupId>
- <artifactId>guice</artifactId>
- </dependency>
- <dependency>
- <groupId>net.jmob</groupId>
- <artifactId>guice.conf</artifactId>
- </dependency>
- <dependency>
- <groupId>com.google.inject.extensions</groupId>
- <artifactId>guice-multibindings</artifactId>
- </dependency>
-
- <dependency>
- <groupId>io.fd.honeycomb</groupId>
- <artifactId>translate-impl</artifactId>
- <version>${honeycomb.infra.version}</version>
- </dependency>
- <dependency>
- <groupId>io.fd.honeycomb</groupId>
- <artifactId>translate-api</artifactId>
- <version>${honeycomb.infra.version}</version>
- </dependency>
- <dependency>
- <groupId>io.fd.honeycomb</groupId>
- <artifactId>notification-api</artifactId>
- <version>${honeycomb.infra.version}</version>
- </dependency>
- <dependency>
- <groupId>io.fd.honeycomb</groupId>
- <artifactId>cfg-init</artifactId>
- <version>${honeycomb.infra.version}</version>
- </dependency>
- </dependencies>
-</project>
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/LowerLayerAccess.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/LowerLayerAccess.java
deleted file mode 100644
index 4b815bf35..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/LowerLayerAccess.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping;
-
-import com.google.common.collect.Lists;
-import com.google.inject.Inject;
-import io.fd.honeycomb.samples.interfaces.mapping.cfgattrs.InterfacesPluginConfiguration;
-import io.fd.honeycomb.translate.write.WriteContext;
-import java.util.ArrayList;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.Interface;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This is a sample class representing common resource for readers and writers to access the lower layer
- */
-public final class LowerLayerAccess {
-
- private static final Logger LOG = LoggerFactory.getLogger(LowerLayerAccess.class);
-
- @Inject
- public LowerLayerAccess(@Nonnull final InterfacesPluginConfiguration configuration) {
- LOG.info("Creating lower layer access with configuration: {}", configuration);
- }
-
- public void writeInterface(final InstanceIdentifier<Interface> id, final Interface dataAfter,
- final WriteContext writeContext) {
- LOG.info("Writing interface: {}. to {}", dataAfter, id);
- // This is where actual write/propagation happens
- dataAfter.getMtu();
- }
-
- public void deleteInterface(final InstanceIdentifier<Interface> id, final Interface dataBefore,
- final WriteContext writeContext) {
- LOG.info("Deleting interface: {}. to {}", dataBefore, id);
- final String ifcToBeDeleted = id.firstKeyOf(Interface.class).getInterfaceId().getValue();
- // This is where actual write/propagation happens
- }
-
- public long getTotalPacketsForInterface(final String ifcName) {
- return 500L;
- }
-
- public long getDroppedPacketsForIfc(final String ifcName) {
- return 50L;
- }
-
- public ArrayList<String> getAllInterfaceNames() {
- return Lists.newArrayList("ifc1", "ifc2");
- }
-
- public int getMtuForInterface(final String ifcName) {
- return 66;
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/SampleInterfaceModule.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/SampleInterfaceModule.java
deleted file mode 100644
index ea8a72724..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/SampleInterfaceModule.java
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping;
-
-import com.google.inject.AbstractModule;
-import com.google.inject.Singleton;
-import com.google.inject.multibindings.Multibinder;
-import io.fd.honeycomb.notification.ManagedNotificationProducer;
-import io.fd.honeycomb.samples.interfaces.mapping.cfgattrs.InterfacesPluginConfiguration;
-import io.fd.honeycomb.samples.interfaces.mapping.config.InterfacesWriterFactory;
-import io.fd.honeycomb.samples.interfaces.mapping.notification.InterfaceUpNotificationProducer;
-import io.fd.honeycomb.samples.interfaces.mapping.oper.InterfacesReaderFactory;
-import io.fd.honeycomb.translate.read.ReaderFactory;
-import io.fd.honeycomb.translate.write.WriterFactory;
-import net.jmob.guice.conf.core.ConfigurationModule;
-
-/**
- * This is some glue code necessary for Honeycomb distribution to pick up the plugin classes
- */
-public final class SampleInterfaceModule extends AbstractModule {
-
- @Override
- protected void configure() {
- // These are plugin specific config attributes
- install(ConfigurationModule.create());
- requestInjection(InterfacesPluginConfiguration.class);
-
- // These are plugin's internal components
- bind(LowerLayerAccess.class).in(Singleton.class);
-
- // Below are classes picked up by HC framework
- Multibinder.newSetBinder(binder(), WriterFactory.class).addBinding().to(InterfacesWriterFactory.class);
- Multibinder.newSetBinder(binder(), ReaderFactory.class).addBinding().to(InterfacesReaderFactory.class);
- Multibinder.newSetBinder(binder(), ManagedNotificationProducer.class).addBinding()
- .to(InterfaceUpNotificationProducer.class);
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/cfgattrs/InterfacesPluginConfiguration.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/cfgattrs/InterfacesPluginConfiguration.java
deleted file mode 100644
index 881c18aa0..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/cfgattrs/InterfacesPluginConfiguration.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.cfgattrs;
-
-import net.jmob.guice.conf.core.BindConfig;
-import net.jmob.guice.conf.core.InjectConfig;
-import net.jmob.guice.conf.core.Syntax;
-
-@BindConfig(value = "sample-interfaces", syntax = Syntax.JSON)
-public class InterfacesPluginConfiguration {
-
- @InjectConfig("some-config-attribute")
- String someConfigAttribute;
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfaceWriterCustomizer.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfaceWriterCustomizer.java
deleted file mode 100644
index af185d8b0..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfaceWriterCustomizer.java
+++ /dev/null
@@ -1,80 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.config;
-
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import io.fd.honeycomb.translate.spi.write.ListWriterCustomizer;
-import io.fd.honeycomb.translate.write.WriteContext;
-import io.fd.honeycomb.translate.write.WriteFailedException;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.Interface;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.InterfaceKey;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This is a customizer responsible for writing(updating and also deleting) Interface config data
- */
-public class InterfaceWriterCustomizer implements ListWriterCustomizer<Interface, InterfaceKey> {
-
- private static final Logger LOG = LoggerFactory.getLogger(InterfaceWriterCustomizer.class);
-
- private final LowerLayerAccess access;
-
- public InterfaceWriterCustomizer(final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Override
- public void writeCurrentAttributes(@Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final Interface dataAfter, @Nonnull final WriteContext writeContext)
- throws WriteFailedException {
- try {
- // Context can be used just like the context in ReadCustomizer see InterfaceReaderCustomizer
- // + it also provides a window into the entire configuration tree before current transaction and during current transaction
- // just in case, some additional data is necessary here
- access.writeInterface(id, dataAfter, writeContext);
- } catch (Exception e) {
- throw new WriteFailedException.CreateFailedException(id, dataAfter, e);
- }
- }
-
- @Override
- public void updateCurrentAttributes(@Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final Interface dataBefore, @Nonnull final Interface dataAfter,
- @Nonnull final WriteContext writeContext) throws WriteFailedException {
- // There are cases when lower layer does not support all of the CRUD operations, in which case, the handler
- // should look like this (This will reject configuration from upper layers, returning error/rpc-error):
- throw new WriteFailedException.UpdateFailedException(id, dataBefore, dataAfter,
- new UnsupportedOperationException("Unable to update interface data, unsupported at lower layer"));
- }
-
- @Override
- public void deleteCurrentAttributes(@Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final Interface dataBefore, @Nonnull final WriteContext writeContext)
- throws WriteFailedException {
- try {
- // Context can be used just like the context in ReadCustomizer see InterfaceReaderCustomizer
- // + it also provides a window into the entire configuration tree before current transaction and during current transaction
- // just in case, some additional data is necessary here
- access.deleteInterface(id, dataBefore, writeContext);
- } catch (Exception e) {
- throw new WriteFailedException.DeleteFailedException(id, e);
- }
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfacesWriterFactory.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfacesWriterFactory.java
deleted file mode 100644
index d3b22c345..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/config/InterfacesWriterFactory.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.config;
-
-import com.google.inject.Inject;
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import io.fd.honeycomb.translate.impl.write.GenericListWriter;
-import io.fd.honeycomb.translate.write.WriterFactory;
-import io.fd.honeycomb.translate.write.registry.ModifiableWriterRegistryBuilder;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.Interfaces;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.Interface;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-
-public class InterfacesWriterFactory implements WriterFactory {
-
- @Nonnull
- private final LowerLayerAccess access;
-
- @Inject
- public InterfacesWriterFactory(@Nonnull final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Override
- public void init(@Nonnull final ModifiableWriterRegistryBuilder registry) {
- // ReaderFactory is intended for registering Writers into HC framework
- // Writers handle ONLY config (config "true") data coming from upper layers and propagate them into lower layer/device
- // they are triggered when RESTCONF PUT/POST on config is invoked or when NETCONF edit-config + commit operation is executed
-
- // Our model root for operational data is Interfaces
- final InstanceIdentifier<Interfaces> root = InstanceIdentifier.create(Interfaces.class);
- // But unlike ReaderFactories, there's no need to create a structural writer, we can "ignore" any nodes
- // that do not contain actual data (leaves)
-
- // Next child node is Interface (list)
- final InstanceIdentifier<Interface> ifcListId = root.child(Interface.class);
- registry.add(new GenericListWriter<>(ifcListId, new InterfaceWriterCustomizer(access)));
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/notification/InterfaceUpNotificationProducer.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/notification/InterfaceUpNotificationProducer.java
deleted file mode 100644
index 76d2c5dc8..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/notification/InterfaceUpNotificationProducer.java
+++ /dev/null
@@ -1,96 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.notification;
-
-import com.google.inject.Inject;
-import io.fd.honeycomb.notification.ManagedNotificationProducer;
-import io.fd.honeycomb.notification.NotificationCollector;
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import java.util.Collection;
-import java.util.Collections;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfaceId;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfaceUp;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfaceUpBuilder;
-import org.opendaylight.yangtools.yang.binding.Notification;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Notification producer for sample interfaces plugin
- */
-public class InterfaceUpNotificationProducer implements ManagedNotificationProducer {
-
- private static final Logger LOG = LoggerFactory.getLogger(InterfaceUpNotificationProducer.class);
-
- @Nonnull
- private final LowerLayerAccess access;
-
- private Thread thread;
-
- @Inject
- public InterfaceUpNotificationProducer(@Nonnull final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Override
- public void start(@Nonnull final NotificationCollector collector) {
- LOG.info("Starting notification stream for interfaces");
-
- // Simulating notification producer
- thread = new Thread(() -> {
- while(true) {
- if (Thread.currentThread().isInterrupted()) {
- return;
- }
-
- try {
- Thread.sleep(2000);
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- break;
- }
-
-
- final InterfaceUp ifc1 = new InterfaceUpBuilder().setInterfaceId(new InterfaceId("ifc1")).build();
- LOG.info("Emitting notification: {}", ifc1);
- collector.onNotification(ifc1);
- }
- }, "NotificationProducer");
- thread.setDaemon(true);
- thread.start();
- }
-
- @Override
- public void stop() {
- if(thread != null) {
- thread.interrupt();
- }
- }
-
- @Nonnull
- @Override
- public Collection<Class<? extends Notification>> getNotificationTypes() {
- // Producing only this single type of notification
- return Collections.singleton(InterfaceUp.class);
- }
-
- @Override
- public void close() throws Exception {
- stop();
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/CountersReaderCustomizer.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/CountersReaderCustomizer.java
deleted file mode 100644
index 71476baa3..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/CountersReaderCustomizer.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.oper;
-
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import io.fd.honeycomb.translate.read.ReadContext;
-import io.fd.honeycomb.translate.read.ReadFailedException;
-import io.fd.honeycomb.translate.spi.read.ReaderCustomizer;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810._interface.state.Counters;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810._interface.state.CountersBuilder;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.Interface;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.InterfaceBuilder;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.InterfaceKey;
-import org.opendaylight.yangtools.concepts.Builder;
-import org.opendaylight.yangtools.yang.binding.DataObject;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This is a customizer responsible for reading Counters operational data
- */
-public class CountersReaderCustomizer implements ReaderCustomizer<Counters, CountersBuilder> {
-
- private static final Logger LOG = LoggerFactory.getLogger(CountersReaderCustomizer.class);
- private final LowerLayerAccess access;
-
- public CountersReaderCustomizer(final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Nonnull
- @Override
- public CountersBuilder getBuilder(@Nonnull final InstanceIdentifier<Counters> id) {
- return new CountersBuilder();
- }
-
- @Override
- public void readCurrentAttributes(@Nonnull final InstanceIdentifier<Counters> id,
- @Nonnull final CountersBuilder builder, @Nonnull final ReadContext ctx)
- throws ReadFailedException {
- // Get the information about which interface to get counters for
- final InterfaceKey interfaceKey = id.firstKeyOf(Interface.class);
- LOG.info("Reading counters for interface: {} at {}", interfaceKey.getInterfaceId(), id);
-
- // Set some random data
- builder.setDroppedPackets(access.getDroppedPacketsForIfc(interfaceKey.getInterfaceId().getValue()));
- builder.setTotalPackets(access.getTotalPacketsForInterface(interfaceKey.getInterfaceId().getValue()));
- }
-
- @Override
- public void merge(@Nonnull final Builder<? extends DataObject> parentBuilder, @Nonnull final Counters readValue) {
- ((InterfaceBuilder) parentBuilder).setCounters(readValue);
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfaceReaderCustomizer.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfaceReaderCustomizer.java
deleted file mode 100644
index 850c1396b..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfaceReaderCustomizer.java
+++ /dev/null
@@ -1,120 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.oper;
-
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import io.fd.honeycomb.translate.read.ReadContext;
-import io.fd.honeycomb.translate.read.ReadFailedException;
-import io.fd.honeycomb.translate.spi.read.Initialized;
-import io.fd.honeycomb.translate.spi.read.InitializingListReaderCustomizer;
-import java.util.List;
-import java.util.stream.Collectors;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfaceId;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.Interfaces;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfacesStateBuilder;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.Interface;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.InterfaceBuilder;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.InterfaceKey;
-import org.opendaylight.yangtools.concepts.Builder;
-import org.opendaylight.yangtools.yang.binding.DataObject;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This is a customizer responsible for reading Interface operational data
- */
-public class InterfaceReaderCustomizer implements
- InitializingListReaderCustomizer<Interface, InterfaceKey, InterfaceBuilder> {
-
- private static final Logger LOG = LoggerFactory.getLogger(InterfaceReaderCustomizer.class);
- private final LowerLayerAccess access;
-
- public InterfaceReaderCustomizer(final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Nonnull
- @Override
- public List<InterfaceKey> getAllIds(@Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final ReadContext context) throws ReadFailedException {
- // context can be used to access cache (lifetime during a transaction) to store any information for
- // subsequent invocations or for other customizers
- // context.getModificationCache();
-
- // context can also be used to access context data. Context data are stored in a persistent data store
- // and usually are additional data required to perform the translation in customizers e.g. if underlying layer
- // does not recognize interface-ids as string names, but only indices, the mapping between them can should
- // be stored in the context data store
- // Note: The context datastore is also YANG drive, so context data must be modeled in YANG prior to using them
- // context.getMappingContext();
-
- // return some sample IDs
- return access.getAllInterfaceNames().stream()
- .map(InterfaceId::new)
- .map(InterfaceKey::new)
- .collect(Collectors.toList());
- }
-
- @Override
- public void merge(@Nonnull final Builder<? extends DataObject> builder, @Nonnull final List<Interface> readData) {
- // Just set the result of this customizers read into parent builder
- // Builder has to be cast properly
- ((InterfacesStateBuilder) builder).setInterface(readData);
- }
-
- @Nonnull
- @Override
- public InterfaceBuilder getBuilder(@Nonnull final InstanceIdentifier<Interface> id) {
- // Just providing empty builder
- return new InterfaceBuilder();
- }
-
- @Override
- public void readCurrentAttributes(@Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final InterfaceBuilder builder, @Nonnull final ReadContext ctx)
- throws ReadFailedException {
- // This is where the actual "read" is happening, read attributes for a specific interface
- final InterfaceKey k = id.firstKeyOf(Interface.class);
- final String ifcId = k.getInterfaceId().getValue();
- LOG.info("Reading data for interface: {} at {}", ifcId, id);
-
- // Fill in some random values, this is actually the place where communication with lower layer
- // would occur to get the real values
- builder.setMtu(access.getMtuForInterface(ifcId));
- builder.setInterfaceId(k.getInterfaceId());
- // Counters container is not set here, instead a dedicated customizer is created for it
- // It could be set here, if this customizer + its reader were marked as subtree reader in the ReaderFactory
- // However its a good practice to provide a dedicated reader+customizer for every complex node
- }
-
- @Override
- public Initialized<org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.Interface> init(
- @Nonnull final InstanceIdentifier<Interface> id,
- @Nonnull final Interface readValue,
- @Nonnull final ReadContext ctx) {
- return Initialized.create(InstanceIdentifier.create(Interfaces.class)
- .child(org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.Interface.class,
- new org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.InterfaceKey(
- id.firstKeyOf(Interface.class).getInterfaceId())),
- new org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.InterfaceBuilder()
- .setMtu(readValue.getMtu())
- .setInterfaceId(readValue.getInterfaceId())
- .build());
- }
-}
diff --git a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfacesReaderFactory.java b/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfacesReaderFactory.java
deleted file mode 100644
index 5e34eea74..000000000
--- a/samples/interfaces/mapping/src/main/java/io/fd/honeycomb/samples/interfaces/mapping/oper/InterfacesReaderFactory.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * 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 io.fd.honeycomb.samples.interfaces.mapping.oper;
-
-import com.google.inject.Inject;
-import io.fd.honeycomb.samples.interfaces.mapping.LowerLayerAccess;
-import io.fd.honeycomb.translate.impl.read.GenericListReader;
-import io.fd.honeycomb.translate.impl.read.GenericReader;
-import io.fd.honeycomb.translate.read.ReaderFactory;
-import io.fd.honeycomb.translate.read.registry.ModifiableReaderRegistryBuilder;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfacesState;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.InterfacesStateBuilder;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810._interface.state.Counters;
-import org.opendaylight.yang.gen.v1.io.fd.honeycomb.samples.interfaces.rev160810.interfaces.state.Interface;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-
-public class InterfacesReaderFactory implements ReaderFactory {
-
- @Nonnull
- private final LowerLayerAccess access;
-
- @Inject
- public InterfacesReaderFactory(@Nonnull final LowerLayerAccess access) {
- this.access = access;
- }
-
- @Override
- public void init(@Nonnull final ModifiableReaderRegistryBuilder registry) {
- // ReaderFactory is intended for registering Readers into HC framework
- // Readers provide ONLY operational (config "false") data straight from underlying device/layer
- // they are triggered when RESTCONF GET on operational is invoked or when NETCONF get operation is executed
-
- // Our model root for operational data is InterfacesState
- final InstanceIdentifier<InterfacesState> root = InstanceIdentifier.create(InterfacesState.class);
- // Since InterfacesState has no direct data children (leaves) only a structural reader is registered
- // This reader just fills in the composite hierarchy of readers
- // Honeycomb can't automatically instantiate structural readers and plugins have to help it by invoking as:
- registry.addStructuralReader(root, InterfacesStateBuilder.class);
-
- // Next child node is Interface (list)
- final InstanceIdentifier<Interface> ifcListId = root.child(Interface.class);
- registry.add(new GenericListReader<>(ifcListId, new InterfaceReaderCustomizer(access)));
-
- // Next child is a container Counters
- final InstanceIdentifier<Counters> countersId = ifcListId.child(Counters.class);
- // By adding the reader with addAfter, we can ensure ordering of execution among the readers
- // Useful in cases when a certain read has to be invoked before/after another
- // In this case, we are ensuring that Counters are read after Interface is read
- // "add" could be used instead, leaving the ordering to "nature"
- // Same applies for writers
- registry.addAfter(new GenericReader<>(countersId, new CountersReaderCustomizer(access)), ifcListId);
- }
-}
diff --git a/samples/interfaces/mapping/src/main/resources/honeycomb-minimal-resources/config/sample-interfaces.json b/samples/interfaces/mapping/src/main/resources/honeycomb-minimal-resources/config/sample-interfaces.json
deleted file mode 100644
index 69d527a0e..000000000
--- a/samples/interfaces/mapping/src/main/resources/honeycomb-minimal-resources/config/sample-interfaces.json
+++ /dev/null
@@ -1,3 +0,0 @@
-{
- "some-config-attribute": "some-value"
-} \ No newline at end of file