protocol

Feb 15, 2021

Changes in this version

type ApplicationContext

+ AppReady bool

Jun 13, 2020

Changes in this version

type ZookeeperClient

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

Mar 16, 2020

Changes in this version

type ConsumerOffset

+ ObservedTimestamp int64

Jan 13, 2020

Changes in this version

type ConsumerOffset

+ Order int64

+ type Lag struct

+ Value uint64

+ func (lag *Lag) UnmarshalJSON(b []byte) error

+ func (lag Lag) MarshalJSON() ([]byte, error)

type StorageRequest

+ Order int64

Feb 21, 2019

Changes in this version

type ConsumerPartition

+ ClientID string

type PartitionStatus

+ ClientID string

type StorageRequest

+ ClientID string

May 3, 2018

Changes in this version

type ConsumerPartition

+ BrokerOffsets []int64

type ZookeeperClient

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

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