Method GetCursor

pkg/events/bus.go:465–469

GetCursor 获取当前cursor

()

// GetCursor 获取当前cursor
func (eb *EventBus) GetCursor() int64 {
	eb.mu.RLock()
	defer eb.mu.RUnlock()
	return eb.cursor
}

// GetLastBookmark 获取最后一个bookmark
func (eb *EventBus) GetLastBookmark() *types.Bookmark {