2 * Copyright (c) 2017 Cisco Systems Inc and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.unimgr.mef.nrp.template.driver;
11 import java.util.ArrayList;
12 import java.util.List;
13 import java.util.Optional;
14 import java.util.stream.Collectors;
16 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
17 import org.opendaylight.unimgr.mef.nrp.api.ActivationDriver;
18 import org.opendaylight.unimgr.mef.nrp.api.ActivationDriverBuilder;
19 import org.opendaylight.unimgr.mef.nrp.api.EndPoint;
20 import org.opendaylight.unimgr.mef.nrp.common.ResourceActivatorException;
21 import org.opendaylight.unimgr.mef.nrp.template.TemplateConstants;
22 import org.opendaylight.yang.gen.v1.urn.mef.yang.nrp._interface.rev180321.NrpConnectivityServiceAttrs;
23 import org.slf4j.Logger;
24 import org.slf4j.LoggerFactory;
27 * Example driver builder.
28 * @author bartosz.michalik@amartus.com
30 public class TemplateDriver implements ActivationDriverBuilder {
31 private static final Logger LOG = LoggerFactory.getLogger(TemplateDriver.class);
34 public Optional<ActivationDriver> driverFor(BuilderContext context) {
35 // build a stateful driver
36 // the API contract is following
37 // 1. initialize is called
38 // 2. activate or deactivate metod is called depending on NRP call (update will be supported soon)
39 // 3. if activation/deactivation succeeds for all drivers the commit metod is called
40 // 3a. if activation/deactivation fails for any driver rollback is called
41 return Optional.of(new ActivationDriver() {
43 public List<EndPoint> endpoints;
44 public String serviceId;
47 public void commit() {
48 LOG.info("commit was triggered for {}", serviceId);
52 public void rollback() {
53 LOG.info("rollback was triggered for {}", serviceId);
57 public void initialize(List<EndPoint> endPoints, String serviceId, NrpConnectivityServiceAttrs context) {
58 this.serviceId = serviceId;
59 this.endpoints = new ArrayList<>(endPoints);
61 LOG.info("Driver initialized with: " + epsInfo());
65 public void activate() throws TransactionCommitFailedException, ResourceActivatorException {
66 // method can fail if you wish
67 LOG.info("activate was triggered for {}", serviceId);
71 public void deactivate() throws TransactionCommitFailedException, ResourceActivatorException {
72 // method can fail if you wish
73 LOG.info("dectivate was triggered for {}", serviceId);
77 public void update() throws TransactionCommitFailedException, ResourceActivatorException {
82 public int priority() {
83 //if you would like to make your driver first on the list
88 private String epsInfo() {
89 return endpoints.stream().map(e -> e.getNepRef().getNodeId().getValue() + ":"
90 + e.getNepRef().getOwnedNodeEdgePointId().getValue())
91 .collect(Collectors.joining(",", "[", "]"));
97 public String getActivationDriverId() {
98 return TemplateConstants.DRIVER_ID;