NewControllerUpstreamMessageServiceServer creates a new service implementing UpstreamMessageServiceServer, storing values used for the implementing functions.

NewMultihopServiceServer creates a new service implementing MultihopServiceServer, storing values used for the implementing functions.

NewWorkerUpstreamMessageServiceServer creates a new service implementing UpstreamMessageServiceServer, storing values used for the implementing functions.

RegisterUpstreamMessageHandler will register an UpstreamMessageHandler for the specified msg name.

TestRegisterHandlerFn returns a func that will register a handler for the test and then unregister it when the test is complete.

TestUpstreamService starts a controller with a downstream worker, which are tore down at the end of the test.

WithKeyProducer provides an option types.NodeInformation.

TestMockEncryptedUpstreamMessageHandler provides a test mock handler.

TestMockUpstreamMessageHandler provides a test mock handler.

UpstreamMessageHandler defines a handler for an UpstreamMessageRequest(s).

UpstreamMessageTypeSpecifier defines an interface for specifying type information for an UpstreamMessageRequest(s).

Option - how Options are passed as arguments.

UpstreamMessageServiceClientProducer produces a client and should be self-healing if an existing grpc connection closes.