Using the master as an outgoing message relay

As we saw in the RunJob method's initialization block, once we gain access to an executor instance for the graph, we register a bspgraph.Replayer instance which serves as an escape hatch for relaying messages destined for vertices, which are managed by a different graph instance.

This is how the relayNonLocalMessage helper method is implemented:

Get Hands-On Software Engineering with Golang now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.