Add an actor for entity rpc execution.
[controller.git] / opendaylight / md-sal / eos-dom-akka / src / main / java / org / opendaylight / controller / eos / akka / owner / checker / command / GetCandidatesForEntity.java
1 /*
2  * Copyright (c) 2021 PANTHEON.tech, s.r.o. and others.  All rights reserved.
3  *
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
7  */
8 package org.opendaylight.controller.eos.akka.owner.checker.command;
9
10 import static java.util.Objects.requireNonNull;
11
12 import akka.actor.typed.ActorRef;
13 import akka.cluster.ddata.ORMap;
14 import akka.cluster.ddata.ORSet;
15 import akka.cluster.ddata.typed.javadsl.Replicator.GetResponse;
16 import org.eclipse.jdt.annotation.NonNull;
17 import org.eclipse.jdt.annotation.Nullable;
18 import org.opendaylight.mdsal.eos.dom.api.DOMEntity;
19
20 public final class GetCandidatesForEntity extends StateCheckerCommand {
21     private final @Nullable GetResponse<ORMap<DOMEntity, ORSet<String>>> response;
22     private final @NonNull DOMEntity entity;
23     private final @NonNull ActorRef<GetEntityReply> replyTo;
24
25     public GetCandidatesForEntity(final GetResponse<ORMap<DOMEntity, ORSet<String>>> response,
26                                   final DOMEntity entity, final ActorRef<GetEntityReply> replyTo) {
27         this.response = response;
28         this.entity = requireNonNull(entity);
29         this.replyTo = requireNonNull(replyTo);
30     }
31
32     public @Nullable GetResponse<ORMap<DOMEntity, ORSet<String>>> getResponse() {
33         return response;
34     }
35
36     public @NonNull DOMEntity getEntity() {
37         return entity;
38     }
39
40     public @NonNull ActorRef<GetEntityReply> getReplyTo() {
41         return replyTo;
42     }
43 }