This file contains 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
import kotlin.random.Random | |
/** | |
* This class holds state about when a task was last | |
* executed and helps determining if it should execute again or not | |
* depending on configuration and the current time | |
*/ | |
class TaskDecider( | |
private val taskIntervalMillis: Long, |
This file contains 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
import org.assertj.core.api.Assertions.assertThat | |
import org.junit.jupiter.api.Test | |
import org.junit.jupiter.api.BeforeEach | |
import org.junit.jupiter.api.AfterEach | |
import io.mockk.clearMocks | |
import io.mockk.every | |
import io.mockk.mockk | |
import io.mockk.verify |
This file contains 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
### Compiles and hot-reloads for development | |
run: | |
NODE_ENV="development" npm run serve | |
prod: | |
NODE_ENV="production" npm run serve | |
#NVM_DIR="${XDG_CONFIG_HOME/:-$HOME/.}nvm" [ -s "$NVM_DIR/nvm.sh" ] && \. "$NVM_DIR/nvm.sh" | |
### Compiles and minifies for production |
This file contains 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
<!-- ________________________________________________________________________________ --> | |
<!-- HTML --> | |
<!-- ________________________________________________________________________________ --> | |
<template> | |
<div class="container has-text-centered"> | |
<h1 class="title">Account</h1> | |
<label-text label="UniqueId">{{uniqueId}}</label-text> | |
<label-text label="Account Balance"> | |
<router-link to="/user/payments">{{amount | currency}}</router-link> |
This file contains 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
import com.fasterxml.jackson.databind.ObjectMapper | |
import org.fissore.slf4j.FluentLoggerFactory | |
import org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent | |
import org.springframework.beans.factory.annotation.Autowired | |
import org.springframework.context.ApplicationListener | |
import org.springframework.context.annotation.Bean | |
import org.springframework.context.annotation.Configuration | |
import java.util.concurrent.ExecutorService | |
import java.util.concurrent.LinkedBlockingQueue |
This file contains 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
<!doctype html> | |
<html lang="en"> | |
<head> | |
<meta charset="utf-8"> | |
<title>Logging Configuration</title> | |
<meta name="description" content=""> | |
<style type="text/css"> | |
/** GLOBAL **/ |
This file contains 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
import com.google.common.io.ByteStreams | |
import com.rabbitmq.client.* | |
import org.apache.flink.configuration.Configuration | |
import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction | |
import org.apache.flink.streaming.api.functions.source.SourceFunction | |
import org.slf4j.LoggerFactory | |
import java.io.IOException | |
import java.util.concurrent.CountDownLatch | |
This file contains 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
package eco.analytics.rabbit | |
import com.rabbitmq.client.* | |
import io.vertx.core.json.JsonObject | |
import io.vertx.rabbitmq.RabbitMQOptions | |
import kotlinx.coroutines.channels.awaitClose | |
import kotlinx.coroutines.flow.Flow | |
import kotlinx.coroutines.flow.callbackFlow | |
import kotlinx.coroutines.flow.flow | |
import org.fissore.slf4j.FluentLoggerFactory |
This file contains 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
import io.micrometer.core.instrument.Metrics | |
import io.micrometer.core.instrument.Tags | |
import com.google.common.util.concurrent.ThreadFactoryBuilder | |
import java.util.concurrent.ExecutorService | |
import java.util.concurrent.SynchronousQueue | |
import java.util.concurrent.ThreadPoolExecutor | |
import java.util.concurrent.TimeUnit | |
@Bean(destroyMethod = "shutdown") | |
fun connectionExecutorService(): ExecutorService { |
This file contains 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
# | |
# Automatically generated file; DO NOT EDIT. | |
# Linux/x86 5.16.12 Kernel Configuration | |
# | |
CONFIG_CC_VERSION_TEXT="gcc (Ubuntu 11.2.0-7ubuntu2) 11.2.0" | |
CONFIG_CC_IS_GCC=y | |
CONFIG_GCC_VERSION=110200 | |
CONFIG_CLANG_VERSION=0 | |
CONFIG_AS_IS_GNU=y | |
CONFIG_AS_VERSION=23700 |
OlderNewer