package org.opendaylight.neutron.transcriber;
+import com.google.common.collect.ImmutableBiMap;
import java.util.ArrayList;
import java.util.List;
-
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronLoadBalancerHealthMonitorCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerHealthMonitor;
import org.opendaylight.neutron.spi.Neutron_ID;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.lbaasv2.rev150712.lbaas.attributes.healthmonitors.HealthmonitorBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.google.common.collect.ImmutableBiMap;
-
-public class NeutronLoadBalancerHealthMonitorInterface extends AbstractNeutronInterface<Healthmonitor, Healthmonitors, NeutronLoadBalancerHealthMonitor> implements INeutronLoadBalancerHealthMonitorCRUD {
+public final class NeutronLoadBalancerHealthMonitorInterface
+ extends AbstractNeutronInterface<Healthmonitor, Healthmonitors, NeutronLoadBalancerHealthMonitor>
+ implements INeutronLoadBalancerHealthMonitorCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronLoadBalancerHealthMonitorInterface.class);
- private static final ImmutableBiMap<Class<? extends ProbeBase>,String> PROBE_MAP
- = new ImmutableBiMap.Builder<Class<? extends ProbeBase>,String>()
- .put(ProbeHttp.class,"HTTP")
- .put(ProbeHttps.class,"HTTPS")
- .put(ProbePing.class,"PING")
- .put(ProbeTcp.class,"TCP")
- .build();
+ private static final ImmutableBiMap<Class<? extends ProbeBase>,
+ String> PROBE_MAP = new ImmutableBiMap.Builder<Class<? extends ProbeBase>, String>()
+ .put(ProbeHttp.class, "HTTP").put(ProbeHttps.class, "HTTPS").put(ProbePing.class, "PING")
+ .put(ProbeTcp.class, "TCP").build();
-
- NeutronLoadBalancerHealthMonitorInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronLoadBalancerHealthMonitorInterface(DataBroker db) {
+ super(HealthmonitorBuilder.class, db);
}
@Override
}
@Override
- protected Healthmonitor toMd(String uuid) {
- final HealthmonitorBuilder healthmonitorBuilder = new HealthmonitorBuilder();
- healthmonitorBuilder.setUuid(toUuid(uuid));
- return healthmonitorBuilder.build();
- }
-
- @Override
- protected InstanceIdentifier<Healthmonitor> createInstanceIdentifier(
- Healthmonitor healthMonitor) {
- return InstanceIdentifier.create(Neutron.class)
- .child(Healthmonitors.class )
- .child(Healthmonitor.class, healthMonitor.getKey());
- }
-
- @Override
- protected InstanceIdentifier<Healthmonitors> createInstanceIdentifier() {
- return InstanceIdentifier.create(Neutron.class)
- .child(Healthmonitors.class);
+ protected InstanceIdentifier<Healthmonitor> createInstanceIdentifier(Healthmonitor healthMonitor) {
+ return InstanceIdentifier.create(Neutron.class).child(Healthmonitors.class).child(Healthmonitor.class,
+ healthMonitor.getKey());
}
@Override
healthmonitorBuilder.setTimeout(Long.valueOf(healthMonitor.getLoadBalancerHealthMonitorTimeout()));
}
if (healthMonitor.getLoadBalancerHealthMonitorType() != null) {
- final ImmutableBiMap<String, Class<? extends ProbeBase>> mapper =
- PROBE_MAP.inverse();
- healthmonitorBuilder.setType((Class<? extends ProbeBase>) mapper.get(healthMonitor.getLoadBalancerHealthMonitorType()));
+ final ImmutableBiMap<String, Class<? extends ProbeBase>> mapper = PROBE_MAP.inverse();
+ healthmonitorBuilder
+ .setType((Class<? extends ProbeBase>) mapper.get(healthMonitor.getLoadBalancerHealthMonitorType()));
}
if (healthMonitor.getLoadBalancerHealthMonitorUrlPath() != null) {
healthmonitorBuilder.setUrlPath(healthMonitor.getLoadBalancerHealthMonitorUrlPath());
protected NeutronLoadBalancerHealthMonitor fromMd(Healthmonitor healthMonitor) {
final NeutronLoadBalancerHealthMonitor answer = new NeutronLoadBalancerHealthMonitor();
if (healthMonitor.isAdminStateUp() != null) {
- answer.setLoadBalancerHealthMonitorAdminStateIsUp(healthMonitor.isAdminStateUp());
+ answer.setLoadBalancerHealthMonitorAdminStateIsUp(healthMonitor.isAdminStateUp());
}
if (healthMonitor.getDelay() != null) {
answer.setLoadBalancerHealthMonitorDelay(healthMonitor.getDelay().intValue());
}
return answer;
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronLoadBalancerHealthMonitorInterface neutronLoadBalancerHealthMonitorInterface = new NeutronLoadBalancerHealthMonitorInterface(providerContext);
- final ServiceRegistration<INeutronLoadBalancerHealthMonitorCRUD> neutronLoadBalancerHealthMonitorInterfaceRegistration = context.registerService(INeutronLoadBalancerHealthMonitorCRUD.class, neutronLoadBalancerHealthMonitorInterface, null);
- if(neutronLoadBalancerHealthMonitorInterfaceRegistration != null) {
- registrations.add(neutronLoadBalancerHealthMonitorInterfaceRegistration);
- }
- }
}