1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.service.slobrok;
import com.yahoo.config.model.api.ApplicationInfo;
import com.yahoo.config.provision.ApplicationId;
import com.yahoo.jrt.Transport;
import com.yahoo.vespa.applicationmodel.ClusterId;
import com.yahoo.vespa.applicationmodel.ConfigId;
import com.yahoo.vespa.applicationmodel.ServiceStatus;
import com.yahoo.vespa.applicationmodel.ServiceType;
import com.yahoo.vespa.service.duper.DuperModelManager;
import org.junit.Before;
import org.junit.Test;
import java.util.Optional;
import java.util.function.Supplier;
import static org.junit.Assert.assertEquals;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
public class SlobrokMonitorManagerImplTest {
// IntelliJ complains if parametrized type is specified, Maven complains if not specified.
@SuppressWarnings("unchecked")
private final Supplier<SlobrokMonitor> slobrokMonitorFactory = mock(Supplier.class);
private final DuperModelManager duperModelManager = mock(DuperModelManager.class);
private final SlobrokMonitorManagerImpl slobrokMonitorManager =
new SlobrokMonitorManagerImpl(slobrokMonitorFactory, mock(Transport.class), duperModelManager);
private final SlobrokMonitor slobrokMonitor = mock(SlobrokMonitor.class);
private final ApplicationId applicationId = ApplicationId.from("tenant", "app", "instance");
private final ApplicationInfo application = mock(ApplicationInfo.class);
private final ClusterId clusterId = new ClusterId("cluster-id");
@Before
public void setup() {
when(slobrokMonitorFactory.get()).thenReturn(slobrokMonitor);
when(application.getApplicationId()).thenReturn(applicationId);
}
@Test
public void testActivationOfApplication() {
slobrokMonitorManager.applicationActivated(application);
verify(slobrokMonitorFactory, times(1)).get();
}
@Test
public void testGetStatus_ApplicationNotInSlobrok() {
when(slobrokMonitor.registeredInSlobrok("config.id")).thenReturn(true);
assertEquals(ServiceStatus.DOWN, getStatus("container"));
}
@Test
public void testGetStatus_ApplicationInSlobrok() {
slobrokMonitorManager.applicationActivated(application);
when(slobrokMonitor.registeredInSlobrok("vespa/service/config.id")).thenReturn(true);
assertEquals(ServiceStatus.UP, getStatus("container"));
}
@Test
public void testGetStatus_ServiceNotInSlobrok() {
slobrokMonitorManager.applicationActivated(application);
when(slobrokMonitor.registeredInSlobrok("storage/cluster.config.id")).thenReturn(false);
assertEquals(ServiceStatus.DOWN, getStatus("storagenode"));
}
@Test
public void testGetStatus_NotChecked() {
assertEquals(ServiceStatus.NOT_CHECKED, getStatus("slobrok"));
verify(slobrokMonitor, times(0)).registeredInSlobrok(any());
}
private ServiceStatus getStatus(String serviceType) {
return slobrokMonitorManager.getStatus(
application.getApplicationId(),
clusterId,
new ServiceType(serviceType), new ConfigId("config.id")).serviceStatus();
}
@Test
public void testLookup() {
assertEquals(
Optional.of("vespa/service/config.id"),
findSlobrokServiceName("container", "config.id"));
assertEquals(
Optional.empty(),
findSlobrokServiceName("logserver", "config.id"));
}
private Optional<String> findSlobrokServiceName(String serviceType, String configId) {
return slobrokMonitorManager.findSlobrokServiceName(
new ServiceType(serviceType),
new ConfigId(configId));
}
}
|
