NewGRPCServer returns a new gRPC handler with a reference to the output publisher.

NewShipperServer creates a new server instance for handling gRPC endpoints.

InputHandler wraps the input side of the shipper, and is responsible for starting and stopping the gRPC endpoint.

Publisher contains all operations required for the shipper server to publish incoming events.

ShipperServer contains all the gRPC operations for the shipper endpoints.