Functions — github.com/dajudge/kafkaproxy

hub / github.com/dajudge/kafkaproxy / functions

Functions325 in github.com/dajudge/kafkaproxy

⨍ Functions 325◇ Types & classes 84

↓ 1 callersMethoddisable

(TestEnvironment testEnvironment)

core/src/test/java/com/dajudge/kafkaproxy/config/BaseOptionalConfigTest.java:34

↓ 1 callersMethoddump

(final Consumer<String> dumper)

testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestEnvironment.java:69

↓ 1 callersMethodentrypointScript

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:105

↓ 1 callersMethodfindFreePorts

()

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:54

↓ 1 callersMethodfreePort

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:79

↓ 1 callersMethodfullEnvironment

()

core/src/test/java/com/dajudge/kafkaproxy/config/BaseConfigTest.java:27

↓ 1 callersMethodgetBindAddress

()

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:88

↓ 1 callersMethodgetBootstrapBrokers

(final Environment environment)

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:47

↓ 1 callersMethodgetBootstrapServerList

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaCluster.java:53

↓ 1 callersMethodgetBootstrapServers

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaCluster.java:49

↓ 1 callersMethodgetBrokerMapping

(final Endpoint brokerEndpoint)

core/src/main/java/com/dajudge/kafkaproxy/BrokerMapper.java:39

↓ 1 callersMethodgetClientAuth

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:41

↓ 1 callersMethodgetConfigClass

()

core/src/main/java/com/dajudge/kafkaproxy/config/ConfigSource.java:25

↓ 1 callersMethodgetConnectionAttempts

()

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/ManyConnectsTest.java:35

↓ 1 callersMethodgetDirectClientFactory

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:48

↓ 1 callersMethodgetEndpoint

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/ZookeeperContainer.java:41

↓ 1 callersMethodgetKeyPassword

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSslConfig.java:25

↓ 1 callersMethodgetKeyStore

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:43

↓ 1 callersMethodgetKeyStorePassword

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSslConfig.java:23

↓ 1 callersMethodgetKeyStoreType

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSslConfig.java:27

↓ 1 callersMethodgetProxiedClientFactory

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/TestSetup.java:44

↓ 1 callersMethodgetProxyBasePort

()

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:84

↓ 1 callersMethodgetProxyCertStrategy

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSslConfig.java:29

↓ 1 callersMethodgetProxyEndpoint

()

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:84

↓ 1 callersMethodgetProxyHostname

()

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:80

↓ 1 callersMethodgetTrustStorePassword

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java:25

↓ 1 callersMethodkeyOf

(final Endpoint host)

core/src/main/java/com/dajudge/kafkaproxy/BrokerMapper.java:50

↓ 1 callersMethodkeyStoreOf

