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

protocol

package

Go to main page

Versions in this module

v1

v1.1.0

May 3, 2018

Changes in this version

type ConsumerPartition

+ BrokerOffsets []int64

type ZookeeperClient

+ ExistsW func(path string) (bool, *zk.Stat, <-chan zk.Event, error)

v1.0.0

Dec 3, 2017

Changes in this version

+ type ApplicationContext struct

+ ConfigurationValid bool

+ EvaluatorChannel chan *EvaluatorRequest

+ LogLevel *zap.AtomicLevel

+ Logger *zap.Logger

+ StorageChannel chan *StorageRequest

+ Zookeeper ZookeeperClient

+ ZookeeperConnected bool

+ ZookeeperExpired *sync.Cond

+ ZookeeperRoot string

+ type ConsumerGroupStatus struct

+ Cluster string

+ Complete float32

+ Group string

+ Maxlag *PartitionStatus

+ Partitions []*PartitionStatus

+ Status StatusConstant

+ TotalLag uint64

+ TotalPartitions int

+ type ConsumerOffset struct

+ Lag uint64

+ Offset int64

+ Timestamp int64

+ type ConsumerPartition struct

+ CurrentLag uint64

+ Offsets []*ConsumerOffset

+ Owner string

+ type ConsumerPartitions []*ConsumerPartition

+ type ConsumerTopics map[string]ConsumerPartitions

+ type Coordinator interface

+ Configure func()

+ Start func() error

+ Stop func() error

+ type EvaluatorRequest struct

+ Cluster string

+ Group string

+ Reply chan *ConsumerGroupStatus

+ ShowAll bool

+ type Module interface

+ Configure func(name string, configRoot string)

+ Start func() error

+ Stop func() error

+ type PartitionStatus struct

+ Complete float32

+ CurrentLag uint64

+ End *ConsumerOffset

+ Owner string

+ Partition int32

+ Start *ConsumerOffset

+ Status StatusConstant

+ Topic string

+ type StatusConstant int

+ const StatusError

+ const StatusNotFound

+ const StatusOK

+ const StatusRewind

+ const StatusStall

+ const StatusStop

+ const StatusWarning

+ func (c StatusConstant) MarshalJSON() ([]byte, error)

+ func (c StatusConstant) MarshalText() ([]byte, error)

+ func (c StatusConstant) String() string

+ type StorageRequest struct

+ Cluster string

+ Group string

+ Offset int64

+ Owner string

+ Partition int32

+ Reply chan interface{}

+ RequestType StorageRequestConstant

+ Timestamp int64

+ Topic string

+ TopicPartitionCount int32

+ type StorageRequestConstant int

+ const StorageClearConsumerOwners

+ const StorageFetchClusters

+ const StorageFetchConsumer

+ const StorageFetchConsumers

+ const StorageFetchConsumersForTopic

+ const StorageFetchTopic

+ const StorageFetchTopics

+ const StorageSetBrokerOffset

+ const StorageSetConsumerOffset

+ const StorageSetConsumerOwner

+ const StorageSetDeleteGroup

+ const StorageSetDeleteTopic

+ func (c StorageRequestConstant) MarshalJSON() ([]byte, error)

+ func (c StorageRequestConstant) MarshalText() ([]byte, error)

+ func (c StorageRequestConstant) String() string

+ type ZookeeperClient interface

+ ChildrenW func(path string) ([]string, *zk.Stat, <-chan zk.Event, error)

+ Close func()

+ Create func(string, []byte, int32, []zk.ACL) (string, error)

+ GetW func(path string) ([]byte, *zk.Stat, <-chan zk.Event, error)

+ NewLock func(path string) ZookeeperLock

+ type ZookeeperLock interface

+ Lock func() error

+ Unlock func() error