Package net.sf.katta.protocol

Examples of net.sf.katta.protocol.InteractionProtocol

92
93
94
95
96
97
98
  public ZkClient getZkClient() {
    return _zkServer.getZkClient();
  }

  public InteractionProtocol getInteractionProtocol() {
    return new InteractionProtocol(_zkServer.getZkClient(), _conf);
  }
View Full Code Here
96
97
98
99
100
101
102
  public InteractionProtocol getInteractionProtocol() {
    return new InteractionProtocol(_zkServer.getZkClient(), _conf);
  }

  public InteractionProtocol createInteractionProtocol() {
    return new InteractionProtocol(createZkClient(), _conf);
  }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
59
60
  @Test
  public void testMockRemove() throws Exception {
    String nodeName = "nodeA";
    String someOldShard = AbstractIndexOperation.createShardName("someOldIndex", "someOldShard");
    InteractionProtocol protocol = mock(InteractionProtocol.class);
    MasterQueue queue = mock(MasterQueue.class);
    MasterContext context = new MasterContext(protocol, Mocks.mockMaster(), new DefaultDistributionPolicy(), queue);
    when(protocol.getNodeShards(nodeName)).thenReturn(Arrays.asList(someOldShard));

    RemoveObsoleteShardsOperation operation = new RemoveObsoleteShardsOperation(nodeName);
    operation.execute(context, EMPTY_LIST);

    ArgumentCaptor<NodeOperation> captor = ArgumentCaptor.forClass(NodeOperation.class);
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
79
80
81
  @Test
  public void testNotRemoveDeployingIndex() throws Exception {
    String nodeName = "nodeA";
    String indexName = "someOldIndex";
    String someOldShard = AbstractIndexOperation.createShardName(indexName, "someOldShard");
    InteractionProtocol protocol = mock(InteractionProtocol.class);
    MasterQueue queue = mock(MasterQueue.class);
    MasterContext context = new MasterContext(protocol, Mocks.mockMaster(), new DefaultDistributionPolicy(), queue);
    when(protocol.getNodeShards(nodeName)).thenReturn(Arrays.asList(someOldShard));

    RemoveObsoleteShardsOperation operation = new RemoveObsoleteShardsOperation(nodeName);
    operation.execute(context, new ArrayList<MasterOperation>(Arrays.asList(new IndexDeployOperation(indexName, "path",
            1))));
View Full Code Here
TOP

Related Classes of net.sf.katta.protocol.InteractionProtocol

  • net.sf.katta.client.Client
  • net.sf.katta.client.ClientTest
  • net.sf.katta.client.DeployClient
  • net.sf.katta.DefaultNameSpaceImpl
  • net.sf.katta.integrationTest.DeployPolicyIntegrationTest
  • net.sf.katta.integrationTest.FailoverTest
  • net.sf.katta.integrationTest.lib.sleep.SleepClientTest
  • net.sf.katta.integrationTest.MasterIntegrationTest
  • net.sf.katta.integrationTest.NodeIntegrationTest
  • net.sf.katta.integrationTest.support.KattaMiniCluster
    • 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.