99932a7237792fcb8eb112817497a3ccdd38cd74
[nonrtric.git] / enrichment-coordinator-service / src / main / java / org / oransc / enrichment / repository / EiProducer.java
1 /*-
2  * ========================LICENSE_START=================================
3  * O-RAN-SC
4  * %%
5  * Copyright (C) 2019 Nordix Foundation
6  * %%
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ========================LICENSE_END===================================
19  */
20
21 package org.oransc.enrichment.repository;
22
23 import java.util.Collection;
24
25 import lombok.Getter;
26
27 public class EiProducer {
28     @Getter
29     private final String id;
30
31     @Getter
32     private final Collection<EiType> eiTypes;
33
34     @Getter
35     private final String jobCreationCallbackUrl;
36
37     @Getter
38     private final String jobDeletionCallbackUrl;
39
40     @Getter
41     private final String producerSupervisionCallbackUrl;
42
43     private int unresponsiveCounter = 0;
44
45     public EiProducer(String id, Collection<EiType> eiTypes, String jobCreationCallbackUrl,
46         String jobDeletionCallbackUrl, String producerSupervisionCallbackUrl) {
47         this.id = id;
48         this.eiTypes = eiTypes;
49         this.jobCreationCallbackUrl = jobCreationCallbackUrl;
50         this.jobDeletionCallbackUrl = jobDeletionCallbackUrl;
51         this.producerSupervisionCallbackUrl = producerSupervisionCallbackUrl;
52     }
53
54     public synchronized void setAliveStatus(boolean isAlive) {
55         if (isAlive) {
56             unresponsiveCounter = 0;
57         } else {
58             unresponsiveCounter++;
59         }
60     }
61
62     public synchronized boolean isDead() {
63         return this.unresponsiveCounter >= 3;
64     }
65
66     public synchronized boolean isAvailable() {
67         return this.unresponsiveCounter == 0;
68     }
69
70 }