Method Accept

e2e/logging.go:67–83

(node string, source LogSource, content string)

}

func (m *LogManager) Accept(node string, source LogSource, content string) {
	m.mu.Lock()
	defer m.mu.Unlock()

	event := LogEvent{
		At:      time.Since(m.start),
		Node:    node,
		Source:  source,
		Content: content,
	}
	key := sourceKey{node, source}
	m.histories[key] = append(m.histories[key], event)
	for _, observer := range m.observers {
		observer(event)
	}
	m.checkMatchLocked(key)
}

func (m *LogManager) checkMatchLocked(key sourceKey) {
	sub, ok := m.subscribers[key]