2 * Copyright (c) 2016 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.netconf.topology.singleton.impl.utils;
11 import akka.actor.ActorSystem;
12 import io.netty.util.concurrent.EventExecutor;
13 import org.opendaylight.controller.config.threadpool.ScheduledThreadPool;
14 import org.opendaylight.controller.config.threadpool.ThreadPool;
15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
16 import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
17 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
18 import org.opendaylight.netconf.client.NetconfClientDispatcher;
19 import org.opendaylight.netconf.sal.connect.netconf.NetconfDevice;
20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
22 import scala.concurrent.duration.Duration;
24 public class NetconfTopologySetup {
26 private final ClusterSingletonServiceProvider clusterSingletonServiceProvider;
27 private final RpcProviderRegistry rpcProviderRegistry;
28 private final DataBroker dataBroker;
29 private final InstanceIdentifier<Node> instanceIdentifier;
30 private final Node node;
31 private final ScheduledThreadPool keepaliveExecutor;
32 private final ThreadPool processingExecutor;
33 private final ActorSystem actorSystem;
34 private final EventExecutor eventExecutor;
35 private final NetconfClientDispatcher netconfClientDispatcher;
36 private final String topologyId;
37 private final NetconfDevice.SchemaResourcesDTO schemaResourceDTO;
38 private final Duration idleTimeout;
40 private NetconfTopologySetup(final NetconfTopologySetupBuilder builder) {
41 this.clusterSingletonServiceProvider = builder.getClusterSingletonServiceProvider();
42 this.rpcProviderRegistry = builder.getRpcProviderRegistry();
43 this.dataBroker = builder.getDataBroker();
44 this.instanceIdentifier = builder.getInstanceIdentifier();
45 this.node = builder.getNode();
46 this.keepaliveExecutor = builder.getKeepaliveExecutor();
47 this.processingExecutor = builder.getProcessingExecutor();
48 this.actorSystem = builder.getActorSystem();
49 this.eventExecutor = builder.getEventExecutor();
50 this.netconfClientDispatcher = builder.getNetconfClientDispatcher();
51 this.topologyId = builder.getTopologyId();
52 this.schemaResourceDTO = builder.getSchemaResourceDTO();
53 this.idleTimeout = builder.getIdleTimeout();
56 public ClusterSingletonServiceProvider getClusterSingletonServiceProvider() {
57 return clusterSingletonServiceProvider;
60 public RpcProviderRegistry getRpcProviderRegistry() {
61 return rpcProviderRegistry;
64 public DataBroker getDataBroker() {
68 public InstanceIdentifier<Node> getInstanceIdentifier() {
69 return instanceIdentifier;
72 public Node getNode() {
76 public ThreadPool getProcessingExecutor() {
77 return processingExecutor;
80 public ScheduledThreadPool getKeepaliveExecutor() {
81 return keepaliveExecutor;
84 public ActorSystem getActorSystem() {
88 public EventExecutor getEventExecutor() {
92 public String getTopologyId() {
96 public NetconfClientDispatcher getNetconfClientDispatcher() {
97 return netconfClientDispatcher;
100 public NetconfDevice.SchemaResourcesDTO getSchemaResourcesDTO() {
101 return schemaResourceDTO;
104 public Duration getIdleTimeout() {
108 public static class NetconfTopologySetupBuilder {
110 private ClusterSingletonServiceProvider clusterSingletonServiceProvider;
111 private RpcProviderRegistry rpcProviderRegistry;
112 private DataBroker dataBroker;
113 private InstanceIdentifier<Node> instanceIdentifier;
115 private ScheduledThreadPool keepaliveExecutor;
116 private ThreadPool processingExecutor;
117 private ActorSystem actorSystem;
118 private EventExecutor eventExecutor;
119 private String topologyId;
120 private NetconfClientDispatcher netconfClientDispatcher;
121 private NetconfDevice.SchemaResourcesDTO schemaResourceDTO;
122 private Duration idleTimeout;
124 public NetconfTopologySetupBuilder(){
127 private ClusterSingletonServiceProvider getClusterSingletonServiceProvider() {
128 return clusterSingletonServiceProvider;
131 public NetconfTopologySetupBuilder setClusterSingletonServiceProvider(
132 final ClusterSingletonServiceProvider clusterSingletonServiceProvider) {
133 this.clusterSingletonServiceProvider = clusterSingletonServiceProvider;
137 private RpcProviderRegistry getRpcProviderRegistry() {
138 return rpcProviderRegistry;
141 public NetconfTopologySetupBuilder setRpcProviderRegistry(final RpcProviderRegistry rpcProviderRegistry) {
142 this.rpcProviderRegistry = rpcProviderRegistry;
146 private DataBroker getDataBroker() {
150 public NetconfTopologySetupBuilder setDataBroker(final DataBroker dataBroker) {
151 this.dataBroker = dataBroker;
155 private InstanceIdentifier<Node> getInstanceIdentifier() {
156 return instanceIdentifier;
159 public NetconfTopologySetupBuilder setInstanceIdentifier(final InstanceIdentifier<Node> instanceIdentifier) {
160 this.instanceIdentifier = instanceIdentifier;
164 public Node getNode() {
168 public NetconfTopologySetupBuilder setNode(final Node node) {
173 public NetconfTopologySetup build() {
174 return new NetconfTopologySetup(this);
177 private ScheduledThreadPool getKeepaliveExecutor() {
178 return keepaliveExecutor;
181 public NetconfTopologySetupBuilder setKeepaliveExecutor(final ScheduledThreadPool keepaliveExecutor) {
182 this.keepaliveExecutor = keepaliveExecutor;
186 private ThreadPool getProcessingExecutor() {
187 return processingExecutor;
190 public NetconfTopologySetupBuilder setProcessingExecutor(final ThreadPool processingExecutor) {
191 this.processingExecutor = processingExecutor;
195 private ActorSystem getActorSystem() {
199 public NetconfTopologySetupBuilder setActorSystem(final ActorSystem actorSystem) {
200 this.actorSystem = actorSystem;
204 private EventExecutor getEventExecutor() {
205 return eventExecutor;
208 public NetconfTopologySetupBuilder setEventExecutor(final EventExecutor eventExecutor) {
209 this.eventExecutor = eventExecutor;
213 private String getTopologyId() {
217 public NetconfTopologySetupBuilder setTopologyId(final String topologyId) {
218 this.topologyId = topologyId;
222 private NetconfClientDispatcher getNetconfClientDispatcher() {
223 return netconfClientDispatcher;
226 public NetconfTopologySetupBuilder setNetconfClientDispatcher(final NetconfClientDispatcher clientDispatcher) {
227 this.netconfClientDispatcher = clientDispatcher;
231 public NetconfTopologySetupBuilder setSchemaResourceDTO(
232 final NetconfDevice.SchemaResourcesDTO schemaResourceDTO) {
233 this.schemaResourceDTO = schemaResourceDTO;
237 private NetconfDevice.SchemaResourcesDTO getSchemaResourceDTO() {
238 return schemaResourceDTO;
241 public NetconfTopologySetupBuilder setIdleTimeout(final Duration idleTimeout) {
242 this.idleTimeout = idleTimeout;
246 private Duration getIdleTimeout() {
250 public static NetconfTopologySetupBuilder create() {
251 return new NetconfTopologySetupBuilder();