Skip to content

Commit

Permalink
check
Browse files Browse the repository at this point in the history
  • Loading branch information
@Alonexc
Alonexc committed Apr 10, 2024
1 parent 7b1d72e commit 51dc359
Show file tree
Hide file tree
Showing 7 changed files with 182 additions and 119 deletions.
30 changes: 20 additions & 10 deletions .../eventmesh/dashboard/core/function/SDK/operation/RuntimeGrpcConsumerSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,21 +25,31 @@
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class RuntimeGrpcConsumerSDKOperationTest {

private final RuntimeGrpcConsumerSDKOperation grpcConsumerSDKOperation = new RuntimeGrpcConsumerSDKOperation();

@Test
void testCreateClient() {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10205")
.consumerGroup("EventMeshTest-consumerGroup")
.env("test")
.idc("idc")
.sys("1234")
.build();
final SimpleEntry<String, EventMeshGrpcConsumer> grpcConsumerSimpleEntry =
grpcConsumerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10205", grpcConsumerSimpleEntry.getKey());
SimpleEntry<String, EventMeshGrpcConsumer> grpcConsumerSimpleEntry = null;
try {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10205")
.consumerGroup("EventMeshTest-consumerGroup")
.env("test")
.idc("idc")
.sys("1234")
.build();
grpcConsumerSimpleEntry = grpcConsumerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10205", grpcConsumerSimpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime GRPC consumer client failed", e);
if (grpcConsumerSimpleEntry != null) {
grpcConsumerSimpleEntry.getValue().close();
}
}
}
}
30 changes: 20 additions & 10 deletions .../eventmesh/dashboard/core/function/SDK/operation/RuntimeGrpcProducerSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,21 +25,31 @@
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class RuntimeGrpcProducerSDKOperationTest {

private final RuntimeGrpcProducerSDKOperation grpcProducerSDKOperation = new RuntimeGrpcProducerSDKOperation();

@Test
void testCreateClient() {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10205")
.producerGroup("EventMeshTest-producerGroup")
.env("test")
.idc("idc")
.sys("1234")
.build();
final SimpleEntry<String, EventMeshGrpcProducer> grpcProducerSimpleEntry =
grpcProducerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10205", grpcProducerSimpleEntry.getKey());
SimpleEntry<String, EventMeshGrpcProducer> grpcProducerSimpleEntry = null;
try {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10205")
.producerGroup("EventMeshTest-producerGroup")
.env("test")
.idc("idc")
.sys("1234")
.build();
grpcProducerSimpleEntry = grpcProducerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10205", grpcProducerSimpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime GRPC producer client failed", e);
if (grpcProducerSimpleEntry != null) {
grpcProducerSimpleEntry.getValue().close();
}
}
}
}
38 changes: 24 additions & 14 deletions .../eventmesh/dashboard/core/function/SDK/operation/RuntimeHttpConsumerSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,25 +27,35 @@
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class RuntimeHttpConsumerSDKOperationTest {

private final RuntimeHttpConsumerSDKOperation httpConsumerSDKOperation = new RuntimeHttpConsumerSDKOperation();

@Test
void testCreateClient() {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10105")
.consumerGroup("EventMeshTest-consumerGroup")
.env("test")
.idc("idc")
.ip(IPUtils.getLocalAddress())
.sys("1234")
.pid(String.valueOf(ThreadUtils.getPID()))
.username("eventmesh")
.password("123456")
.build();
final SimpleEntry<String, EventMeshHttpConsumer> httpConsumerSimpleEntry =
httpConsumerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10105", httpConsumerSimpleEntry.getKey());
SimpleEntry<String, EventMeshHttpConsumer> httpConsumerSimpleEntry = null;
try {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10105")
.consumerGroup("EventMeshTest-consumerGroup")
.env("test")
.idc("idc")
.ip(IPUtils.getLocalAddress())
.sys("1234")
.pid(String.valueOf(ThreadUtils.getPID()))
.username("eventmesh")
.password("123456")
.build();
httpConsumerSimpleEntry = httpConsumerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10105", httpConsumerSimpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime GRPC consumer client failed", e);
if (httpConsumerSimpleEntry != null) {
httpConsumerSimpleEntry.getValue().close();
}
}
}
}
38 changes: 24 additions & 14 deletions .../eventmesh/dashboard/core/function/SDK/operation/RuntimeHttpProducerSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,25 +27,35 @@
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class RuntimeHttpProducerSDKOperationTest {

private final RuntimeHttpProducerSDKOperation httpProducerSDKOperation = new RuntimeHttpProducerSDKOperation();

@Test
void testCreateClient() {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10105")
.producerGroup("EventMeshTest-producerGroup")
.env("test")
.idc("idc")
.ip(IPUtils.getLocalAddress())
.sys("1234")
.pid(String.valueOf(ThreadUtils.getPID()))
.username("eventmesh")
.password("123456")
.build();
final SimpleEntry<String, EventMeshHttpProducer> httpProducerSimpleEntry =
httpProducerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10105", httpProducerSimpleEntry.getKey());
SimpleEntry<String, EventMeshHttpProducer> httpProducerSimpleEntry = null;
try {
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10105")
.producerGroup("EventMeshTest-producerGroup")
.env("test")
.idc("idc")
.ip(IPUtils.getLocalAddress())
.sys("1234")
.pid(String.valueOf(ThreadUtils.getPID()))
.username("eventmesh")
.password("123456")
.build();
httpProducerSimpleEntry = httpProducerSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10105", httpProducerSimpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime EventMesh HTTP producer client failed", e);
if (httpProducerSimpleEntry != null) {
httpProducerSimpleEntry.getValue().close();
}
}
}
}
58 changes: 34 additions & 24 deletions ...a/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,35 +28,45 @@
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import lombok.extern.slf4j.Slf4j;

