Auryn Engel auryn31
auryn31
/ SseModel.kt
Created
July 19, 2019 09:26
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| data class SseModel(val event: String? = null, val data: String = "", val id: String? = null, val retry: Number? = null) { | |
| override fun toString(): String { | |
| val sseStrings = arrayListOf<String>() | |
| if(event != null) sseStrings.add("event: $event") | |
| sseStrings.add("data: $data") | |
| if(id != null) sseStrings.add("id: $id") | |
| if(retry != null) sseStrings.add("retry: $retry") | |
| sseStrings.add("\n") |
auryn31
/ RestEndpoint.kt
Created
July 10, 2019 21:25
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @Controller | |
| class RestEndpoint { | |
| var streamResponse: CSVStreamResponseOutput | |
| constructor(csvStreamResponseOutput: CSVStreamResponseOutput) { | |
| this.streamResponse = csvStreamResponseOutput | |
| } | |
| @GetMapping(path = ["stream"], produces = [MediaType.APPLICATION_STREAM_JSON_VALUE]) |
auryn31
/ CSVStreamResponseOutput.kt
Created
July 10, 2019 21:24
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @Component | |
| class CSVStreamResponseOutput : StreamingResponseBody { | |
| var dataProvider: DataProvider | |
| constructor(dataProvider: DataProvider) { | |
| this.dataProvider = dataProvider | |
| } | |
| /** |
auryn31
/ DataProvider.kt
Created
July 10, 2019 21:24
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @Component | |
| class DataProvider { | |
| /** | |
| * create flowable from sampledata.csv | |
| * @return every 100ms one line | |
| */ | |
| fun getDataStream(): Flowable<String> { | |
| val csvFile = this::class.java.getResource("/static/sampledata.csv").openStream() |
auryn31
/ load_sampledata.sh
Created
July 10, 2019 21:22
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| wget https://pysparksampledata.blob.core.windows.net/sampledata/sampledata.csv > sampledata.csv |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| wrk -c 400 -d 10 - latency - timeout 1s http://localhost:8080/cars-locust |
auryn31
/ Dockerfile Wildfly Cluster
Last active
April 25, 2019 09:17
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| FROM jboss/wildfly | |
| ADD helloworld.war /opt/jboss/wildfly/standalone/deployments/ | |
| ARG WILDFLY_NAME | |
| ARG CLUSTER_PW | |
| ENV WILDFLY_NAME=${WILDFLY_NAME} | |
| ENV CLUSTER_PW=${CLUSTER_PW} |
auryn31
/ wildfly docker cluster log
Created
April 25, 2019 09:14
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ... | |
| wildfly1_1 | ... INFO [org.infinispan.CLUSTER] (MSC service thread 1-3) ISPN000094: Received new cluster view for channel ejb: [wildfly_2_test|1] (2) [wildfly_2_test, wildfly_1_test] | |
| wildfly1_1 | ... INFO [org.infinispan.CLUSTER] (MSC service thread 1-5) ISPN000094: Received new cluster view for channel ejb: [wildfly_2_test|1] (2) [wildfly_2_test, wildfly_1_test] | |
| wildfly1_1 | ... INFO [org.infinispan.CLUSTER] (MSC service thread 1-1) ISPN000094: Received new cluster view for channel ejb: [wildfly_2_test|1] (2) [wildfly_2_test, wildfly_1_test] | |
| wildfly1_1 | ... INFO [org.infinispan.CLUSTER] (MSC service thread 1-7) ISPN000094: Received new cluster view for channel ejb: [wildfly_2_test|1] (2) [wildfly_2_test, wildfly_1_test] | |
| ... | |
| wildfly2_1 | ... INFO [org.infinispan.CLUSTER] (remote-thread--p6-t2) [Context=client-mappings] ISPN100002: Starting rebalance with members [wildfly_2_test, wildfly_1_test], phase READ_OLD_WRITE_ALL, topology id 2 |
auryn31
/ docker compose wildfly cluster
Created
April 25, 2019 09:12
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| version: '3.5' | |
| services: | |
| wildfly1: | |
| build: | |
| context: . | |
| args: | |
| WILDFLY_NAME: wildfly_1_test | |
| CLUSTER_PW: secret_password | |
| image: wildfly_1_test |
auryn31
/ wildfly standard start cmd
Created
April 25, 2019 09:10
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| CMD ["/opt/jboss/wildfly/bin/standalone.sh", "-b", "0.0.0.0"] |