MCPcopy Create free account

hub / github.com/dajudge/kafkaproxy / functions

Functions325 in github.com/dajudge/kafkaproxy

MethodSslServerSecurity
( final KeyStoreData keyStore, final KeyStoreData trustStore, final boolea
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:33
MethodStarterThread
(final T container)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/StarterThread.java:26
MethodTestConfiguration
( final CommunicationSetup clientComm, final CommunicationSetup brokerComm
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:64
MethodTestRunner
( in string bootstrapServers, in int sinkCount, in int pollCount )
itests/src/main/clients/dotnet/TestRunner.cs:45
MethodTestSetup
( final KafkaCluster kafka, final KafkaProxyApplication proxy, final Clien
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:30
MethodToConsoleConsumer
(final PrintStream stream)
itests/src/test/java/com/dajudge/kafkaproxy/itest/util/ToConsoleConsumer.java:28
MethodUpdateLastMessageTimestamp
()
itests/src/main/clients/dotnet/PollMaster.cs:34
MethodUtil
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/util/Util.java:25
MethodZookeeperContainer
(final Network network)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/ZookeeperContainer.java:32
MethodappliesTo
(final RequestHeader requestHeader)
core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/FindCoordinatorRewriter.java:42
MethodappliesTo
(final RequestHeader requestHeader)
core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/MetadataRewriter.java:65
Methodapply
(final Endpoint brokerEndpoint)
core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:81
MethodassertAllowsUnset
(final String envVar, final Function<C, T> configProperty)
core/src/test/java/com/dajudge/kafkaproxy/config/BaseConfigTest.java:29
Methodbuild
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/CommunicationSetupBuilder.java:55
Methodcancel
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:119
MethodchannelRead
(final ChannelHandlerContext ctx, final Object msg)
core/src/main/java/com/dajudge/kafkaproxy/protocol/RewritingKafkaMessageDuplexHandler.java:37
Methodclose
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:182
Methodclose
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:204
Methodclose
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:230
Methodclose
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaCluster.java:44
Methodclose
()
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/PortFinder.java:39
MethodcontainerIsStarting
(final InspectContainerResponse containerInfo)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:110
MethodcreateNewMessage
()
core/src/main/java/com/dajudge/kafkaproxy/protocol/DecodingKafkaMessageInboundHandler.java:29
Methoddefault_is_disabled
()
core/src/test/java/com/dajudge/kafkaproxy/config/BaseOptionalConfigTest.java:29
Methoddownstream_truststore_is_optional
()
core/src/test/java/com/dajudge/kafkaproxy/config/DownstreamSslConfigTest.java:27
Methodequals
(final Object o)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/ZookeeperContainer.java:45
MethodgetBootstrapBrokers
()
core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:76
MethodgetBroker
()
core/src/main/java/com/dajudge/kafkaproxy/BrokerMapping.java:31
MethodgetClientAuth
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:83
MethodgetClientAuth
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:65
MethodgetClientEndpoint
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:131
MethodgetClientProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:43
MethodgetClientProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:25
MethodgetClientSecurity
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslCommunicationSetup.java:54
MethodgetClientSecurity
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextCommunicationSetup.java:26
MethodgetConfigClass
()
core/src/main/java/com/dajudge/kafkaproxy/config/DownstreamSslConfigSource.java:34
MethodgetConfigClass
()
core/src/main/java/com/dajudge/kafkaproxy/config/UpstreamSslConfigSource.java:35
MethodgetConfigClass
()
core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:32
MethodgetContainer
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/StarterThread.java:50
MethodgetKafka
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:52
MethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/KeyStoreData.java:50
MethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:54
MethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:96
MethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:78
MethodgetKeyPassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:60
MethodgetKeyStore
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:88
MethodgetKeyStore
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:70
MethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:44
MethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:86
MethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:63
MethodgetKeyStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:45
MethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/KeyStoreData.java:46
MethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:49
MethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:91
MethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:68
MethodgetKeyStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:50
MethodgetKeyStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:59
MethodgetKeyStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:101
MethodgetKeyStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:73
MethodgetKeyStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:55
MethodgetProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:21
MethodgetProtocol
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:60
MethodgetProxy
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:56
MethodgetProxyBootstrapPort
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:66
MethodgetProxyCertStrategy
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:64
MethodgetProxyCertStrategy
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:106
MethodgetServerSecurity
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslCommunicationSetup.java:44
MethodgetServerSecurity
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextCommunicationSetup.java:21
MethodgetTrustStore
(final String type)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/CertAuthority.java:82
MethodgetTrustStore
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:93
MethodgetTrustStore
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:75
MethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:26
MethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:66
MethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:48
MethodgetTrustStoreLocation
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:30
MethodgetTrustStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:31
MethodgetTrustStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:71
MethodgetTrustStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:53
MethodgetTrustStorePassword
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:35
MethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:36
MethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java:27
MethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:76
MethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java:58
MethodgetTrustStoreType
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java:40
MethodhashCode
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/ZookeeperContainer.java:50
MethodhashCode
()
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:140
Methodmain
(final String[] args)
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/Startup.java:10
MethodnewClient
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java:41
MethodnewClient
(final String dn)
core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:81
MethodnextChunkSize
(final List<ByteBuf> list)
core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:53
MethodonMessageComplete
(final ChannelHandlerContext ctx, final KafkaMessage msg)
core/src/main/java/com/dajudge/kafkaproxy/protocol/DecodingKafkaMessageInboundHandler.java:24
MethodonStart
(@Observes StartupEvent ev)
app/src/main/java/com/dajudge/kafkaproxy/Startup.java:35
MethodonStop
(@Observes ShutdownEvent ev)
app/src/main/java/com/dajudge/kafkaproxy/Startup.java:39
MethodoptionalInt
(final String variable)
core/src/main/java/com/dajudge/kafkaproxy/config/RealEnvironment.java:42
MethodoptionalInt
(final String variable)
testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestEnvironment.java:54
Methodparse
(final Environment environment)
core/src/main/java/com/dajudge/kafkaproxy/config/DownstreamSslConfigSource.java:39
Methodparse
(final Environment environment)
core/src/main/java/com/dajudge/kafkaproxy/config/UpstreamSslConfigSource.java:40
Methodparse
(final Environment environment)
core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:37
Methodpoll
()
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:107
Methodpublish
(final String uid)
itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:134
← previousnext →201–300 of 325, ranked by callers