( final KeyPair keyPair, final X509Certificate cert, final char[] keyStore

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/CertAuthority.java:70

↓ 1 callersMethodlastMessageTimestamp

()

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:200

↓ 1 callersMethodlengthHeader

(final int payloadBytes)

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:47

↓ 1 callersMethodoptionalKeyStoreConfig

(final Environment environment, final String prefix)

core/src/main/java/com/dajudge/kafkaproxy/config/KeyStoreConfigHelper.java:43

↓ 1 callersMethodparse

(Environment e)

core/src/test/java/com/dajudge/kafkaproxy/config/BaseConfigTest.java:35

↓ 1 callersMethodpasswordFile

( final TestEnvironment env, final TestFilesystem filesystem, final String

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:131

↓ 1 callersMethodprocess

(final KafkaMessage response)

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaRequestStore.java:48

↓ 1 callersMethodproducer

(final String bootstrapServers, final String topicName)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:126

↓ 1 callersMethodproducer

(final String dn)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:73

↓ 1 callersMethodrandomSink

()

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:238

↓ 1 callersMethodrequestHeader

()

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:70

↓ 1 callersMethodrequiredInt

(String proxy_base_port)

core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java:33

↓ 1 callersMethodrequiredKeyStoreConfig

(final Environment environment, final String prefix)

core/src/main/java/com/dajudge/kafkaproxy/config/KeyStoreConfigHelper.java:39

↓ 1 callersMethodrequiredString

(final String variable, final String defaultValue)

testutil/src/main/java/com/dajudge/kafkaproxy/roundtrip/util/TestEnvironment.java:37

↓ 1 callersMethodresponseHeader

(final RequestHeader requestHeader)

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:74

↓ 1 callersMethodrewrite

( final RequestHeader requestHeader, final KafkaMessage message )

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/BaseReflectingRewriter.java:33

↓ 1 callersMethodrewriteMessage

(final RequestHeader requestHeader, final KafkaMessage message)

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/BaseReflectingRewriter.java:49

↓ 1 callersMethodrewriteMessageBody

(final RequestHeader requestHeader, final KafkaMessage message)

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/BaseReflectingRewriter.java:66

↓ 1 callersMethodrunRoundtripTest

( final ClientFactory producerClientFactory, final ClientFactory consumerClientFactory

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java:111

↓ 1 callersMethoduploadKeyStores

(BiConsumer<Transferable, String> uploader)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java:47

↓ 1 callersMethodwithKafka

(final CommunicationSetup communicationSetup)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:59

↓ 1 callersMethodwithMutualTls

(final String keyStoreType)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/CommunicationSetupBuilder.java:40

↓ 1 callersMethodwithPlaintext

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/CommunicationSetupBuilder.java:31

↓ 1 callersMethodwithProxy

(final CommunicationSetup communicationSetup)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java:64

↓ 1 callersMethodwriteToTemp

(final KeyStoreData trustStore)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:47

MethodApplicationConfig

(final Environment environment)

core/src/main/java/com/dajudge/kafkaproxy/config/ApplicationConfig.java:35

MethodBrokerConfig

( final List<Endpoint> bootstrapBrokers, final String proxyHostname,

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java:64

MethodBrokerMapper

(final BrokerConfigSource.BrokerConfig brokerConfig)

core/src/main/java/com/dajudge/kafkaproxy/BrokerMapper.java:33

MethodBrokerMapping

(final Endpoint broker, final Endpoint proxy)

core/src/main/java/com/dajudge/kafkaproxy/BrokerMapping.java:26

MethodCancel

()

itests/src/main/clients/dotnet/ConsumerPoll.cs:22

MethodCertAuthority

(final String dn)

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/CertAuthority.java:38

MethodClientFactory

( final String bootstrapServers, final ClientSecurity clientSecurity )

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/client/ClientFactory.java:45

MethodCommunicationSetupBuilder

()

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/CommunicationSetupBuilder.java:28

MethodCompositeRewriter

(final List<ResponseRewriter> rewriters)

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/CompositeRewriter.java:30

MethodConsumerPoll

( in IConsumer<string, string> consumer )

itests/src/main/clients/dotnet/ConsumerPoll.cs:10

MethodCreatePoll

()

itests/src/main/clients/dotnet/TestRunner.cs:30

MethodCreateSink

()

itests/src/main/clients/dotnet/TestRunner.cs:21

MethodDispose

()

itests/src/main/clients/dotnet/TestRunner.cs:116

MethodDispose

()

itests/src/main/clients/dotnet/SinkMaster.cs:19

MethodDispose

()

itests/src/main/clients/dotnet/ConsumerPoll.cs:27

MethodDispose

()

itests/src/main/clients/dotnet/ProducerSink.cs:28

MethodFindCoordinatorRewriter

(final Function<Endpoint, BrokerMapping> brokerResolver)

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/FindCoordinatorRewriter.java:38

MethodITest

(final String image)

itests/src/test/java/com/dajudge/kafkaproxy/itest/util/ITest.java:46

MethodKafkaCluster

( final List<GenericContainer<?>> containers, final String bootstrapServers )

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaCluster.java:35

MethodKafkaContainer

( final ZookeeperContainer zookeeper, final int brokerId, final Network ne

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/container/KafkaContainer.java:55

MethodKafkaMessage

()

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java:39

MethodKafkaProxyApplication

( final ApplicationConfig appConfig, final Supplier<Long> clock, final Fil

core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java:60

MethodKafkaProxyContainer

()

itests/src/test/java/com/dajudge/kafkaproxy/itest/util/KafkaProxyContainer.java:22

MethodKafkaProxyPorts

(final int proxyPort, final int httpPort)

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:64

MethodKafkaRequestStore

(final ResponseRewriter rewriter)

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaRequestStore.java:36

MethodKafkaWaitStrategy

( final int internalClientPort, final ClientSecurity clientSecurity )

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaWaitStrategy.java:37

MethodKeyStoreConfigHelper

()

core/src/main/java/com/dajudge/kafkaproxy/config/KeyStoreConfigHelper.java:36

MethodKeyStoreData

( final byte[] keyStore, final char[] keyStorePassword, final char[] keyPa

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/ssl/KeyStoreData.java:26

MethodMain

(string[] args)

itests/src/main/clients/dotnet/Startup.cs:10

MethodManyConnectsTest

(final String bootstrapServers)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/ManyConnectsTest.java:15

MethodMetadataRewriter

(final Function<Endpoint, BrokerMapping> brokerResolver)

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/MetadataRewriter.java:36

MethodMultiClientTest

(final String bootstrapServers)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:31

MethodPoll

()

itests/src/main/clients/dotnet/ConsumerPoll.cs:17

MethodPollMaster

(final Set<String> messages, final int pollThreadCount, final Supplier<Poll> pollFactory)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:191

MethodPollMaster

( in ISet<string> messages, in int pollThreadCount, in PollFactory pollFac

itests/src/main/clients/dotnet/PollMaster.cs:13

MethodPollThread

(final Poll poll, final Set<String> messages, final Runnable onMessage)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:151

MethodPollThread

( in Poll poll, in ISet<string> messages, in OnMessageCallback onMessageCa

itests/src/main/clients/dotnet/PollThread.cs:17

MethodProducerSink

( in IProducer<string, string> producer, in string topic )

itests/src/main/clients/dotnet/ProducerSink.cs:10

MethodProxyContainer

(final KafkaProxyContainer container, final String proxyEndpoint)

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java:74

MethodPublish

(string message)

itests/src/main/clients/dotnet/SinkMaster.cs:24

MethodPublish

(string message)

itests/src/main/clients/dotnet/ProducerSink.cs:19

MethodRewritingKafkaMessageDuplexHandler

(final KafkaRequestStore kafkaRequestStore)

core/src/main/java/com/dajudge/kafkaproxy/protocol/RewritingKafkaMessageDuplexHandler.java:27

MethodRun

(object p)

itests/src/main/clients/dotnet/PollThread.cs:34

MethodSinkMaster

(final Set<String> messages, final int sinkCount, final Supplier<Sink> sinkFactory)

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java:220

MethodSinkMaster

( in ISet<string> messages, in int sinkCount, in SinkFactory sinkFactory

itests/src/main/clients/dotnet/SinkMaster.cs:40

MethodSinkWrapper

(Sink wrapped, ISet<string> messages)

itests/src/main/clients/dotnet/SinkMaster.cs:13

MethodSslClientSecurity

( final KeyStoreData trustStore, final Optional<Function<String, KeyStoreData>> keySto

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java:36

MethodSslCommunicationSetup

( final String clientCaDn, final String brokerCaDn, final boolean requireC

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslCommunicationSetup.java:32

← previous next →101–200 of 325, ranked by callers