MCPcopy Create free account

hub / github.com/dajudge/kafkaproxy / functions

Functions325 in github.com/dajudge/kafkaproxy

⨍ Functions 325◇ Types & classes 84
↓ 44 callersMethodwithEnv
(final String var, final String value)
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestEnvironment.java:32
↓ 13 callersMethodgetProxy
()
core/src/main/java/com/dajudge/kafkaproxy/BrokerMapping.java:35
↓ 12 callersMethodsafeToString
(final char[] c)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/util/Util.java:43
↓ 10 callersMethodoptionalString
(final String variable)
core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java:27
↓ 8 callersMethodapply
(I t)
itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:90
↓ 8 callersMethodgetBytes
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/KeyStoreData.java:38
↓ 8 callersMethodmtls
(final String keyStoreType)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:157
↓ 7 callersMethodCurrentTimeMillis
()
itests/src/main/clients/dotnet/TimeUtils.cs:10
↓ 6 callersMethodadd
(final KafkaMessage request)
core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaRequestStore.java:40
↓ 6 callersMethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:35
↓ 6 callersMethodparse
(final Environment environment)
core/src/main/java/com/dajudge/kafkaproxy/config/ConfigSource.java:27
↓ 6 callersMethodplaintext
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:161
↓ 6 callersMethodtls
(final String keyStoreType)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:153
↓ 5 callersMethodcreate
( final Environment environment, final Supplier<Long> clock, final Filesys
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:185
↓ 5 callersMethodjoin
(final List<? extends T>... collections)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:175
↓ 5 callersMethodrandomIdentifier
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/util/Util.java:38
↓ 5 callersMethodwithFile
(final String path, final byte[] data)
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestFilesystem.java:28
↓ 4 callersMethodbuild
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:69
↓ 4 callersMethodclose
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:114
↓ 4 callersMethodgetClientSecurity
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/CommunicationSetup.java:23
↓ 4 callersMethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:39
↓ 4 callersMethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:33
↓ 4 callersMethodgetTrustStore
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:45
↓ 4 callersMethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:27
↓ 4 callersMethodnewClient
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java:29
↓ 4 callersMethodrequiredBoolean
(String variable, boolean defaultValue)
core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java:31
↓ 4 callersMethodrequiredString
(final String variable, final String defaultValue)
core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java:23
↓ 4 callersMethodtoString
()
core/src/main/java/com/dajudge/kafkaproxy/BrokerMapping.java:39
↓ 4 callersMethodwithPayload
(final Function<ByteBuf, T> f)
core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:91
↓ 3 callersMethodaccept
(final OutputFrame outputFrame)
itests/src/test/java/com/dajudge/kafkaproxy/itest/util/ToConsoleConsumer.java:32
↓ 3 callersMethodconnectConfig
(final ClientSslConfig sslConfig)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:53
↓ 3 callersMethoddumpConfig
(final String type, final Map<String, Object> config)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:89
↓ 3 callersMethodequals
(final Object o)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:135
↓ 3 callersMethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSslConfig.java:21
↓ 3 callersMethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java:23
↓ 3 callersMethodgetTrustStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:29
↓ 3 callersMethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:31
↓ 3 callersMethodgetType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/KeyStoreData.java:42
↓ 3 callersMethodindent
(final int spaces, final String string)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/util/Util.java:28
↓ 3 callersMethodnextPort
()
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/PortFinder.java:28
↓ 3 callersMethodoptionalString
(final String variable)
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestEnvironment.java:49
↓ 3 callersMethodpoll
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:40
↓ 3 callersMethodtoString
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslCommunicationSetup.java:63
↓ 2 callersMethodadmin
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:67
↓ 2 callersMethodassertDisabled
(Environment env)
core/src/test/java/com/dajudge/kafkaproxy/config/BaseOptionalConfigTest.java:36
↓ 2 callersMethodclose
()
itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:79
↓ 2 callersMethodcorrelationId
()
core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:66
↓ 2 callersMethodcreateSignedKeyPair
(final String dn, final String keystoreType)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/CertAuthority.java:51
↓ 2 callersMethoddata
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:73
↓ 2 callersMethodexec
(final String... command)
itests/src/test/java/com/dajudge/kafkaproxy/itest/util/ITest.java:53
↓ 2 callersMethodgetBootstrapBrokers
()
core/src/main/java/com/dajudge/kafkaproxy/BrokerMapper.java:46
↓ 2 callersMethodgetClientProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:25
↓ 2 callersMethodgetKeyStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:37
↓ 2 callersMethodgetProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java:21
↓ 2 callersMethodgetServerSecurity
(String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/CommunicationSetup.java:21
↓ 2 callersMethodloadKeyStoreConfig
( final Environment environment, final String prefix, final boolean requir
core/src/main/java/com/dajudge/kafkaproxy/config/KeyStoreConfigHelper.java:63
↓ 2 callersMethodloadTrustStoreConfig
( final Environment environment, final String prefix )
core/src/main/java/com/dajudge/kafkaproxy/config/KeyStoreConfigHelper.java:47
↓ 2 callersMethodoptional
(final Class<T> configClass)
core/src/main/java/com/dajudge/kafkaproxy/config/ApplicationConfig.java:39
↓ 2 callersMethodoptionalInt
(final String variable)
core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java:29
↓ 2 callersMethodoptionalString
(final String variable)
core/src/main/java/com/dajudge/kafkaproxy/config/RealEnvironment.java:37
↓ 2 callersMethodpublish
(String uid)
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:36
↓ 2 callersMethodread
(final String path)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:144
↓ 2 callersMethodrequire
(final Class<T> configClass)
core/src/main/java/com/dajudge/kafkaproxy/config/ApplicationConfig.java:44
↓ 2 callersMethodrequiredString
(final String variable, final String defaultValue)
core/src/main/java/com/dajudge/kafkaproxy/config/RealEnvironment.java:25
↓ 2 callersMethodresponseBody
(final RequestHeader requestHeader)
core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:79
↓ 2 callersMethodrewrite
(RequestHeader requestHeader, KafkaMessage message)
core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/ResponseRewriter.java:24
↓ 2 callersMethodrun
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/Startup.java:7
↓ 2 callersMethodwithKafkaProxy
(final ThrowingFunction<String, T> runnable)
itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:35
↓ 2 callersMethodwithSsl
(final String keyStoreType)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/CommunicationSetupBuilder.java:36
↓ 2 callersMethodwrite
(final ChannelHandlerContext ctx, final Object msg, final ChannelPromise promise)
core/src/main/java/com/dajudge/kafkaproxy/protocol/RewritingKafkaMessageDuplexHandler.java:31
↓ 1 callersMethodCreateTopic
()
itests/src/main/clients/dotnet/TestRunner.cs:58
↓ 1 callersMethodDispose
()
itests/src/main/clients/dotnet/PollMaster.cs:44
↓ 1 callersMethodDispose
()
itests/src/main/clients/dotnet/PollThread.cs:63
↓ 1 callersMethodDispose
()
itests/src/main/clients/dotnet/SinkMaster.cs:57
↓ 1 callersMethodGetLastMessageTimestamp
()
itests/src/main/clients/dotnet/PollMaster.cs:39
↓ 1 callersMethodIsSucceeded
()
itests/src/main/clients/dotnet/TestRunner.cs:122
↓ 1 callersMethodPoll
()
itests/src/main/clients/dotnet/Poll.cs:7
↓ 1 callersMethodProduce
()
itests/src/main/clients/dotnet/TestRunner.cs:71
↓ 1 callersMethodPublish
(string message)
itests/src/main/clients/dotnet/Sink.cs:7
↓ 1 callersMethodRandomSink
()
itests/src/main/clients/dotnet/SinkMaster.cs:52
↓ 1 callersMethodReport
()
itests/src/main/clients/dotnet/TestRunner.cs:103
↓ 1 callersMethodStart
()
itests/src/main/clients/dotnet/PollThread.cs:29
↓ 1 callersMethodWaitForConsumers
()
itests/src/main/clients/dotnet/TestRunner.cs:93
↓ 1 callersMethodappliesTo
(RequestHeader requestHeader)
core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/BaseReflectingRewriter.java:76
↓ 1 callersMethodbuildDirectClientFactory
(final KafkaCluster kafka)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:89
↓ 1 callersMethodbuildKafkaCluster
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:155
↓ 1 callersMethodbuildProxiedClientFactory
(final int bootstrapPort)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:85
↓ 1 callersMethodbuildProxyApp
( final KafkaCluster kafka, final int bootstrapPort )
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:93
↓ 1 callersMethodcancel
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:42
↓ 1 callersMethodclose
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:60
↓ 1 callersMethodconfigFile
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:119
↓ 1 callersMethodconfigureDownstream
( final Endpoint downstream, final Optional<DownstreamSslConfig> sslConfig,
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:156
↓ 1 callersMethodconfigureUpstream
( final Optional<UpstreamSslConfig> sslConfig, final Channel upstreamChannel,
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:139
↓ 1 callersMethodconsumer
(final String bootstrapServers, final String topicName, final String groupId)
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:96
↓ 1 callersMethodconsumer
(final String dn, final String groupId)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:79
↓ 1 callersMethodcreateKafkaProxy
(final String kafkaHost, final int kafkaPort)
itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:43
↓ 1 callersMethodcreateProxy
( final ProxyChannelFactory channelFactory, final BrokerMapper brokerMapper,
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:99
↓ 1 callersMethodcreateProxyRuntime
( final ApplicationConfig appConfig, final Supplier<Long> clock, final Fil
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:69
↓ 1 callersMethodcreateTestSetup
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:102
↓ 1 callersMethodcreateTopic
(final String bootstrapServers, final String topicName)
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:88
next →1–100 of 325, ranked by callers