review #1

[darkdarkdragon]

Here

livepeer-data/health/record.go

Line 90 in cfda3ec

s.records = sync.Map{}

is data race.
Here

livepeer-data/pkg/event/stream_consumer.go

Line 91 in cfda3ec

msgChan <- StreamMessage{consumerCtx, message}

it can write to msgChan after it was closed here

livepeer-data/pkg/event/stream_consumer.go

Line 111 in cfda3ec

close(msgChan)

Here

livepeer-data/health/core.go

Line 136 in cfda3ec

return record.LastStatus, nil

and here

livepeer-data/health/core.go

Line 106 in cfda3ec

status := record.LastStatus

LastStatus being copied not under the lock.