solution: lint
This commit is contained in:
@@ -64,7 +64,7 @@ class AccessLogWriter(
|
|||||||
log.info("Writing Access Log to ${filename.absolutePath}")
|
log.info("Writing Access Log to ${filename.absolutePath}")
|
||||||
scheduler.schedule(runner, START_SLEEP_MS, TimeUnit.MILLISECONDS)
|
scheduler.schedule(runner, START_SLEEP_MS, TimeUnit.MILLISECONDS)
|
||||||
|
|
||||||
//propagate current config to the Event Builder, so it knows which details to include
|
// propagate current config to the Event Builder, so it knows which details to include
|
||||||
EventsBuilder.accessLogConfig = config
|
EventsBuilder.accessLogConfig = config
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -17,9 +17,7 @@ package io.emeraldpay.dshackle.monitoring.accesslog
|
|||||||
|
|
||||||
import io.emeraldpay.api.proto.BlockchainOuterClass
|
import io.emeraldpay.api.proto.BlockchainOuterClass
|
||||||
import io.emeraldpay.api.proto.Common
|
import io.emeraldpay.api.proto.Common
|
||||||
import io.emeraldpay.dshackle.Global
|
|
||||||
import io.emeraldpay.dshackle.config.AccessLogConfig
|
import io.emeraldpay.dshackle.config.AccessLogConfig
|
||||||
import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcError
|
|
||||||
import io.emeraldpay.grpc.Chain
|
import io.emeraldpay.grpc.Chain
|
||||||
import io.grpc.Attributes
|
import io.grpc.Attributes
|
||||||
import io.grpc.Grpc
|
import io.grpc.Grpc
|
||||||
|
|||||||
@@ -23,13 +23,13 @@ import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcException
|
|||||||
import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcRequest
|
import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcRequest
|
||||||
import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcResponse
|
import io.emeraldpay.dshackle.upstream.rpcclient.JsonRpcResponse
|
||||||
import io.emeraldpay.etherjar.rpc.RpcException
|
import io.emeraldpay.etherjar.rpc.RpcException
|
||||||
import java.util.function.BiFunction
|
|
||||||
import java.util.function.Function
|
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
import reactor.core.publisher.Flux
|
import reactor.core.publisher.Flux
|
||||||
import reactor.core.publisher.Mono
|
import reactor.core.publisher.Mono
|
||||||
import reactor.util.function.Tuple2
|
import reactor.util.function.Tuple2
|
||||||
import reactor.util.function.Tuples
|
import reactor.util.function.Tuples
|
||||||
|
import java.util.function.BiFunction
|
||||||
|
import java.util.function.Function
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Makes request with applying Quorum
|
* Makes request with applying Quorum
|
||||||
|
|||||||
Reference in New Issue
Block a user