You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by sa...@apache.org on 2018/10/08 22:03:18 UTC
[pulsar] 12/13: Fixed unittest
This is an automated email from the ASF dual-hosted git repository.
sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d6c62cf823064d3c136ee423bf0c08f192f1828d
Author: Sanjeev Kulkarni <sa...@streaml.io>
AuthorDate: Mon Oct 8 14:13:45 2018 -0700
Fixed unittest
---
.../apache/pulsar/admin/cli/CmdFunctionsTest.java | 23 +++++++++++-----------
1 file changed, 12 insertions(+), 11 deletions(-)
diff --git a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java
index de5a9e0..0c512b8 100644
--- a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java
+++ b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/CmdFunctionsTest.java
@@ -44,6 +44,7 @@ import org.apache.pulsar.functions.api.Context;
import org.apache.pulsar.functions.api.Function;
import org.apache.pulsar.functions.proto.Function.FunctionDetails;
import org.apache.pulsar.functions.sink.PulsarSink;
+import org.apache.pulsar.functions.utils.FunctionConfig;
import org.apache.pulsar.functions.utils.Reflections;
import org.apache.pulsar.functions.utils.Utils;
import org.powermock.api.mockito.PowerMockito;
@@ -213,7 +214,7 @@ public class CmdFunctionsTest {
assertEquals(outputTopicName, creater.getOutput());
assertEquals(false, creater.isAutoAck());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@@ -343,7 +344,7 @@ public class CmdFunctionsTest {
assertEquals(fnName, creater.getFunctionName());
assertEquals(inputTopicName, creater.getInputs());
assertEquals(outputTopicName, creater.getOutput());
- verify(functions, times(1)).createFunctionWithUrl(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunctionWithUrl(any(FunctionConfig.class), anyString());
}
@Test
@@ -420,7 +421,7 @@ public class CmdFunctionsTest {
assertEquals(topicPatterns, creater.getTopicsPattern());
assertEquals(outputTopicName, creater.getOutput());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@@ -441,7 +442,7 @@ public class CmdFunctionsTest {
CreateFunction creater = cmd.getCreater();
assertEquals("public", creater.getFunctionConfig().getTenant());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@Test
@@ -461,7 +462,7 @@ public class CmdFunctionsTest {
CreateFunction creater = cmd.getCreater();
assertEquals("public", creater.getFunctionConfig().getTenant());
assertEquals("default", creater.getFunctionConfig().getNamespace());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@Test
@@ -486,7 +487,7 @@ public class CmdFunctionsTest {
assertEquals(tenant, creater.getFunctionConfig().getTenant());
assertEquals(namespace, creater.getFunctionConfig().getNamespace());
assertEquals(functionName, creater.getFunctionConfig().getName());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@Test
@@ -505,7 +506,7 @@ public class CmdFunctionsTest {
CreateFunction creater = cmd.getCreater();
assertEquals("CmdFunctionsTest$DummyFunction", creater.getFunctionConfig().getName());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@Test
@@ -522,7 +523,7 @@ public class CmdFunctionsTest {
CreateFunction creater = cmd.getCreater();
assertNull(creater.getFunctionConfig().getOutput());
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
}
@@ -613,7 +614,7 @@ public class CmdFunctionsTest {
assertEquals(inputTopicName, updater.getInputs());
assertEquals(outputTopicName, updater.getOutput());
- verify(functions, times(1)).updateFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).updateFunction(any(FunctionConfig.class), anyString());
}
@Test
@@ -711,9 +712,9 @@ public class CmdFunctionsTest {
}
if (type.equals("create")) {
- verify(functions, times(1)).createFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).createFunction(any(FunctionConfig.class), anyString());
} else if (type.equals("update")) {
- verify(functions, times(1)).updateFunction(any(FunctionDetails.class), anyString());
+ verify(functions, times(1)).updateFunction(any(FunctionConfig.class), anyString());
}
setup();