track

Documentation

Index

• func ParseTrackDesc(trackType int) string
• type MessageTrack
  • func NewMessageTrack(consumerGroupId string) *MessageTrack
  • func (track *MessageTrack) ToString() string
• type TrackTypes

Functions

func ParseTrackDesc

func ParseTrackDesc(trackType int) string

Types

type MessageTrack

type MessageTrack struct {
	ConsumerGroupId string     `json:"consumerGroup"` // 消费组
	TrackType       TrackTypes `json:"trackType"`     // 消息轨迹类型
	ExceptionDesc   string     `json:"exceptionDesc"` // 消费组描述
	Code            int        `json:"code"`          // 0:查询成功, 非0:查询异常
}

func NewMessageTrack

func NewMessageTrack(consumerGroupId string) *MessageTrack

func (*MessageTrack) ToString

func (track *MessageTrack) ToString() string

type TrackTypes

type TrackTypes int

const (
	SubscribedAndConsumed       TrackTypes = iota // 已订阅并已消费(Offset越过了)
	SubscribedButFilterd                          // 已订阅，但消息被过滤掉了
	SubscribedButPull                             // 已订阅，但PULL拉取中，消费结果未知
	SubscribedAndNotConsumeYet                    // 已订阅，未消费(Offset较小)
	UnknowExeption                                // 触发未知异常
	NotSubscribedAndNotConsumed                   // 未订阅，未消费
	ConsumerGroupIdNotOnline                      // 消费组不在线(未消费)
)