lag

Documentation

Index

• func GetGroupOffset(broker *sarama.Broker, topic string, partition int32, group string) (int64, error)
• func GetLag(brokers string, topic string, group string) (map[int32]OffsetStatus, error)
• func GetTimestamp(broker *sarama.Broker, topic string, partition int32, offset int64) (time.Time, error)
• type OffsetStatus

Functions

func GetGroupOffset

func GetGroupOffset(broker *sarama.Broker, topic string, partition int32, group string) (int64, error)

func GetLag

func GetLag(brokers string, topic string, group string) (map[int32]OffsetStatus, error)

func GetTimestamp

func GetTimestamp(broker *sarama.Broker, topic string, partition int32, offset int64) (time.Time, error)

Types

type OffsetStatus

type OffsetStatus struct {
	Leader         int32
	Replicas       int
	InSyncReplicas int
	Current        int64
	Newest         int64
	Oldest         int64
	MsgNumber      int64
	OffsetLag      int64
	OldestTime     time.Duration
	TimeLag        time.Duration
}