BroadcastMessage creates a new Message with the given value This is used to broadcast the message to other side input vertices.

NewSideInputServer creates a new server object.

NoBroadcastMessage creates a new Message with noBroadcast flag set to true This is used to drop the message and not to broadcast it to other side input vertices.

WithMaxMessageSize sets the server max receive message size and the server max send message size to the given size.

WithServerInfoFilePath sets the server info file path to the given path.

WithSockAddr start the server with the given sock addr.

Message is used to wrap the data return by UserSideInput function.

Service implements the proto gen server interface and contains the retrieve operation handler.

SideInputRetriever is the interface for side input retrieval implementation.

Option is the interface to apply options.

RetrieveFunc is a utility type used to convert a RetrieveSideInput function to a SideInputRetriever.