Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

check

package

Go to main page

Versions in this module

v0

v0.0.2

Sep 25, 2017

v0.0.1

Sep 16, 2017

v0.0.0

Aug 10, 2017

Changes in this version

+ type BrokerConnection interface

+ Close func()

+ Consumer func(conf kafka.ConsumerConf) (kafka.Consumer, error)

+ Dial func(nodeAddresses []string, conf kafka.BrokerConf) error

+ Metadata func() (*proto.MetadataResp, error)

+ Producer func(conf kafka.ProducerConf) kafka.Producer

+ type BrokerMetadata struct

+ ID int32

+ Problem string

+ Status string

+ type BrokerStatus struct

+ OutOfSync []ReplicationStatus

+ ReplicationFailures uint

+ Status string

+ func (s BrokerStatus) Json() (data []byte, err error)

+ func (s BrokerStatus) Summary() string

+ type ClusterStatus struct

+ Metadata []BrokerMetadata

+ Status string

+ Topics []TopicStatus

+ ZooKeeper string

+ func (s ClusterStatus) Json() (data []byte, err error)

+ func (s ClusterStatus) Summary() string

+ type HealthCheck struct

+ func New(config HealthCheckConfig) *HealthCheck

+ func (check *HealthCheck) CheckHealth(brokerUpdates chan<- Update, clusterUpdates chan<- Update, ...)

+ func (check *HealthCheck) ParseCommandLineArguments()

+ func (check *HealthCheck) ServeHealth(brokerUpdates <-chan Update, clusterUpdates <-chan Update, ...)

+ type HealthCheckConfig struct

+ CheckInterval time.Duration

+ CheckTimeout time.Duration

+ DataWaitInterval time.Duration

+ MessageLength int

+ NoTopicCreation bool

+ type MockBrokerConnection struct

+ func NewMockBrokerConnection(ctrl *gomock.Controller) *MockBrokerConnection

+ func (_m *MockBrokerConnection) Close()

+ func (_m *MockBrokerConnection) Consumer(conf kafka.ConsumerConf) (kafka.Consumer, error)

+ func (_m *MockBrokerConnection) Dial(nodeAddresses []string, conf kafka.BrokerConf) error

+ func (_m *MockBrokerConnection) EXPECT() *_MockBrokerConnectionRecorder

+ func (_m *MockBrokerConnection) Metadata() (*proto.MetadataResp, error)

+ func (_m *MockBrokerConnection) Producer(conf kafka.ProducerConf) kafka.Producer

+ type MockZkConnection struct

+ func NewMockZkConnection(ctrl *gomock.Controller) *MockZkConnection

+ func (_m *MockZkConnection) Children(path string) ([]string, *zk.Stat, error)

+ func (_m *MockZkConnection) Close()

+ func (_m *MockZkConnection) Connect(servers []string, sessionTimeout time.Duration) (<-chan zk.Event, error)

+ func (_m *MockZkConnection) Create(path string, data []byte, flags int32, acl []zk.ACL) (string, error)

+ func (_m *MockZkConnection) EXPECT() *_MockZkConnectionRecorder

+ func (_m *MockZkConnection) Exists(path string) (bool, *zk.Stat, error)

+ func (_m *MockZkConnection) Get(path string) ([]byte, *zk.Stat, error)

+ func (_m *MockZkConnection) Set(path string, data []byte, version int32) (*zk.Stat, error)

+ type PartitionStatus struct

+ OutOfSyncReplicas []int32

+ Status string

+ ZooKeeper string

+ type ReplicationStatus struct

+ Partition int32

+ Topic string

+ type StatusReport interface

+ Json func() ([]byte, error)

+ Summary func() string

+ type TopicStatus struct

+ Partitions map[string]PartitionStatus

+ Status string

+ Topic string

+ ZooKeeper string

+ type Update struct

+ Data []byte

+ Status string

+ type ZkConnection interface

+ Children func(path string) ([]string, *zk.Stat, error)

+ Close func()

+ Connect func(servers []string, sessionTimeout time.Duration) (<-chan zk.Event, error)

+ Create func(path string, data []byte, flags int32, acl []zk.ACL) (string, error)

+ Exists func(path string) (bool, *zk.Stat, error)

+ Get func(path string) ([]byte, *zk.Stat, error)

+ Set func(path string, data []byte, version int32) (*zk.Stat, error)

+ type ZkTopic struct

+ Name string

+ Partitions map[int32][]int32