MCPcopy Create free account

hub / github.com/andreas-schroeder/kafka-health-check / functions

Functions188 in github.com/andreas-schroeder/kafka-health-check

⨍ Functions 188◇ Types & classes 22
↓ 46 callersMethodEXPECT
()
check/connectors_mock.go:102
↓ 21 callersFunctionnewTestCheck
()
check/test_helpers.go:14
↓ 19 callersMethodClose
()
check/connectors.go:57
↓ 14 callersMethodExists
(path string)
check/connectors.go:58
↓ 12 callersMethodConnect
(servers []string, sessionTimeout time.Duration)
check/connectors.go:56
↓ 10 callersMethodGet
(path string)
check/connectors.go:62
↓ 10 callersFunctionhealthyMetadata
(topicNames ...string)
check/test_helpers.go:104
↓ 10 callersFunctionmockBroker
(check *HealthCheck, ctrl *gomock.Controller)
check/test_helpers.go:36
↓ 10 callersFunctionnewZkTestCheck
(ctrl *gomock.Controller)
check/test_helpers.go:338
↓ 9 callersMethodcheckClusterHealth
periodically checks health of the Kafka cluster
check/cluster_health_check.go:10
↓ 9 callersFunctioncontains
(a []int32, el int32)
check/int32_slice.go:3
↓ 9 callersFunctioncreateZkNode
(zookeeper ZkConnection, path string, content string, failIfExists bool)
check/setup.go:251
↓ 9 callersFunctionsimpleStatus
(status string)
check/status.go:61
↓ 8 callersFunctionNewMockZkConnection
(ctrl *gomock.Controller)
check/connectors_mock.go:96
↓ 8 callersMethodPrintf
(string, ...interface{})
check/connectors.go:73
↓ 7 callersMethodDial
(nodeAddresses []string, conf kafka.BrokerConf)
check/connectors.go:13
↓ 7 callersMethodfindPartitionID
(topicName string, forHealthCheck bool, createIfMissing *bool, metadata *proto.MetadataResp)
check/setup.go:74
↓ 7 callersFunctionhealthyZkBrokers
()
check/test_helpers.go:209
↓ 7 callersMethodmockSuccessfulPathCreation
(path string)
check/test_helpers.go:354
↓ 6 callersMethodCreate
(path string, data []byte, flags int32, acl []zk.ACL)
check/connectors.go:60
↓ 6 callersMethodMetadata
()
check/connectors.go:19
↓ 6 callersMethodcheckBrokerHealth
sends one message to the broker partition, wait for it to appear on the consumer.
check/broker_health_check.go:13
↓ 5 callersMethodChildren
(path string)
check/connectors.go:61
↓ 5 callersMethodConsumer
(conf kafka.ConsumerConf)
check/connectors.go:15
↓ 5 callersMethodProducer
(conf kafka.ProducerConf)
check/connectors.go:17
↓ 5 callersMethodcreateTopic
(name string, forHealthCheck bool)
check/setup.go:149
↓ 5 callersMethoddeleteTopic
(zkConn ZkConnection, chroot, name string, partitionID int32)
check/setup.go:290
↓ 5 callersFunctionhealthyZkTopics
()
check/test_helpers.go:178
↓ 5 callersFunctionworkingBroker
(check *HealthCheck, ctrl *gomock.Controller, stop <-chan struct{})
check/test_helpers.go:52
↓ 5 callersFunctionworstStatus
(s1 string, s2 string)
check/cluster_health_check.go:119
↓ 5 callersFunctionzookeeperEnsembleAndChroot
(connectString string)
check/setup.go:133
↓ 4 callersFunctionnewServerSetup
()
check/status_server_testhelpers_test.go:12
↓ 4 callersFunctionoutOfSyncMetadata
(topicNames ...string)
check/test_helpers.go:141
↓ 4 callersMethodtryConnectOnce
(createBrokerTopic, createReplicationTopic *bool)
check/setup.go:31
↓ 4 callersFunctionzkPartitions
(topic *ZkTopic, zk ZkConnection, name, chroot string)
check/zk_metadata.go:73
↓ 3 callersMethodmockFailingPathCreation
(path string)
check/test_helpers.go:359
↓ 3 callersMethodmockTopicGet
(name string)
check/test_helpers.go:350
↓ 3 callersFunctionvalidTopicName
(name string)
check/parse_args.go:65
↓ 2 callersMethodCheckHealth
CheckHealth checks broker and cluster health.
check/health_check.go:57
↓ 2 callersMethodServeHealth
ServeHealth answers http queries for broker and cluster health.
check/status_server.go:14
↓ 2 callersMethodSummary
()
check/status.go:19
↓ 2 callersMethodcloseConnection
(deleteTopicIfPresent bool)
check/setup.go:272
↓ 2 callersMethodconnect
(firstConnection bool, stop <-chan struct{})
check/setup.go:14
↓ 2 callersFunctionfindTopic
(name string, metadata *proto.MetadataResp)
check/setup.go:114
↓ 2 callersFunctionmetadataWithoutTopic
()
check/test_helpers.go:324
↓ 2 callersFunctionnewUpdate
(report StatusReport, name string)
check/health_check.go:112
↓ 2 callersFunctionreassignPartition
(zk ZkConnection, partitionID int32, replicas []int32, topicName, chroot string)
check/setup.go:218
↓ 2 callersFunctionstopAll
(zkID, kafkaID string, hcCmd *exec.Cmd)
compatibility/test.go:159
↓ 2 callersFunctionwaitForExpectedResponse
(url, expected string)
check/status_server_testhelpers_test.go:46
↓ 2 callersFunctionwaitForResponse
(url, expected string)
compatibility/test.go:195
↓ 2 callersFunctionwaitForResponse
(url string, t *testing.T)
check/status_server_testhelpers_test.go:26
↓ 1 callersMethodJson
()
check/status.go:20
↓ 1 callersFunctionNewMockBrokerConnection
(ctrl *gomock.Controller)
check/connectors_mock.go:25
↓ 1 callersMethodParseCommandLineArguments
ParseCommandLineArguments parses the command line arguments.
check/parse_args.go:15
↓ 1 callersMethodSet
(path string, data []byte, version int32)
check/connectors.go:59
↓ 1 callersFunctionaddShutdownHook
()
main.go:24
↓ 1 callersFunctionbrokenBroker
(check *HealthCheck, ctrl *gomock.Controller)
check/test_helpers.go:75
↓ 1 callersMethodbrokerConfig
()
check/health_check.go:121
↓ 1 callersFunctionbrokerExists
(brokerID int32, metadata *proto.MetadataResp)
check/setup.go:124
↓ 1 callersMethodbrokerInSync
checks whether the broker is in all ISRs of all partitions it replicates.
check/broker_health_check.go:57
↓ 1 callersMethodbrokerReplicates
(brokerStatus *BrokerStatus, metadata *proto.MetadataResp)
check/broker_health_check.go:78
↓ 1 callersFunctionbuildDocker
(tag string, dir string, buildArgs ...string)
compatibility/test.go:225
↓ 1 callersMethodcheckBrokerMetadata
(metadata *proto.MetadataResp, zkBrokers []int32, cluster *ClusterStatus)
check/cluster_health_check.go:18
↓ 1 callersFunctioncheckPartition
(partition *proto.MetadataRespPartition, zkTopic *ZkTopic, topicStatus *TopicStatus)
check/cluster_health_check.go:83
↓ 1 callersMethodcheckTopics
(metadata *proto.MetadataResp, zkTopics []ZkTopic, cluster *ClusterStatus)
check/cluster_health_check.go:41
↓ 1 callersFunctioncleanup
cleaning up intermediately created docker files.
compatibility/test.go:261
↓ 1 callersMethodconsumerConfig
()
check/health_check.go:128
↓ 1 callersFunctiondelAll
(a []int32, el int32)
check/int32_slice.go:27
↓ 1 callersFunctiondelAt
(a []int32, i int)
check/int32_slice.go:21
↓ 1 callersFunctiondetermineIp
()
compatibility/test.go:63
↓ 1 callersFunctiondockerBuildArgs
(tag string, dir string, buildArgs []string)
compatibility/test.go:239
↓ 1 callersMethodgetZooKeeperMetadata
()
check/zk_metadata.go:16
↓ 1 callersFunctioninSyncMetadata
()
check/test_helpers.go:250
↓ 1 callersFunctionindexOf
(a []int32, el int32)
check/int32_slice.go:12
↓ 1 callersFunctionmaybeExpandReplicationTopic
(zk ZkConnection, brokerID, partitionID int32, topicName, chroot string)
check/setup.go:197
↓ 1 callersFunctionmetadataWithoutBroker
()
check/test_helpers.go:311
↓ 1 callersFunctionmissingZkBrokers
()
check/test_helpers.go:213
↓ 1 callersMethodmockGet
(path, data string)
check/test_helpers.go:346
↓ 1 callersMethodmockHealthyMetadata
(topics ...string)
check/test_helpers.go:364
↓ 1 callersFunctionmustReplaceBuildArgs
Docker versions prior to 1.9 do not support --build-args
compatibility/test.go:305
↓ 1 callersFunctionofflineMetadata
()
check/test_helpers.go:283
↓ 1 callersFunctionparseVersionSpecs
(baseDir string)
compatibility/test.go:325
↓ 1 callersFunctionpartitionMissingZkTopics
()
check/test_helpers.go:200
↓ 1 callersMethodproducerConfig
()
check/health_check.go:137
↓ 1 callersFunctionrandomBytes
creates a random message payload. based on the solution http://stackoverflow.com/a/31832326 provided by http://stackoverflow.com/users/1705598/icza
check/broker_health_check.go:108
↓ 1 callersMethodreconnect
(stop <-chan struct{})
check/setup.go:331
↓ 1 callersFunctionreplaceBuildArgs
(dir string, buildArgs []string)
compatibility/test.go:270
↓ 1 callersFunctionreplicaMissingZkTopics
()
check/test_helpers.go:189
↓ 1 callersFunctionrunTest
(tag string, spec versionSpec, healthCheckCommand string)
compatibility/test.go:91
↓ 1 callersFunctionstartAll
(tag, healthCheckCommand string)
compatibility/test.go:115
↓ 1 callersFunctionunderReplicatedMetadata
()
check/test_helpers.go:217
↓ 1 callersMethodvalidateConfig
(l *log.Logger)
check/parse_args.go:48
↓ 1 callersMethodwaitForMessage
waits for a message with the payload of the given message to appear on the consumer side.
check/broker_health_check.go:35
↓ 1 callersMethodwaitForTopicDeletion
(topicPath string)
check/setup.go:318
↓ 1 callersFunctionwaitForZooKeeper
()
compatibility/test.go:170
↓ 1 callersFunctionzkBrokers
(zk ZkConnection, chroot string)
check/zk_metadata.go:40
↓ 1 callersFunctionzkTopics
(zk ZkConnection, chroot string)
check/zk_metadata.go:55
MethodChildren
(path string)
check/connectors_mock.go:159
MethodChildren
(arg0 interface{})
check/connectors_mock.go:167
MethodChildren
(path string)
check/connectors.go:100
next →1–100 of 188, ranked by callers