@Slf4j
class RuntimeSDKOperationTest {

private final RuntimeSDKOperation runtimeSDKOperation = new RuntimeSDKOperation();

@Test
void testCreateClient() {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8366)
.subsystem("502")
.pid(32894)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.protocol("TCP")
.protocolName(Constants.EM_MESSAGE_PROTOCOL_NAME)
.userAgent(userAgent)
.build();
final SimpleEntry<String, RuntimeSDKWrapper> sdkWrapperSimpleEntry =
runtimeSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", sdkWrapperSimpleEntry.getKey());
Assertions.assertNotNull(sdkWrapperSimpleEntry.getValue().getTcpEventMeshClient());
SimpleEntry<String, RuntimeSDKWrapper> sdkWrapperSimpleEntry = null;
try {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8366)
.subsystem("502")
.pid(32894)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.protocol("TCP")
.protocolName(Constants.EM_MESSAGE_PROTOCOL_NAME)
.userAgent(userAgent)
.build();
sdkWrapperSimpleEntry = runtimeSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", sdkWrapperSimpleEntry.getKey());
Assertions.assertNotNull(sdkWrapperSimpleEntry.getValue().getTcpEventMeshClient());
} catch (Exception e) {
log.error("create runtime client failed", e);
if (sdkWrapperSimpleEntry != null) {
sdkWrapperSimpleEntry.getValue().close();
}
}
}
}
54 changes: 30 additions & 24 deletions ...eventmesh/dashboard/core/function/SDK/operation/RuntimeTcpCloudEventSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,29 +36,35 @@ public class RuntimeTcpCloudEventSDKOperationTest {

@Test
void testCreateClient() {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8366)
.subsystem("502")
.pid(32894)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
log.info("{}", userAgent);
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.userAgent(userAgent)
.build();
log.info("{}", runtimeConfig);
final SimpleEntry<String, CloudEventTCPClient> simpleEntry =
runtimeTCPPushSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", simpleEntry.getKey());
SimpleEntry<String, CloudEventTCPClient> simpleEntry = null;
try {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8366)
.subsystem("502")
.pid(32894)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
log.info("{}", userAgent);
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.userAgent(userAgent)
.build();
log.info("{}", runtimeConfig);
simpleEntry = runtimeTCPPushSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", simpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime tcp CloudEvent client failed", e);
if (simpleEntry != null) {
simpleEntry.getValue().close();
}
}
}

}
53 changes: 30 additions & 23 deletions .../eventmesh/dashboard/core/function/SDK/operation/RuntimeTcpEventMeshSDKOperationTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,28 +36,35 @@ public class RuntimeTcpEventMeshSDKOperationTest {

@Test
void testCreateClient() {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8365)
.subsystem("501")
.pid(32893)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
log.info("userAgent {}", userAgent);
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.userAgent(userAgent)
.build();
log.info("{}", runtimeConfig);
final SimpleEntry<String, EventMeshMessageTCPClient> simpleEntry =
eventMeshSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", simpleEntry.getKey());
SimpleEntry<String, EventMeshMessageTCPClient> simpleEntry = null;
try {
final UserAgent userAgent = UserAgent.builder()
.env("test")
.host("localhost")
.password("123456")
.username("eventmesh")
.group("EventmeshTestGroup")
.path("/")
.port(8365)
.subsystem("501")
.pid(32893)
.version("2.1")
.idc("A")
.purpose(EventMeshCommon.USER_AGENT_PURPOSE_PUB)
.build();
log.info("userAgent {}", userAgent);
final CreateRuntimeConfig runtimeConfig = CreateRuntimeConfig.builder()
.runtimeServerAddress("127.0.0.1:10000")
.userAgent(userAgent)
.build();
log.info("{}", runtimeConfig);
simpleEntry = eventMeshSDKOperation.createClient(runtimeConfig);
Assertions.assertEquals("127.0.0.1:10000", simpleEntry.getKey());
} catch (Exception e) {
log.error("create runtime tcp EventMeshMessage client failed", e);
if (simpleEntry != null) {
simpleEntry.getValue().close();
}
}
}
}

0 comments on commit 51dc359

Please sign in to comment.