Package com.netflix.exhibitor.core.activity

Examples of com.netflix.exhibitor.core.activity.ActivityLog$Message

124
125
126
127
128
129
130
131
132
133
134
    public Exhibitor(ConfigProvider configProvider, Collection<? extends UITab> additionalUITabs, BackupProvider backupProvider, ExhibitorArguments arguments) throws Exception
    {
        System.out.println(getVersion());

        this.arguments = arguments;
        log = new ActivityLog(arguments.logWindowSizeLines);
        this.configManager = new ConfigManager(this, configProvider, arguments.configCheckMs);
        this.additionalUITabs = (additionalUITabs != null) ? ImmutableList.copyOf(additionalUITabs) : ImmutableList.<UITab>of();
        this.processOperations = new StandardProcessOperations(this);
        monitorRunningInstance = new MonitorRunningInstance(this);
        cleanupManager = new CleanupManager(this);
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
{
    @Test
    public void  testGCOldLockFiles() throws Exception
    {
        final BlockingQueue<String>   queue = new ArrayBlockingQueue<String>(1);
        ActivityLog                   mockLog = Mockito.mock(ActivityLog.class);
        MockS3Client                  client = new MockS3Client(null, null)
        {
            @Override
            public void deleteObject(String bucket, String key) throws Exception
            {
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
        final AtomicBoolean             isLocked = new AtomicBoolean(false);
        final AtomicInteger             lockCount = new AtomicInteger(0);

        final MockS3Client              client = new MockS3Client(null, null);
        final ActivityLog               mockLog = Mockito.mock(ActivityLog.class);

        ExecutorCompletionService<Void> completionService = new ExecutorCompletionService<Void>(Executors.newFixedThreadPool(QTY));
        for ( int i = 0; i < QTY; ++i )
        {
            completionService.submit
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
    public void         testMulti() throws Exception
    {
        final int       QTY = 5;
        final int       POLLING_MS = 1;

        ActivityLog     mockLog = Mockito.mock(ActivityLog.class);

        List<S3PseudoLock>  locks = Lists.newArrayList();
        for ( int i = 0; i < QTY; ++i )
        {
            MockS3Client        client = new MockS3Client();
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
    @Test
    public void         testSingle() throws Exception
    {
        MockS3Client        client = new MockS3Client();
        ActivityLog         mockLog = Mockito.mock(ActivityLog.class);

        S3PseudoLock        lock = new S3PseudoLock(client, "foo", "bar", 10000, 1, 0);
        Assert.assertTrue(lock.lock(mockLog, 5, TimeUnit.SECONDS));
        lock.unlock();
    }
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    private final ForkJoinPool mockForkJoinPool;
    private final MockConfigProvider mockConfigProvider;

    MockExhibitorInstance(String hostname) throws Exception
    {
        ActivityLog log = new ActivityLog(100);
        ActivityQueue activityQueue = new ActivityQueue();

        MonitorRunningInstance      monitorRunningInstance = Mockito.mock(MonitorRunningInstance.class);
        Mockito.when(monitorRunningInstance.getCurrentInstanceState()).thenReturn(InstanceStateTypes.SERVING);
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
            {
                return clazz.cast("foo");
            }
        };

        ActivityLog         log = new ActivityLog(100);
        ActivityQueue       activityQueue = new ActivityQueue();
        Exhibitor           mockExhibitor = Mockito.mock(Exhibitor.class);
        MonitorRunningInstance mockMonitorRunningInstance = makeMockMonitorRunningInstance();
        Mockito.when(mockExhibitor.getMonitorRunningInstance()).thenReturn(mockMonitorRunningInstance);
        Mockito.when(mockExhibitor.getLog()).thenReturn(log);
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
            {
                throw new Exception();
            }
        };

        ActivityLog         log = new ActivityLog(100);
        ActivityQueue       activityQueue = new ActivityQueue();
        Exhibitor           mockExhibitor = Mockito.mock(Exhibitor.class);
        MonitorRunningInstance mockMonitorRunningInstance = makeMockMonitorRunningInstance();
        Mockito.when(mockExhibitor.getMonitorRunningInstance()).thenReturn(mockMonitorRunningInstance);
        Mockito.when(mockExhibitor.getLog()).thenReturn(log);
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
            {
                throw new Exception();
            }
        };

        ActivityLog         log = new ActivityLog(100);
        ActivityQueue       activityQueue = new ActivityQueue();
        Exhibitor           mockExhibitor = Mockito.mock(Exhibitor.class);
        MonitorRunningInstance mockMonitorRunningInstance = makeMockMonitorRunningInstance();
        Mockito.when(mockExhibitor.getMonitorRunningInstance()).thenReturn(mockMonitorRunningInstance);
        Mockito.when(mockExhibitor.getLog()).thenReturn(log);
View Full Code Here
282
283
284
285
286
287
288
289
290
291
292
                }
                return clazz.cast("foo");
            }
        };

        ActivityLog         log = new ActivityLog(100);
        ActivityQueue       activityQueue = new ActivityQueue();
        Exhibitor           mockExhibitor = Mockito.mock(Exhibitor.class);
        MonitorRunningInstance mockMonitorRunningInstance = makeMockMonitorRunningInstance();
        Mockito.when(mockExhibitor.getMonitorRunningInstance()).thenReturn(mockMonitorRunningInstance);
        Mockito.when(mockExhibitor.getLog()).thenReturn(log);
View Full Code Here
TOP

Related Classes of com.netflix.exhibitor.core.activity.ActivityLog$Message

  • com.netflix.exhibitor.core.automanage.MockExhibitorInstance
  • com.netflix.exhibitor.core.config.s3.TestS3PseudoLock
  • com.netflix.exhibitor.core.config.TestRollingConfigChange
  • com.netflix.exhibitor.core.Exhibitor
  • de.anomic.search.Switchboard
  • de.anomic.server.serverObjects
  • de.anomic.yacy.yacySeed
  • net.yacy.peers.Seed
  • net.yacy.search.Switchboard
  • org.apache.commons.lang.builder.ReflectionToStringBuilder
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.