Method Subscribe

e2e/logging.go:115–143

(node string, source LogSource, pattern string, isRegex bool)

}

func (m *LogManager) Subscribe(node string, source LogSource, pattern string, isRegex bool) (*LogSubscription, error) {
	m.mu.Lock()
	defer m.mu.Unlock()

	key := sourceKey{node, source}
	if _, ok := m.subscribers[key]; ok {
		return nil, fmt.Errorf("node %s source %s already has a subscriber", node, source)
	}

	sub := &LogSubscription{
		Node:    node,
		Source:  source,
		MatchCh: make(chan struct{}, 1),
	}
	if isRegex {
		re, err := regexp.Compile(pattern)
		if err != nil {
			return nil, err
		}
		sub.Regex = re
	} else {
		sub.Pattern = pattern
	}

	m.subscribers[key] = sub
	m.checkMatchLocked(key)

	return sub, nil
}

func (m *LogManager) Unsubscribe(sub *LogSubscription) {
	m.mu.Lock()